Struct Channel 

pub struct Channel { /* private fields */ }

Window-based reliable messaging channel.

Follows the action-queue model: send/receive/tick return Vec<ChannelAction>. The caller dispatches actions.

Implementations

impl Channel

pub fn new(initial_rtt: f64) -> Self

Create a new Channel with initial RTT.

pub fn set_rtt(&mut self, rtt: f64)

Update the RTT value.

pub fn mdu(&self, link_mdu: usize) -> usize

Maximum data unit available for message payload.

pub fn is_ready_to_send(&self) -> bool

Check if channel is ready to send (has window capacity).

pub fn send( &mut self, msgtype: u16, payload: &[u8], now: f64, link_mdu: usize, ) -> Result<Vec<ChannelAction>, ChannelError>

Send a message. Returns SendOnLink action with packed envelope.

pub fn receive(&mut self, raw: &[u8], _now: f64) -> Vec<ChannelAction>

Receive decrypted envelope bytes.

Returns MessageReceived for contiguous sequences starting from next_rx_sequence.

pub fn flush_tx(&mut self)

Clear all outstanding TX entries, restoring the window to full capacity. Used after holepunch completion where signaling messages are fire-and-forget.

pub fn packet_delivered(&mut self, sequence: Sequence) -> Vec<ChannelAction>

Notify that a packet with given sequence was delivered (acknowledged).

pub fn packet_timeout( &mut self, sequence: Sequence, now: f64, ) -> Vec<ChannelAction>

Notify that a packet with given sequence timed out.

pub fn get_packet_timeout(&self, tries: u8) -> f64

Compute timeout duration for the given try count.

Formula: 1.5^(tries-1) * max(rtt*2.5, 0.025) * (tx_ring.len() + 1.5)

pub fn get_tries(&self, sequence: Sequence) -> Option<u8>

Get the current try count for a given sequence.

pub fn shutdown(&mut self)

Shut down the channel, clearing all rings.

pub fn window(&self) -> u16

Current window size.

pub fn window_max(&self) -> u16

Current maximum window size.

pub fn outstanding(&self) -> usize

Number of outstanding (undelivered) envelopes in TX ring.