Struct BarrierController 

pub struct BarrierController { /* private fields */ }

Full runtime barrier executor for in-process station sets.

Implementations

impl BarrierController

pub const fn active(&self) -> Option<RuntimeBarrier>

Returns the active barrier, if any.

pub fn request( &mut self, stations: &StationSet, id: BarrierId, scope: BarrierScope, target_tick: Tick, command_mode: CommandQueueMode, ) -> Result<BarrierProgress, BarrierRuntimeError>

Requests a barrier over stations matching scope.

pub fn poll( &mut self, stations: &StationSet, ) -> Result<BarrierProgress, BarrierRuntimeError>

Polls station ticks and freezes the barrier once all covered stations are aligned.

pub fn export_snapshots( &mut self, stations: &StationSet, version: SnapshotVersion, ) -> Result<Vec<StationSnapshot>, BarrierRuntimeError>

Exports station snapshots while the barrier is frozen.

pub fn export_snapshots_into<'a>( &mut self, stations: &StationSet, version: SnapshotVersion, scratch: &'a mut BarrierSnapshotScratch, ) -> Result<&'a [StationSnapshot], BarrierRuntimeError>

Exports frozen snapshots into caller-owned reusable Station slots.

pub fn resume(&mut self) -> Result<BarrierMetrics, BarrierRuntimeError>

Resumes all stations covered by the barrier and returns final metrics.

pub fn progress(&self) -> BarrierProgress

Returns current barrier progress.

Trait Implementations

impl Clone for BarrierController

fn clone(&self) -> BarrierController

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BarrierController

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

Formats the value using the given formatter.

impl Default for BarrierController

fn default() -> BarrierController

Returns the “default value” for a type.