Struct ReassemblyPool 

pub struct ReassemblyPool<const SLOTS: usize, const PAGES: usize> {
    pub slots: [Option<Slot>; SLOTS],
    /* private fields */
}

Fixed-capacity reassembly pool.

Fields

slots: [Option<Slot>; SLOTS]

Implementations

impl<const SLOTS: usize, const PAGES: usize> ReassemblyPool<SLOTS, PAGES>

pub fn new() -> Self

pub fn read_fragment( &self, slot_index: usize, fragment: u8, out: &mut [u8], ) -> usize

Copy a stored fragment into out (which must hold FRAGMENT_BODY_MAX bytes), returning its length.

pub fn find_slot( &self, stream: &StreamKey, epoch: u16, message_id: u8, ) -> Option<usize>

pub fn open_slot(&mut self, slot: Slot) -> Option<usize>

pub fn oldest_slot(&self) -> Option<usize>

Index of the oldest incomplete slot, for eviction under pressure.

pub fn close_slot(&mut self, index: usize) -> Option<Slot>

Release a slot and all its pages, returning it.

pub fn drop_stream(&mut self, stream: &StreamKey) -> usize

Drop every slot belonging to stream (after a sequence reset), returning how many were dropped.

pub fn insert_fragment( &mut self, index: usize, fragment: u8, bytes: &[u8], ) -> InsertOutcome

Store one fragment’s bytes into a slot.

Trait Implementations

impl<const SLOTS: usize, const PAGES: usize> Default for ReassemblyPool<SLOTS, PAGES>

fn default() -> Self

Returns the “default value” for a type.