Struct ReceiverState 

pub struct ReceiverState { /* private fields */ }

Per-peer receiver-side MMP state.

Accumulates per-frame observations and produces ReceiverReport snapshots.

Implementations

impl ReceiverState

pub fn new(owd_window_size: usize) -> Self

pub fn new_with_cold_start(owd_window_size: usize, cold_start_ms: u64) -> Self

Create with a custom cold-start interval (ms).

Used by session-layer MMP which needs a longer initial interval since reports consume bandwidth on every transit link.

pub fn reset_for_rekey(&mut self, now: Instant)

Reset counter-dependent state for rekey cutover.

After cutover, the new session starts with counter 0 and reset timestamps. Without resetting, the old highest_counter and GapTracker.expected_next cause false reorder/loss detection.

pub fn record_recv( &mut self, counter: u64, sender_timestamp_ms: u32, bytes: usize, ce_flag: bool, now: Instant, )

Record a received frame from this peer.

Called on the RX path after AEAD decryption, before message dispatch.

• counter: AEAD counter from outer header
• sender_timestamp_ms: session-relative timestamp from inner header (ms)
• bytes: wire payload size
• ce_flag: CE bit from flags byte
• now: current local time

pub fn build_report(&mut self, now: Instant) -> Option<ReceiverReport>

Build a ReceiverReport from current state and reset the interval.

Returns None if no frames have been received since the last report.

pub fn should_send_report(&self, now: Instant) -> bool

Check if it’s time to send a report.

pub fn update_report_interval_from_srtt(&mut self, srtt_us: i64)

Update the report interval based on SRTT (link-layer defaults).

Receiver reports at 1× SRTT clamped to [floor, MAX]. During cold-start (first COLD_START_SAMPLES updates), the floor is the cold-start interval (200ms) for fast SRTT convergence. After that, it rises to MIN_REPORT_INTERVAL_MS (1000ms) for steady-state efficiency.

pub fn update_report_interval_with_bounds( &mut self, srtt_us: i64, min_ms: u64, max_ms: u64, )

Update the report interval based on SRTT with custom bounds.

Used by session-layer MMP which needs higher clamp values since each report consumes bandwidth on every transit link.

pub fn cumulative_packets_recv(&self) -> u64

pub fn cumulative_bytes_recv(&self) -> u64

pub fn highest_counter(&self) -> u64

pub fn jitter_us(&self) -> u32

pub fn report_interval(&self) -> Duration

pub fn last_recv_time(&self) -> Option<Instant>

pub fn ecn_ce_count(&self) -> u32

Trait Implementations

impl Default for ReceiverState

fn default() -> Self

Returns the “default value” for a type.