Struct mpi::topology::AnyProcess

pub struct AnyProcess<'a, C>(_) where C: 'a + Communicator;

Identifies an arbitrary process that is a member of a certain communicator, e.g. for use as a Source in point to point communication.

Trait Implementations

impl<'a, C> Source for AnyProcess<'a, C> where C: 'a + Communicator

fn source_rank(&self) -> Rank

Rank that identifies the source

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

Probe a source for incoming messages.

fn probe(&self) -> Status

Probe a source for incoming messages.

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

Probe a source for incoming messages with guaranteed reception.

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

Probe a source for incoming messages with guaranteed reception.

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

Receive a message containing a single instance of type Msg.

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

Receive a message containing a single instance of type Msg.

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

Receive a message into a Buffer.

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

Receive a message into a Buffer.

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

Receive a message containing multiple instances of type Msg into a Vec.

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

Receive a message containing multiple instances of type Msg into a Vec.

fn immediate_receive_into_with_tag<'b, Buf: ?Sized>(&self,
                                                    buf: &'b mut Buf,
                                                    tag: Tag)
                                                    -> WriteRequest<'b, Buf> where Buf: 'b + BufferMut

Initiate an immediate (non-blocking) receive operation.

fn immediate_receive_into<'b, Buf: ?Sized>(&self,
                                           buf: &'b mut Buf)
                                           -> WriteRequest<'b, Buf> where Buf: 'b + BufferMut

Initiate an immediate (non-blocking) receive operation.

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

Initiate a non-blocking receive operation for messages matching tag tag.

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

Initiate a non-blocking receive operation.

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

Asynchronously probe a source for incoming messages.

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

Asynchronously probe a source for incoming messages.

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

Asynchronously probe a source for incoming messages with guaranteed reception.

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

Asynchronously probe a source for incoming messages with guaranteed reception.

impl<'a, C> AsCommunicator for AnyProcess<'a, C> where C: 'a + Communicator

type Out = C

The type of the associated communicator

fn as_communicator(&self) -> &Self::Out

Returns the associated communicator.