Struct RdmaRemoteBuffer 

pub struct RdmaRemoteBuffer {
    pub id: usize,
    pub size: usize,
    pub owner: ActorRef<RdmaManagerActor>,
    pub backends: Vec<RdmaRemoteBackendContext>,
}

Lightweight handle representing a registered RDMA buffer.

Contains an id for the buffer registration, the buffer size, a reference to the owning RdmaManagerActor, and backend-specific contexts for performing RDMA operations.

Fields

id: usize

size: usize

owner: ActorRef<RdmaManagerActor>

backends: Vec<RdmaRemoteBackendContext>

Implementations

impl RdmaRemoteBuffer

pub async fn choose_backend( &self, client: &(impl Actor + Send + Sync), ) -> Result<RdmaLocalBackend, Error>

Choose the best available backend for this buffer.

Prefers ibverbs when both the local and remote sides support it. Falls back to TCP when ibverbs is unavailable and RDMA_ALLOW_TCP_FALLBACK is enabled.

pub async fn write_from_local( &self, client: &(impl Actor + Send + Sync), local: Arc<dyn RdmaLocalMemory>, timeout: u64, ) -> Result<bool, Error>

Push data from local memory into this remote buffer (local->remote).

pub async fn read_into_local( &self, client: &(impl Actor + Send + Sync), local: Arc<dyn RdmaLocalMemory>, timeout: u64, ) -> Result<bool, Error>

Pull data from this remote buffer into local memory (remote->local).

pub async fn drop_buffer(&self, client: &impl Actor) -> Result<(), Error>

Drop the buffer and release remote handles.

pub async fn resolve_ibv( &self, client: &impl Actor, ) -> Option<Result<(ActorRef<IbvManagerActor>, IbvBuffer), Error>>

Resolve the ibverbs backend context for this buffer.

Returns None if the buffer has no ibverbs backend context (i.e., the remote side was created without ibverbs). Returns Some(Err(...)) if the context exists but lazy MR resolution fails. Returns Some(Ok(...)) on success.

pub fn resolve_tcp(&self) -> Result<(ActorRef<TcpManagerActor>, usize), Error>

Extract the TCP backend context from this buffer.

Unlike [resolve_ibv], no lazy initialization is needed – the TCP backend only needs the remote actor ref and the buffer id.

Trait Implementations

impl Clone for RdmaRemoteBuffer

fn clone(&self) -> RdmaRemoteBuffer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RdmaRemoteBuffer

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RdmaRemoteBuffer

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Named for RdmaRemoteBuffer

fn typename() -> &'static str

The globally unique type name for the type. This should typically be the fully qualified Rust name of the type.

fn typehash() -> u64

A globally unique hash for this type. TODO: actually enforce perfect hashing

fn typeid() -> TypeId

The TypeId for this type. TypeIds are unique only within a binary, and should not be used for global identification.

fn port() -> u64

The globally unique port for this type. Typed ports are in the range of 1<<63..1<<64-1.

fn arm(&self) -> Option<&'static str>

If the named type is an enum, this returns the name of the arm of the value self.

unsafe fn arm_unchecked(self_: *const ()) -> Option<&'static str>

An unsafe version of ‘arm’, accepting a pointer to the value, for use in type-erased settings.

impl Serialize for RdmaRemoteBuffer

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.