Struct AnyProcess 

pub struct AnyProcess<'a> { /* private fields */ }

A handle matching any source (MPI_ANY_SOURCE); implements Source only.

Trait Implementations

impl<'a> Clone for AnyProcess<'a>

fn clone(&self) -> AnyProcess<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for AnyProcess<'a>

impl Source for AnyProcess<'_>

fn source_rank(&self) -> Rank

The rank being received from (or MPI_ANY_SOURCE).

fn receive<Msg: Equivalence>(&self) -> (Msg, Status)

Receive a single value (MPI_Recv).

fn receive_with_tag<Msg: Equivalence>(&self, tag: Tag) -> (Msg, Status)

Receive a single value with a specific tag.

fn receive_vec<Msg: Equivalence>(&self) -> (Vec<Msg>, Status)

Receive a variable number of values into a new Vec.

fn receive_vec_with_tag<Msg: Equivalence>(&self, tag: Tag) -> (Vec<Msg>, Status)

Receive a variable number of values into a new Vec, with a tag.

fn receive_into<Buf: BufferMut + ?Sized>(&self, buf: &mut Buf) -> Status

Receive into an existing buffer (MPI_Recv).

fn receive_into_with_tag<Buf: BufferMut + ?Sized>( &self, buf: &mut Buf, tag: Tag, ) -> Status

Receive into an existing buffer, with a tag.

fn probe(&self) -> Status

Blocking probe (MPI_Probe): wait for a matching message, describe it without receiving.

fn probe_with_tag(&self, tag: Tag) -> Status

Blocking probe with a tag.

fn immediate_probe(&self) -> Option<Status>

Non-blocking probe (MPI_Iprobe).

fn immediate_probe_with_tag(&self, tag: Tag) -> Option<Status>

Non-blocking probe with a tag.

fn matched_probe(&self) -> (Message, Status)

Matched probe (MPI_Mprobe): remove a matching message from the queue and return a Message to receive it.

fn matched_probe_with_tag(&self, tag: Tag) -> (Message, Status)

Matched probe with a tag.

fn immediate_matched_probe(&self) -> Option<(Message, Status)>

Non-blocking matched probe (MPI_Improbe).

fn immediate_matched_probe_with_tag( &self, tag: Tag, ) -> Option<(Message, Status)>

Non-blocking matched probe with a tag.

fn immediate_receive<Msg: Equivalence>(&self) -> ReceiveFuture<Msg>

Non-blocking receive of a single value, returning a ReceiveFuture.

fn immediate_receive_with_tag<Msg: Equivalence>( &self, tag: Tag, ) -> ReceiveFuture<Msg>

Non-blocking receive of a single value with a tag.

fn immediate_receive_into<'a, Sc, Buf>( &self, scope: Sc, buf: &'a mut Buf, ) -> Request<'a, Buf, Sc>

where Buf: 'a + BufferMut + ?Sized, Sc: Scope<'a>,

Non-blocking receive into an existing buffer (MPI_Irecv), returning a Request that must be completed via wait/test.

fn immediate_receive_into_with_tag<'a, Sc, Buf>( &self, scope: Sc, buf: &'a mut Buf, tag: Tag, ) -> Request<'a, Buf, Sc>

where Buf: 'a + BufferMut + ?Sized, Sc: Scope<'a>,

Non-blocking receive into a buffer, with a tag.

fn receive_init<'a, Buf: BufferMut + ?Sized>( &self, buf: &'a mut Buf, ) -> PersistentRequest<'a>

Create a persistent receive request bound to buf (MPI_Recv_init). start it (and wait) repeatedly to re-post the receive.