Struct StreamCache 

pub struct StreamCache { /* private fields */ }

Cached state for one active voice stream on one module.

Implementations

impl StreamCache

pub const fn new( stream_id: StreamId, header: DStarHeader, from: SocketAddr, now: Instant, ) -> Self

Construct a new stream cache entry.

Called when the reflector sees a fresh voice header from a client. now is the wall-clock instant of receipt, used as both started_at and the initial last_activity.

pub const fn new_with_bytes( stream_id: StreamId, header: DStarHeader, header_bytes: Vec<u8>, from: SocketAddr, now: Instant, ) -> Self

Construct a new stream cache entry with the raw header bytes cached for retransmit.

Preferred entry point for the fan-out engine, which needs to re-send the original wire-format header verbatim every 21 frames without re-encoding it.

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

Raw wire-format bytes of the cached voice header.

Returns an empty slice if the cache was constructed via Self::new rather than Self::new_with_bytes.

pub const fn record_frame(&mut self, now: Instant)

Record the arrival of another voice frame.

Increments the internal sequence counter and refreshes last_activity so the inactivity watchdog stays armed.

pub const fn should_rebroadcast_header(&self) -> bool

Whether the cached header should be rebroadcast on the next tick.

Returns true once every 21 frames, matching the xlxd / MMDVMHost cadence. The boundary is (seq_counter + 1) % 21 == 0 so the first rebroadcast happens after 20 data frames.

pub fn should_evict(&self, now: Instant, timeout: Duration) -> bool

Whether this stream has been idle long enough to be evicted.

pub const fn header(&self) -> &DStarHeader

The cached voice header.

pub const fn stream_id(&self) -> StreamId

The stream id this cache tracks.

pub const fn from(&self) -> SocketAddr

The peer that originated the stream (so fan-out can avoid echo).

pub const fn started_at(&self) -> Instant

When the stream first began (useful for duration metrics).

pub const fn last_activity(&self) -> Instant

When the last frame was observed (useful for watchdogs / metrics).

Trait Implementations

impl Clone for StreamCache

fn clone(&self) -> StreamCache

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamCache

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

Formats the value using the given formatter.