Struct CompletionQueue 

pub struct CompletionQueue { /* private fields */ }

An RDMA Completion Queue (ibv_cq).

Implementations

impl CompletionQueue

pub fn new(ctx: Arc<Context>, cqe: i32) -> Result<Arc<Self>>

Create a new CQ with cqe entries.

pub fn poll(&self, wc_buf: &mut [WorkCompletion]) -> Result<usize>

Poll up to wc_buf.len() completions.

Returns the number of completions written to wc_buf.

pub fn req_notify(&self, solicited_only: bool) -> Result<()>

Request notification for the next completion.

pub fn as_raw(&self) -> *mut ibv_cq

Raw pointer (for advanced/FFI use).

pub fn with_comp_channel( ctx: Arc<Context>, cqe: i32, channel: &CompletionChannel, ) -> Result<Arc<Self>>

Create a CQ associated with a completion channel.

When completions arrive, the channel’s fd becomes readable, enabling async notification via epoll/kqueue.

Trait Implementations

impl Drop for CompletionQueue

fn drop(&mut self)

Executes the destructor for this type.

impl Send for CompletionQueue

impl Sync for CompletionQueue