Struct DirectoryOutputHandler

pub struct DirectoryOutputHandler {
    pub shared_info: DirectoryOutputSharedInfo,
    pub id: Uuid,
    pub gaps: Vec<Range<u64>>,
    pub segments: Vec<SegmentInfo>,
    pub got_handshake_done: bool,
    pub files: Option<DirectoryOutputHandlerFiles>,
}

ConnectionHandler to write data to a directory

Fields

shared_info: DirectoryOutputSharedInfo

id: Uuid

gaps: Vec<Range<u64>>

segments: Vec<SegmentInfo>

got_handshake_done: bool

whether we received the handshake_done event

files: Option<DirectoryOutputHandlerFiles>

Implementations

impl DirectoryOutputHandler

pub fn write_stream_data( &mut self, connection: &mut Connection<Self>, direction: Direction, maybe_dump_len: Option<usize>, ) -> Result<()>

Trait Implementations

impl ConnectionHandler for DirectoryOutputHandler

type InitialData = DirectoryOutputSharedInfo

initial data provided to new

type ConstructError = Report

error type raised from new

fn new( shared_info: Self::InitialData, connection: &mut Connection<Self>, ) -> Result<Self>

construct handler object

fn handshake_done(&mut self, connection: &mut Connection<Self>)

called on handshake finish (or incomplete handshake)

fn data_received( &mut self, connection: &mut Connection<Self>, direction: Direction, )

called on data received

fn will_retire(&mut self, connection: &mut Connection<Self>)

called when the connection is removed from the hashtable

fn ack_received( &mut self, _connection: &mut Connection<Self>, _direction: Direction, )

called when data is acked, direction is of the ack packet, not the stream

fn fin_received( &mut self, _connection: &mut Connection<Self>, _direction: Direction, )

called on FIN

fn rst_received( &mut self, _connection: &mut Connection<Self>, _direction: Direction, _extra: PacketExtra, )

called on RST

fn stream_end( &mut self, _connection: &mut Connection<Self>, _direction: Direction, )

ACK for FIN received for stream

fn connection_desync( &mut self, _connection: &mut Connection<Self>, _direction: Direction, )

connection fatally desynchronized, direction is our best guess for the direction of the packet which caused the desync