MPIenv Class Reference

MPI environment setup. More...

#include <MPImanager.h>

Collaboration diagram for MPIenv:

Public Member Functions
	MPIenv (int *argc, char ***argv, MPImanager *&_p)
bool	isMaster () const
int	workerCount () const
int	workerRank () const
std::string	hostName () const

Static Public Member Functions
static void	abort (int i)
static void	finish (MPImanager *p)

Private Attributes
int	size
int	rank
std::string	host

Detailed Description

MPI environment setup.

Provides basic node information: rank (0 is master, 1...size-1 are workers), hostname. Constructor creates the MPImanagers (Master or worker). This can be instantiated also in a single cpu situation, will return trivial values. The abort() function should always be used instead of exit().

Constructor & Destructor Documentation

MPIenv()

MPIenv::MPIenv	(	int *	argc,
		char ***	argv,
		MPImanager *&	_p
	)

{
#ifdef USE_MPI
 
#ifdef DEBUG_MPI
  message(">>>> STARTING NEMO MPI <<<<\n");
#endif
 
  MPI_Init( argc, argv );
 
  MPI_Comm_size(MPI_COMM_WORLD, &size);
  MPI_Comm_rank(MPI_COMM_WORLD, &rank);
 
  if(0 > size - 1){
    fatal("MPI environment needs more than 1 cpu to run properly (found %i cpu).\n", size);
  }
 
  int lhost;
//  char *thost = new char[100];
  char thost[MPI_MAX_PROCESSOR_NAME];
 
  //  MPI::Get_processor_name(thost, lhost);
  MPI_Get_processor_name(&thost[0], &lhost);
 
  host = std::string( thost, lhost );
 
  if ( rank == 0 ) _p = new MPImaster(size-1);
  else             _p = new MPIworker();
 
#ifdef DEBUG_MPI
  message(">>>> MPI_COMM_WORLD::size = %i\n",size);
  message(">>>> I have rank %i (%s) on host %s <<<<\n", rank, (rank==0?"Master":"Worker"), host.c_str());
#endif
 
#else
  size = 1;
  rank = 0;
  host = std::string( "local" );
#endif
}

References fatal(), host, message(), rank, and size.

Member Function Documentation

abort()

void MPIenv::abort ( int  i )

static

{
#ifdef USE_MPI
//  MPI::COMM_WORLD.Abort(i);
  MPI_Abort(MPI_COMM_WORLD, i);
#endif
  exit(i);
}

Referenced by abort(), and fatal().

finish()

void MPIenv::finish ( MPImanager *  p )

static

{
#ifdef USE_MPI
  delete p;
  MPI_Finalize();
#endif
}

Referenced by SimRunner::run().

hostName()

std::string MPIenv::hostName ( ) const

inline

{ return host; }

References host.

isMaster()

bool MPIenv::isMaster ( ) const

inline

{ return (rank==0); }

References rank.

Referenced by BinaryDataSaver::finish(), FileServices::init(), SimRunner::init_random_seed(), FileParser::read(), SimRunner::Replicate_LOOP(), SimRunner::run(), ParamManager::set_parameters(), and FileHandler::update().

workerCount()

int MPIenv::workerCount ( ) const

inline

{ return size-1; }

References size.

Referenced by RAND::init().

workerRank()

int MPIenv::workerRank ( ) const

inline

{ return rank; }

References rank.

Referenced by BinaryDataSaver::finish(), FileServices::getFirstReplicateFileName(), and RAND::init().

Member Data Documentation

host

std::string MPIenv::host

private

Referenced by hostName(), and MPIenv().

rank

int MPIenv::rank

private

Referenced by isMaster(), MPIenv(), and workerRank().

size

int MPIenv::size

private

Referenced by MPIenv(), and workerCount().

---

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

• MPImanager.h
• MPImanager.cc