Struct Connection

pub struct Connection<H: ConnectionHandler> {
    pub uuid: Uuid,
    pub forward_flow: Flow,
    pub conn_state: ConnectionState,
    pub observed_handshake: bool,
    pub observed_close: bool,
    pub forward_stream: Stream,
    pub reverse_stream: Stream,
    pub event_handler: Option<H>,
}

object representing TCP connection

Fields

uuid: Uuid

unique identifier for connection

forward_flow: Flow

forward direction flow identifier

conn_state: ConnectionState

state of connection handshake

observed_handshake: bool

whether the full 3-way handshake was observed

observed_close: bool

whether the connection close was observed (either by FIN or RST)

forward_stream: Stream

forward direction stream

reverse_stream: Stream

reverse direction stream

event_handler: Option<H>

event handler object

Implementations

impl<H: ConnectionHandler> Connection<H>

pub fn new( forward_flow: Flow, handler_init_data: H::InitialData, ) -> Result<Connection<H>, H::ConstructError>

create new connection with flow

pub fn get_stream(&mut self, direction: Direction) -> &mut Stream

get stream in direction

pub fn handle_packet( &mut self, meta: &TcpMeta, data: &[u8], extra: &PacketExtra, ) -> bool

handle a packet supposedly belonging to this connection

pub fn handle_syn(&mut self, meta: &TcpMeta) -> bool

handle packet with SYN flag

pub fn handle_rst(&mut self, meta: &TcpMeta, extra: &PacketExtra) -> bool

handle packet with RST flag

pub fn handle_data_hs1( &mut self, meta: &TcpMeta, data: &[u8], extra: &PacketExtra, ) -> bool

handle data packet received before SYN/ACK

pub fn handle_data_hs2( &mut self, meta: &TcpMeta, data: &[u8], extra: &PacketExtra, ) -> bool

handle data packet received after SYN/ACK

pub fn handle_data_established( &mut self, meta: &TcpMeta, data: &[u8], extra: &PacketExtra, ) -> bool

handle data after handshake is completed

pub fn handle_data( &mut self, meta: &TcpMeta, data: &[u8], extra: &PacketExtra, ) -> bool

handle ordinary data packet

pub fn call_handler(&mut self, do_thing: impl FnOnce(&mut Self, &mut H))

call the event handler, if one exists

pub fn will_retire(&mut self)

called before connection is removed from hashtable