Struct CompletionQueue 

pub struct CompletionQueue { /* private fields */ }

A shared handle to a Completion Queue (CQ).

This struct is thread-safe (Sync) and reference-counted (Arc). It holds a strong reference to the Context that created it, ensuring the device remains open.

Implementations

impl CompletionQueue

pub fn create( context: &Context, min_capacity: u32, ) -> IbvResult<CompletionQueue>

Creates a new Completion Queue.

Arguments

• context — The device context on which to create the CQ.
• min_capacity — The minimum number of completion entries this CQ must hold. The hardware may allocate a larger queue.

Errors

• Returns IbvError::InvalidInput if min_capacity is too large (exceeds device limits) or cannot fit in an i32.
• Returns IbvError::Resource if the system cannot allocate the necessary resources.

pub fn poll<'poll_buff>( &self, completions: &'poll_buff mut [PollSlot], ) -> IbvResult<PolledCompletions<'poll_buff>>

Polls the CQ for completed work requests.

This method checks the hardware queue for completions. It is non-blocking: if no completions are available, it returns an empty iterator immediately.

Arguments

• completions — A mutable slice of PollSlots. This buffer serves as the destination where the NIC/driver will write the completion data. By requiring the caller to provide this buffer, the library avoids internal heap allocations during the hot polling loop. If the buffer length exceeds i32::MAX, only i32::MAX entries will be polled and the remaining slots will be unused; a warning is logged in that case.

Returns

Returns a PolledCompletions iterator wrapper. This iterator yields owned WorkCompletion values constructed from the data copied by the NIC into the provided completions buffer.

pub fn min_capacity(&self) -> u32

Returns the minimum capacity of the Completion Queue.

pub fn context(&self) -> &Context

Returns a reference to the Context associated with this CQ.

Trait Implementations

impl Clone for CompletionQueue

fn clone(&self) -> CompletionQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CompletionQueue

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

Formats the value using the given formatter.