Struct s2n_netbench::Driver

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

Fields

connection: C

Implementations

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

pub fn new(scenario: &'a Connection, connection: C) -> 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: Connection> Connection for Driver<'a, C>

fn id(&self) -> u64

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

where T: Trace, Ch: Checkpoints,

impl<'a, C: Debug + Connection> Debug for Driver<'a, C>

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

Formats the value using the given formatter.

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

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

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