Struct TcpReassembler 

pub struct TcpReassembler { /* private fields */ }

TCP stream reassembler.

Implementations

impl TcpReassembler

pub fn new() -> Self

pub fn get_or_create( &mut self, connection_id: u64, direction: Direction, ) -> &mut StreamBuffer

Get or create a stream buffer.

pub fn add_segment( &mut self, connection_id: u64, direction: Direction, seq: u32, data: &[u8], frame_number: u64, timestamp: i64, )

Add a segment to the appropriate stream.

pub fn get_contiguous(&self, connection_id: u64, direction: Direction) -> &[u8]

Get contiguous data for a stream.

pub fn consume( &mut self, connection_id: u64, direction: Direction, bytes: usize, )

Consume bytes from a stream.

pub fn mark_fin(&mut self, connection_id: u64, direction: Direction)

Mark FIN received for a stream.

pub fn is_complete(&self, connection_id: u64, direction: Direction) -> bool

Check if a stream is complete.

pub fn remove(&mut self, connection_id: u64)

Remove a stream (connection closed).

pub fn stats( &self, connection_id: u64, direction: Direction, ) -> Option<StreamStats>

Get stream statistics.

Trait Implementations

impl Default for TcpReassembler

fn default() -> Self

Returns the “default value” for a type.