Struct PendingSyncs 

pub struct PendingSyncs { /* private fields */ }

Coordinates durability operations for a DelayedSyncContext or DelayedSyncBlob.

Every started sync parks in a deferred queue (in start order) until a test releases it. Self::arm additionally installs a one-shot gate that blocks the next durability operation and counts operations from that point on (Self::calls). The gate is pushed onto the deferred queue when Self::arm is called, before any operation reaches it.

Implementations

impl PendingSyncs

pub fn lock(&self) -> MutexGuard<'_, Vec<DeferredSync>>

Locks the deferred sync queue.

pub fn arm(&self)

Begins counting durability operations and blocks the next one behind a one-shot gate (pushed onto the deferred queue so tests can release it).

Once the gate is consumed, started syncs park in the deferred queue as usual while Self::calls keeps counting.

pub fn calls(&self) -> usize

Returns the number of durability operations observed since Self::arm.

Trait Implementations

impl Clone for PendingSyncs

fn clone(&self) -> PendingSyncs

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for PendingSyncs

fn default() -> PendingSyncs

Returns the “default value” for a type.