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§
source§impl PingCache
impl PingCache
pub fn new(ttl: Duration, rate_limit_delay: 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§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request