QUESO::FullEnvironment Class Reference

This class sets up the full environment underlying the use of the QUESO library by an executable. More...

#include <Environment.h>

Inheritance diagram for QUESO::FullEnvironment:

Collaboration diagram for QUESO::FullEnvironment:

Public Member Functions
Constructor/Destructor methods
	FullEnvironment (RawType_MPI_Comm inputComm, const char *passedOptionsInputFileName, const char *prefix, const EnvOptionsValues *alternativeOptionsValues)
	Default constructor. More...
	~FullEnvironment ()
	Destructor. More...
I/O methods
void	print (std::ostream &os) const
	Sends the environment options to the stream. More...
Public Member Functions inherited from QUESO::BaseEnvironment
	BaseEnvironment (const char *passedOptionsInputFileName, const EnvOptionsValues *alternativeOptionsValues)
	Default constructor. More...
	BaseEnvironment (const BaseEnvironment &obj)
	Copy constructor. It should not be used be the user. More...
virtual	~BaseEnvironment ()
	Destructor. More...
BaseEnvironment &	operator= (const BaseEnvironment &rhs)
	Assignment operator. It should not be used be the user. More...
bool	fullEnvIsReady () const
	Returns whether the full environment class is ready (constructor has successfully been called). More...
int	worldRank () const
	Returns the process world rank. More...
int	fullRank () const
	Returns the process full rank. More...
const MpiComm &	fullComm () const
	Access function for MpiComm full communicator. More...
RawType_MPI_Group	subGroup () const
	Access function for sub-group. More...
int	subRank () const
	Access function for sub-rank. More...
const MpiComm &	subComm () const
	Access function for MpiComm sub communicator. More...
const MpiComm &	selfComm () const
	Access function for MpiComm self-communicator. More...
int	inter0Rank () const
	Returns the process inter0 rank. More...
const MpiComm &	inter0Comm () const
	Access function for MpiComm inter0-communicator. More...
std::ofstream *	subDisplayFile () const
	Access function for m_subDisplayFile (displays file on stream). More...
std::string	subDisplayFileName () const
	Access function for m_subDisplayFileName (displays filename on stream). More...
unsigned int	numSubEnvironments () const
	Access function to the number of sub-environments. More...
unsigned int	subId () const
	Access function to the number of each sub-environment Id: m_subId. More...
const std::string &	subIdString () const
	Access to the attribute m_subIdString; which stores the string for the sub-environment, and it will be used, for instance, to create the output files for each sub-environment. More...
void	checkTheParallelEnvironment () const
std::string	optionsInputFileName () const
	Access to the attribute m_optionsInputFileName, which stores the name of the input file passed by the user to QUESO. More...
void	setOptionsInputFileAccessState (bool newState) const
po::variables_map &	allOptionsMap () const
void	scanInputFileForMyOptions (const po::options_description &optionsDesc) const
	This method scans the input file provided by the user to QUESO. More...
unsigned int	displayVerbosity () const
unsigned int	syncVerbosity () const
	Access function to private attribute m_syncVerbosity. More...
unsigned int	checkingLevel () const
	Access function to private attribute m_checkingLevel. More...
const RngBase *	rngObject () const
	Access to the RNG object. More...
void	resetSeed (int newSeedOption)
	Reset RNG seed. More...
int	seed () const
	Access to the RNG seed. More...
const BasicPdfsBase *	basicPdfs () const
	Access to Basic PDFs. More...
std::string	platformName () const
	Access to the platform name. More...
std::string	identifyingString () const
	Access function to private attribute m_identifyingString: identifying string. More...
void	resetIdentifyingString (const std::string &newString) const
	Reset private attribute m_identifyingString with the value newString. More...
bool	isThereInputFile () const
	//TODO Not implemented? it is called in examples/validationCycle/tests_old/results_5_25/uqTgaEx4.h. More...
