Struct mpi::topology::AnyProcess
[−]
[src]
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, [src]
C: 'a + Communicator,
fn source_rank(&self) -> Rank[src]
Rank that identifies the source
fn probe_with_tag(&self, tag: Tag) -> Status[src]
Probe a source for incoming messages. Read more
fn probe(&self) -> Status[src]
Probe a source for incoming messages. Read more
fn matched_probe_with_tag(&self, tag: Tag) -> (Message, Status)[src]
Probe a source for incoming messages with guaranteed reception. Read more
fn matched_probe(&self) -> (Message, Status)[src]
Probe a source for incoming messages with guaranteed reception. Read more
fn receive_with_tag<Msg>(&self, tag: Tag) -> (Msg, Status) where
Msg: Equivalence, [src]
Msg: Equivalence,
Receive a message containing a single instance of type Msg. Read more
fn receive<Msg>(&self) -> (Msg, Status) where
Msg: Equivalence, [src]
Msg: Equivalence,
Receive a message containing a single instance of type Msg. Read more
fn receive_into_with_tag<Buf: ?Sized>(&self, buf: &mut Buf, tag: Tag) -> Status where
Buf: BufferMut, [src]
Buf: BufferMut,
Receive a message into a Buffer. Read more
fn receive_into<Buf: ?Sized>(&self, buf: &mut Buf) -> Status where
Buf: BufferMut, [src]
Buf: BufferMut,
Receive a message into a Buffer. Read more
fn receive_vec_with_tag<Msg>(&self, tag: Tag) -> (Vec<Msg>, Status) where
Msg: Equivalence, [src]
Msg: Equivalence,
Receive a message containing multiple instances of type Msg into a Vec. Read more
fn receive_vec<Msg>(&self) -> (Vec<Msg>, Status) where
Msg: Equivalence, [src]
Msg: Equivalence,
Receive a message containing multiple instances of type Msg into a Vec. Read more
fn immediate_receive_into_with_tag<'a, Sc, Buf: ?Sized>(
&self,
scope: Sc,
buf: &'a mut Buf,
tag: Tag
) -> Request<'a, Sc> where
Buf: 'a + BufferMut,
Sc: Scope<'a>, [src]
&self,
scope: Sc,
buf: &'a mut Buf,
tag: Tag
) -> Request<'a, Sc> where
Buf: 'a + BufferMut,
Sc: Scope<'a>,
Initiate an immediate (non-blocking) receive operation. Read more
fn immediate_receive_into<'a, Sc, Buf: ?Sized>(
&self,
scope: Sc,
buf: &'a mut Buf
) -> Request<'a, Sc> where
Buf: 'a + BufferMut,
Sc: Scope<'a>, [src]
&self,
scope: Sc,
buf: &'a mut Buf
) -> Request<'a, Sc> where
Buf: 'a + BufferMut,
Sc: Scope<'a>,
Initiate an immediate (non-blocking) receive operation. Read more
fn immediate_receive_with_tag<Msg>(&self, tag: Tag) -> ReceiveFuture<Msg> where
Msg: Equivalence, [src]
Msg: Equivalence,
Initiate a non-blocking receive operation for messages matching tag tag. Read more
fn immediate_receive<Msg>(&self) -> ReceiveFuture<Msg> where
Msg: Equivalence, [src]
Msg: Equivalence,
Initiate a non-blocking receive operation. Read more
fn immediate_probe_with_tag(&self, tag: Tag) -> Option<Status>[src]
Asynchronously probe a source for incoming messages. Read more
fn immediate_probe(&self) -> Option<Status>[src]
Asynchronously probe a source for incoming messages. Read more
fn immediate_matched_probe_with_tag(
&self,
tag: Tag
) -> Option<(Message, Status)>[src]
&self,
tag: Tag
) -> Option<(Message, Status)>
Asynchronously probe a source for incoming messages with guaranteed reception. Read more
fn immediate_matched_probe(&self) -> Option<(Message, Status)>[src]
Asynchronously probe a source for incoming messages with guaranteed reception. Read more
impl<'a, C> AsCommunicator for AnyProcess<'a, C> where
C: 'a + Communicator, [src]
C: 'a + Communicator,
type Out = C
The type of the associated communicator
fn as_communicator(&self) -> &Self::Out[src]
Returns the associated communicator.