Struct s2n_quic_transport::recovery::Manager

pub struct Manager<Config: Config> { /* private fields */ }

Implementations

impl<Config: Config> Manager<Config>

pub fn new(space: PacketNumberSpace) -> Self

Constructs a new recovery::Manager

pub fn on_retry_packet(&mut self, path: &mut Path<Config>)

Invoked when the Client processes a Retry packet.

Reset congestion controller state by discarding sent bytes and replacing recovery manager with a new instance of itself.

pub fn on_timeout<Ctx: Context<Config>, Pub: ConnectionPublisher>(
    &mut self,
    timestamp: Timestamp,
    context: &mut Ctx,
    publisher: &mut Pub
)

pub fn on_packet_sent<Ctx: Context<Config>, Pub: ConnectionPublisher>(
    &mut self,
    packet_number: PacketNumber,
    outcome: Outcome,
    time_sent: Timestamp,
    ecn: ExplicitCongestionNotification,
    context: &mut Ctx,
    publisher: &mut Pub
)

pub fn update_pto_timer(
    &mut self,
    path: &Path<Config>,
    now: Timestamp,
    is_handshake_confirmed: bool
)

Updates the PTO timer

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

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

pub fn on_ack_frame<A: AckRanges, Ctx: Context<Config>, Pub: ConnectionPublisher>(
    &mut self,
    datagram: &DatagramInfo,
    frame: Ack<A>,
    context: &mut Ctx,
    publisher: &mut Pub
) -> Result<(), Error>

Process ACK frame.

Update congestion controller, timers and meta data around acked packet ranges.

pub fn requires_probe(&self) -> bool

Returns true if the recovery manager requires a probe packet to be sent.

pub fn on_packet_number_space_discarded<Pub: ConnectionPublisher>(
    &mut self,
    path: &mut Path<Config>,
    path_id: Id,
    publisher: &mut Pub
)

Clears bytes in flight for sent packets.

Trait Implementations

impl<Config: Debug + Config> Debug for Manager<Config>

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

Formats the value using the given formatter.

impl<Config: Config> Provider for Manager<Config>

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>(&self, f: F) where
    F: FnMut(&Timer) -> Result<(), QueryBreak>, 

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