Enum IbvManagerLocalMessage 

pub enum IbvManagerLocalMessage {
    RegisterMr {
        addr: usize,
        size: usize,
        reply: OncePortHandle<Result<(IbvMemoryRegionView, String), String>>,
    },
    RegisterRemoteBuffer {
        remote_buf_id: usize,
        local: Arc<KeepaliveLocalMemory>,
        reply: OncePortHandle<Result<IbvBuffer, String>>,
    },
    RequestQueuePair {
        other: ActorRef<IbvManagerActor>,
        self_device: String,
        other_device: String,
        reply: OncePortHandle<Result<IbvQueuePair, String>>,
    },
}

Local-only messages for IbvManagerActor.

Variants

RegisterMr

Register a memory region, returning the MR view and device name.

Fields

addr: usize

size: usize

reply: OncePortHandle<Result<(IbvMemoryRegionView, String), String>>

RegisterRemoteBuffer

Register a remote-facing buffer’s MR and return its IbvBuffer. Called by [crate::rdma_manager_actor::RdmaManagerActor::request_buffer] at buffer-creation time.

The MR lives in IbvManagerActor::buffer_registrations and is deregistered on IbvManagerMessage::ReleaseBuffer.

Fields

remote_buf_id: usize

local: Arc<KeepaliveLocalMemory>

reply: OncePortHandle<Result<IbvBuffer, String>>

RequestQueuePair

User-facing entry point: get a connected IbvQueuePair for (self_device, other actor's id, other_device). Lazily creates the QP + initializer if absent; if a handshake is in flight, the reply port is queued and answered when the QP becomes Ready (or fails).

No #[reply] because the handler may park reply on the Pending entry and answer it later from [QpInitializerDone]/ [QpInitializerFailed].

Fields

other: ActorRef<IbvManagerActor>

self_device: String

other_device: String

reply: OncePortHandle<Result<IbvQueuePair, String>>

Trait Implementations

impl Debug for IbvManagerLocalMessage

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

Formats the value using the given formatter.

impl Handler<IbvManagerLocalMessage> for IbvManagerActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, Self>, message: IbvManagerLocalMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle the next M-typed message.