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, performs eager validation (size check + local memory range race detection), and then runs them concurrently across the available backends on Self::submit.

Local-memory race detection treats an add_read_into_local claim as a write to the local range and an add_write_from_local claim as a read; two reads of the same range merge into one claim, anything else errors. Remote-side ranges are deliberately not tracked.

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. Records a local write claim over the local memory range.

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

Queue a write from local into remote. Records a local read claim over the local memory range.

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 and overlap claims are left intact.

Takes &mut self so the borrow checker prevents two submit futures from being alive on the same action simultaneously; otherwise the local-range overlap detection would be meaningless (two in-flight dispatches over the same claimed local memory).

Trait Implementations

impl Default for RdmaAction

fn default() -> Self

Returns the “default value” for a type.