Struct s2n_netbench::client::Driver

pub struct Driver<'a, C: Client<'a>> { /* private fields */ }

Implementations

impl<'a, C: Client<'a>> Driver<'a, C>

pub fn new(client: C, scenario: &'a Client, addresses: &'a AddressMap) -> Self

pub async fn run<T: Trace, Ch: Checkpoints, Ti: Timer>( self, trace: &mut T, checkpoints: &mut Ch, timer: &mut Ti ) -> Result<C>

pub fn poll_with_timer<T: Trace, Ch: Checkpoints, Ti: Timer>( &mut self, trace: &mut T, checkpoints: &mut Ch, timer: &mut Ti, cx: &mut Context<'_> ) -> Poll<Result<()>>

pub fn poll<T: Trace, Ch: Checkpoints>( &mut self, trace: &mut T, checkpoints: &mut Ch, now: Timestamp, cx: &mut Context<'_> ) -> Poll<Result<()>>

Trait Implementations

impl<'a, C: Client<'a>> Provider for Driver<'a, C>

fn timers<Q>(&self, query: &mut Q) -> Result

where Q: Query,

Notifies the query of any timers owned by the provider

fn next_expiration(&self) -> Option<Timestamp>

Returns the next Timestamp at which the earliest timer is armed in the provider

fn is_armed(&self) -> bool

Returns true if there are any timers armed

fn armed_timer_count(&self) -> usize

Counts the number of armed timers in the provider

fn for_each_timer<F>(&self, f: F)

where F: FnMut(&Timer) -> Result<(), QueryBreak>,

Iterates over each timer in the provider and calls the provided function