Struct Netstack 

pub struct Netstack<D> { /* private fields */ }

A userspace network stack.

This is a relatively thin shell around CoreStack to provide convenience runtime features.

Implementations

impl<D> Netstack<D>

pub fn with_clock(dev: D, config: Config, clock: Clock) -> Self

Construct a new netstack with the given device, configuration, and clock.

pub fn run_blocking(&mut self, poll_delay: Duration)

where D: Device,

Run the netstack, driving the internal event loop to consume commands.

Runs forever, blocking the current thread.

poll_delay is the amount of time to sleep when we’re done with I/O and commands to process: a smaller delay improves latency at the cost of CPU cycles spent polling. Consider the async methods for an event-driven approach.

pub async fn run_with_sleep(&mut self, sleep: impl AsyncFn(Duration) + Clone)

where D: Device + AsyncWakeDevice + Unpin,

Run the netstack, driving the internal event loop to consume commands.

The sleep function is the runtime-specific sleep implementation. It has the Clone bound for esoteric async type system reasons (the loop needs to call the function multiple times, but it doesn’t want to reason about &impl AsyncFn). A normal closure or async fn ref will satisfy the bound.

Trait Implementations

impl<D> HasChannel for Netstack<D>

fn borrow_channel(&self) -> impl Borrow<Channel> + Send

Retrieve a Channel borrow.

fn command_channel(&self) -> WeakSender<Request>

Clone a new command channel.

fn request_blocking( &self, handle: Option<SocketHandle>, command: impl Into<Command>, ) -> Result<Response, ChannelClosedError>

Send a request through the channel.

fn request( &self, handle: Option<SocketHandle>, command: impl Into<Command>, ) -> impl Future<Output = Result<Response, Error>> + Send

Asynchronously send a request through the channel.

fn request_nonblocking( &self, handle: Option<SocketHandle>, command: impl Into<Command>, ) -> Result<(), ChannelClosedError>

Send a nonblocking request, discarding any response.