Struct MlxQueuePair 

pub struct MlxQueuePair(/* private fields */);

An mlx5 RC queue pair created through mlx5dv_create_qp, so it carries the mlx5dv send-ops flags that arm a direct-WQE/doorbell data path.

Operations delegate to an inner RCQueuePair, driving the QP through the standard ibv_post_send/ibv_poll_cq verbs; the mlx5dv send-ops flags are not exercised by that path.

Trait Implementations

impl Debug for MlxQueuePair

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

Formats the value using the given formatter.

impl IbvQueuePair for MlxQueuePair

unsafe fn new<I: IbvDomainImpl<QueuePair = Self>>( domain: &IbvDomain<I>, config: IbvConfig, send_cq: Arc<IbvCq>, recv_cq: Arc<IbvCq>, ) -> Result<Self, Error>

Creates a queue pair against domain in the RESET state, reporting its completions on send_cq and recv_cq; Self::connect transitions it to RTS before use.

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

Transitions the QP through INIT -> RTR -> RTS, connected to info.

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

Returns the local endpoint other peers need in order to connect to this QP.

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

Returns the current ibv_qp_state of the QP.

fn put( &mut self, remote_dst: IbvRemoteMemoryRegionView, local_src: IbvMemoryRegionView, ) -> Result<Vec<u64>, Error>

Post an RDMA WRITE of local_src into remote_dst. The request may be chunked into multiple WRs. This method returns the list of WR ids that were posted.

fn get( &mut self, local_dst: IbvMemoryRegionView, remote_src: IbvRemoteMemoryRegionView, ) -> Result<Vec<u64>, Error>

Post an RDMA READ of remote_src into local_dst. The request may be chunked into multiple WRs. This method returns the list of WR ids that were posted.

fn max_msg_size(&self) -> usize

Largest transfer this QP issues as a single work request; Self::put and Self::get split anything larger into that many WRs. The owning [QueuePairActor] budgets send-queue credits against this value, so an implementation that chunks more finely must report it here or it will over-commit the send queue.