Struct AcceptLoop 

pub struct AcceptLoop { /* private fields */ }

Accept loop for network listeners.

The loop runs on its own threads and passes accepted connections to the server.

Implementations

impl AcceptLoop

pub fn new() -> AcceptLoop

Creates an accept loop with one accept thread.

Panics

Panics if the poller cannot be created.

pub fn name<T: AsRef<str>>(&mut self, name: T)

Sets the server name.

The first accept thread is named {name}:accept, additional threads are named {name}:accept{n}.

pub fn acceptors(&mut self, num: usize)

Sets the number of accept threads.

Every TCP listener is replicated with SO_REUSEPORT, so each accept thread has its own socket for the same address and the kernel spreads incoming connections between them. Unix domain listeners are served by the first thread only.

Multiple accept threads are supported on Linux and Android. On other platforms, a single thread is used.

Panics

Panics if a poller cannot be created.

pub fn notify(&self) -> AcceptNotify

Returns a handle for sending commands to the loop.

pub fn testing(&mut self)

Enables test mode, which skips the exit delay on stop.

pub fn start(self, socks: Vec<(Token, Listener)>, srv: Server)

Starts the accept loop on new threads.

Blocks until the listeners are registered.

Trait Implementations

impl Debug for AcceptLoop

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AcceptLoop

fn default() -> Self

Returns the “default value” for a type.