Struct AcknowledgmentHandler 

pub struct AcknowledgmentHandler { /* private fields */ }

Responsible for handling the acknowledgment of packets.

Implementations

impl AcknowledgmentHandler

pub fn new() -> Self

Creates a new acknowledgment handler with default congestion control.

pub fn with_congestion(congestion: CongestionControl) -> Self

Creates a new acknowledgment handler with custom congestion control.

pub fn packets_in_flight(&self) -> u16

Returns the number of sent packets not yet acknowledged.

pub fn local_sequence_num(&self) -> SequenceNumber

Returns the local sequence number for the next outgoing packet.

pub fn remote_sequence_num(&self) -> SequenceNumber

Returns the most recent remote sequence number received.

pub fn rtt(&self) -> Duration

Returns the current round-trip time.

pub fn rto(&self) -> Duration

Returns the retransmission timeout.

pub fn loss_rate(&self) -> f32

Returns the current packet loss rate (0.0 to 1.0).

pub fn throttle(&self) -> f32

Returns the current throttle value (0.0 to 1.0).

pub fn congestion(&self) -> &CongestionControl

Returns a reference to the congestion control.

pub fn congestion_mut(&mut self) -> &mut CongestionControl

Returns a mutable reference to the congestion control.

pub fn update_throttle(&mut self, now: Instant) -> bool

Updates the dynamic throttle based on current network conditions.

pub fn should_drop_unreliable(&self) -> bool

Returns whether an unreliable packet should be dropped based on congestion.

pub fn ack_bitfield(&self) -> u32

Returns the acknowledgment bitfield for the last 32 packets.

pub fn process_incoming( &mut self, remote_seq_num: u16, remote_ack_seq: u16, remote_ack_field: u32, now: Instant, )

Processes an incoming packet and updates congestion metrics. Calculates RTT when ACKs are received.

pub fn process_outgoing( &mut self, packet_type: PacketType, payload: &[u8], ordering_guarantee: OrderingGuarantee, item_identifier: Option<SequenceNumber>, now: Instant, )

Processes an outgoing packet and tracks it for acknowledgment.

pub fn dropped_packets(&mut self) -> Vec<SentPacket>

Returns packets that are considered dropped (not ACKed beyond window). Records packet loss for congestion control.

A packet is considered dropped if it is more than REDUNDANT_PACKET_ACKS_SIZE (32) sequence numbers behind the latest acknowledged sequence number.

Trait Implementations

impl Default for AcknowledgmentHandler

fn default() -> Self

Returns the “default value” for a type.