Struct SocketTx 

pub struct SocketTx<'a, T: Default + Copy> { /* private fields */ }

A Tx only AF_XDP socket

Implementations

impl<'a, T: Default + Copy> SocketTx<'a, T>

pub fn try_send( &mut self, bufs: &mut ArrayDeque<[BufMmap<'_, T>; 4096], Wrapping>, batch_size: usize, ) -> Result<usize, SocketError>

Attempt to send up to batch_size buffers on the socket.

pub fn needs_wakeup(&mut self) -> bool

Identify if this socket needs to be woken up (see AF_XDP docs).

Trait Implementations

impl<'a, T: Debug + Default + Copy> Debug for SocketTx<'a, T>

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

Formats the value using the given formatter.

impl<'a, T: Default + Copy> Drop for SocketTx<'a, T>

fn drop(&mut self)

Executes the destructor for this type.

impl<'a, T: Default + Copy> Send for SocketTx<'a, T>