Struct solana_core::ping_pong::PingCache[][src]

pub struct PingCache { /* fields omitted */ }

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

impl PingCache[src]

pub fn new(ttl: Duration, cap: usize) -> Self[src]

pub fn add(&mut self, pong: &Pong, socket: SocketAddr, now: Instant) -> bool[src]

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.

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>>, 
[src]

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).

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<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T> Instrument for T[src]

impl<T> Instrument for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> IntoRequest<T> for T[src]

impl<T> Pointable for T[src]

type Init = T

The type for initializers.

impl<T> Same<T> for T[src]

type Output = T

Should always be Self

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<T> Typeable for T where
    T: Any

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, 
[src]

impl<T> WithSubscriber for T[src]