Struct ReliableDataOutputChannel 

pub struct ReliableDataOutputChannel { /* private fields */ }

Converts application data into ordered, fragmented reliable data packets.

Implementations

impl ReliableDataOutputChannel

pub fn new( config: OutputConfig, cipher: Option<Rc4KeyState>, _now: Instant, ) -> Self

Creates a new output channel. cipher is the initial RC4 key state; pass Some(..) to enable RC4 encryption of the proxied application data, or None to pass it through unencrypted.

pub fn stats(&self) -> &DataOutputStats

Returns the gathered output statistics.

pub fn take_outgoing(&mut self) -> Vec<OutgoingReliable>

Drains the outgoing reliable data packets accumulated so far.

pub fn queued_len(&self) -> usize

Returns the number of reliable data packets currently awaiting acknowledgement.

pub fn set_max_data_length(&mut self, max_data_length: usize)

Sets the maximum length of the data portion (sequence + data) of a single packet. Should not be called after data has been enqueued.

pub fn enqueue_data(&mut self, data: &[u8])

Enqueues application data to be sent on the reliable channel. The data is fragmented as required to fit within the configured maximum packet length.

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

Runs a tick of the output channel, moving due packets into the outgoing buffer. If the oldest in-flight packet has gone unacknowledged for longer than the current (adaptive) retransmit timeout, dispatch restarts from the front of the window (go-back-N) and the RTO is backed off exponentially (Karn).

pub fn notify_of_acknowledge(&mut self, sequence: u16, now: Instant)

Notifies the channel that the remote has acknowledged a single sequence.

pub fn notify_of_acknowledge_all(&mut self, sequence: u16, now: Instant)

Notifies the channel that the remote has acknowledged all sequences up to and including the given one.

Trait Implementations

impl Debug for ReliableDataOutputChannel

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

Formats the value using the given formatter.