Struct SendWindow 

pub struct SendWindow { /* private fields */ }

Sliding window for send-side reliability

Implementations

impl SendWindow

pub fn new(config: ArqConfig) -> Self

Create a new send window

pub fn with_defaults() -> Self

Create with default config

pub fn next_seq(&self) -> SequenceNumber

Get next sequence number to use

pub fn can_send(&self) -> bool

Check if window has room for more packets

pub fn is_full(&self) -> bool

Check if window is full

pub fn in_flight(&self) -> usize

Number of packets currently in flight

pub fn len(&self) -> usize

Alias for in_flight() - number of unacked packets

pub fn is_empty(&self) -> bool

Check if no packets are in flight

pub fn send(&mut self, data: Vec<u8>) -> Option<SequenceNumber>

Add a packet to the send window

Returns the sequence number assigned to the packet, or None if window is full.

pub fn add( &mut self, seq: SequenceNumber, data: Vec<u8>, ) -> Result<(), ConstrainedError>

Add a packet with a specific sequence number

Used when the caller manages sequence numbers. Returns error if window is full.

pub fn acknowledge(&mut self, ack: SequenceNumber) -> usize

Process a cumulative ACK

Acknowledges all packets up to and including the given sequence number. Returns the number of packets acknowledged.

pub fn rto(&self) -> Duration

Get current RTO

pub fn get_retransmissions(&mut self) -> Option<Vec<(SequenceNumber, Vec<u8>)>>

Get packets that need retransmission

Returns a list of packets that have exceeded RTO and haven’t exceeded max retries. Returns None if any packet has exceeded max retries (connection should fail).

pub fn reset(&mut self)

Reset the window (for connection close/reset)

Trait Implementations

impl Debug for SendWindow

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

Formats the value using the given formatter.