Struct ServerConnection 

pub struct ServerConnection {
    pub data: StreamWrapper,
    pub control: StreamWrapper,
}

A client connection (from the server’s perspective)

Fields

data: StreamWrapper

Data stream for raw byte stream

control: StreamWrapper

Control stream for JSON messages

Implementations

impl ServerConnection

pub fn read_data(&self, buf: &mut [u8]) -> Result<usize>

Read available data from the data socket (non-blocking)

pub fn write_data(&self, buf: &[u8]) -> Result<()>

Write data to the data socket

pub fn read_control(&self) -> Result<Option<String>>

Read a control message (blocking)

pub fn write_control(&self, msg: &str) -> Result<()>

Write a control message

Control messages MUST be delivered atomically: the client frames them by reading up to a trailing newline, so a partial write (message body with no terminating \n) wedges the client’s blocking read_control() forever, waiting for a newline that never arrives.

The server keeps the control socket in non-blocking mode for its polling reads in process_clients(). On a non-blocking socket a large message (e.g. a SetClipboard carrying a big selection) overflows the kernel send buffer: write_all writes part of it, hits WouldBlock, and returns an error — leaving a truncated, newline-less message on the wire. To guarantee the whole message (and its newline) is delivered we force blocking mode for the duration of the write, then restore non-blocking mode for the next polling read.