Struct HostSession 

pub struct HostSession { /* private fields */ }

The daemon’s end of a device connection.

Implementations

impl HostSession

pub fn new(config: HostConfig, now: Instant) -> HostSession

Starts waiting for the agent’s hello; it must arrive within the peer timeout.

pub fn receive(&mut self, bytes: &[u8], now: Instant)

Feeds bytes read from the connection.

pub fn receive_eof(&mut self, now: Instant)

The connection reached its end.

pub fn handle_timeout(&mut self, now: Instant)

Acts on deadlines and liveness that are due at now.

pub fn poll_timeout(&self) -> Option<Instant>

When handle_timeout must next run; None once closed.

pub fn send_request( &mut self, call: Call, deadline: Option<Duration>, now: Instant, ) -> Result<u32, Error>

Sends a request, returning its id. Fails at once, sending nothing, when the session is not ready or closed, when the agent did not advertise the capability the method needs, or when the request exceeds the negotiated frame size.

pub fn resync(&mut self, stream: Stream, now: Instant) -> Result<u32, Error>

Asks the agent to resynchronize stream; the outcome arrives as HostEvent::Resynced or HostEvent::ResyncFailed.

pub fn streams(&self) -> &StreamTracker

Sequence state of the event streams.

pub fn poll_transmit(&mut self) -> Option<Vec<u8>>

Bytes to write to the connection.

pub fn poll_event(&mut self) -> Option<HostEvent>

pub fn negotiated(&self) -> Option<&Negotiated>

What the handshake settled, once it has.

pub fn is_closed(&self) -> bool

pub fn close_reason(&self) -> Option<&DisconnectReason>

Why the session closed, once it has.

pub fn close(&mut self)

Closes the session from this side, failing every pending request.

Trait Implementations

impl Debug for HostSession

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

Formats the value using the given formatter.