Enum RdmaManagerMessage 

pub enum RdmaManagerMessage {
    RequestBuffer {
        local: Arc<dyn RdmaLocalMemory>,
        reply: OncePortHandle<RdmaRemoteBuffer>,
    },
    RequestLocalMemory {
        remote_buf_id: usize,
        reply: OncePortHandle<Option<Arc<dyn RdmaLocalMemory>>>,
    },
}

Local-only messages for the RdmaManagerActor.

These messages carry Arc<dyn RdmaLocalMemory> 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: Arc<dyn RdmaLocalMemory>

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<Arc<dyn RdmaLocalMemory>>>

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.