Struct arti_bench::StreamIsolationTracker

pub(crate) struct StreamIsolationTracker {
    pub(crate) streams_per_circ: usize,
    pub(crate) cur_run: usize,
    pub(crate) next_stream: usize,
    pub(crate) cur_token: IsolationToken,
}

Helper type: track a StreamIsolation token over a set of runs.

We want to return a new token every streams_per_circ calls for each run, but always give a new token when a new run begins.

Fields

streams_per_circ: usize

The number of streams to assign to each circuit.

cur_run: usize

The current run index.

next_stream: usize

The stream index within the run that we expect on the next call to next_in.

cur_token: IsolationToken

The isolation token we’re currently handing out.

Implementations

impl StreamIsolationTracker

pub(crate) fn new(streams_per_circ: usize) -> Self

Construct a new StreamIsolationTracker.

pub(crate) fn next_in(&mut self, run: usize) -> IsolationToken

Return the isolation token to use for the next stream in the given run. Requires that runs are not interleaved.

Trait Implementations

impl Clone for StreamIsolationTracker

fn clone(&self) -> StreamIsolationTracker

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StreamIsolationTracker

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

Formats the value using the given formatter.