Struct ControlSession 

pub struct ControlSession {
    pub connection_id: ConnectionId,
    pub client_session_id: u64,
    pub server_session_id: u64,
    pub key_id: u8,
    pub answered_key_exchange: bool,
    pub bytes_sent: u64,
    pub bytes_received: u64,
    /* private fields */
}

The control channel of one peer.

Fields

connection_id: ConnectionId

client_session_id: u64

server_session_id: u64

key_id: u8

answered_key_exchange: bool

Whether this server has written its own key-method-2 answer.

bytes_sent: u64

bytes_received: u64

Implementations

impl ControlSession

pub fn new( connection_id: ConnectionId, client_session_id: u64, server_session_id: u64, key_id: u8, client_reset_packet_id: u32, tls_config: Arc<ServerConfig>, ) -> Result<Self>

Start a session and queue the P_CONTROL_HARD_RESET_SERVER_V2 that answers the client’s reset.

The reply goes through the reliability layer like any other control packet, so it is retransmitted until the client acknowledges it instead of relying on the client’s own reset retransmissions to trigger a re-send.

pub fn on_client_reset_retransmit(&mut self)

The client retransmitted its reset, so it never saw our reply. Put everything in flight back on the wire.

pub fn on_ack_frame(&mut self, frame: &ControlFrame)

Process a P_ACK_V1 from the peer.

pub fn on_control_frame(&mut self, frame: ControlFrame) -> Vec<SessionEvent>

Process a P_CONTROL_V1 (or any control frame carrying a packet id).

pub fn write_key_method_2_answer( &mut self, client_options: &str, ) -> Result<String>

Write the server’s key-method-2 answer into the TLS session.

The key material is fresh random bytes. Nothing is derived from it: the data channel that would consume it does not exist, and inventing keys nothing can use would be worse than not having them.

pub fn drain_datagrams(&mut self, now: Instant) -> Vec<Vec<u8>>

Everything this session wants to put on the wire right now.

Pending acknowledgements go first: a peer that is retransmitting needs to hear that we have its packets before it needs anything we have to say.

pub fn is_dead(&self) -> bool

True once a control packet has been retransmitted to exhaustion: the peer has stopped listening.