havoqgt::environment Class Reference

Start 'new' environmet here. More...

#include <environment.hpp>

Collaboration diagram for havoqgt::environment:

Public Member Functions
	environment (int *argc, char ***argv)
	~environment ()
const communicator &	world_comm () const
const communicator &	node_local_comm () const
const communicator &	node_offset_comm () const

Private Member Functions
MPI_Comm	split_node_local_comm (MPI_Comm world_comm)
MPI_Comm	split_node_offset_comm (MPI_Comm world_comm, MPI_Comm node_local_comm)
bool	is_node_mapping_round_robin (MPI_Comm world_comm, MPI_Comm node_local_comm)
bool	is_node_mapping_block (MPI_Comm world_comm, MPI_Comm node_local_comm)

Private Attributes
communicator	m_world_comm
communicator	m_node_local_comm
communicator	m_node_offset_comm

Detailed Description

Start 'new' environmet here.

Definition at line 136 of file environment.hpp.

Constructor & Destructor Documentation

havoqgt::environment::environment ( int *  argc, char ***  argv  )

inline

Definition at line 138 of file environment.hpp.

                                       {
    // Init MPI
    MPI_Init(argc, argv);
    
    // Create communicators
    m_world_comm = communicator(MPI_COMM_WORLD);
    MPI_Comm tmp_node_local_comm  = split_node_local_comm(MPI_COMM_WORLD);
    m_node_local_comm = communicator(tmp_node_local_comm);
    MPI_Comm tmp_node_offset_comm = split_node_offset_comm(MPI_COMM_WORLD, tmp_node_local_comm);
    m_node_offset_comm = communicator(tmp_node_offset_comm);
  }

Here is the call graph for this function:

havoqgt::environment::~environment ( )

inline

Definition at line 150 of file environment.hpp.

                 {
    m_world_comm.barrier();
    MPI_Finalize();
  }

Here is the call graph for this function:

Member Function Documentation

bool havoqgt::environment::is_node_mapping_block ( MPI_Comm  world_comm, MPI_Comm  node_local_comm  )

inlineprivate

Definition at line 219 of file environment.hpp.

  {
    int world_rank, world_size, node_local_rank, node_local_size;
    MPI_Comm_rank(world_comm, &world_rank);
    MPI_Comm_size(world_comm, &world_size);
    MPI_Comm_rank(node_local_comm, &node_local_rank);
    MPI_Comm_size(node_local_comm, &node_local_size);

  }

bool havoqgt::environment::is_node_mapping_round_robin ( MPI_Comm  world_comm, MPI_Comm  node_local_comm  )

inlineprivate

Definition at line 214 of file environment.hpp.

  {

  }

const communicator& havoqgt::environment::node_local_comm ( ) const

inline

Definition at line 156 of file environment.hpp.

{ return m_node_local_comm; }

Here is the caller graph for this function:

const communicator& havoqgt::environment::node_offset_comm ( ) const

inline

Definition at line 157 of file environment.hpp.

{ return m_node_offset_comm; }

MPI_Comm havoqgt::environment::split_node_local_comm ( MPI_Comm  world_comm )

inlineprivate

Definition at line 161 of file environment.hpp.

  {
    MPI_Comm to_return;
    int rank;
    MPI_Comm_rank(world_comm, &rank);

    int color = 0;
    char* cnodeid   = NULL;//getenv("SLURM_NODEID");
    char chostname[256];
    gethostname(chostname, 256);
    if(cnodeid) {
      color = boost::lexical_cast<int>(cnodeid);
    } else if(chostname) {
      std::string shostname(chostname);
      std::hash<std::string> hasher;
      color = hasher(shostname);
      if(color < 0) color *= -1;
    }

    int key = rank;
    int ret = MPI_Comm_split(world_comm, color, key, &to_return);

    int node_local_rank, node_local_size;
    MPI_Comm_rank(to_return, &node_local_rank);
    MPI_Comm_size(to_return, &node_local_size);

    if(rank < node_local_size)
    {
      if(rank != node_local_rank) {
        std::cerr << "ERROR:   Only blocked task mapping is supported" << std::endl; exit(-1);
      }
    }



    return to_return;
  }

Here is the caller graph for this function:

MPI_Comm havoqgt::environment::split_node_offset_comm ( MPI_Comm  world_comm, MPI_Comm  node_local_comm  )

inlineprivate

Definition at line 199 of file environment.hpp.

  {
    MPI_Comm to_return;
    int world_rank, node_local_rank;
    MPI_Comm_rank(world_comm, &world_rank);
    MPI_Comm_rank(node_local_comm, &node_local_rank);

    int color = node_local_rank;
    int key   = world_rank;

    int ret = MPI_Comm_split(world_comm, color, key, &to_return);

    return to_return;
  }

Here is the caller graph for this function:

const communicator& havoqgt::environment::world_comm ( ) const

inline

Definition at line 155 of file environment.hpp.

{ return m_world_comm; }

Here is the caller graph for this function:

Member Data Documentation

communicator havoqgt::environment::m_node_local_comm

private

Definition at line 230 of file environment.hpp.

communicator havoqgt::environment::m_node_offset_comm

private

Definition at line 231 of file environment.hpp.

communicator havoqgt::environment::m_world_comm

private

Definition at line 229 of file environment.hpp.

---

The documentation for this class was generated from the following file:

• include/havoqgt/environment.hpp