Struct RdmaAction 

pub struct RdmaAction { /* private fields */ }

A batch of RDMA operations submitted as a single unit.

RdmaAction is a builder that accumulates read-into-local and write-from-local ops, checking each op’s sizes as it is added, and then runs them concurrently across the available backends on Self::submit.

Overlap between the queued ops’ memory ranges is not tracked, on either the local or the remote side. Two ops in one action that write the same range race, and it is the caller’s job not to queue them.

Implementations

impl RdmaAction

pub fn new() -> Self

pub fn add_read_into_local( &mut self, remote: RdmaRemoteBuffer, local: KeepaliveLocalMemory, ) -> Result<&mut Self, Error>

Queue a read from remote into local.

pub fn add_write_from_local( &mut self, remote: RdmaRemoteBuffer, local: KeepaliveLocalMemory, ) -> Result<&mut Self, Error>

Queue a write from local into remote.

pub async fn submit( &mut self, client: &(impl Actor + Send + Sync), timeout: Duration, ) -> Result<(), Error>

Submit all queued ops. Ops are grouped by backend and each group is submitted in parallel. Safe to call more than once on the same action — the queued ops are left intact.

Takes &mut self so the borrow checker prevents two submit futures from being alive on the same action at once, which would put two in-flight dispatches over the same local memory.

Trait Implementations

impl Default for RdmaAction

fn default() -> Self

Returns the “default value” for a type.