Struct InterfaceAnnounceQueue 

pub struct InterfaceAnnounceQueue {
    pub entries: Vec<AnnounceQueueEntry>,
    pub announce_allowed_at: f64,
}

Per-interface announce queue with bandwidth tracking.

Fields

entries: Vec<AnnounceQueueEntry>

Queued announce entries.

announce_allowed_at: f64

Earliest time another announce is allowed on this interface.

Implementations

impl InterfaceAnnounceQueue

pub fn new() -> Self

pub fn insert(&mut self, entry: AnnounceQueueEntry)

Insert an announce into the queue. If an entry for the same destination already exists, update it if the new one has fewer hops or is newer.

pub fn remove_stale(&mut self, now: f64)

Remove stale entries (older than QUEUED_ANNOUNCE_LIFE).

pub fn select_next(&self) -> Option<usize>

Select the next announce to send: minimum hops, then oldest (FIFO). Returns the index of the selected entry, or None if empty.

pub fn is_allowed(&self, now: f64) -> bool

Check if an announce is allowed now based on bandwidth.

pub fn calculate_next_allowed( now: f64, raw_len: usize, bitrate: u64, announce_cap: f64, ) -> f64

Calculate the next allowed time after sending an announce. raw_len: size of the announce in bytes bitrate: interface bitrate in bits/second announce_cap: fraction of bitrate reserved for announces

Trait Implementations

impl Clone for InterfaceAnnounceQueue

fn clone(&self) -> InterfaceAnnounceQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InterfaceAnnounceQueue

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

Formats the value using the given formatter.