Struct de_net::connection::dispatch::resends::Resends

pub(super) struct Resends {
    queue: PriorityQueue<PackageId, Timing>,
    headers: AHashMap<PackageId, PackageHeader>,
    data: DataBuf,
}

This struct governs reliable package re-sending (until each package is confirmed).

Fields

queue: PriorityQueue<PackageId, Timing>

headers: AHashMap<PackageId, PackageHeader>

data: DataBuf

Implementations

impl Resends

pub(super) fn new() -> Self

pub(super) fn len(&self) -> usize

Return the number of pending actions.

pub(super) fn is_empty(&self) -> bool

Returns true if there is no pending action.

pub(super) fn push(&mut self, header: PackageHeader, data: &[u8], now: Instant)

Registers new package for re-sending until it is resolved.

Panics

• If the package (ID) is already stored.

• If data is longer than MAX_PACKAGE_SIZE.

pub(super) fn resolve(&mut self, id: PackageId)

Marks a package as delivered. No more re-sends will be scheduled and package data will be dropped.

pub(super) fn reschedule( &mut self, buf: &mut [u8], now: Instant ) -> RescheduleResult

Retrieves next package to be resend or None if there is not (yet) such a package.

Each package is resent multiple times with randomized exponential backoff.

Arguments

• buf - the package payload is written to this buffer. The buffer length must be greater or equal to the length of the payload.

• now - current time, used for the retry scheduling.

Panics

Panics if buf is smaller than the retrieved package payload.