Struct ShmSequencedSlotsProducer 

pub struct ShmSequencedSlotsProducer { /* private fields */ }

Single-producer handle over SequencedSlotsLayout4.

v1: single-writer claim/publish (no MPMC claiming).

Implementations

impl ShmSequencedSlotsProducer

pub fn attach( opts: &AttachOptions, lane: &str, refcnt_on_publish: u32, active_gating: usize, ) -> Result<Self, BackingError>

Attach a producer.

refcnt_on_publish controls the slot refcount initialized for each published entry.

• Use 1 for single-ring pipelines where only the final stage releases.
• Use k for multicast scenarios with k independent consumers.

pub fn window_capacity(&self) -> u64

Maximum number of outstanding unpublished/ungated sequences permitted by this backing.

This is currently min(INDEXBUS_QUEUE_CAPACITY, INDEXBUS_SLOTS_CAPACITY).

pub fn try_claim_next(&mut self) -> Result<u64, SequencedSlotsError>

Try to reserve the next sequence.

pub fn publish_bytes( &mut self, bytes: &[u8], ) -> Result<u64, SequencedSlotsError>

Publish bytes as the next sequenced entry.

pub fn publish_claimed_with<F>( &mut self, seq: u64, f: F, ) -> Result<u64, SequencedSlotsError>

where F: FnOnce(&mut [u8]) -> Result<usize, SequencedSlotsError>,

Publish a previously-claimed sequence by writing into the slot buffer.

Trait Implementations

impl LaneTx for ShmSequencedSlotsProducer

fn publish(&mut self, msg: &[u8]) -> Result<(), LaneTxError>

Publish the message.