Struct DelayedSyncBlob 

pub struct DelayedSyncBlob<B> { /* private fields */ }

Blob wrapper that parks each started sync and supports one-shot blocking sync tracking.

Implementations

impl<B> DelayedSyncBlob<B>

pub fn new(inner: B) -> (Self, PendingSyncs)

Wrap inner, returning the blob and the list its deferred syncs are pushed onto.

Trait Implementations

impl<B: Blob> Blob for DelayedSyncBlob<B>

async fn read_at_buf( &self, offset: u64, len: usize, bufs: impl Into<IoBufsMut> + Send, ) -> Result<IoBufsMut, Error>

Read len bytes at offset into caller-provided buffer(s).

async fn read_at(&self, offset: u64, len: usize) -> Result<IoBufsMut, Error>

Read len bytes at offset, returning a buffer(s) with exactly len bytes of data read from the blob starting at offset.

async fn write_at( &self, offset: u64, bufs: impl Into<IoBufs> + Send, ) -> Result<(), Error>

Write bufs to the blob at the given offset.

async fn write_at_sync( &self, offset: u64, bufs: impl Into<IoBufs> + Send, ) -> Result<(), Error>

Write bufs to the blob at the given offset and durably persist that write.

async fn resize(&self, len: u64) -> Result<(), Error>

Resize the blob to the given length.

async fn sync(&self) -> Result<(), Error>

Ensure all pending data is durably persisted.

async fn start_sync(&self) -> Handle<()>

Request that all pending data is durably persisted.

impl<B: Clone> Clone for DelayedSyncBlob<B>

fn clone(&self) -> DelayedSyncBlob<B>

Returns a duplicate of the value.

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

Performs copy-assignment from source.