Struct SurbRoundTripRegistry 

pub struct SurbRoundTripRegistry {
    inner: Arc<DashMap<ForwardAndReturnPath, Arc<SurbRoundTripCounters>>>,
    destinations: Arc<DashMap<ForwardAndReturnPath, OffchainPublicKey>>,
    silence: Arc<DashMap<ForwardAndReturnPath, Silence>>,
    replanned: Arc<DashMap<OffchainPublicKey, u32>>,
    me_slot: Arc<AtomicU64>,
}

Round-trip counts keyed by the legs they were observed over.

Batching is not an optimisation here but a requirement: recording an edge takes a write lock on the whole graph, a packet carries several SURBs, and a session at 0.5 MB/s moves hundreds of packets a second – reporting per event would contend the graph thousands of times a second.

Fields

inner: Arc<DashMap<ForwardAndReturnPath, Arc<SurbRoundTripCounters>>>

destinations: Arc<DashMap<ForwardAndReturnPath, OffchainPublicKey>>

Destination each pair of legs leads to, so a collapse can name what to re-plan.

silence: Arc<DashMap<ForwardAndReturnPath, Silence>>

What each pair’s recent flushes say about whether it still works.

replanned: Arc<DashMap<OffchainPublicKey, u32>>

Flushes since each destination was last reported, so one is not re-planned repeatedly.

me_slot: Arc<AtomicU64>

Slot this node occupies, learned from the first pair recorded.

A [PathId] is zero-padded with no length, and slot 0 is a legitimate index, so the end of a leg cannot be found by looking for padding. It can be found by looking for us: every reply leg terminates here. ME_SLOT_UNKNOWN means not yet known.

Implementations

impl SurbRoundTripRegistry

fn counters(&self, paths: ForwardAndReturnPath) -> Arc<SurbRoundTripCounters>

pub fn note_me_slot(&self, slot: u64)

Tells the registry which slot is ours, so a leg’s relayers can be told from its padding.

pub fn record_expected( &self, paths: ForwardAndReturnPath, count: u64, destination: OffchainPublicKey, )

Records that count SURBs were minted over these legs and are expected back.

pub fn degraded_destinations(&self) -> Vec<OffchainPublicKey>

Destinations whose return path has been silent for long enough to act on.

Deliberately keyed on no reply at all rather than on a delivery rate. A rate cannot separate these cases: measured immediately after a kill, a healthy leg read 0.089 while the dead one read 0.123, and replies straddling a flush boundary push a healthy leg above 1. Only sustained silence distinguishes them, and it does so within seconds.

The claim made is narrower than “this pair is silent”: it is “this pair used to deliver and has now stopped”. Silence alone was measured to fire during healthy operation, because a pair that has not yet returned its first reply is indistinguishable from a dead one.

pub fn record_observed(&self, paths: ForwardAndReturnPath, count: u64)

Records that count replies arrived over these legs.

pub fn drain(&self) -> Vec<(ForwardAndReturnPath, u64, u64)>

Takes every non-empty entry, resetting the counts.

Trait Implementations

impl Clone for SurbRoundTripRegistry

fn clone(&self) -> SurbRoundTripRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SurbRoundTripRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SurbRoundTripRegistry

fn default() -> Self

Returns the “default value” for a type.