Skip to main content

SenderState

Struct SenderState 

Source
pub struct SenderState { /* private fields */ }
Expand description

Per-peer sender-side MMP state.

Records cumulative and interval counters for every frame transmitted to this peer. Produces SenderReport snapshots on demand.

Implementations§

Source§

impl SenderState

Source

pub fn new() -> Self

Source

pub fn new_with_cold_start(cold_start_ms: u64) -> Self

Create with a custom cold-start interval (ms).

Used by session-layer MMP which needs a longer initial interval since reports consume bandwidth on every transit link.

Source

pub fn record_sent(&mut self, counter: u64, timestamp: u32, bytes: usize)

Record a frame sent to this peer.

Called on the TX path for every encrypted link message. counter is the AEAD nonce/counter, timestamp is the inner header session-relative timestamp (ms), bytes is the wire payload size.

Source

pub fn build_report(&mut self, now: Instant) -> Option<SenderReport>

Build a SenderReport from current state and reset the interval.

Returns None if no frames have been sent since the last report.

Source

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

Check if it’s time to send a report.

When consecutive send failures have occurred, the effective interval is multiplied by an exponential backoff factor (2^failures, capped at 32×).

Source

pub fn record_send_failure(&mut self) -> u32

Record a send failure. Returns the new consecutive failure count.

Source

pub fn record_send_success(&mut self) -> u32

Record a successful send. Returns the previous failure count (for summary logging).

Source

pub fn send_failure_backoff_multiplier(&self) -> f64

Get the backoff multiplier based on consecutive failures.

Returns 1.0 for no failures, 2.0 for 1 failure, 4.0 for 2, … capped at 32.0 (5 failures).

Source

pub fn update_report_interval_from_srtt(&mut self, srtt_us: i64)

Update the report interval based on SRTT (link-layer defaults).

Sender reports at 2× SRTT clamped to [floor, MAX]. During cold-start (first COLD_START_SAMPLES updates), the floor is the cold-start interval (200ms) for fast SRTT convergence. After that, it rises to MIN_REPORT_INTERVAL_MS (1000ms) for steady-state efficiency.

Source

pub fn update_report_interval_with_bounds( &mut self, srtt_us: i64, min_ms: u64, max_ms: u64, )

Update the report interval based on SRTT with custom bounds.

Used by session-layer MMP which needs higher clamp values since each report consumes bandwidth on every transit link.

Source

pub fn cumulative_packets_sent(&self) -> u64

Source

pub fn cumulative_bytes_sent(&self) -> u64

Source

pub fn report_interval(&self) -> Duration

Source

pub fn consecutive_send_failures(&self) -> u32

Trait Implementations§

Source§

impl Default for SenderState

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more