Struct FlatWriter 

pub struct FlatWriter<T: FlatStruct> { /* private fields */ }

Writes FlatStruct samples directly into SHM slots — without CDR encoding.

Implementations

impl<T: FlatStruct> FlatWriter<T>

pub fn new( alloc: Arc<InMemorySlotAllocator>, active_readers_mask: ReaderMask, ) -> Self

Creates a writer over an allocator. active_readers_mask lists the reader bits that must all have read before a slot can be reused.

pub fn write(&self, sample: &T) -> Result<u32, SlotError>

Spec §8.1 write_flat — reserve + memcpy + commit in a single call.

Errors

SlotError::NoFreeSlot under resource pressure; SampleTooLarge when the slot is smaller than T::WIRE_SIZE.

pub fn write_bp( &self, sample: &T, reliability: Reliability, timeout: Duration, ) -> Result<WriteOutcome, SlotError>

Spec §10.5 backpressure-aware write. On NoFreeSlot: BestEffort drops the sample (WriteOutcome::Dropped); Reliable blocks event-driven on the allocator’s notify until a slot frees or timeout elapses (WriteOutcome::TimedOut) — no busy-poll.

Errors

Non-NoFreeSlot slot errors (e.g. SampleTooLarge, lock poison).

pub fn loan_slot(&self) -> Result<FlatSlot<'_, T>, SlotError>

Spec §8.2 loan_slot — lower level: explicit slot borrow. The caller writes directly into the loaned &mut T buffer and commits.

Errors

NoFreeSlot.