Struct IbvQueuePair 

pub struct IbvQueuePair {
    pub send_cq: usize,
    pub recv_cq: usize,
    pub qp: usize,
    pub dv_qp: usize,
    pub dv_send_cq: usize,
    pub dv_recv_cq: usize,
    /* private fields */
}

An RDMA Queue Pair (QP) for communication between two endpoints.

Encapsulates the send/receive queues, completion queues, and mlx5dv device-specific structures needed for RDMA communication.

Connection Lifecycle

1. Create with new() from context and protection domain pointers
2. Get connection info with get_qp_info()
3. Exchange connection info with remote peer
4. Connect to remote endpoint with connect()
5. Perform RDMA operations with put() or get()
6. Poll for completions with poll_completion()

Notes

• The qp field stores a pointer to rdmaxcel_qp_t (not ibv_qp)
• rdmaxcel_qp_t contains atomic counters and completion caches internally
• This makes IbvQueuePair trivially Clone and Serialize
• Multiple clones share the same underlying rdmaxcel_qp_t via the pointer

Fields

send_cq: usize

recv_cq: usize

qp: usize

dv_qp: usize

dv_send_cq: usize

dv_recv_cq: usize

Implementations

impl IbvQueuePair

pub fn new( context: *mut ibv_context, pd: *mut ibv_pd, config: IbvConfig, ) -> Result<Self, Error>

Creates a new IbvQueuePair.

Initializes a new Queue Pair (QP) and associated Completion Queues (CQ) using the provided context and protection domain. The QP is created in the RESET state and must be transitioned via connect() before use.

Errors

Returns errors if CQ or QP creation fails.

pub fn get_qp_info(&mut self) -> Result<IbvQpInfo, Error>

Returns the connection info needed by a remote peer to connect to this QP.

pub fn state(&mut self) -> Result<u32, Error>

Returns the current state of the QP.

pub fn connect(&mut self, connection_info: &IbvQpInfo) -> Result<(), Error>

Transitions the QP through INIT -> RTR -> RTS to establish a connection.

Arguments

• connection_info - The remote connection info to connect to

pub fn recv( &mut self, lhandle: IbvBuffer, rhandle: IbvBuffer, ) -> Result<u64, Error>

pub fn put_with_recv( &mut self, lhandle: IbvBuffer, rhandle: IbvBuffer, ) -> Result<Vec<u64>, Error>

pub fn put( &mut self, lhandle: IbvBuffer, rhandle: IbvBuffer, ) -> Result<Vec<u64>, Error>

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

Rings the doorbell to execute all enqueued operations.

pub fn enqueue_put( &mut self, lhandle: IbvBuffer, rhandle: IbvBuffer, ) -> Result<Vec<u64>, Error>

Enqueues a put operation without ringing the doorbell.

pub fn enqueue_put_with_recv( &mut self, lhandle: IbvBuffer, rhandle: IbvBuffer, ) -> Result<Vec<u64>, Error>

Enqueues a put-with-receive operation without ringing the doorbell.

pub fn enqueue_get( &mut self, lhandle: IbvBuffer, rhandle: IbvBuffer, ) -> Result<Vec<u64>, Error>

Enqueues a get operation without ringing the doorbell.

pub fn get( &mut self, lhandle: IbvBuffer, rhandle: IbvBuffer, ) -> Result<Vec<u64>, Error>

pub fn poll_completion( &mut self, target: PollTarget, expected_wr_ids: &[u64], ) -> Result<Vec<(u64, IbvWc)>, Error>

Polls for work completions by wr_ids.

Arguments

• target - Which completion queue to poll (Send, Receive)
• expected_wr_ids - Slice of work request IDs to wait for

Returns

• Ok(Vec<(u64, IbvWc)>) - Vector of (wr_id, completion) pairs found
• Err(e) - An error occurred

Trait Implementations

impl Clone for IbvQueuePair

fn clone(&self) -> IbvQueuePair

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IbvQueuePair

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for IbvQueuePair

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Named for IbvQueuePair

fn typename() -> &'static str

The globally unique type name for the type. This should typically be the fully qualified Rust name of the type.

fn typehash() -> u64

A globally unique hash for this type. TODO: actually enforce perfect hashing

fn typeid() -> TypeId

The TypeId for this type. TypeIds are unique only within a binary, and should not be used for global identification.

fn port() -> u64

The globally unique port for this type. Typed ports are in the range of 1<<63..1<<64-1.

fn arm(&self) -> Option<&'static str>

If the named type is an enum, this returns the name of the arm of the value self.

unsafe fn arm_unchecked(self_: *const ()) -> Option<&'static str>

An unsafe version of ‘arm’, accepting a pointer to the value, for use in type-erased settings.

impl Serialize for IbvQueuePair

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.