Struct WindowsControlChannelServer 

pub struct WindowsControlChannelServer {
    pipe: NamedPipeServer,
    endpoint: OsString,
}

Daemon-side control channel backed by a Windows named pipe server.

One instance owns one [NamedPipeServer] endpoint. accept waits for the matching client process to connect; send / recv then exchange already-framed bytes produced by cssh-rs-protocol.

Fields

pipe: NamedPipeServer

endpoint: OsString

Implementations

impl WindowsControlChannelServer

pub fn bind(endpoint: &OsStr) -> Result<WindowsControlChannelServer, Error>

Open a new named-pipe server endpoint at endpoint.

Arguments

• endpoint - Fully-qualified Windows named-pipe name (e.g. \\.\pipe\cssh-rs-named-pipe-for-ipc).

Returns

Ready-to-accept server, or the underlying I/O error from [ServerOptions::create].

pub fn endpoint(&self) -> &OsStr

Endpoint name the server is bound to.

Returns

The named-pipe path supplied to Self::bind.

pub async fn ready_to_read(&mut self) -> Result<bool, Error>

Test for pending readable bytes without blocking.

Returns

Ok(true) when the pipe has bytes ready to read, Ok(false) otherwise, or the underlying I/O error.

Trait Implementations

impl ControlChannelServer for WindowsControlChannelServer

type Error = Error

Error type returned by control-channel operations.

async fn accept( &mut self, ) -> Result<(), <WindowsControlChannelServer as ControlChannelServer>::Error>

Wait for the client process to connect.

async fn send( &mut self, frame: &[u8], ) -> Result<(), <WindowsControlChannelServer as ControlChannelServer>::Error>

Send an already-framed control message to the connected client.

async fn recv( &mut self, buf: &mut [u8], ) -> Result<usize, <WindowsControlChannelServer as ControlChannelServer>::Error>

Read up to buf.len() bytes from the connected client into buf.