Struct FlowController 

pub struct FlowController { /* private fields */ }

Sliding window flow controller with AIMD congestion control and retransmission support.

Implementations

impl FlowController

pub fn new(window_size: usize) -> Self

Create a new flow controller with the given maximum window size.

pub fn with_rto(window_size: usize, rto_ms: u64) -> Self

Create a flow controller with a custom retransmission timeout.

pub fn can_send(&self) -> bool

Returns true if the effective window has space to send another packet.

pub fn available_slots(&self) -> usize

Returns how many more packets can be sent right now.

pub fn window_size(&self) -> usize

Returns the hard maximum window size.

pub fn cwnd(&self) -> f64

Returns the current congestion window size.

pub fn effective_window(&self) -> usize

Returns the effective window: min(cwnd as usize, window_size), at least 1.

pub fn in_slow_start(&self) -> bool

Returns true if currently in slow start phase.

pub fn set_window_size(&mut self, size: usize)

Dynamically adjust the hard maximum window size.

pub fn in_flight_count(&self) -> usize

Returns the number of packets currently in flight.

pub fn oldest_unacked_sequence(&self) -> Option<u64>

Returns the sequence number of the oldest unacknowledged packet.

pub fn on_send(&mut self, sequence: u64, data: Vec<u8>) -> bool

Register a packet as sent with its data payload (for retransmission).

Returns false if the effective window is full.

pub fn on_ack(&mut self, sequence: u64) -> bool

Register a packet as acknowledged.

Updates RTT estimate and advances congestion window via AIMD. Returns true if the packet was found and removed.

pub fn timed_out_packets(&mut self) -> Vec<RetransmitRequest>

Returns all in-flight packets that have exceeded the retransmission timeout.

Returns RetransmitRequests with data to resend. Triggers AIMD multiplicative decrease on loss.

pub fn srtt(&self) -> Option<Duration>

Returns the current smoothed RTT estimate.

pub fn rttvar(&self) -> Option<Duration>

Returns the current RTT variance estimate.

pub fn rto(&self) -> Duration

Returns the current retransmission timeout.

pub fn total_sent(&self) -> u64

Returns total packets sent.

pub fn total_acked(&self) -> u64

Returns total packets acknowledged.

pub fn total_lost(&self) -> u64

Returns total packets detected as lost.

pub fn total_retransmits(&self) -> u64

Returns total retransmissions performed.

pub fn loss_rate(&self) -> f64

Returns the packet loss rate: lost / sent.

pub fn is_acked(&self, sequence: u64) -> bool

Returns true if a sequence number has been acknowledged.

pub fn reset(&mut self)

Reset all state.

Trait Implementations

impl Default for FlowController

fn default() -> Self

Returns the “default value” for a type.