Struct s2n_quic_core::path::ecn::Controller

pub struct Controller { /* private fields */ }

Implementations

impl Controller

pub fn restart<Pub: ConnectionPublisher>( &mut self, path: Path<'_>, publisher: &mut Pub )

Restart testing of ECN capability

pub fn on_timeout<Pub: ConnectionPublisher>( &mut self, now: Timestamp, path: Path<'_>, random_generator: &mut dyn Generator, rtt: Duration, publisher: &mut Pub )

Called when the connection timer expires

pub fn ecn( &mut self, transmission_mode: Mode, now: Timestamp ) -> ExplicitCongestionNotification

Gets the ECN marking to use on packets sent to the peer

pub fn is_capable(&self) -> bool

Returns true if the path has been determined to be capable of handling ECN marked packets

pub fn validate<Pub: ConnectionPublisher>( &mut self, newly_acked_ecn_counts: EcnCounts, sent_packet_ecn_counts: EcnCounts, baseline_ecn_counts: EcnCounts, ack_frame_ecn_counts: Option<EcnCounts>, now: Timestamp, rtt: Duration, path: Path<'_>, publisher: &mut Pub ) -> ValidationOutcome

Validate the given EcnCounts, updating the current validation state based on the validation outcome.

• newly_acked_ecn_counts - total ECN counts that were sent on packets newly acknowledged by the peer
• sent_packet_ecn_counts - total ECN counts for all outstanding packets, including those newly acknowledged during this validation
• baseline_ecn_counts - the ECN counts present in the Ack frame the last time ECN counts were processed
• ack_frame_ecn_counts - the ECN counts present in the current Ack frame (if any)
• now - the time the Ack frame was received

pub fn on_packet_sent<Pub: ConnectionPublisher>( &mut self, ecn: ExplicitCongestionNotification, path: Path<'_>, publisher: &mut Pub )

This method gets called when a packet has been sent

pub fn on_packet_ack( &mut self, time_sent: Timestamp, ecn: ExplicitCongestionNotification )

This method gets called when a packet delivery got acknowledged

pub fn on_packet_loss<Pub: ConnectionPublisher>( &mut self, time_sent: Timestamp, ecn: ExplicitCongestionNotification, now: Timestamp, path: Path<'_>, publisher: &mut Pub )

This method gets called when a packet loss is reported

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 Default for Controller

fn default() -> Controller

Returns the “default value” for a type.

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