Struct PacketFragmentationAssembler 

pub struct PacketFragmentationAssembler { /* private fields */ }

Packet fragmentation and reassembly engine.

Thread safety

This struct is Send but not Sync; wrap in Arc<Mutex<...>> for shared use.

Implementations

impl PacketFragmentationAssembler

pub fn new(config: PfaAssemblerConfig) -> Self

Create a new assembler with the given configuration.

pub fn with_defaults() -> Self

Convenience constructor using default configuration.

pub fn generate_msg_id(&mut self) -> PfaMessageId

Generate a new message ID that is not currently in use.

pub fn fragment( &mut self, msg_id: PfaMessageId, data: &[u8], ) -> Result<Vec<PfaFragment>, String>

Split data into MTU-sized fragments tagged with msg_id.

Returns an empty Vec if data is empty.

Errors

Returns Err if the payload would require more than config.max_fragments fragments.

pub fn receive_fragment( &mut self, fragment: PfaFragment, now_ts: u64, ) -> PfaReceiveResult

Process a received fragment.

now_ts is the current Unix-epoch timestamp in seconds and is used for the fragment log and buffer creation timestamps.

pub fn reassemble(&mut self, msg_id: PfaMessageId) -> Option<Vec<u8>>

Attempt to reassemble message msg_id if all fragments are present.

Returns None if the buffer does not exist or is incomplete.

pub fn expire_stale(&mut self, now_ts: u64)

Remove all buffers whose created_at is older than the configured timeout.

pub fn pending_messages(&self) -> Vec<(PfaMessageId, u32, u32)>

List pending messages: (msg_id, received_count, total_fragments).

pub fn verify_checksum(&self, fragment: &PfaFragment) -> bool

Verify the checksum of a fragment (instance method forwarding to static).

pub fn assembler_stats(&self) -> PfaAssemblerStats

Return a snapshot of assembler-level statistics.

pub fn config(&self) -> &PfaAssemblerConfig

Reference to the configuration.

pub fn pending_count(&self) -> usize

Number of messages currently awaiting full reassembly.

pub fn fragment_log(&self) -> &VecDeque<PfaFragmentRecord>

A slice of the most recent fragment log entries.

pub fn has_pending(&self) -> bool

True if the engine holds any in-flight reassembly buffers.

pub fn get_buffer(&self, msg_id: PfaMessageId) -> Option<&PfaReassemblyBuffer>

Return a reference to the reassembly buffer for msg_id, if any.

pub fn drain_log(&mut self) -> Vec<PfaFragmentRecord>

Drain and return all fragment log entries.

pub fn reset(&mut self)

Reset all state while keeping configuration.