pub struct TcpSimRunner<const N: usize, const Q: usize> { /* private fields */ }Expand description
Drives SimNodeErased slices over a TcpSimBus.
N - max message payload bytes
Q - max messages in-flight on the bus
Implementations§
Source§impl<const N: usize, const Q: usize> TcpSimRunner<N, Q>
impl<const N: usize, const Q: usize> TcpSimRunner<N, Q>
pub fn new(bus: TcpSimBus<N, Q>) -> Self
pub fn bus(&mut self) -> &mut TcpSimBus<N, Q>
pub fn now(&self) -> Instant
Sourcepub fn tick(
&mut self,
nodes: &mut [&mut dyn SimNodeErased<N, Q>],
tcp_event_nodes: &mut [&mut dyn TcpEventHandler],
duration: Duration,
) -> usize
pub fn tick( &mut self, nodes: &mut [&mut dyn SimNodeErased<N, Q>], 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.
Auto Trait Implementations§
impl<const N: usize, const Q: usize> Freeze for TcpSimRunner<N, Q>
impl<const N: usize, const Q: usize> RefUnwindSafe for TcpSimRunner<N, Q>
impl<const N: usize, const Q: usize> Send for TcpSimRunner<N, Q>
impl<const N: usize, const Q: usize> Sync for TcpSimRunner<N, Q>
impl<const N: usize, const Q: usize> Unpin for TcpSimRunner<N, Q>
impl<const N: usize, const Q: usize> UnsafeUnpin for TcpSimRunner<N, Q>
impl<const N: usize, const Q: usize> UnwindSafe for TcpSimRunner<N, Q>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more