14 #ifndef COMMUNICATOR_MPI_INCLUDED
15 #define COMMUNICATOR_MPI_INCLUDED
34 static int init(
int *pargc,
char ***pargv);
38 static int setup(
int ninstance = 1);
43 #ifdef ENABLE_MULTI_INSTANCE
44 static bool is_primary_master();
50 #ifdef ENABLE_MULTI_INSTANCE
51 static int self_global();
52 static int world_id();
61 #ifdef ENABLE_MULTI_INSTANCE
62 static int sync_global();
74 static int reduce(
int count,
void *recv_buf,
void *send_buf, MPI_Datatype type, MPI_Op op,
int pattern);
76 static int exchange(
size_t size,
void *recv_buf,
void *send_buf,
int idir,
int ipm,
int tag);
78 static int send_1to1(
size_t size,
void *recv_buf,
void *send_buf,
int send_to,
int recv_from,
int tag);
98 #ifdef ENABLE_MULTI_INSTANCE
99 static int m_n_instance;
100 static int m_instance_id;
102 static int m_global_rank;
103 static int m_global_size;
static int send_1to1(size_t size, void *recv_buf, void *send_buf, int send_to, int recv_from, int tag)
static int broadcast(size_t size, void *data, int sender)
static int sync()
synchronize within small world.
static int setup(int ninstance=1)
static int status()
for debug
static bool is_primary()
info about rank
Channel class for asynchronous communication.
static int reduce(int count, void *recv_buf, void *send_buf, int type, int op, int pattern)
static int init(int *pargc, char ***pargv)
static int m_comm
instead of MPI_Comm m_comm;
static MPI_Comm & world()
retrieves current communicator.
static int broadcast_string(int count, string &data, int sender)
for specific datatypes
Communicator_impl & operator=(const Communicator_impl &)
static double get_time()
for getting time interval using clock count.
static Channel * recv_init(int count, int idir, int ipm)
static Channel * send_init(int count, int idir, int ipm)
async communication
Communicator_impl(const Communicator_impl &)
Implementation of Communicator with BGNET library.
static int exchange(size_t size, void *recv_buf, void *send_buf, int idir, int ipm, int tag)