Enum RdmaManagerMessage 

pub enum RdmaManagerMessage {
    RequestBuffer {
        local: KeepaliveLocalMemory,
        reply: OncePortHandle<RdmaRemoteBuffer>,
    },
    RequestLocalMemory {
        remote_buf_id: usize,
        reply: OncePortHandle<Option<KeepaliveLocalMemory>>,
    },
    GetBackendHandles {
        reply: OncePortHandle<Vec<RdmaBackendHandle>>,
    },
}

Local-only messages for the RdmaManagerActor.

These messages carry KeepaliveLocalMemory and are therefore not serializable – they can only be sent within the same process.

Variants

RequestBuffer

Register a local memory handle and return a RdmaRemoteBuffer that remote peers can use to address this buffer over RDMA.

Fields

local: KeepaliveLocalMemory

reply: OncePortHandle<RdmaRemoteBuffer>

RequestLocalMemory

Look up the local memory handle for a given remote_buf_id. Returns None if the id does not correspond to a registered buffer.

Fields

remote_buf_id: usize

reply: OncePortHandle<Option<KeepaliveLocalMemory>>

GetBackendHandles

Return in-process handles to all spawned backends, in priority order.

Fields

reply: OncePortHandle<Vec<RdmaBackendHandle>>

Trait Implementations

impl Debug for RdmaManagerMessage

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

Formats the value using the given formatter.

impl Handler<RdmaManagerMessage> for RdmaManagerActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, Self>, message: RdmaManagerMessage, ) -> 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.

fn message_status_reporting() -> MessageStatusReporting

Select which layer reports the message’s terminal telemetry status.