Struct IntrusiveMailbox 

pub struct IntrusiveMailbox {
    head: AtomicUsize,
    pool: NodePool,
}

Fields

head: AtomicUsize

pool: NodePool

Pool of pre-allocated nodes for IRQ-safe push/pop without heap alloc.

Implementations

impl IntrusiveMailbox

pub fn new() -> Self

Create a new empty mailbox with FREELIST_CAPACITY pre-allocated nodes.

pub const fn new_empty() -> Self

Create a new empty mailbox without pre-allocation. Only for const contexts (e.g., static initialisers); the caller must call preallocate_nodes() at runtime before use in IRQ context.

pub fn preallocate_nodes(&self, count: usize)

Pre-allocate additional nodes at runtime.

pub fn push(&self, msg: &[u8]) -> Result<(), MailboxError>

Push a message onto the mailbox (LIFO : inserted at head).

Tries the pre-allocated node pool first. Falls back to heap allocation only if the pool is empty. In IRQ context the pool should never be empty if FREELIST_CAPACITY is large enough.

pub fn pop(&self) -> Option<IpcMessage>

Pop a message from the mailbox (LIFO : from head).

Copies the message data out of the intrusive node, then returns the node to the pre-allocated pool. The caller receives an owned IpcMessage value : no pointers into recycled memory.

pub fn is_empty(&self) -> bool

Whether the mailbox is empty.

Trait Implementations

impl Debug for IntrusiveMailbox

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl IpcConsumer for IntrusiveMailbox

fn recv(&self, buf: &mut [u8]) -> Result<usize, IpcError>

Receive a message, blocking if the buffer is empty.

fn try_recv(&self, buf: &mut [u8]) -> Result<Option<usize>, IpcError>

Receive without blocking.

impl IpcProducer for IntrusiveMailbox

fn send(&self, msg: &[u8]) -> Result<(), IpcError>

Send a message, blocking if the buffer is full.

fn try_send(&self, msg: &[u8]) -> Result<(), IpcError>

Send without blocking.

fn send_vectored(&self, bufs: &[&[u8]]) -> Result<(), IpcError>

Send using vectored I/O (scatter-gather).

impl IpcTransport for IntrusiveMailbox

fn level(&self) -> TransportLevel

The isolation level of this transport.

fn capabilities(&self) -> TransportCapabilities

Static capabilities of this transport.

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

Human-readable name for debugging / profiling.