Skip to main content

Write

Struct Write 

Source
pub struct Write<B: Blob> { /* private fields */ }
Expand description

A writer that buffers the raw content of a Blob to optimize the performance of appending or updating data.

§Allocation Semantics

  • Self::new starts with a detached tip buffer and allocates backing on first buffered write.
  • Subsequent writes reuse that backing, copy-on-write allocation only occurs when buffered data is shared (for example, after handing out immutable views) or a merge needs more capacity.
  • Sparse writes merged into tip extend logical length and zero-fill any gap in-buffer.
  • Flush paths (Self::sync, Self::resize, overlap flushes in Self::write_at) hand drained bytes to the blob and leave the tip detached until the next buffered write.

§Access

Write is a single-owner buffered handle that owns mutation ordering and durability bookkeeping for the wrapped Blob. Raw Blob handles shared before wrapping observe only flushed data and may not see the latest buffered writes until Self::sync, Self::resize, or an overlapping Self::write_at flushes them. Those raw handles must not be used to write, resize, or otherwise mutate the blob while a Write exists. External mutations bypass the buffer state and Self::sync may use Blob::write_at with WriteOptions::SYNC, which is not a durability barrier for those external mutations.

Storage-mutating functions consume the writer and return it only on success: an error (or a dropped future) destroys the handle.

§Example

use commonware_runtime::{Runner, buffer::{Write, Read}, Blob, Error, Storage, deterministic};
use commonware_utils::NZUsize;

let executor = deterministic::Runner::default();
executor.start(|context| async move {
    // Open a blob for writing
    let (blob, size) = context.open("my_partition", b"my_data").await.expect("unable to open blob");
    assert_eq!(size, 0);

    // Create a buffered writer with 16-byte buffer
    let blob = Write::new(blob, 0, NZUsize!(16));
    let blob = blob.write_at(0, b"hello").await.expect("write failed");
    let blob = blob.sync().await.expect("sync failed");

    // Write more data in multiple flushes
    let blob = blob.write_at(5, b" world").await.expect("write failed");
    let blob = blob.write_at(11, b"!").await.expect("write failed");
    let blob = blob.sync().await.expect("sync failed");

    // Release the writer and read back the persisted data through a new open.
    drop(blob);
    let (blob, size) = context.open("my_partition", b"my_data").await.expect("unable to reopen blob");
    let mut reader = Read::new(blob, size, NZUsize!(8));
    let buf = reader.read(size as usize).await.expect("read failed");
    assert_eq!(buf.coalesce().as_ref(), b"hello world!");
});

Implementations§

Source§

impl<B: Blob> Write<B>

Source

pub fn new(blob: B, size: u64, capacity: NonZeroUsize) -> Self

Creates a new Write that buffers up to capacity bytes of data to be appended to the tip of blob with the provided size.

Source

pub const fn size(&self) -> u64

Returns the current logical size of the blob including any buffered data.

This represents the total size of data that would be present after flushing.

Source

pub const fn needs_sync(&self) -> bool

Whether Self::sync would write buffered bytes, sync the blob, or observe a started sync.

Source

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

Read exactly len immutable bytes starting at offset.

Source

pub fn try_write_at(&mut self, offset: u64, buf: &[u8]) -> bool

Merge buf into the in-memory tip buffer at offset.

Returns whether buf fit. Returns false without changing the writer when it does not fit. Performs no I/O and does not make the write durable. Callers can fall back to Self::write_at when it does not fit.

Source

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

Write bytes from buf at offset.

Data is merged into the in-memory tip buffer when possible, otherwise buffered data may be flushed and chunks are written directly to the underlying blob.

Returns Error::OffsetOverflow when offset + bufs.len() overflows.

Source

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

Resize the logical blob to len.

If buffered data exists and the resize extends beyond current size, buffered data is flushed before resizing the underlying blob.

Source

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

Flush buffered bytes and durably sync mutations tracked by this writer.

Source

pub async fn start_sync(self) -> Result<(Self, Handle<()>), Error>

Flush buffered bytes and begin durably syncing mutations tracked by this writer.

Awaiting the returned Handle waits for the same durability guarantee as Self::sync for the state flushed by this call. Later calls to Self::sync and writer methods that mutate the blob wait before issuing blob operations. A failure of the started sync is reported by the handle and by the next such call. Flush errors are returned directly.

Source

pub async fn wait_for_sync(self) -> Result<Self, Error>

Wait for any started sync to complete without starting a new sync.

Auto Trait Implementations§

§

impl<B> !Freeze for Write<B>

§

impl<B> !RefUnwindSafe for Write<B>

§

impl<B> !UnwindSafe for Write<B>

§

impl<B> Send for Write<B>

§

impl<B> Sync for Write<B>

§

impl<B> Unpin for Write<B>
where B: Unpin,

§

impl<B> UnsafeUnpin for Write<B>
where B: UnsafeUnpin,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FutureExt for T

Source§

fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
Source§

fn with_current_context(self) -> WithContext<Self> ⓘ

Attaches the current Context to this type, returning a WithContext wrapper. Read more
Source§

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> Threaded<T> for T

Source§

type Rest = ()

The outputs beyond the threaded value.
Source§

fn split(self) -> (T, ())

Splits into the threaded value and the extra outputs.
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more