Struct LpReliability 

pub struct LpReliability { /* private fields */ }

Per-face NDNLPv2 reliability state.

Tracks outbound TxSequences, piggybacked Acks, and adaptive RTO. All methods are synchronous and return wire-ready packets.

Implementations

impl LpReliability

pub fn new(mtu: usize) -> Self

Create with default configuration (RFC 6298, conservative).

pub fn from_config(mtu: usize, config: ReliabilityConfig) -> Self

Create from a full configuration.

pub fn apply_config(&mut self, config: ReliabilityConfig)

Apply a new configuration. Resets RTO adaptation state.

pub fn config(&self) -> ReliabilityConfig

Current configuration (snapshot).

pub fn on_send(&mut self, pkt: &[u8]) -> Vec<Bytes>

Process an outbound packet: fragment if needed, assign TxSequences, piggyback pending Acks, buffer for retransmit.

Returns wire-ready LpPackets.

pub fn on_receive(&mut self, raw: &[u8])

Process an inbound raw LpPacket: extract TxSequence (queue for Ack) and process any piggybacked Acks (clear unacked, measure RTT).

pub fn check_retransmit(&mut self) -> Vec<Bytes>

Check for retransmit-eligible entries. Returns wire packets to resend.

Rate-limited to MAX_RETX_PER_TICK to prevent burst retransmissions from blocking the face_sender (which would starve new packet delivery and cause throughput collapse).

pub fn flush_acks(&mut self) -> Option<Bytes>

Flush pending Acks as a bare Ack-only LpPacket. Call when the retransmit timer fires and there’s been no recent outgoing traffic.

pub fn unacked_count(&self) -> usize

Number of unacknowledged packets in flight.

pub fn rto_us(&self) -> u64

Current RTO in microseconds.