Struct SimpleMux

pub struct SimpleMux<P: IOProtocol> { /* private fields */ }

Simple server implementation that creates one AF_INET/SOCK_STREAM socket and uses it to bind/listen at the specified address. It instantiates one epoll to accept new connections and one instance per cpu left to perform I/O.

TODO rename to something more interesting TODO think about how to support request pipelining

Events are handled synchronously TODO explain why useful for RPC or protocols that support request/message pipelining

New connections are load balanced from the connections epoll to the rest in a round-robin fashion.

Implementations

impl<P> SimpleMux<P>

where P: IOProtocol,

pub fn new(config: SimpleMuxConfig, protocol: P) -> Result<SimpleMux<P>>

Trait Implementations

impl<P> Drop for SimpleMux<P>

where P: IOProtocol,

fn drop(&mut self)

Executes the destructor for this type.

impl<P> Handler<EpollEvent> for SimpleMux<P>

where P: IOProtocol,

fn is_terminated(&self) -> bool

fn ready(&mut self, _: &EpollEvent)

impl<P> ServerImpl for SimpleMux<P>

where P: IOProtocol + 'static,

fn get_loop_ms(&self) -> isize

fn stop(&mut self)

fn bind(self, mask: SigSet) -> Result<()>