Struct TcpSimRunner 

pub struct TcpSimRunner<const MAX_DATA: usize, const MAX_QUEUED: usize, const TCP_MAX_EVENTS: usize, const MAX_OUTBOX: usize> { /* private fields */ }

Drives SimNodeErased slices over a TcpSimBus.

N - max message payload bytes Q - max messages in-flight on the bus

Implementations

impl<const MAX_DATA: usize, const MAX_QUEUED: usize, const TCP_MAX_EVENTS: usize, const MAX_OUTBOX: usize> TcpSimRunner<MAX_DATA, MAX_QUEUED, TCP_MAX_EVENTS, MAX_OUTBOX>

pub fn new(bus: TcpSimBus<MAX_DATA, MAX_QUEUED, TCP_MAX_EVENTS>) -> Self

pub fn bus(&mut self) -> &mut TcpSimBus<MAX_DATA, MAX_QUEUED, TCP_MAX_EVENTS>

pub fn now(&self) -> Instant

pub fn tick( &mut self, nodes: &mut [&mut dyn SimNodeErased<MAX_DATA, MAX_OUTBOX>], tcp_event_nodes: &mut [&mut dyn TcpEventHandler], duration: Duration, ) -> usize

Ticks the simulation by duration.

Order of operations per tick: 1. Advance bus clock, apply TCP fault injection, deliver due messages 2. Deliver TCP connection events to nodes implementing TcpEventHandler 3. Tick all nodes for time-based transitions 4. Drain node outboxes and enqueue onto the bus

Returns the number of messages delivered.