Struct solana_gossip::ping_pong::PingCache
source · [−]pub struct PingCache { /* private fields */ }
Expand description
Maintains records of remote nodes which have returned a valid response to a ping message, and on-the-fly ping messages pending a pong response from the remote node.
Implementations
sourceimpl PingCache
impl PingCache
pub fn new(ttl: Duration, cap: usize) -> Self
sourcepub fn add(&mut self, pong: &Pong, socket: SocketAddr, now: Instant) -> bool
pub fn add(&mut self, pong: &Pong, socket: SocketAddr, now: Instant) -> bool
Checks if the pong hash, pubkey and socket match a ping message sent out previously. If so records current timestamp for the remote node and returns true. Note: Does not verify the signature.
sourcepub fn check<T, F>(
&mut self,
now: Instant,
node: (Pubkey, SocketAddr),
pingf: F
) -> (bool, Option<Ping<T>>) where
T: Serialize,
F: FnMut() -> Option<Ping<T>>,
pub fn check<T, F>(
&mut self,
now: Instant,
node: (Pubkey, SocketAddr),
pingf: F
) -> (bool, Option<Ping<T>>) where
T: Serialize,
F: FnMut() -> Option<Ping<T>>,
Returns true if the remote node has responded to a ping message. Removes expired pong messages. In order to extend verifications before expiration, if the pong message is not too recent, and the node has not been pinged recently, calls the given function to generates a new ping message, records current timestamp and hash of ping token, and returns the ping message. Caller should verify if the socket address is valid. (e.g. by using ContactInfo::is_valid_address).
sourcepub fn mock_pong(&mut self, node: Pubkey, socket: SocketAddr, now: Instant)
pub fn mock_pong(&mut self, node: Pubkey, socket: SocketAddr, now: Instant)
Only for tests and simulations.
Auto Trait Implementations
impl RefUnwindSafe for PingCache
impl Send for PingCache
impl Sync for PingCache
impl Unpin for PingCache
impl UnwindSafe for PingCache
Blanket Implementations
sourceimpl<T> AbiExample for T
impl<T> AbiExample for T
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcepub fn borrow_mut(&mut self) -> &mut T
pub fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcepub fn into_request(self) -> Request<T>
pub fn into_request(self) -> Request<T>
Wrap the input message T
in a tonic::Request
impl<T> Pointable for T
impl<T> Pointable for T
impl<T> TupleTree<T, ()> for T
impl<T> TupleTree<T, ()> for T
pub const SIZE: Size
pub fn descendants(_indirect_level: usize) -> usize
pub fn height() -> usize
pub fn preorder(self, f: &mut impl FnMut(Visit<T>))
pub fn preorder_with_size_hint(self, f: &mut impl FnMut(Visit<T>, Size))
pub fn postorder(self, f: &mut impl FnMut(Visit<T>))
pub fn postorder_with_size_hint(self, f: &mut impl FnMut(Visit<T>, Size))
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
pub fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more