Struct RayonComm 

pub struct RayonComm { /* private fields */ }

Implementations

impl RayonComm

pub fn new(rank: usize, size: usize) -> Self

Trait Implementations

impl Clone for RayonComm

fn clone(&self) -> RayonComm

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Communicator for RayonComm

type SendHandle = LocalSendHandle

Handle returned by isend.

type RecvHandle = LocalRecvHandle

Handle returned by irecv.

fn isend(&self, peer: usize, tag: u16, buf: &[u8]) -> Self::SendHandle

fn irecv(&self, peer: usize, tag: u16, buf: &mut [u8]) -> Self::RecvHandle

fn rank(&self) -> usize

Rank of this process (0..size-1)

fn size(&self) -> usize

Total number of ranks

fn barrier(&self)

Synchronization barrier (default: no-op for non-MPI comms)

fn isend_result( &self, peer: usize, tag: u16, buf: &[u8], ) -> Result<Self::SendHandle, MeshSieveError>

Fallible send initiation for backends that can error.

fn irecv_result( &self, peer: usize, tag: u16, buf: &mut [u8], ) -> Result<Self::RecvHandle, MeshSieveError>

Fallible receive initiation for backends that can error.

fn is_no_comm(&self) -> bool

Returns true if this communicator is NoComm (for test logic)

fn barrier_result(&self) -> Result<(), MeshSieveError>

Fallible barrier for backends that can error.

fn broadcast(&self, root: usize, buf: &mut [u8])

Broadcast a byte buffer from root to all ranks.

fn broadcast_result( &self, root: usize, buf: &mut [u8], ) -> Result<(), MeshSieveError>

Fallible broadcast for backends that can error.

fn allreduce_sum(&self, values: &mut [u64])

All-reduce sum for u64 buffers.

fn allreduce_sum_result(&self, values: &mut [u64]) -> Result<(), MeshSieveError>

Fallible all-reduce for backends that can error.

fn allgather(&self, sendbuf: &[u8], recvbuf: &mut [u8])

All-gather fixed-size byte buffers into recvbuf (rank-major order).

fn allgather_result( &self, sendbuf: &[u8], recvbuf: &mut [u8], ) -> Result<(), MeshSieveError>

Fallible all-gather for backends that can error.

fn reserve_tag_range(&self, n: u16) -> Result<CommTag, MeshSieveError>

Reserve a contiguous range of tags for this communicator.

impl Debug for RayonComm

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

Formats the value using the given formatter.