Struct CompletionReaper 

pub struct CompletionReaper<R: DeviceRuntime> { /* private fields */ }

Scheduler-owned completion registry. The global map lock only resolves a slot; each fence is queried or waited under its own record lock.

Implementations

impl<R: DeviceRuntime> CompletionReaper<R>

pub fn new() -> Arc<Self>

pub fn retained_count(&self) -> usize

pub fn quarantined_count(&self) -> usize

pub fn poll_bounded( &self, maximum_slots: usize, ) -> Result<CompletionSweepReceipt, VNextError>

Polls a bounded scheduler-owned snapshot. This path remains available after every external completion handle has detached.

pub fn recover_slot_by_draining_lane( &self, slot_id: CompletionSlotId, ) -> Result<CompletionRecoveryOutcome, VNextError>

Runs the blocking recovery path for an exact slot after an indeterminate observation. A failed drain moves ownership into an auditable, retryable quarantine record instead of releasing or forgetting it.

pub fn wait_slot_for_recovery( &self, slot_id: CompletionSlotId, ) -> Result<CompletionObservation, VNextError>

Performs the blocking exact-fence observation required before lane recovery. Schedulers must call this from an independent recovery worker, never from a request or admission thread.

Trait Implementations

impl<R: DeviceRuntime> Debug for CompletionReaper<R>

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

Formats the value using the given formatter.

impl<R: DeviceRuntime> Drop for CompletionReaper<R>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.