Struct EvQue 

pub struct EvQue { /* private fields */ }

C event_que (dbEvent.c:69-82) — one ring, shared by every subscription attached to it.

Exposes no mutating method: events enter through EventSink::post and leave through EventReader::recv / EventReader::try_recv, which are the sole owners of C’s two decisions. The accessors below are read-only views of C’s counters for diagnostics and tests.

Implementations

impl EvQue

pub fn n_duplicates(&self) -> usize

C nDuplicates — entries queued beyond the first for their monitor, across every subscription on this queue.

pub fn nreplace(&self, sid: u32) -> u64

C nreplace for one monitor — posts that overwrote its last entry.

pub fn npend(&self, sid: u32) -> usize

C npend for one monitor — entries queued and not yet delivered.

pub fn quota(&self) -> usize

C quota — ring entries reserved by the monitors attached here.