G4RootMpiAnalysisManager Class Reference

#include <G4RootMpiAnalysisManager.hh>

Inheritance diagram for G4RootMpiAnalysisManager:

Public Member Functions
	G4RootMpiAnalysisManager (G4bool isMaster=true)
virtual	~G4RootMpiAnalysisManager ()
void	SetMpiNtupleMerging (tools::impi *impi, G4int mpiRank, G4int mpiSize, G4int nofReducedNtupleFiles=0)

Static Public Member Functions
static G4RootMpiAnalysisManager *	Instance ()

Protected Member Functions
virtual G4bool	OpenFileImpl (const G4String &fileName) final
virtual G4bool	WriteImpl () final
virtual G4bool	CloseFileImpl (G4bool reset) final

Static Private Attributes
static G4RootMpiAnalysisManager *	fgInstance { nullptr }

Detailed Description

Definition at line 44 of file G4RootMpiAnalysisManager.hh.

Constructor & Destructor Documentation

G4RootMpiAnalysisManager()

G4RootMpiAnalysisManager::G4RootMpiAnalysisManager ( G4bool  isMaster = true )

explicit

Definition at line 46 of file G4RootMpiAnalysisManager.cc.

 : G4RootAnalysisManager()
{
  fgInstance = this;
 
  // Reset the ntuple file manager
  fNtupleFileManager.reset();
 
  // Ntuple file manager
  fNtupleFileManager = std::make_shared<G4RootMpiNtupleFileManager>(fState);
  SetNtupleFileManager(fNtupleFileManager);
  fNtupleFileManager->SetFileManager(fFileManager);
  fNtupleFileManager->SetBookingManager(fNtupleBookingManager);
}

~G4RootMpiAnalysisManager()

G4RootMpiAnalysisManager::~G4RootMpiAnalysisManager ( )

virtual

Definition at line 62 of file G4RootMpiAnalysisManager.cc.

{
  fgInstance = 0;
}

Member Function Documentation

Instance()

G4RootMpiAnalysisManager * G4RootMpiAnalysisManager::Instance ( )

static

Definition at line 40 of file G4RootMpiAnalysisManager.cc.

{
  return fgInstance;
}

SetMpiNtupleMerging()

void G4RootMpiAnalysisManager::SetMpiNtupleMerging	(	tools::impi *	impi,
		G4int	mpiRank,
		G4int	mpiSize,
		G4int	nofReducedNtupleFiles = 0
	)

Definition at line 72 of file G4RootMpiAnalysisManager.cc.

{
  // G4cout << "SetMpiNtupleMerging: "
  //        << impi << ", "
  //        << mpiRank << ","
  //        << mpiSize << ","
  //        << nofNtupleFiles << G4endl;
 
  std::static_pointer_cast<G4RootMpiNtupleFileManager>(fNtupleFileManager)
    ->SetMpiNtupleMerging(impi, mpiRank, mpiSize, nofNtupleFiles);
}

OpenFileImpl()

G4bool G4RootMpiAnalysisManager::OpenFileImpl ( const G4String &  fileName )

finalprotectedvirtual

Definition at line 91 of file G4RootMpiAnalysisManager.cc.

{
  if ( fNtupleFileManager->GetMergeMode() == G4NtupleMergeMode::kNone )  {
    return G4ToolsAnalysisManager::OpenFileImpl(fileName);
  }
 
  // Create ntuple manager(s)
  // and set it to base class which takes then their ownership
  if ( ! fVNtupleManager ) {
    SetNtupleManager(fNtupleFileManager->CreateNtupleManager());
  }
 
  auto result = true;
 
  // Open file
  // In difference from base class a file is open also on slave ranks
  result &= fFileManager->OpenFile(fileName);
 
  // Open ntuple file(s) and create ntuples from bookings
  result &= fNtupleFileManager->ActionAtOpenFile(fFileManager->GetFullFileName());
 
  return result;
}  

WriteImpl()

G4bool G4RootMpiAnalysisManager::WriteImpl ( )

finalprotectedvirtual

Definition at line 116 of file G4RootMpiAnalysisManager.cc.

{
 
  auto result = true;
 
  // Call base class method
  result &= G4ToolsAnalysisManager::WriteImpl();
 
  // Write file also on Slave
  // (skipped in base class)
  if ( fNtupleFileManager->GetMergeMode() == G4NtupleMergeMode::kSlave )  {
    // write all open files
    result &= fFileManager->WriteFiles();
  }
 
  Message(kVL2, "write", "slave files", "", result);
 
  return result;
}

CloseFileImpl()

G4bool G4RootMpiAnalysisManager::CloseFileImpl ( G4bool  reset )

finalprotectedvirtual

Definition at line 137 of file G4RootMpiAnalysisManager.cc.

{
// Cannot call base class function, as we need to close files also
// on slave; an option in the base class can be added for this in future
 
  Message(kVL4, "close", "files");
 
  auto result = true;
  if (fVNtupleFileManager) {
    result &= fVNtupleFileManager->ActionAtCloseFile();
  }
 
  // close file also on Slave
  // - the conditoon used in the base class is commented out
  // if ( (fVNtupleFileManager == nullptr) ||
  //      (fVNtupleFileManager->GetMergeMode() != G4NtupleMergeMode::kSlave) )  {
    if ( ! fVFileManager->CloseFiles() ) {
      Warn("Closing files failed", fkClass, "CloseFileImpl");
      result = false;
    }
  // }
 
  // delete empty files
  if ( ! fVFileManager->DeleteEmptyFiles() ) {
    Warn("Deleting empty files failed", fkClass, "CloseFileImpl");
    result = false;
  }
 
  // reset histograms
  if ( reset ) {
    if ( ! Reset() ) {
      Warn("Resetting data failed", fkClass, "CloseFileImpl");
      result = false;
    }
  }
 
  Message(kVL3, "close", "files", "", result);
  G4cout << "### Done G4RootMpiAnalysisManager::CloseFileImpl" << G4endl;
 
  return result;
}

Member Data Documentation

fgInstance

G4RootMpiAnalysisManager* G4RootMpiAnalysisManager::fgInstance { nullptr }

inlinestaticprivate

Definition at line 66 of file G4RootMpiAnalysisManager.hh.

{ nullptr };

---

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

• extended/parallel/MPI/source/analysis/include/G4RootMpiAnalysisManager.hh
• extended/parallel/MPI/source/analysis/src/G4RootMpiAnalysisManager.cc