Struct Channel 

pub struct Channel { /* private fields */ }

Blocking, length-prefixed JSON channel over a Unix stream socket.

Uses 4-byte big-endian length + JSON payload for robustness.

Implementations

impl Channel

pub fn new(stream: UnixStream) -> Self

pub fn send<T: Serialize>(&mut self, msg: &T) -> Result<()>

Send a serializable message.

pub fn recv<T: for<'de> Deserialize<'de>>(&mut self) -> Result<Option<T>>

Receive a deserializable message. Blocks until a message arrives. Returns Ok(None) on clean EOF (peer closed).

pub fn set_read_timeout(&mut self, timeout: Option<Duration>) -> Result<()>

Set a read timeout on the underlying socket. After this, recv() will return an error if no data arrives within the given duration (instead of blocking forever).

pub fn set_write_timeout(&mut self, timeout: Option<Duration>) -> Result<()>

Set a write timeout on the underlying socket.

Without this, send() calls write_all() which blocks indefinitely when the peer stops draining its receive buffer — e.g. a wedged shim that stopped reading. A blocking write_all inside the daemon’s poll_shim_handles / ping_pong tick wedges the ENTIRE daemon event loop on a single stuck handle, which matches the documented “daemon freezes after 10-15 min productive window” failure mode. Setting a bounded write timeout turns that hard-hang into a regular send() error that the caller can classify as a stale / dead handle and escalate via the usual respawn / crash paths.

pub fn try_clone(&self) -> Result<Self>

Clone the underlying fd for use in a second thread.