communicator_bgnet.h

Go to the documentation of this file.

#ifndef COMMUNICATOR_BGNET_INCLUDED
#define COMMUNICATOR_BGNET_INCLUDED

#include <exception>
#include <cassert>

#include <bgnet.h>

#include "channel.h"


class Communicator_impl {
 public:
  static int init(int *pargc, char ***pargv);
  static int finalize();
  static void abort();

  static int setup(int ninstance = 1);

  static bool is_primary();

#ifdef ENABLE_MULTI_INSTANCE
  static bool is_primary_master();
#endif

  static int self();  //< rank within small world.
  static int size();  //< size of small world.

#ifdef ENABLE_MULTI_INSTANCE
  static int self_global();
  static int world_id();
#endif


  //  static MPI_Comm& world() { return m_comm; }
  static int world() { return m_comm; }

#if 0
  static int ipe(const int dir);  
  static int npe(const int dir);  

  static int grid_rank(int *rank, const int *grid_coord);
  static int grid_coord(int *grid_coord, const int rank);
  static int grid_dims(int *grid_dims);
#endif

// synchronize
  static int sync();   

#ifdef ENABLE_MULTI_INSTANCE
  static int sync_global();  
#endif

  static double get_time();

  static int status();

  class Base {
   public:
    static int reduce(int count, void *recv_buf, void *send_buf,
                      int type, int op, int pattern);

    static int broadcast(size_t size, void *data, int sender);

    static int exchange(size_t size, void *recv_buf, void *send_buf,
                        int idir, int ipm, int tag);

    static int send_1to1(size_t size, void *recv_buf, void *send_buf,
                         int send_to, int recv_from, int tag);
  };

  static int broadcast_string(int count, string& data, int sender);
  static int broadcast_double(int count, double *data, int sender);
  static int broadcast_int(int count, int *data, int sender);

  static Channel *send_init(int count, int idir, int ipm);
  static Channel *recv_init(int count, int idir, int ipm);

  class Layout;

 private:

  Communicator_impl() {}
  Communicator_impl(const Communicator_impl&) {}
  Communicator_impl& operator=(const Communicator_impl&);

  ~Communicator_impl() {}

#ifdef ENABLE_MULTI_INSTANCE
  static int m_n_instance;   
  static int m_instance_id;  

  static int m_global_rank;
  static int m_global_size;
#endif

  static int m_grid_rank;
  static int m_grid_size;

  static int m_comm;      
};
#endif /* #ifndef COMMUNICATOR_BGNET_INCLUDED */