![]() |
fpmas 1.6
|
#include <communication.h>
Public Member Functions | |
void | init () |
![]() | |
MPI_Comm | getMpiComm () const |
MPI_Group | getMpiGroup () const |
int | getRank () const override |
int | getSize () const override |
void | send (const void *data, int count, MPI_Datatype datatype, int destination, int tag) override |
void | send (const DataPack &data, MPI_Datatype datatype, int destination, int tag) override |
void | send (int destination, int tag) override |
void | Isend (const void *data, int count, MPI_Datatype datatype, int destination, int tag, Request &req) override |
void | Isend (const DataPack &data, MPI_Datatype datatype, int destination, int tag, Request &req) override |
void | Isend (int destination, int tag, Request &req) override |
void | Issend (const void *data, int count, MPI_Datatype datatype, int destination, int tag, Request &req) override |
void | Issend (const DataPack &data, MPI_Datatype datatype, int destination, int tag, Request &req) override |
void | Issend (int destination, int tag, Request &req) override |
void | recv (int source, int tag, Status &status=Status::IGNORE) override |
void | recv (void *buffer, int count, MPI_Datatype datatype, int source, int tag, Status &status=Status::IGNORE) override |
void | recv (DataPack &data, MPI_Datatype datatype, int source, int tag, Status &status=Status::IGNORE) override |
void | probe (MPI_Datatype type, int source, int tag, Status &) override |
bool | Iprobe (MPI_Datatype type, int source, int tag, Status &) override |
bool | test (Request &req) override |
void | wait (Request &req) override |
void | waitAll (std::vector< Request > &req) override |
std::unordered_map< int, DataPack > | allToAll (std::unordered_map< int, DataPack > export_map, MPI_Datatype datatype) override |
std::vector< DataPack > | gather (DataPack data, MPI_Datatype datatype, int root) override |
std::vector< DataPack > | allGather (DataPack data, MPI_Datatype datatype) override |
DataPack | bcast (DataPack data, MPI_Datatype datatype, int root) override |
void | barrier () override |
virtual int | getRank () const =0 |
virtual int | getSize () const =0 |
virtual void | send (const void *data, int count, MPI_Datatype datatype, int destination, int tag)=0 |
virtual void | send (const DataPack &data, MPI_Datatype datatype, int destination, int tag)=0 |
virtual void | send (int destination, int tag)=0 |
virtual void | Isend (const void *data, int count, MPI_Datatype datatype, int destination, int tag, Request &request)=0 |
virtual void | Isend (const DataPack &data, MPI_Datatype datatype, int destination, int tag, Request &request)=0 |
virtual void | Isend (int destination, int tag, Request &request)=0 |
virtual void | Issend (const void *data, int count, MPI_Datatype datatype, int destination, int tag, Request &request)=0 |
virtual void | Issend (const DataPack &data, MPI_Datatype datatype, int destination, int tag, Request &request)=0 |
virtual void | Issend (int destination, int tag, Request &request)=0 |
virtual void | probe (MPI_Datatype type, int source, int tag, Status &status)=0 |
virtual bool | Iprobe (MPI_Datatype type, int source, int tag, Status &status)=0 |
virtual void | recv (int source, int tag, Status &status=Status::IGNORE)=0 |
virtual void | recv (void *buffer, int count, MPI_Datatype datatype, int source, int tag, Status &status)=0 |
virtual void | recv (DataPack &data, MPI_Datatype datatype, int source, int tag, Status &status)=0 |
virtual bool | test (Request &request)=0 |
virtual void | wait (Request &request)=0 |
virtual void | waitAll (std::vector< Request > &requests)=0 |
virtual std::unordered_map< int, DataPack > | allToAll (std::unordered_map< int, DataPack > export_map, MPI_Datatype datatype)=0 |
virtual std::vector< DataPack > | gather (DataPack data, MPI_Datatype datatype, int root)=0 |
virtual std::vector< DataPack > | allGather (DataPack data, MPI_Datatype datatype)=0 |
virtual DataPack | bcast (DataPack data, MPI_Datatype datatype, int root)=0 |
virtual void | barrier ()=0 |
Additional Inherited Members | |
![]() | |
static MPI_Datatype | IGNORE_TYPE = MPI_INT |
![]() | |
int | size |
int | rank |
MPI_Group | group |
MPI_Comm | comm |
Special api::communication::MpiCommunicator implementation, built from MPI_COMM_WORLD.
|
inline |
Initializes internal MPI structures from MPI_COMM_WORLD.
This must be called after MPI_Init(). Since an MpiCommWorld instance is very likely to be declared static (see WORLD), this can't be performed in the constructor, since MPI_Init() can't be called before the call to a constructor of a static variable.