Struct ScatterGatherState 

pub struct ScatterGatherState<T> {
    pub worker_count: usize,
    pub results: Vec<T>,
    pub responded_workers: Vec<KernelId>,
    pub start_time_us: u64,
}

Tracks scatter-gather operation state.

Fields

worker_count: usize

Number of workers to scatter to.

results: Vec<T>

Results received so far.

responded_workers: Vec<KernelId>

Workers that have responded.

start_time_us: u64

Start timestamp (microseconds).

Implementations

impl<T> ScatterGatherState<T>

pub fn new(worker_count: usize, start_time_us: u64) -> Self

Create new scatter-gather state.

pub fn receive_result(&mut self, worker: KernelId, result: T)

Record a result from a worker.

pub fn is_complete(&self) -> bool

Check if all workers have responded.

pub fn pending_count(&self) -> usize

Get count of pending responses.

pub fn take_results(self) -> Vec<T>

Get the results (consumes the state).

Trait Implementations

impl<T: Debug> Debug for ScatterGatherState<T>

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

Formats the value using the given formatter.