Struct HostRing 

pub struct HostRing { /* private fields */ }

Default in-process ring backed by a Vec<u8>. Both RingProducer and RingConsumer are implemented on a single &mut /& borrow so the producer-consumer parity test can drive both halves with the same buffer.

Implementations

impl HostRing

pub fn new(slot_count: u32) -> Result<Self, ProtocolError>

Allocate a new ring of slot_count empty slots.

Errors

Returns ProtocolError::ByteLengthOverflow if slot_count exceeds protocol::MAX_ENCODED_RING_SLOTS.

pub fn as_bytes(&self) -> &[u8]

Borrow the underlying ring bytes (for the dispatch path that still consumes &[u8] directly).

pub fn as_bytes_mut(&mut self) -> &mut [u8]

Mutably borrow the underlying ring bytes.

Trait Implementations

impl RingConsumer for HostRing

fn read_slot(&self, slot_idx: u32, out: &mut [u8]) -> Result<(), ProtocolError>

Copy slot slot_idx’s bytes into out. out must be exactly SLOT_BYTES long; otherwise returns ProtocolError::MisalignedByteLength.

fn try_done_count(&self) -> Result<u32, ProtocolError>

Fallibly count slots currently in DONE status.

fn slot_count(&self) -> u32

Number of slots in the underlying ring.

fn done_count(&self) -> u32

👎Deprecated:

use RingConsumer::try_done_count so malformed ring snapshots do not collapse to zero

Compatibility-only lossy count of slots currently in DONE status.

impl RingProducer for HostRing

fn publish( &mut self, slot_idx: u32, encoded: &[u8], ) -> Result<(), ProtocolError>

Publish encoded into slot_idx. encoded must be exactly SLOT_BYTES long; otherwise returns ProtocolError::MisalignedByteLength.

fn slot_count(&self) -> u32

Number of slots in the underlying ring.

fn name(&self) -> &'static str

Stable identifier for telemetry (e.g. "in-process-host", "uring-cmd-nvme", "gds").