Struct LivenessRegistry 

pub(crate) struct LivenessRegistry(Arc<DashMap<PeerId, Arc<AtomicBool>>>);

Shared registry mapping each peer to its connection-liveness flag.

A clone of this registry is held by both crate::HoprNetwork and the swarm event-loop closure. When libp2p reports a peer fully disconnected, the loop calls LivenessRegistry::remove, which clears the flag and removes the entry. Any LivenessStream that already cloned the old Arc<AtomicBool> will see false on its next poll.

Tuple Fields

0: Arc<DashMap<PeerId, Arc<AtomicBool>>>

Implementations

impl LivenessRegistry

pub(crate) fn get_or_create_connected(&self, peer: &PeerId) -> Arc<AtomicBool>

Registers peer and returns its liveness flag, creating a fresh true flag if none exists. Call this when opening or accepting a stream.

pub(crate) fn get(&self, peer: &PeerId) -> Option<Arc<AtomicBool>>

Returns the current liveness flag for peer, or None if the peer is not registered. Does not create an entry.

pub(crate) fn remove(&self, peer: &PeerId)

Removes peer from the registry and sets its flag to false.

Any LivenessStream still holding the old Arc will error on its next poll. A subsequent Self::get_or_create_connected call mints a fresh true flag.

Trait Implementations

impl Clone for LivenessRegistry

fn clone(&self) -> LivenessRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for LivenessRegistry

fn default() -> LivenessRegistry

Returns the “default value” for a type.