struct timeval	timevalBegin () const
	Used to save the time when the combo `QUESO+user's application' started to run. More...
bool	openOutputFile (const std::string &fileName, const std::string &fileType, const std::set< unsigned int > &allowedSubEnvIds, bool writeOver, FilePtrSetStruct &filePtrSet) const
	Opens an output file for each sub-environment that was chosen to send data to the file. More...
bool	openUnifiedOutputFile (const std::string &fileName, const std::string &fileType, bool writeOver, FilePtrSetStruct &filePtrSet) const
	Opens a unified output file, that will contain data from all sub-environments. More...
bool	openInputFile (const std::string &fileName, const std::string &fileType, const std::set< unsigned int > &allowedSubEnvIds, FilePtrSetStruct &filePtrSet) const
	Opens an input file. More...
bool	openUnifiedInputFile (const std::string &fileName, const std::string &fileType, FilePtrSetStruct &filePtrSet) const
	Opens the unified input file. More...
void	closeFile (FilePtrSetStruct &filePtrSet, const std::string &fileType) const
	Closes the file. More...
void	setExceptionalCircumstance (bool value) const
	Set an exceptional circumstance. More...
bool	exceptionalCircumstance () const
	Decides whether there is an exceptional circumstance. More...

Private Member Functions
void	readOptionsInputFile ()
	Checks the options input file and reads the options. More...

Additional Inherited Members
Protected Attributes inherited from QUESO::BaseEnvironment
bool	m_fullEnvIsReady
int	m_worldRank
MpiComm *	m_fullComm
int	m_fullRank
int	m_fullCommSize
RawType_MPI_Group	m_fullGroup
std::string	m_optionsInputFileName
bool	m_optionsInputFileAccessState
po::options_description *	m_allOptionsDesc
po::variables_map *	m_allOptionsMap
unsigned int	m_subId
std::string	m_subIdString
RawType_MPI_Group	m_subGroup
MpiComm *	m_subComm
int	m_subRank
int	m_subCommSize
MpiComm *	m_selfComm
RawType_MPI_Group	m_inter0Group
MpiComm *	m_inter0Comm
int	m_inter0Rank
int	m_inter0CommSize
std::ofstream *	m_subDisplayFile
RngBase *	m_rngObject
BasicPdfsBase *	m_basicPdfs
struct timeval	m_timevalBegin
bool	m_exceptionalCircumstance
EnvOptionsValues	m_alternativeOptionsValues
EnvironmentOptions *	m_optionsObj

Detailed Description

This class sets up the full environment underlying the use of the QUESO library by an executable.

This is the class that is actually used during a QUESO+application run.

Definition at line 420 of file Environment.h.

Constructor & Destructor Documentation

QUESO::FullEnvironment::FullEnvironment	(	RawType_MPI_Comm	inputComm,
		const char *	passedOptionsInputFileName,
		const char *	prefix,
		const EnvOptionsValues *	alternativeOptionsValues
	)

Default constructor.

It initializes the full communicator, reads the options, deals with multiple sub-environments, e.g. dealing with sub/self/inter0-communicators, handles path for output files.

Definition at line 1207 of file Environment.C.

References QUESO::MpiComm::Barrier(), QUESO::CheckFilePath(), QUESO::MpiComm::Comm(), QUESO::BaseEnvironment::displayVerbosity(), QUESO::BaseEnvironment::m_allOptionsDesc, QUESO::BaseEnvironment::m_allOptionsMap, QUESO::BaseEnvironment::m_alternativeOptionsValues, QUESO::BaseEnvironment::m_basicPdfs, QUESO::BaseEnvironment::m_fullComm, QUESO::BaseEnvironment::m_fullCommSize, QUESO::BaseEnvironment::m_fullEnvIsReady, QUESO::BaseEnvironment::m_fullGroup, QUESO::BaseEnvironment::m_fullRank, QUESO::BaseEnvironment::m_inter0Comm, QUESO::BaseEnvironment::m_inter0CommSize, QUESO::BaseEnvironment::m_inter0Group, QUESO::BaseEnvironment::m_inter0Rank, QUESO::EnvOptionsValues::m_numSubEnvironments, QUESO::BaseEnvironment::m_optionsInputFileName, QUESO::BaseEnvironment::m_optionsObj, QUESO::EnvironmentOptions::m_ov, QUESO::BaseEnvironment::m_rngObject, QUESO::EnvOptionsValues::m_rngType, QUESO::EnvOptionsValues::m_seed, QUESO::BaseEnvironment::m_selfComm, QUESO::BaseEnvironment::m_subComm, QUESO::BaseEnvironment::m_subCommSize, QUESO::EnvOptionsValues::m_subDisplayAllowAll, QUESO::EnvOptionsValues::m_subDisplayAllowedSet, QUESO::EnvOptionsValues::m_subDisplayAllowInter0, QUESO::BaseEnvironment::m_subDisplayFile, QUESO::EnvOptionsValues::m_subDisplayFileName, QUESO::BaseEnvironment::m_subGroup, QUESO::BaseEnvironment::m_subId, QUESO::BaseEnvironment::m_subIdString, QUESO::BaseEnvironment::m_subRank, QUESO::BaseEnvironment::m_timevalBegin, QUESO::BaseEnvironment::m_worldRank, QUESO::MpiComm::MyPID(), QUESO::MpiComm::NumProc(), QUESO::old_terminate_handler, QUESO::queso_terminate_handler(), QUESO::QUESO_version_print(), RawValue_MPI_COMM_SELF, readOptionsInputFile(), QUESO::EnvironmentOptions::scanOptionsValues(), UQ_ENV_FILENAME_FOR_NO_OUTPUT_FILE, UQ_FATAL_TEST_MACRO, and QUESO::UQ_UNAVAILABLE_RANK.

  :
  BaseEnvironment(passedOptionsInputFileName,alternativeOptionsValues)
{
#ifdef QUESO_MEMORY_DEBUGGING
  std::cout << "Entering FullEnv" << std::endl;
#endif

  // Initialize "full" communicator -- Not necessarily MPI_COMM_WORLD
  int mpiRC = MPI_Comm_rank(inputComm,&m_worldRank);
  UQ_FATAL_TEST_MACRO(mpiRC != MPI_SUCCESS,
                      UQ_UNAVAILABLE_RANK,
                      "FullEnvironment::commonConstructor()",
                      "failed to get world fullRank()");

  m_fullComm = new MpiComm(*this,inputComm);
  m_fullRank     = m_fullComm->MyPID();
  m_fullCommSize = m_fullComm->NumProc();

  mpiRC = MPI_Comm_group(m_fullComm->Comm(), &m_fullGroup);
  UQ_FATAL_TEST_MACRO(mpiRC != MPI_SUCCESS,
                      m_worldRank,
                      "FullEnvironment::commonConstructor()",
                      "failed MPI_Comm_group()");

  // saving old uncaught exception handler, invoking queso_terminate
  old_terminate_handler = std::set_terminate(queso_terminate_handler);

#ifdef QUESO_MEMORY_DEBUGGING
  std::cout << "In FullEnv, finished dealing with MPI initially" << std::endl;
#endif

  // Read options
  if (m_optionsInputFileName == "") {
    m_optionsObj = new EnvironmentOptions(*this,prefix,m_alternativeOptionsValues);
  }
  else {
    m_allOptionsMap  = new po::variables_map();
    m_allOptionsDesc = new po::options_description("Allowed options");
    m_optionsObj = new EnvironmentOptions(*this,prefix);

    readOptionsInputFile();

    m_optionsObj->scanOptionsValues();
  }

#ifdef QUESO_MEMORY_DEBUGGING
  std::cout << "In FullEnv, finished scanning options" << std::endl;
#endif

  // Only display these messages if the user wants them
  // NOTE: This got moved below the Read Options section
  // because we need the options to be read to know what
  // the verbosity level is.
  if (this->displayVerbosity() > 0) {
    // Display main initial messages
    // 'std::cout' is for: main trace messages + synchronized trace messages + error messages prior to 'exit()' or 'abort()'
    /*int iRC = 0;*/
    /*iRC = */gettimeofday(&m_timevalBegin, NULL);
      
    if (m_fullRank == 0) {
      QUESO_version_print(std::cout);
    }
      
    if (m_fullRank == 0) {
      std::cout << "Beginning run at " << ctime(&m_timevalBegin.tv_sec)
                << std::endl;
    }
  }

  // Deal with multiple subEnvironments: create the sub communicators, one for each subEnvironment
  unsigned int numRanksPerSubEnvironment = m_fullCommSize/m_optionsObj->m_ov.m_numSubEnvironments;

  m_subId = m_fullRank/numRanksPerSubEnvironment;
  char tmpSubId[16];
  sprintf(tmpSubId,"%u",m_subId);
  m_subIdString = tmpSubId;

  if (m_optionsObj->m_ov.m_subDisplayAllowAll) {
    m_optionsObj->m_ov.m_subDisplayAllowedSet.insert((unsigned int) m_subId);
  }

  std::vector<int> fullRanksOfMySubEnvironment(numRanksPerSubEnvironment,0);
  for (unsigned int i = 0; i < numRanksPerSubEnvironment; ++i) {
    fullRanksOfMySubEnvironment[i] = m_subId * numRanksPerSubEnvironment + i;
  }

  mpiRC = MPI_Group_incl(m_fullGroup, (int) numRanksPerSubEnvironment, &fullRanksOfMySubEnvironment[0], &m_subGroup);
  UQ_FATAL_TEST_MACRO(mpiRC != MPI_SUCCESS,
                      m_worldRank,
                      "FullEnvironment::commonConstructor()",
                      "failed MPI_Group_incl() for a subEnvironment");

  RawType_MPI_Comm subRawComm;
  mpiRC = MPI_Comm_create(m_fullComm->Comm(), m_subGroup, &subRawComm);
  UQ_FATAL_TEST_MACRO(mpiRC != MPI_SUCCESS,
                      m_worldRank,
                      "FullEnvironment::commonConstructor()",
                      "failed MPI_Comm_group() for a subEnvironment");
  m_subComm = new MpiComm(*this,subRawComm);
  m_subRank     = m_subComm->MyPID();
  m_subCommSize = m_subComm->NumProc();

  // Deal with multiple subEnvironments: create the self communicator
  m_selfComm = new MpiComm(*this,RawValue_MPI_COMM_SELF);

  // Deal with multiple subEnvironments: create the inter0 communicator
  std::vector<int> fullRanksOfInter0(m_optionsObj->m_ov.m_numSubEnvironments,0);
  for (unsigned int i = 0; i < m_optionsObj->m_ov.m_numSubEnvironments; ++i) {
    fullRanksOfInter0[i] = i * numRanksPerSubEnvironment;
  }
  mpiRC = MPI_Group_incl(m_fullGroup, (int) m_optionsObj->m_ov.m_numSubEnvironments, &fullRanksOfInter0[0], &m_inter0Group);
  UQ_FATAL_TEST_MACRO(mpiRC != MPI_SUCCESS,
                      m_worldRank,
                      "FullEnvironment::commonConstructor()",
                      "failed MPI_Group_incl() for inter0");
  RawType_MPI_Comm inter0RawComm;
  mpiRC = MPI_Comm_create(m_fullComm->Comm(), m_inter0Group, &inter0RawComm);
  UQ_FATAL_TEST_MACRO(mpiRC != MPI_SUCCESS,
                      m_worldRank,
                      "FullEnvironment::commonConstructor()",
                      "failed MPI_Comm_group() for inter0");
  if (m_fullRank%numRanksPerSubEnvironment == 0) {
    m_inter0Comm = new MpiComm(*this,inter0RawComm);
    m_inter0Rank     = m_inter0Comm->MyPID();
    m_inter0CommSize = m_inter0Comm->NumProc();
  }

  if (m_optionsObj->m_ov.m_subDisplayAllowAll) {
    // This situation has been already taken care of above
  }
  else if (m_optionsObj->m_ov.m_subDisplayAllowInter0) {
    if (m_inter0Rank >= 0) {
      m_optionsObj->m_ov.m_subDisplayAllowedSet.insert((unsigned int) m_subId);
    }
  }


  // Open "screen" file
  bool openFile = false;
  if ((m_subRank                                               == 0                                              ) &&
      (m_optionsObj->m_ov.m_subDisplayFileName                 != UQ_ENV_FILENAME_FOR_NO_OUTPUT_FILE             ) &&
      (m_optionsObj->m_ov.m_subDisplayAllowedSet.find(m_subId) != m_optionsObj->m_ov.m_subDisplayAllowedSet.end())) {
    openFile = true;
  }

  if (openFile && m_worldRank == 0) {
    // Verify parent directory exists (for cases when a user
    // specifies a relative path for the desired output file).
    int irtrn = CheckFilePath((m_optionsObj->m_ov.m_subDisplayFileName+"_sub"+m_subIdString+".txt").c_str());
    UQ_FATAL_TEST_MACRO(irtrn < 0,
                        m_worldRank,
                        "Environment::constructor()",
                        "unable to verify output path");
  }

  // Ensure that rank 0 has created path, if necessary, before other tasks use it
  m_fullComm->Barrier(); 

  if (openFile) {
    // Always write over an eventual pre-existing file
    m_subDisplayFile = new std::ofstream((m_optionsObj->m_ov.m_subDisplayFileName+"_sub"+m_subIdString+".txt").c_str(),
                                         std::ofstream::out | std::ofstream::trunc);
    UQ_FATAL_TEST_MACRO((m_subDisplayFile && m_subDisplayFile->is_open()) == false,
                        m_worldRank,
                        "Environment::constructor()",
                        "failed to open sub screen file");

    QUESO_version_print(*m_subDisplayFile);

    *m_subDisplayFile << "Beginning run at " << ctime(&m_timevalBegin.tv_sec)
                      << std::endl;
  }

  // Debug message related to subEnvironments
  if (this->displayVerbosity() >= 2) {
    for (int i = 0; i < m_fullCommSize; ++i) {
      if (i == m_fullRank) {
        //std::cout << "In FullEnvironment::commonConstructor()"
        std::cout << "MPI node of worldRank "             << m_worldRank
                  << " has fullRank "                     << m_fullRank
                  << ", belongs to subEnvironment of id " << m_subId
                  << ", and has subRank "                 << m_subRank
                  << std::endl;

        std::cout << "MPI node of worldRank " << m_worldRank
                  << " belongs to sub communicator with full ranks";
        for (unsigned int j = 0; j < fullRanksOfMySubEnvironment.size(); ++j) {
          std::cout << " " << fullRanksOfMySubEnvironment[j];
        }
        std::cout << "\n";

        if (m_inter0Comm) {
          std::cout << "MPI node of worldRank " << m_worldRank
                    << " also belongs to inter0 communicator with full ranks";
          for (unsigned int j = 0; j < fullRanksOfInter0.size(); ++j) {
            std::cout << " " << fullRanksOfInter0[j];
          }
          std::cout << ", and has inter0Rank " << m_inter0Rank;
        }
        std::cout << "\n";

        std::cout << std::endl;
      }
      m_fullComm->Barrier();
    }
    //if (this->fullRank() == 0) std::cout << "Sleeping 3 seconds..."
    //                                     << std::endl;
    //sleep(3);
  }

  // Deal with seed
  if (m_optionsObj->m_ov.m_rngType == "gsl") {
    m_rngObject = new RngGsl(m_optionsObj->m_ov.m_seed,m_worldRank);
    m_basicPdfs = new BasicPdfsGsl(m_worldRank);
  }
  else if (m_optionsObj->m_ov.m_rngType == "boost") {
    m_rngObject = new RngBoost(m_optionsObj->m_ov.m_seed,m_worldRank);
    m_basicPdfs = new BasicPdfsBoost(m_worldRank);
  }
  else {
    std::cerr << "In Environment::constructor()"
              << ": rngType = " << m_optionsObj->m_ov.m_rngType
              << std::endl;
    UQ_FATAL_TEST_MACRO(true,
                        m_worldRank,
                        "Environment::constructor()",
                        "the requested 'rngType' is not supported yet");
  }

  // Leave commonConstructor()
  m_fullComm->Barrier();
  m_fullEnvIsReady = true;

  if ((m_subDisplayFile) && (this->displayVerbosity() >= 5)) {
    *m_subDisplayFile << "Done with initializations at FullEnvironment::commonConstructor()"
                      << std::endl;
  }

  return;
}

QUESO::FullEnvironment::~FullEnvironment

(

)

Destructor.

Definition at line 1479 of file Environment.C.

{
}

Member Function Documentation

void QUESO::FullEnvironment::print ( std::ostream &  os ) const

virtual

Sends the environment options to the stream.

Implements QUESO::BaseEnvironment.

Definition at line 1484 of file Environment.C.

{
  os.flush(); // just to avoid icpc warnings
  return;
}

void QUESO::FullEnvironment::readOptionsInputFile ( )

private

Checks the options input file and reads the options.

Definition at line 1513 of file Environment.C.

References QUESO::BaseEnvironment::m_fullRank, QUESO::BaseEnvironment::m_optionsInputFileName, and queso_error.

Referenced by FullEnvironment().

{
  std::ifstream* ifs = new std::ifstream(m_optionsInputFileName.c_str());
  if (ifs->is_open()) {
    //ifs->close();
    delete ifs;
  }
  else {
    if (m_fullRank == 0) std::cout << "An invalid input file has been passed to the 'environment' class constructor!"
                                   << ": name of file is '" << m_optionsInputFileName.c_str() << "'"
                                   << std::endl;

    if (m_fullRank == 0) std::cout << "\nThis is a help message of the QUESO library."
                                   << "\nAn application using the QUESO library shall be executed by typing"
                                   << "\n  '<eventual mpi commands and options> <Application> <InputFile>'"
                                   << "\nin the command line."
                                   << "\n"
                                   << std::endl;
    queso_error();
  }

  return;
}

---

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

• src/core/inc/Environment.h
• src/core/src/Environment.C