Struct Namespace 

pub(super) struct Namespace {
    pub(super) path: PathBuf,
    linger: Duration,
    requests: Mutex<Option<Sender<Sender<Result<Vec<(IpAddr, Result<TcpStream>)>>>>>>,
    pub(super) connect_budget: Budget,
}

Creates the sockets of a session in its network namespace, which stay in the namespace they got created in. The runtime connects them. A thread enters the namespace and serves the connections which follow within the linger time, then it ends and leaves the namespace, at once when the session ends. Failures are not kept, every connection which fails gets its own error.

Fields

path: PathBuf

linger: Duration

requests: Mutex<Option<Sender<Sender<Result<Vec<(IpAddr, Result<TcpStream>)>>>>>>

The requests of the thread which got started last.

connect_budget: Budget

What the connections which get established hold, see CONNECT_BUDGET.

Implementations

impl Namespace

pub(super) fn new(path: PathBuf) -> Arc<Self>

The network namespace at path, whose thread lingers for SOCKET_THREAD_LINGER.

pub(super) fn with_linger(path: PathBuf, linger: Duration) -> Arc<Self>

The network namespace at path, whose thread lingers for linger.

pub(super) async fn sockets(&self) -> Result<Vec<(IpAddr, Result<TcpStream>)>>

New sockets in the namespace from its thread, which gets started if it ended.

fn send( &self, reply: Sender<Result<Vec<(IpAddr, Result<TcpStream>)>>>, ) -> Result<()>

Send a request to the thread, which gets started if it ended.

fn lock( &self, ) -> MutexGuard<'_, Option<Sender<Sender<Result<Vec<(IpAddr, Result<TcpStream>)>>>>>>

fn start( &self, ) -> Result<Sender<Sender<Result<Vec<(IpAddr, Result<TcpStream>)>>>>>

fn serve( path: &Path, linger: Duration, requests: &Receiver<Sender<Result<Vec<(IpAddr, Result<TcpStream>)>>>>, )

Create sockets until no request arrived for the linger time or the session is gone. The thread enters the namespace for its first request, a request which finds it outside of the namespace tries again and gets its own error.

fn enter(path: &Path) -> Result<()>

Enter the network namespace with the current thread.

fn create_sockets() -> Vec<(IpAddr, Result<TcpStream>)>

A socket of each family, for one connection. The IPv6 one is only needed if IPv4 fails, creating it right away costs less than another round trip into the namespace thread.