Struct OptimizedRingBuffer 

pub struct OptimizedRingBuffer<const N: usize = 64> { /* private fields */ }

Optimized lock-free ring buffer with power-of-2 size.

Uses atomic operations for thread-safe enqueue/dequeue. Power-of-2 size enables fast modulo via bitwise AND.

Implementations

impl<const N: usize> OptimizedRingBuffer<N>

pub fn new(region: RegionHandle) -> Self

Creates a new optimized ring buffer.

Arguments

• region - Handle to the backing region

Panics

Panics if N is not a power of 2.

pub fn region(&self) -> RegionHandle

Returns the region handle.

pub const fn capacity(&self) -> usize

Returns the ring capacity.

pub fn len(&self) -> u32

Returns the number of entries currently in the ring.

pub fn is_empty(&self) -> bool

Returns true if the ring is empty.

pub fn is_full(&self) -> bool

Returns true if the ring is full.

pub fn available(&self) -> u32

Returns the number of free slots.

pub fn enqueue(&mut self, data: &[u8], priority: MsgPriority) -> Result<()>

Enqueues a message into the ring buffer (<200ns target).

Arguments

• data - Message payload (max 56 bytes for inline)
• priority - Message priority

Errors

Returns QueueFull if the ring is full. Returns MessageTooLarge if the message exceeds inline limit.

pub fn dequeue(&mut self, buf: &mut [u8]) -> Result<(OptimizedRingEntry, usize)>

Dequeues a message from the ring buffer (<200ns target).

Arguments

• buf - Buffer to receive the message data

Returns

On success, returns the entry header and number of bytes copied.

Errors

Returns QueueEmpty if the ring is empty.

pub fn peek(&self) -> Option<&OptimizedRingEntry>

Peeks at the next entry without removing it.

pub fn try_enqueue(&mut self, data: &[u8], priority: MsgPriority) -> Result<()>

Tries to enqueue without blocking, returns immediately.

pub fn try_dequeue( &mut self, buf: &mut [u8], ) -> Result<(OptimizedRingEntry, usize)>

Tries to dequeue without blocking, returns immediately.

pub fn clear(&mut self)

Clears all entries from the ring.

Trait Implementations

impl<const N: usize> Default for OptimizedRingBuffer<N>

fn default() -> Self

Returns the “default value” for a type.

impl<const N: usize> Send for OptimizedRingBuffer<N>

impl<const N: usize> Sync for OptimizedRingBuffer<N>