Struct EventQueue 

pub struct EventQueue { /* private fields */ }

EventQueue represents the queue of events that are waiting to be processed in order (time-wise). The queue is split into four parts:

• base: TriggerEvent::NormalSent events that are from the parsed base trace
• blocking: TunnelSent events that may be blocked by blocking machines
• bypassable: TunnelSent events that are blocked with bypassable blocking
• internal: all other events

Implementations

impl EventQueue

pub fn new() -> EventQueue

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn no_normal_packets(&self) -> bool

Checks if there are no normal packets in the queue. This involves checking the base queue for TriggerEvent::NormalSent events, the blocking and bypassable queues for TriggerEvent::TunnelSent events without the padding flag, and the internal queue for any TunnelRecv without the padding flag.

pub fn push(&mut self, item: SimEvent)

pub fn peek( &self, network_delay_sum: Duration, current_time: Instant, ) -> (Option<&SimEvent>, Queue, Duration)

pub fn pop(&mut self, q: Queue, network_delay_sum: Duration) -> Option<SimEvent>

remove an event from the queue

pub fn peek_blocking(&self) -> Option<&SimEvent>

peek the next blocking event

pub fn peek_bypassable(&self) -> Option<&SimEvent>

peek the next bypassable event

pub fn peek_non_blocking( &self, network_delay_sum: Duration, ) -> (Option<&SimEvent>, Queue)

peek the next non-blocking event

pub fn get_first_base_time(&self) -> Option<Instant>

get the first time of the base queue: should only be used for the simulator’s current time at startup

Trait Implementations

impl Clone for EventQueue

fn clone(&self) -> EventQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventQueue

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

Formats the value using the given formatter.

impl Default for EventQueue

fn default() -> Self

Returns the “default value” for a type.