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 or Self::unblock runs. 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) -> MappedMutexGuard<'_, 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.

pub fn unblock(&self)

Releases every parked sync and permanently stops parking new ones: future started syncs proceed immediately (or fail, after Self::arm_fail). Unlike release_pending_syncs, which drains the queue once, this is sticky. A gate armed via Self::arm parks in the same queue, so this releases it too.

pub fn arm_fail(&self)

Arms every parked and future started sync to resolve to an injected error once released via Self::unblock. The release helpers send explicit results and ignore this.

pub fn starts(&self) -> usize

Number of started syncs issued.

pub fn entered(&self) -> usize

Number of started syncs whose completion futures have begun executing, parked or not.

pub fn completions(&self) -> usize

Number of started syncs that completed durably.

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.