Struct EfaQueuePair 

pub struct EfaQueuePair { /* private fields */ }

An EFA SRD queue pair, created through efadv_create_qp_ex and driven by the extended work-request builder reached via ibv_qp_to_qp_ex.

SRD is a driver queue-pair type that the device runs through the unreliable datagram state machine, so this shares almost nothing with the reliable-connected path: the connection handshake carries a queue key rather than access flags, and each work request supplies its own destination. Only endpoint discovery, state queries, and completion polling are common, and those delegate to the shared helpers in super::queue_pair.

Single-owner: it owns the [IbvQp] — which in turn owns its two completion queues and the protection domain — and destroys them on drop, so the type is intentionally !Clone.

Trait Implementations

impl Debug for EfaQueuePair

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

Formats the value using the given formatter.

impl IbvQueuePair for EfaQueuePair

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 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.

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.