Struct IoContext 

pub struct IoContext<S: IoState, O: Origin = Solicited> {
    pub reply: ReplyHeader,
    request: O::Request,
    state: S,
}

The server’s work item for one request (or one server event). Owns the reply header and — while Solicited — the parsed request; parameterized by the lifecycle state S and origin O.

Fields

reply: ReplyHeader

Header the eventual reply is framed with.

request: O::Request

Owned request payload for this origin (SmbRequest for Solicited, () otherwise). Accessed only through the state-appropriate methods.

state: S

Lifecycle state value (a ZST for data-less states; carries data for Pending).

Implementations

impl IoContext<Accepted, Solicited>

pub fn accept(reply: ReplyHeader, request: SmbRequest) -> Self

Accept a parsed request for processing; the SmbRequest is moved in and owned by the context from here on.

pub(crate) fn split(self) -> (IoContext<Accepted, Bare>, SmbRequest)

Split the request out to hand it to its concrete Command handler; the context keeps the reply header and becomes request-neutral (Bare).

impl IoContext<Accepted, Unsolicited>

pub fn from_event(reply: ReplyHeader) -> Self

Build a request-less context for a server-initiated response.

impl<O: Origin> IoContext<Accepted, O>

pub fn respond(self, status: Status, body: Vec<u8>) -> SmbResponse

Produce the terminal reply, consuming the context (the request payload is dropped). Reachable in the Accepted state for any origin.

impl IoContext<Accepted, Bare>

pub fn defer(self, async_id: u64) -> IoContext<Pending, Bare>

Defer this request: park it as Pending so an async worker owns it and completes it later; the reader loop is never blocked.

impl IoContext<Pending, Bare>

pub fn async_id(&self) -> u64

The async correlation id this deferred op was parked under.

pub fn interim(&self, status: Status, body: Vec<u8>) -> SmbResponse

Build the immediate interim reply for this deferred op without consuming the parked context ([MS-SMB2] §3.3.4.2). The worker still owns self and completes it later.

pub fn complete(self, status: Status, body: Vec<u8>) -> SmbResponse

Complete a deferred op with its final reply, consuming the parked context. Only callable in the Pending state, so a request cannot be completed unless it was actually deferred.

Trait Implementations

impl<S: Debug + IoState, O: Debug + Origin> Debug for IoContext<S, O>

where O::Request: Debug,

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

Formats the value using the given formatter.