Struct RdmaBuffer

pub struct RdmaBuffer {
    pub owner: ActorRef<RdmaManagerActor>,
    pub mr_id: usize,
    pub lkey: u32,
    pub rkey: u32,
    pub addr: usize,
    pub size: usize,
}

Fields

owner: ActorRef<RdmaManagerActor>

mr_id: usize

lkey: u32

rkey: u32

addr: usize

size: usize

Implementations

impl RdmaBuffer

pub async fn read_into( &self, client: &impl Actor, remote: RdmaBuffer, timeout: u64, ) -> Result<bool, Error>

Read from the RdmaBuffer into the provided memory.

This method transfers data from the buffer into the local memory region provided over RDMA. This involves calling a Put operation on the RdmaBuffer’s actor side.

Arguments

• client - The actor who is reading.
• remote - RdmaBuffer representing the remote memory region
• timeout - Timeout in seconds for the RDMA operation to complete.

Returns

Ok(bool) indicating if the operation completed successfully.

pub async fn write_from( &self, client: &impl Actor, remote: RdmaBuffer, timeout: u64, ) -> Result<bool, Error>

Write from the provided memory into the RdmaBuffer.

This method performs an RDMA write operation, transferring data from the caller’s memory region to this buffer. This involves calling a Fetch operation on the RdmaBuffer’s actor side.

Arguments

• client - The actor who is writing.
• remote - RdmaBuffer representing the remote memory region
• timeout - Timeout in seconds for the RDMA operation to complete.

Returns

Ok(bool) indicating if the operation completed successfully.

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

Drop the buffer and release remote handles.

This method calls the owning RdmaManagerActor to release the buffer and clean up associated memory regions. This is typically called when the buffer is no longer needed and resources should be freed.

Arguments

• client - Mailbox used for communication

Returns

Ok(()) if the operation completed successfully.

Trait Implementations

impl Clone for RdmaBuffer

fn clone(&self) -> RdmaBuffer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RdmaBuffer

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RdmaBuffer

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Named for RdmaBuffer

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 RdmaBuffer

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

where __S: Serializer,

Serialize this value into the given Serde serializer.