Struct Node 

pub struct Node { /* private fields */ }

A ranked RDMA network node with barrier synchronization.

Wraps a MultiChannel with a rank, world size, and a Barrier for collective synchronization across all nodes in the network.

Implementations

impl Node

pub fn builder<'f1>() -> NodeBuilder<'f1>

impl Node

pub fn barrier( &mut self, peers: &[usize], timeout: Duration, ) -> Result<(), BarrierError>

Synchronizes with the given peers, blocking until all have reached the barrier or timeout.

pub fn barrier_unchecked( &mut self, peers: &[usize], timeout: Duration, ) -> Result<(), BarrierError>

Like barrier, but skips validation of the peer list.

impl Node

pub fn send<'op>( &'op mut self, wr: PeerSendWorkRequest<'op, 'op>, ) -> TransportResult<WorkSuccess>

Posts a send to the work request’s target peer and blocks until it completes.

pub fn receive<'op>( &'op mut self, wr: PeerReceiveWorkRequest<'op, 'op>, ) -> TransportResult<WorkSuccess>

Posts a receive to the work request’s target peer and blocks until it completes.

pub fn write<'op>( &'op mut self, wr: PeerWriteWorkRequest<'op, 'op>, ) -> TransportResult<WorkSuccess>

Posts an RDMA write to the work request’s target peer and blocks until it completes.

pub fn read<'op>( &'op mut self, wr: PeerReadWorkRequest<'op, 'op>, ) -> TransportResult<WorkSuccess>

Posts an RDMA read to the work request’s target peer and blocks until it completes.

impl Node

pub unsafe fn send_unpolled<'data>( &mut self, wr: PeerSendWorkRequest<'_, 'data>, ) -> IbvResult<PendingWork<'data>>

Posts a send to the target peer without polling for completion.

Safety

See Channel::send_unpolled.

pub unsafe fn receive_unpolled<'data>( &mut self, wr: PeerReceiveWorkRequest<'_, 'data>, ) -> IbvResult<PendingWork<'data>>

Posts a receive to the target peer without polling for completion.

Safety

See Channel::receive_unpolled.

pub unsafe fn write_unpolled<'data>( &mut self, wr: PeerWriteWorkRequest<'_, 'data>, ) -> IbvResult<PendingWork<'data>>

Posts an RDMA write to the target peer without polling for completion.

Safety

See Channel::write_unpolled.

pub unsafe fn read_unpolled<'data>( &mut self, wr: PeerReadWorkRequest<'_, 'data>, ) -> IbvResult<PendingWork<'data>>

Posts an RDMA read to the target peer without polling for completion.

Safety

See Channel::read_unpolled.

impl Node

pub fn scatter_send<'op, I>( &'op mut self, wrs: I, ) -> TransportResult<Vec<WorkSuccess>>

where I: IntoIterator<Item = PeerSendWorkRequest<'op, 'op>>,

Posts sends to multiple peers and blocks until all complete.

pub fn scatter_write<'op, I>( &'op mut self, wrs: I, ) -> TransportResult<Vec<WorkSuccess>>

where I: IntoIterator<Item = PeerWriteWorkRequest<'op, 'op>>,

Posts RDMA writes to multiple peers and blocks until all complete.

pub fn gather_receive<'op, I>( &'op mut self, wrs: I, ) -> TransportResult<Vec<WorkSuccess>>

where I: IntoIterator<Item = PeerReceiveWorkRequest<'op, 'op>>,

Posts receives from multiple peers and blocks until all complete.

pub fn gather_read<'op, I>( &'op mut self, wrs: I, ) -> TransportResult<Vec<WorkSuccess>>

where I: IntoIterator<Item = PeerReadWorkRequest<'op, 'op>>,

Posts RDMA reads from multiple peers and blocks until all complete.

pub fn multicast_send<'op, I>( &'op mut self, peers: I, wr: SendWorkRequest<'op, 'op>, ) -> TransportResult<Vec<WorkSuccess>>

where I: IntoIterator<Item = usize>,

Posts the same send to multiple peers and blocks until all complete.

impl Node

pub unsafe fn scatter_send_unpolled<'wr, 'data, I>( &mut self, wrs: I, ) -> IbvResult<Vec<PendingWork<'data>>>

where I: IntoIterator<Item = PeerSendWorkRequest<'wr, 'data>>, 'data: 'wr,

Posts sends to multiple peers without polling for completion.

Safety

See Channel::send_unpolled.

pub unsafe fn scatter_write_unpolled<'wr, 'data, I>( &mut self, wrs: I, ) -> IbvResult<Vec<PendingWork<'data>>>

where I: IntoIterator<Item = PeerWriteWorkRequest<'wr, 'data>>, 'data: 'wr,

Posts RDMA writes to multiple peers without polling for completion.

Safety

See Channel::write_unpolled.

pub unsafe fn gather_receive_unpolled<'wr, 'data, I>( &mut self, wrs: I, ) -> IbvResult<Vec<PendingWork<'data>>>

where I: IntoIterator<Item = PeerReceiveWorkRequest<'wr, 'data>>, 'data: 'wr,

Posts receives from multiple peers without polling for completion.

Safety

See Channel::receive_unpolled.

pub unsafe fn gather_read_unpolled<'wr, 'data, I>( &mut self, wrs: I, ) -> IbvResult<Vec<PendingWork<'data>>>

where I: IntoIterator<Item = PeerReadWorkRequest<'wr, 'data>>, 'data: 'wr,

Posts RDMA reads from multiple peers without polling for completion.

Safety

See Channel::read_unpolled.

pub unsafe fn multicast_send_unpolled<'wr, 'data, I>( &mut self, peers: I, wr: SendWorkRequest<'wr, 'data>, ) -> IbvResult<Vec<PendingWork<'data>>>

where I: IntoIterator<Item = usize>,

Posts the same send to multiple peers without polling for completion.

Safety

See Channel::send_unpolled.

impl Node

pub fn scope<'env, F, T, E>(&'env mut self, f: F) -> Result<T, ScopeError<E>>

where F: for<'scope> FnOnce(&mut PollingScope<'scope, 'env, Node>) -> Result<T, E>,

Opens a polling scope that automatically polls all outstanding work requests when it ends.

See Channel::scope for details on the scoping mechanism.

pub fn manual_scope<'env, F, T, E>(&'env mut self, f: F) -> Result<T, E>

where F: for<'scope> FnOnce(&mut PollingScope<'scope, 'env, Node>) -> Result<T, E>,

Opens a polling scope that enforces manual polling of all work requests.

See Channel::manual_scope for details.

impl Node

pub fn pd(&self) -> &ProtectionDomain

Returns the protection domain this node belongs to.

pub fn world_size(&self) -> usize

Returns the total number of nodes in the network.

pub fn rank(&self) -> usize

Returns this node’s rank (index) in the network.

Trait Implementations

impl Debug for Node

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

Formats the value using the given formatter.