Struct RxQueue 

pub struct RxQueue { /* private fields */ }

A receive queue on a DPDK port

Implementations

impl RxQueue

pub fn new( port_id: u16, queue_id: u16, _config: RxQueueConfig, ) -> DpdkResult<Self>

Create a new receive queue

pub fn port_id(&self) -> u16

Get the port ID this queue belongs to

pub fn queue_id(&self) -> u16

Get the queue ID

pub fn receive_burst(&self, max_packets: u16) -> DpdkResult<Vec<Mbuf>>

Receive a burst of packets

Returns a vector of received mbufs, up to max_packets count. This is a non-blocking operation - returns immediately with whatever packets are available.

pub fn receive_burst_timeout( &self, max_packets: u16, timeout_us: u64, ) -> DpdkResult<Vec<Mbuf>>

Poll for packets with a timeout

This is a convenience method that polls until either:

• At least one packet is received
• The timeout expires