Struct StreamBuffer 

pub struct StreamBuffer {
    pub segment_count: u32,
    pub retransmit_count: u32,
    pub out_of_order_count: u32,
    pub fin_received: bool,
    /* private fields */
}

Buffer for one direction of a TCP stream.

Fields

segment_count: u32

Statistics.

retransmit_count: u32

out_of_order_count: u32

fin_received: bool

FIN received.

Implementations

impl StreamBuffer

pub fn new() -> Self

pub fn set_initial_seq(&mut self, seq: u32)

Set the initial sequence number (from SYN).

pub fn add_inorder_data( &mut self, seq: u32, data: &[u8], _frame_number: u64, _timestamp: i64, ) -> bool

Fast path for in-order segment - avoids intermediate Vec allocation. Returns true if the segment was handled (in-order with no pending segments). Returns false if the segment needs to be handled by the slow path.

This copies data directly into the reassembled buffer, avoiding the intermediate Segment { data: data.to_vec(), ... } allocation that the slow path requires.

pub fn add_segment(&mut self, segment: Segment)

Add a segment to the buffer (slow path - takes ownership).

pub fn get_contiguous(&self) -> &[u8]

Get contiguous reassembled data.

pub fn consume(&mut self, bytes: usize)

Consume bytes from the reassembled buffer (after successful parse).

pub fn is_complete(&self) -> bool

Check if stream is complete (no gaps, FIN received).

pub fn gaps(&self) -> &[SequenceGap]

Get current gaps in the stream.

pub fn record_gap(&mut self, start: u32, end: u32)

Record a gap when we detect missing data.

pub fn available(&self) -> usize

Get number of bytes available for parsing.

pub fn gap_count(&self) -> u32

Get the number of gaps in the stream.

pub fn segment_count(&self) -> u32

Get the segment count.

pub fn retransmit_count(&self) -> u32

Get the retransmission count.

pub fn out_of_order_count(&self) -> u32

Get the out-of-order segment count.

Trait Implementations

impl Debug for StreamBuffer

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

Formats the value using the given formatter.

impl Default for StreamBuffer

fn default() -> Self

Returns the “default value” for a type.