Struct AnnounceQueues 

pub struct AnnounceQueues { /* private fields */ }

Manage announce queues for all interfaces.

Implementations

impl AnnounceQueues

pub fn new() -> Self

pub fn gate_announce( &mut self, interface: InterfaceId, raw: Vec<u8>, dest_hash: [u8; 16], hops: u8, emitted: f64, now: f64, bitrate: Option<u64>, announce_cap: f64, ) -> Option<TransportAction>

Try to send an announce on an interface. If bandwidth is available, returns the action immediately. Otherwise, queues it.

Returns Some(action) if the announce should be sent now, None if queued.

pub fn process_queues( &mut self, now: f64, interfaces: &BTreeMap<InterfaceId, InterfaceInfo>, ) -> Vec<TransportAction>

Process all announce queues: dequeue and send when bandwidth is available. Called from tick().

Trait Implementations

impl Clone for AnnounceQueues

fn clone(&self) -> AnnounceQueues

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AnnounceQueues

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

Formats the value using the given formatter.