Struct AsyncSession 

pub struct AsyncSession { /* private fields */ }

Implementations

impl AsyncSession

pub async fn recv(&self, buf: &mut [u8]) -> Result<usize>

pub async fn send(&self, buf: &[u8]) -> Result<usize>

Methods from Deref<Target = Session>

pub fn get_adapter(&self) -> Arc<Adapter>

pub fn allocate_send_packet( self: &Arc<Self>, size: u16, ) -> Result<Packet, Error>

Allocates a send packet of the specified size. Wraps WintunAllocateSendPacket

All packets returned from this function must be sent using Session::send_packet because wintun establishes the send packet order based on the invocation order of this function. Therefore if a packet is allocated using this function, and then never sent, it will hold up the send queue for all other packets allocated in the future. It is okay for the session to shutdown with allocated packets that have not yet been sent

pub fn send_packet(&self, packet: Packet)

Sends a packet previously allocated with Session::allocate_send_packet

pub fn try_receive(self: &Arc<Self>) -> Result<Option<Packet>, Error>

Attempts to receive a packet from the virtual interface without blocking. If there are no packets currently in the receive queue, this function returns Ok(None) without blocking. If blocking until a packet is desirable, use Session::receive_blocking

pub fn get_read_wait_event(&self) -> Result<UnsafeHandle<HANDLE>, Error>

Safety

Returns the low level read event handle that is signaled when more data becomes available to read

pub fn get_shutdown_event(&self) -> UnsafeHandle<HANDLE>

pub fn receive_blocking(self: &Arc<Self>) -> Result<Packet, Error>

Blocks until a packet is available, returning the next packet in the receive queue once this happens. If the session is closed via Session::shutdown all threads currently blocking inside this function will return Err(())

pub fn wait_read(&self) -> Result<(), Error>

pub fn shutdown(&self) -> Result<(), Error>

Cancels any active calls to Session::receive_blocking making them instantly return Err(_) so that session can be shutdown cleanly

pub fn try_recv(&self, buf: &mut [u8]) -> Result<usize>

pub fn recv(&self, buf: &mut [u8]) -> Result<usize>

Blocks until a packet is available, returning the next packet in the receive queue once this happens. If the session is closed via Session::shutdown all threads currently blocking inside this function will return Err(())

pub fn send(&self, buf: &[u8]) -> Result<usize>

Trait Implementations

impl AsyncRead for AsyncSession

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<Result<usize>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl AsyncWrite for AsyncSession

fn poll_write( self: Pin<&mut Self>, _cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

Attempt to flush the object, ensuring that any buffered data reach their destination.

fn poll_close(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

Attempt to close the object.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from bufs into the object using vectored IO operations.

impl Clone for AsyncSession

fn clone(&self) -> AsyncSession

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Deref for AsyncSession

type Target = Session

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl From<Arc<Session>> for AsyncSession

fn from(session: Arc<Session>) -> Self

Converts to this type from the input type.