Struct StatsServerInner

struct StatsServerInner<Req, Res>
where
    Req: Send + 'static,
    Res: Send + 'static,
{
    listener: UnixListener,
    data: Arc<Mutex<StatsServerData<Req, Res>>>,
    inner_ch: ChannelPair<Req, Res>,
    exit: Arc<AtomicBool>,
}

Fields

listener: UnixListener

data: Arc<Mutex<StatsServerData<Req, Res>>>

inner_ch: ChannelPair<Req, Res>

exit: Arc<AtomicBool>

Implementations

impl<Req, Res> StatsServerInner<Req, Res>

where Req: Send + 'static, Res: Send + 'static,

fn new( listener: UnixListener, data: Arc<Mutex<StatsServerData<Req, Res>>>, inner_ch: ChannelPair<Req, Res>, exit: Arc<AtomicBool>, ) -> Self

fn build_resp<T>(errno: i32, resp: &T) -> Result<StatsResponse>

where T: Serialize,

fn handle_request( line: String, data: &Arc<Mutex<StatsServerData<Req, Res>>>, ch: &ChannelPair<Req, Res>, open_ops: &mut StatsOpenOps<Req, Res>, ) -> Result<StatsResponse>

fn serve( stream: UnixStream, data: Arc<Mutex<StatsServerData<Req, Res>>>, inner_ch: ChannelPair<Req, Res>, exit: Arc<AtomicBool>, ) -> Result<()>

fn proxy( inner_ch: ChannelPair<Req, Res>, add_res: Receiver<ChannelPair<Res, Req>>, )

fn listen(self)