Struct s2n_quic_core::path::mtu::Controller

pub struct Controller { /* private fields */ }

Implementations

impl Controller

pub fn new(max_mtu: MaxMtu, peer_socket_address: &SocketAddress) -> Self

Construct a new mtu::Controller with the given max_mtu and peer_socket_address

The UDP header length and IP header length will be subtracted from max_mtu to determine the max_udp_payload used for limiting the payload length of probe packets. max_mtu is the maximum allowed mtu, e.g. for jumbo frames this value is expected to be over 9000.

pub fn enable(&mut self)

Enable path MTU probing

pub fn on_timeout(&mut self, now: Timestamp)

Called when the connection timer expires

pub fn on_packet_ack<CC: CongestionController, Pub: ConnectionPublisher>( &mut self, packet_number: PacketNumber, sent_bytes: u16, congestion_controller: &mut CC, path_id: Id, publisher: &mut Pub )

This method gets called when a packet delivery got acknowledged

pub fn on_packet_loss<CC: CongestionController, Pub: ConnectionPublisher>( &mut self, packet_number: PacketNumber, lost_bytes: u16, new_loss_burst: bool, now: Timestamp, congestion_controller: &mut CC, path_id: Id, publisher: &mut Pub )

This method gets called when a packet loss is reported

pub fn mtu(&self) -> usize

Gets the currently validated maximum transmission unit, not including IP or UDP header len

pub fn max_mtu(&self) -> MaxMtu

Returns the maximum size any packet can reach

pub fn probed_sized(&self) -> usize

Gets the MTU currently being probed for

Trait Implementations

impl Clone for Controller

fn clone(&self) -> Controller

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Controller

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

Formats the value using the given formatter.

impl Provider for Controller

fn on_transmit<W: Writer>(&mut self, context: &mut W)

Queries the component for any outgoing frames that need to get sent

This method assumes that no other data (other than the packet header) has been written to the supplied WriteContext. This necessitates the caller ensuring the probe packet written by this method to be in its own connection transmission.

impl Provider for Controller

fn timers<Q: Query>(&self, query: &mut Q) -> Result

Notifies the query of any timers owned by the provider

fn next_expiration(&self) -> Option<Timestamp>

Returns the next Timestamp at which the earliest timer is armed in the provider

fn is_armed(&self) -> bool

Returns true if there are any timers armed

fn armed_timer_count(&self) -> usize

Counts the number of armed timers in the provider

fn for_each_timer<F: FnMut(&Timer) -> Result>(&self, f: F)

Iterates over each timer in the provider and calls the provided function

impl Provider for Controller

fn transmission_interest<Q: Query>(&self, query: &mut Q) -> Result

fn get_transmission_interest(&self) -> Interest

fn has_transmission_interest(&self) -> bool

fn can_transmit(&self, constraint: Constraint) -> bool