G4MTRunManager Class Reference

#include <G4MTRunManager.hh>

Inheritance diagram for G4MTRunManager:

Public Types
enum class	WorkerActionRequest { UNDEFINED , NEXTITERATION , PROCESSUI , ENDWORKER }
using	masterWorlds_t = std::map<G4int, G4VPhysicalVolume*>
Public Types inherited from G4RunManager
enum	RMType {   sequentialRM , masterRM , workerRM , subEventMasterRM ,   subEventWorkerRM }

Public Member Functions
	G4MTRunManager ()
	~G4MTRunManager () override
void	SetNumberOfThreads (G4int n) override
G4int	GetNumberOfThreads () const override
void	SetPinAffinity (G4int n=1)
G4int	GetPinAffinity () const
void	Initialize () override
void	InitializeEventLoop (G4int n_event, const char *macroFile=nullptr, G4int n_select=-1) override
virtual void	InitializeThreadPool ()
void	TerminateOneEvent () override
void	ProcessOneEvent (G4int i_event) override
void	ConstructScoringWorlds () override
void	RunTermination () override
virtual G4bool	SetUpAnEvent (G4Event *, G4long &s1, G4long &s2, G4long &s3, G4bool reseedRequired=true)
virtual G4int	SetUpNEvents (G4Event *, G4SeedsQueue *seedsQueue, G4bool reseedRequired=true)
std::vector< G4String >	GetCommandStack ()
virtual size_t	GetNumberActiveThreads () const
virtual void	ThisWorkerReady ()
virtual void	ThisWorkerEndEventLoop ()
const CLHEP::HepRandomEngine *	getMasterRandomEngine () const
void	SetUserInitialization (G4VUserPhysicsList *userPL) override
void	SetUserInitialization (G4VUserDetectorConstruction *userDC) override
void	SetUserInitialization (G4UserWorkerInitialization *userInit) override
void	SetUserInitialization (G4UserWorkerThreadInitialization *userInit) override
void	SetUserInitialization (G4VUserActionInitialization *userInit) override
void	SetUserAction (G4UserRunAction *userAction) override
void	SetUserAction (G4VUserPrimaryGeneratorAction *userAction) override
void	SetUserAction (G4UserEventAction *userAction) override
void	SetUserAction (G4UserStackingAction *userAction) override
void	SetUserAction (G4UserTrackingAction *userAction) override
void	SetUserAction (G4UserSteppingAction *userAction) override
virtual void	MergeScores (const G4ScoringManager *localScoringManager)
virtual void	MergeRun (const G4Run *localRun)
virtual void	RequestWorkersProcessCommandsStack ()
virtual void	ThisWorkerProcessCommandsStackDone ()
virtual WorkerActionRequest	ThisWorkerWaitForNextAction ()
void	SetEventModulo (G4int i=1)
G4int	GetEventModulo () const
void	AbortRun (G4bool softAbort=false) override
void	AbortEvent () override
Public Member Functions inherited from G4RunManager
	G4RunManager ()
virtual	~G4RunManager ()
	G4RunManager (const G4RunManager &)=delete
G4RunManager &	operator= (const G4RunManager &)=delete
virtual void	BeamOn (G4int n_event, const char *macroFile=nullptr, G4int n_select=-1)
virtual void	DefineWorldVolume (G4VPhysicalVolume *worldVol, G4bool topologyIsChanged=true)
virtual void	InitializeGeometry ()
virtual void	InitializePhysics ()
virtual G4bool	ConfirmBeamOnCondition ()
virtual void	RunInitialization ()
virtual void	DoEventLoop (G4int n_event, const char *macroFile=nullptr, G4int n_select=-1)
virtual void	TerminateEventLoop ()
virtual G4Event *	GenerateEvent (G4int i_event)
virtual void	AnalyzeEvent (G4Event *anEvent)
void	DumpRegion (const G4String &rname) const
void	DumpRegion (G4Region *region=nullptr) const
void	GeometryHasBeenModified (G4bool prop=true)
void	ReinitializeGeometry (G4bool destroyFirst=false, G4bool prop=true)
void	PhysicsHasBeenModified ()
void	CutOffHasBeenModified ()
void	ReOptimizeMotherOf (G4VPhysicalVolume *)
void	ReOptimize (G4LogicalVolume *)
void	SetGeometryToBeOptimized (G4bool vl)
G4bool	GetGeometryToBeOptimized ()
void	GeometryDirectlyUpdated (G4bool val=true)
virtual void	RestoreRandomNumberStatus (const G4String &fileN)
virtual void	RestoreRndmEachEvent (G4bool)
const G4VUserDetectorConstruction *	GetUserDetectorConstruction () const
const G4VUserPhysicsList *	GetUserPhysicsList () const
const G4VUserActionInitialization *	GetUserActionInitialization () const
G4VUserActionInitialization *	GetNonConstUserActionInitialization () const
const G4UserWorkerInitialization *	GetUserWorkerInitialization () const
const G4UserWorkerThreadInitialization *	GetUserWorkerThreadInitialization () const
const G4UserRunAction *	GetUserRunAction () const
const G4VUserPrimaryGeneratorAction *	GetUserPrimaryGeneratorAction () const
const G4UserEventAction *	GetUserEventAction () const
const G4UserStackingAction *	GetUserStackingAction () const
const G4UserTrackingAction *	GetUserTrackingAction () const
const G4UserSteppingAction *	GetUserSteppingAction () const
void	SetNumberOfAdditionalWaitingStacks (G4int iAdd)
void	SetDefaultClassification (G4TrackStatus ts, G4ClassificationOfNewTrack val, G4ExceptionSeverity es=G4ExceptionSeverity::IgnoreTheIssue)
void	SetDefaultClassification (const G4ParticleDefinition *pd, G4ClassificationOfNewTrack val, G4ExceptionSeverity es=G4ExceptionSeverity::IgnoreTheIssue)
const G4String &	GetVersionString () const
void	SetPrimaryTransformer (G4PrimaryTransformer *pt)
void	StoreRandomNumberStatusToG4Event (G4int vl)
G4int	GetFlagRandomNumberStatusToG4Event () const
void	SetRandomNumberStore (G4bool flag)
G4bool	GetRandomNumberStore () const
void	SetRandomNumberStoreDir (const G4String &dir)
const G4String &	GetRandomNumberStoreDir () const
const G4String &	GetRandomNumberStatusForThisRun () const
const G4String &	GetRandomNumberStatusForThisEvent () const
void	SetRandomNumberStorePerEvent (G4bool flag)
G4bool	GetRandomNumberStorePerEvent () const
void	SetVerboseLevel (G4int vl)
G4int	GetVerboseLevel () const
G4int	GetPrintProgress ()
void	SetPrintProgress (G4int i)
void	SetNumberOfEventsToBeStored (G4int val)
const G4Run *	GetCurrentRun () const
G4Run *	GetNonConstCurrentRun () const
const G4Event *	GetCurrentEvent () const
const G4Event *	GetPreviousEvent (G4int i) const
void	SetRunIDCounter (G4int i)
G4int	GetNumberOfParallelWorld () const
void	SetNumberOfEventsToBeProcessed (G4int val)
G4int	GetNumberOfEventsToBeProcessed () const
G4int	GetNumberOfSelectEvents () const
const G4String &	GetSelectMacro () const
void	SetDCtable (G4DCtable *DCtbl)
RMType	GetRunManagerType () const
virtual void	RegisterSubEventType (G4int, G4int)
virtual void	MergeTrajectories (const G4SubEvent *, const G4Event *)
virtual void	UpdateScoringForSubEvent (const G4SubEvent *, const G4Event *)
virtual const G4SubEvent *	GetSubEvent (G4int, G4bool &, G4long &, G4long &, G4long &, G4bool)
virtual void	SubEventFinished (const G4SubEvent *, const G4Event *)
virtual G4int	GetSubEventType () const
virtual void	SetSubEventType (G4int)
virtual std::size_t	GetMaxNTrack () const
virtual void	TrajectoriesToBeMerged (G4bool)
virtual void	ReportEventDeletion (const G4Event *evt)
void	ResetNavigatorAtInitialization (G4bool val=true)

Static Public Member Functions
static G4ThreadId	GetMasterThreadId ()
static G4ScoringManager *	GetMasterScoringManager ()
static masterWorlds_t &	GetMasterWorlds ()
static void	addWorld (G4int counter, G4VPhysicalVolume *w)
static G4MTRunManager *	GetMasterRunManager ()
static G4RunManagerKernel *	GetMasterRunManagerKernel ()
static G4MTRunManagerKernel *	GetMTMasterRunManagerKernel ()
static G4int	SeedOncePerCommunication ()
static void	SetSeedOncePerCommunication (G4int val)
Static Public Member Functions inherited from G4RunManager
static G4RunManager *	GetRunManager ()
static G4bool	IfGeometryHasBeenDestroyed ()

Protected Types
using	G4ThreadsList = std::list<G4Thread*>

Protected Member Functions
virtual G4bool	InitializeSeeds (G4int)
virtual void	PrepareCommandsStack ()
void	StoreRNGStatus (const G4String &filenamePrefix) override
void	rndmSaveThisRun () override
void	rndmSaveThisEvent () override
virtual void	CreateAndStartWorkers ()
virtual void	WaitForReadyWorkers ()
virtual void	WaitForEndEventLoopWorkers ()
virtual void	TerminateWorkers ()
virtual void	NewActionRequest (WorkerActionRequest newRequest)
virtual void	RefillSeeds ()
Protected Member Functions inherited from G4RunManager
	G4RunManager (RMType rmType)
virtual void	StackPreviousEvent (G4Event *anEvent)
virtual void	CleanUpPreviousEvents ()
virtual void	CleanUpUnnecessaryEvents (G4int keepNEvents)
void	UpdateScoring (const G4Event *evt=nullptr)
virtual void	DeleteUserInitializations ()

Protected Attributes
G4int	nworkers = 2
G4int	forcedNwokers = -1
G4int	numberOfEventToBeProcessed = 0
WorkerActionRequest	nextActionRequest = WorkerActionRequest::UNDEFINED
G4int	eventModuloDef = 0
G4int	eventModulo = 1
G4int	nSeedsUsed = 0
G4int	nSeedsFilled = 0
G4int	nSeedsMax = 10000
G4int	nSeedsPerEvent = 2
G4double *	randDbl = nullptr
G4MTBarrier	beginOfEventLoopBarrier
G4MTBarrier	endOfEventLoopBarrier
G4MTBarrier	nextActionRequestBarrier
G4MTBarrier	processUIBarrier
G4int	pinAffinity = 0
G4ThreadsList	threads
std::vector< G4String >	uiCmdsForWorkers
CLHEP::HepRandomEngine *	masterRNGEngine = nullptr
G4MTRunManagerKernel *	MTkernel = nullptr
Protected Attributes inherited from G4RunManager
G4RunManagerKernel *	kernel = nullptr
G4EventManager *	eventManager = nullptr
G4VUserDetectorConstruction *	userDetector = nullptr
G4VUserPhysicsList *	physicsList = nullptr
G4VUserActionInitialization *	userActionInitialization = nullptr
G4UserWorkerInitialization *	userWorkerInitialization = nullptr
G4UserWorkerThreadInitialization *	userWorkerThreadInitialization = nullptr
G4UserRunAction *	userRunAction = nullptr
G4VUserPrimaryGeneratorAction *	userPrimaryGeneratorAction = nullptr
G4UserEventAction *	userEventAction = nullptr
G4UserStackingAction *	userStackingAction = nullptr
G4UserTrackingAction *	userTrackingAction = nullptr
G4UserSteppingAction *	userSteppingAction = nullptr
G4bool	geometryInitialized = false
G4bool	physicsInitialized = false
G4bool	runAborted = false
G4bool	initializedAtLeastOnce = false
G4bool	geometryToBeOptimized = true
G4int	runIDCounter = 0
G4int	verboseLevel = 0
G4int	printModulo = -1
G4Timer *	timer = nullptr
G4DCtable *	DCtable = nullptr
G4Run *	currentRun = nullptr
G4Event *	currentEvent = nullptr
std::list< G4Event * > *	previousEvents = nullptr
G4int	n_perviousEventsToBeStored = 0
G4int	numberOfEventToBeProcessed = 0
G4bool	storeRandomNumberStatus = false
G4int	storeRandomNumberStatusToG4Event = 0
G4String	randomNumberStatusDir = "./"
G4String	randomNumberStatusForThisRun = ""
G4String	randomNumberStatusForThisEvent = ""
G4bool	rngStatusEventsFlag = false
G4VPhysicalVolume *	currentWorld = nullptr
G4int	nParallelWorlds = 0
G4String	msgText = " "
G4int	n_select_msg = -1
G4int	numberOfEventProcessed = 0
G4String	selectMacro = ""
G4bool	fakeRun = false
G4bool	isScoreNtupleWriter = false
G4bool	geometryDirectlyUpdated = false
RMType	runManagerType

Static Protected Attributes
static G4MTRUN_DLL G4ScoringManager *	masterScM = nullptr
static G4MTRUN_DLL G4MTRunManager *	fMasterRM = nullptr
static G4ThreadId	masterThreadId = G4ThisThread::get_id()
static G4int	seedOncePerCommunication = 0
Static Protected Attributes inherited from G4RunManager
static G4RUN_DLL G4bool	fGeometryHasBeenDestroyed = false

Friends
class	G4RunManagerFactory

Detailed Description

Definition at line 57 of file G4MTRunManager.hh.

Member Typedef Documentation

G4ThreadsList

using G4MTRunManager::G4ThreadsList = std::list<G4Thread*>

protected

Definition at line 273 of file G4MTRunManager.hh.

masterWorlds_t

using G4MTRunManager::masterWorlds_t = std::map<G4int, G4VPhysicalVolume*>

Definition at line 63 of file G4MTRunManager.hh.

Member Enumeration Documentation

WorkerActionRequest

enum class G4MTRunManager::WorkerActionRequest

strong

Enumerator
UNDEFINED
NEXTITERATION
PROCESSUI
ENDWORKER

Definition at line 159 of file G4MTRunManager.hh.

    {
      UNDEFINED,
      NEXTITERATION,  // There is another set of UI commands to be executed
      PROCESSUI,  // Process UI commands w/o a /run/beamOn
      ENDWORKER  // Terminate thread, work finished
    };

Constructor & Destructor Documentation

G4MTRunManager()

G4MTRunManager::G4MTRunManager

(

)

Definition at line 120 of file G4MTRunManager.cc.

                               : G4RunManager(masterRM)
{
  if (fMasterRM != nullptr) {
    G4Exception("G4MTRunManager::G4MTRunManager", "Run0110", FatalException,
                "Another instance of a G4MTRunManager already exists.");
  }
  fMasterRM = this;
  masterThreadId = G4ThisThread::get_id();
  MTkernel = static_cast<G4MTRunManagerKernel*>(kernel);
#ifndef G4MULTITHREADED
  G4ExceptionDescription msg;
  msg << "Geant4 code is compiled without multi-threading support"
      << "(-DG4MULTITHREADED is set to off).\n";
  msg << "G4MTRunManager can only be used in multi-threaded applications.";
  G4Exception("G4MTRunManager::G4MTRunManager", "Run0111", FatalException, msg);
#endif
 
  G4int numberOfStaticAllocators = kernel->GetNumberOfStaticAllocators();
  if (numberOfStaticAllocators > 0) {
    G4ExceptionDescription msg1;
    msg1 << "There are " << numberOfStaticAllocators << " static G4Allocator objects detected.\n"
         << "In multi-threaded mode, all G4Allocator objects must be dynamically "
            "instantiated.";
    G4Exception("G4MTRunManager::G4MTRunManager", "Run1035", FatalException, msg1);
  }
  G4UImanager::GetUIpointer()->SetMasterUIManager(true);
  masterScM = G4ScoringManager::GetScoringManagerIfExist();
 
  // Check if a default RandomNumberGenerator has been created by user,
  // if not create default one
  // Note this call forces creation of defaults if not already there
  // G4Random::getTheEngine(); //User did not specify RNG, create defaults
  // Now remember the master instance of the RNG Engine
  masterRNGEngine = G4Random::getTheEngine();
 
  randDbl = new G4double[nSeedsPerEvent * nSeedsMax];
 
  char* env = std::getenv("G4FORCENUMBEROFTHREADS");
  if (env != nullptr) {
    G4String envS = env;
    if (envS == "MAX" || envS == "max") {
      forcedNwokers = G4Threading::G4GetNumberOfCores();
    }
    else {
      std::istringstream is(env);
      G4int val = -1;
      is >> val;
      if (val > 0) {
        forcedNwokers = val;
      }
      else {
        G4ExceptionDescription msg2;
        msg2 << "Environment variable G4FORCENUMBEROFTHREADS has an invalid "
                "value <"
             << envS << ">. It has to be an integer or a word \"max\".\n"
             << "G4FORCENUMBEROFTHREADS is ignored.";
        G4Exception("G4MTRunManager::G4MTRunManager", "Run1039", JustWarning, msg2);
      }
    }
    if (forcedNwokers > 0) {
      nworkers = forcedNwokers;
      if (verboseLevel > 0) {
        G4cout << "### Number of threads is forced to " << forcedNwokers
               << " by Environment variable G4FORCENUMBEROFTHREADS." << G4endl;
      }
    }
  }
  G4UImanager::GetUIpointer()->SetAlias("RunMode eventParallel");
}

Referenced by GetMasterRunManager(), G4SubEvtRunManager::RequestWorkersProcessCommandsStack(), and G4TaskRunManager::RequestWorkersProcessCommandsStack().

~G4MTRunManager()

G4MTRunManager::~G4MTRunManager ( )

override

Definition at line 191 of file G4MTRunManager.cc.

{
  // TODO: Currently does not work due to concurrent deletion of something
  //      that is shared:
  // G4ProcessTable::DeleteMessenger from ~G4RunManager
  // G4cout<<"Destroy MTRunManager"<<G4endl;//ANDREA
  TerminateWorkers();
  delete[] randDbl;
}

Member Function Documentation

AbortEvent()

void G4MTRunManager::AbortEvent ( )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 655 of file G4MTRunManager.cc.

{
  // nothing to do in the master thread
}

AbortRun()

void G4MTRunManager::AbortRun ( G4bool softAbort = false )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 641 of file G4MTRunManager.cc.

{
  // This method is valid only for GeomClosed or EventProc state
  G4ApplicationState currentState = G4StateManager::GetStateManager()->GetCurrentState();
  if (currentState == G4State_GeomClosed || currentState == G4State_EventProc) {
    runAborted = true;
    MTkernel->BroadcastAbortRun(softAbort);
  }
  else {
    G4cerr << "Run is not in progress. AbortRun() ignored." << G4endl;
  }
}

addWorld()

void G4MTRunManager::addWorld ( G4int counter, G4VPhysicalVolume * w )

static

Definition at line 96 of file G4MTRunManager.cc.

{
  GetMasterWorlds().insert(std::make_pair(counter, w));
}

Referenced by ConstructScoringWorlds(), G4SubEvtRunManager::ConstructScoringWorlds(), and G4TaskRunManager::ConstructScoringWorlds().

ConstructScoringWorlds()

void G4MTRunManager::ConstructScoringWorlds ( )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 463 of file G4MTRunManager.cc.

{
  masterScM = G4ScoringManager::GetScoringManagerIfExist();
  // Call base class stuff...
  G4RunManager::ConstructScoringWorlds();
 
  GetMasterWorlds().clear();
  auto nWorlds = (G4int)G4TransportationManager::GetTransportationManager()->GetNoWorlds();
  auto itrW = G4TransportationManager::GetTransportationManager()->GetWorldsIterator();
  for (G4int iWorld = 0; iWorld < nWorlds; ++iWorld) {
    addWorld(iWorld, *itrW);
    ++itrW;
  }
}

CreateAndStartWorkers()

void G4MTRunManager::CreateAndStartWorkers ( )

protectedvirtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 304 of file G4MTRunManager.cc.

{
  // Now loop on requested number of workers
  // This will also start the workers
  // Currently we do not allow to change the
  // number of threads: threads area created once
  if (threads.empty()) {
    if (verboseLevel > 0) {
      // for consistency with G4TaskRunManager
      std::stringstream msg;
      msg << "--> G4MTRunManager::CreateAndStartWorkers() --> "
          << "Initializing workers...";
 
      std::stringstream ss;
      ss.fill('=');
      ss << std::setw(G4int(msg.str().length())) << "";
      G4cout << "\n" << ss.str() << "\n" << msg.str() << "\n" << ss.str() << "\n" << G4endl;
    }
 
    for (G4int nw = 0; nw < nworkers; ++nw) {
      // Create a new worker and remember it
      auto context = new G4WorkerThread;
      context->SetNumberThreads(nworkers);
      context->SetThreadId(nw);
      G4Thread* thread = userWorkerThreadInitialization->CreateAndStartWorker(context);
      threads.push_back(thread);
    }
  }
  // Signal to threads they can start a new run
  NewActionRequest(WorkerActionRequest::NEXTITERATION);
}

Referenced by InitializeEventLoop().

GetCommandStack()

std::vector< G4String > G4MTRunManager::GetCommandStack

(

)

Definition at line 297 of file G4MTRunManager.cc.

{
  G4AutoLock l(&cmdHandlingMutex);
  return uiCmdsForWorkers;
}

Referenced by G4SubEvtRunManager::CreateAndStartWorkers(), G4TaskRunManager::CreateAndStartWorkers(), G4WorkerRunManager::DoWork(), G4WorkerSubEvtRunManager::ProcessUI(), G4WorkerTaskRunManager::ProcessUI(), G4SubEvtRunManager::RequestWorkersProcessCommandsStack(), and G4TaskRunManager::RequestWorkersProcessCommandsStack().

GetEventModulo()

G4int G4MTRunManager::GetEventModulo ( ) const

inline

Definition at line 182 of file G4MTRunManager.hh.

{ return eventModuloDef; }

Referenced by G4WorkerRunManager::GenerateEvent(), G4WorkerSubEvtRunManager::GenerateEvent(), and G4WorkerTaskRunManager::GenerateEvent().

getMasterRandomEngine()

const CLHEP::HepRandomEngine * G4MTRunManager::getMasterRandomEngine ( ) const

inline

Definition at line 131 of file G4MTRunManager.hh.

{ return masterRNGEngine; }

Referenced by G4TaskRunManagerKernel::InitializeWorker(), G4WorkerRunManager::SetupDefaultRNGEngine(), G4WorkerSubEvtRunManager::SetupDefaultRNGEngine(), G4WorkerTaskRunManager::SetupDefaultRNGEngine(), and G4MTRunManagerKernel::StartThread().

GetMasterRunManager()

G4MTRunManager * G4MTRunManager::GetMasterRunManager ( )

static

Definition at line 65 of file G4MTRunManager.cc.

{
  return fMasterRM;
}

Referenced by G4WorkerRunManager::DoWork(), G4WorkerRunManager::GenerateEvent(), G4WorkerSubEvtRunManager::GenerateEvent(), G4WorkerTaskRunManager::GenerateEvent(), G4SubEvtRunManager::GetMasterRunManager(), G4TaskRunManager::GetMasterRunManager(), G4RunManagerFactory::GetMTMasterRunManager(), G4WorkerRunManager::MergePartialResults(), G4SubEvtRunManager::RequestWorkersProcessCommandsStack(), G4TaskRunManager::RequestWorkersProcessCommandsStack(), G4WorkerRunManager::RunInitialization(), G4WorkerSubEvtRunManager::RunInitialization(), G4WorkerTaskRunManager::RunInitialization(), G4WorkerRunManager::RunTermination(), G4WorkerSubEvtRunManager::RunTermination(), G4WorkerTaskRunManager::RunTermination(), G4WorkerRunManager::SetupDefaultRNGEngine(), G4WorkerSubEvtRunManager::SetupDefaultRNGEngine(), G4WorkerTaskRunManager::SetupDefaultRNGEngine(), G4MTRunManagerKernel::StartThread(), G4RunManagerKernel::WorkerDefineWorldVolume(), and G4RunManagerKernel::WorkerUpdateWorldVolume().

GetMasterRunManagerKernel()

G4RunManagerKernel * G4MTRunManager::GetMasterRunManagerKernel ( )

static

Definition at line 71 of file G4MTRunManager.cc.

{
  return fMasterRM->kernel;
}

Referenced by G4WorkerRunManager::InitializeGeometry().

GetMasterScoringManager()

G4ScoringManager * G4MTRunManager::GetMasterScoringManager ( )

static

Definition at line 83 of file G4MTRunManager.cc.

{
  return masterScM;
}

Referenced by G4WorkerRunManager::ConstructScoringWorlds(), and G4WorkerRunManager::G4WorkerRunManager().

GetMasterThreadId()

G4ThreadId G4MTRunManager::GetMasterThreadId ( )

static

Definition at line 102 of file G4MTRunManager.cc.

{
  return masterThreadId;
}

Referenced by G4TaskRunManagerKernel::ExecuteWorkerInit(), G4TaskRunManagerKernel::ExecuteWorkerTask(), G4TaskRunManager::GetMasterThreadId(), and G4TaskRunManagerKernel::InitializeWorker().

GetMasterWorlds()

G4MTRunManager::masterWorlds_t & G4MTRunManager::GetMasterWorlds ( )

static

Definition at line 89 of file G4MTRunManager.cc.

{
  static masterWorlds_t masterWorlds;
  return masterWorlds;
}

Referenced by addWorld(), ConstructScoringWorlds(), G4SubEvtRunManager::ConstructScoringWorlds(), G4TaskRunManager::ConstructScoringWorlds(), G4RunManagerKernel::WorkerDefineWorldVolume(), and G4RunManagerKernel::WorkerUpdateWorldVolume().

GetMTMasterRunManagerKernel()

G4MTRunManagerKernel * G4MTRunManager::GetMTMasterRunManagerKernel ( )

static

Definition at line 77 of file G4MTRunManager.cc.

{
  return fMasterRM->MTkernel;
}

GetNumberActiveThreads()

virtual size_t G4MTRunManager::GetNumberActiveThreads ( ) const

inlinevirtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 114 of file G4MTRunManager.hh.

{ return threads.size(); }

Referenced by NewActionRequest(), RequestWorkersProcessCommandsStack(), WaitForEndEventLoopWorkers(), and WaitForReadyWorkers().

GetNumberOfThreads()

G4int G4MTRunManager::GetNumberOfThreads ( ) const

inlineoverridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 70 of file G4MTRunManager.hh.

{ return nworkers; }

GetPinAffinity()

G4int G4MTRunManager::GetPinAffinity ( ) const

inline

Definition at line 72 of file G4MTRunManager.hh.

{ return pinAffinity; }

Referenced by G4TaskRunManagerKernel::InitializeWorker(), and G4MTRunManagerKernel::StartThread().

Initialize()

void G4MTRunManager::Initialize ( )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 263 of file G4MTRunManager.cc.

{
  G4RunManager::Initialize();
 
  // make sure all worker threads are set up.
  BeamOn(0);
  SetRunIDCounter(0);
}

InitializeEventLoop()

void G4MTRunManager::InitializeEventLoop ( G4int n_event, const char * macroFile = nullptr, G4int n_select = -1 )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 337 of file G4MTRunManager.cc.

{
  MTkernel->SetUpDecayChannels();
  numberOfEventToBeProcessed = n_event;
  numberOfEventProcessed = 0;
 
  if (!fakeRun) {
    nSeedsUsed = 0;
    nSeedsFilled = 0;
 
    if (verboseLevel > 0) {
      timer->Start();
    }
 
    n_select_msg = n_select;
    if (macroFile != nullptr) {
      if (n_select_msg < 0) n_select_msg = n_event;
      msgText = "/control/execute ";
      msgText += macroFile;
      selectMacro = macroFile;
    }
    else {
      n_select_msg = -1;
      selectMacro = "";
    }
 
    // initialize seeds
    // If user did not implement InitializeSeeds,
    // use default: nSeedsPerEvent seeds per event
    if (eventModuloDef > 0) {
      eventModulo = eventModuloDef;
      if (eventModulo > numberOfEventToBeProcessed / nworkers) {
        eventModulo = numberOfEventToBeProcessed / nworkers;
        if (eventModulo < 1) eventModulo = 1;
        G4ExceptionDescription msgd;
        msgd << "Event modulo is reduced to " << eventModulo
             << " to distribute events to all threads.";
        G4Exception("G4MTRunManager::InitializeEventLoop()", "Run10035", JustWarning, msgd);
      }
    }
    else {
      eventModulo = G4int(std::sqrt(G4double(numberOfEventToBeProcessed / nworkers)));
      if (eventModulo < 1) eventModulo = 1;
    }
    if (!InitializeSeeds(n_event) && n_event > 0) {
      G4RNGHelper* helper = G4RNGHelper::GetInstance();
      switch (seedOncePerCommunication) {
        case 0:
          nSeedsFilled = n_event;
          break;
        case 1:
          nSeedsFilled = nworkers;
          break;
        case 2:
          nSeedsFilled = n_event / eventModulo + 1;
          break;
        default:
          G4ExceptionDescription msgd;
          msgd << "Parameter value <" << seedOncePerCommunication
               << "> of seedOncePerCommunication is invalid. It is reset to 0.";
          G4Exception("G4MTRunManager::InitializeEventLoop()", "Run10036", JustWarning, msgd);
          seedOncePerCommunication = 0;
          nSeedsFilled = n_event;
      }
 
      // Generates up to nSeedsMax seed pairs only.
      if (nSeedsFilled > nSeedsMax) nSeedsFilled = nSeedsMax;
      masterRNGEngine->flatArray(nSeedsPerEvent * nSeedsFilled, randDbl);
      helper->Fill(randDbl, nSeedsFilled, n_event, nSeedsPerEvent);
    }
  }
 
  // Now initialize workers. Check if user defined a WorkerThreadInitialization
  if (userWorkerThreadInitialization == nullptr) {
    userWorkerThreadInitialization = new G4UserWorkerThreadInitialization();
  }
 
  // Prepare UI commands for threads
  PrepareCommandsStack();
 
  // Start worker threads
  CreateAndStartWorkers();
 
  // We need a barrier here. Wait for workers to start event loop.
  // This will return only when all workers have started processing events.
  WaitForReadyWorkers();
}

InitializeSeeds()

virtual G4bool G4MTRunManager::InitializeSeeds ( G4int )

inlineprotectedvirtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 195 of file G4MTRunManager.hh.

{ return false; };

Referenced by InitializeEventLoop().

InitializeThreadPool()

virtual void G4MTRunManager::InitializeThreadPool ( )

inlinevirtual

Reimplemented in G4TaskRunManager.

Definition at line 78 of file G4MTRunManager.hh.

{}

MergeRun()

void G4MTRunManager::MergeRun ( const G4Run * localRun )

virtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 565 of file G4MTRunManager.cc.

{
  G4AutoLock l(&runMergerMutex);
  if (currentRun != nullptr && localRun != nullptr) currentRun->Merge(localRun);
}

Referenced by G4WorkerRunManager::MergePartialResults().

MergeScores()

void G4MTRunManager::MergeScores ( const G4ScoringManager * localScoringManager )

virtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 558 of file G4MTRunManager.cc.

{
  G4AutoLock l(&scorerMergerMutex);
  if (masterScM != nullptr && localScoringManager != nullptr) masterScM->Merge(localScoringManager);
}

Referenced by G4WorkerRunManager::MergePartialResults().

NewActionRequest()

void G4MTRunManager::NewActionRequest ( G4MTRunManager::WorkerActionRequest newRequest )

protectedvirtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 689 of file G4MTRunManager.cc.

{
  nextActionRequestBarrier.Wait((G4int)GetNumberActiveThreads());
  // nextActionRequest is a shared resource, but there is no
  // data-race thanks to the barrier: all threads are waiting
  nextActionRequest = newRequest;
  nextActionRequestBarrier.ReleaseBarrier();
}

Referenced by CreateAndStartWorkers(), RequestWorkersProcessCommandsStack(), and TerminateWorkers().

PrepareCommandsStack()

void G4MTRunManager::PrepareCommandsStack ( )

protectedvirtual

Definition at line 285 of file G4MTRunManager.cc.

{
  G4AutoLock l(&cmdHandlingMutex);
  uiCmdsForWorkers.clear();
  std::vector<G4String>* cmdCopy = G4UImanager::GetUIpointer()->GetCommandStack();
  for (const auto& it : *cmdCopy)
    uiCmdsForWorkers.push_back(it);
  cmdCopy->clear();
  delete cmdCopy;
}

Referenced by InitializeEventLoop(), G4SubEvtRunManager::InitializeEventLoop(), G4TaskRunManager::InitializeEventLoop(), RequestWorkersProcessCommandsStack(), G4SubEvtRunManager::RequestWorkersProcessCommandsStack(), and G4TaskRunManager::RequestWorkersProcessCommandsStack().

ProcessOneEvent()

void G4MTRunManager::ProcessOneEvent ( G4int i_event )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 273 of file G4MTRunManager.cc.

{
  // Nothing to do
}

RefillSeeds()

void G4MTRunManager::RefillSeeds ( )

protectedvirtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 426 of file G4MTRunManager.cc.

{
  G4RNGHelper* helper = G4RNGHelper::GetInstance();
  G4int nFill = 0;
  switch (seedOncePerCommunication) {
    case 0:
      nFill = numberOfEventToBeProcessed - nSeedsFilled;
      break;
    case 1:
      nFill = nworkers - nSeedsFilled;
      break;
    case 2:
    default:
      nFill = (numberOfEventToBeProcessed - nSeedsFilled * eventModulo) / eventModulo + 1;
  }
  // Generates up to nSeedsMax seed pairs only.
  if (nFill > nSeedsMax) nFill = nSeedsMax;
  masterRNGEngine->flatArray(nSeedsPerEvent * nFill, randDbl);
  helper->Refill(randDbl, nFill);
  nSeedsFilled += nFill;
}

Referenced by SetUpAnEvent(), and SetUpNEvents().

RequestWorkersProcessCommandsStack()

void G4MTRunManager::RequestWorkersProcessCommandsStack ( )

virtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 706 of file G4MTRunManager.cc.

{
  PrepareCommandsStack();
  NewActionRequest(WorkerActionRequest::PROCESSUI);
  processUIBarrier.SetActiveThreads((G4int)GetNumberActiveThreads());
  processUIBarrier.WaitForReadyWorkers();
}

Referenced by TerminateWorkers().

rndmSaveThisEvent()

void G4MTRunManager::rndmSaveThisEvent ( )

overrideprotectedvirtual

Reimplemented from G4RunManager.

Definition at line 235 of file G4MTRunManager.cc.

{
  G4Exception("G4MTRunManager::rndmSaveThisEvent", "RUN_RNDM001", FatalException,
              "This method shall not be invoked !!");
}

rndmSaveThisRun()

void G4MTRunManager::rndmSaveThisRun ( )

overrideprotectedvirtual

Reimplemented from G4RunManager.

Definition at line 210 of file G4MTRunManager.cc.

{
  G4int runNumber = 0;
  if (currentRun != nullptr) runNumber = currentRun->GetRunID();
  if (!storeRandomNumberStatus) {
    G4cerr << "Warning from G4RunManager::rndmSaveThisRun():"
           << " Random number status was not stored prior to this run." << G4endl
           << "/random/setSavingFlag command must be issued. "
           << "Command ignored." << G4endl;
    return;
  }
 
  G4fs::path fileIn = randomNumberStatusDir + "G4Worker_currentRun.rndm";
 
  std::ostringstream os;
  os << "run" << runNumber << ".rndm" << '\0';
  G4fs::path fileOut = randomNumberStatusDir + os.str();
 
  if (G4CopyRandomState(fileIn, fileOut, "G4MTRunManager::rndmSaveThisRun()") && verboseLevel > 0)
  {
    G4cout << fileIn << " is copied to " << fileOut << G4endl;
  } 
}

RunTermination()

void G4MTRunManager::RunTermination ( )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 449 of file G4MTRunManager.cc.

{
  // Wait for all worker threads to have finished the run
  // i.e. wait for them to return from RunTermination()
  // This guarantee that userrunaction for workers has been called
 
  // Wait now for all threads to finish event-loop
  WaitForEndEventLoopWorkers();
  // Now call base-class methof
  G4RunManager::TerminateEventLoop();
  G4RunManager::RunTermination();
}

SeedOncePerCommunication()

G4int G4MTRunManager::SeedOncePerCommunication ( )

static

Definition at line 108 of file G4MTRunManager.cc.

{
  return seedOncePerCommunication;
}

Referenced by G4WorkerRunManager::GenerateEvent(), G4WorkerSubEvtRunManager::GenerateEvent(), G4WorkerTaskRunManager::GenerateEvent(), G4RunMessenger::GetCurrentValue(), G4SubEvtRunManager::InitializeEventLoop(), G4TaskRunManager::InitializeEventLoop(), G4SubEvtRunManager::RefillSeeds(), G4TaskRunManager::RefillSeeds(), and G4TaskRunManager::SetUpNEvents().

SetEventModulo()

void G4MTRunManager::SetEventModulo ( G4int i = 1 )

inline

Definition at line 181 of file G4MTRunManager.hh.

{ eventModuloDef = i; }

SetNumberOfThreads()

void G4MTRunManager::SetNumberOfThreads ( G4int n )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 242 of file G4MTRunManager.cc.

{
  if (!threads.empty()) {
    G4ExceptionDescription msg;
    msg << "Number of threads cannot be changed at this moment \n"
        << "(old threads are still alive). Method ignored.";
    G4Exception("G4MTRunManager::SetNumberOfThreads(G4int)", "Run0112", JustWarning, msg);
  }
  else if (forcedNwokers > 0) {
    G4ExceptionDescription msg;
    msg << "Number of threads is forced to " << forcedNwokers
        << " by G4FORCENUMBEROFTHREADS shell variable.\n"
        << "Method ignored.";
    G4Exception("G4MTRunManager::SetNumberOfThreads(G4int)", "Run0113", JustWarning, msg);
  }
  else {
    nworkers = n;
  }
}

Referenced by G4RunManagerFactory::CreateRunManager().

SetPinAffinity()

void G4MTRunManager::SetPinAffinity

(

G4int

n = 1

)

Definition at line 721 of file G4MTRunManager.cc.

{
  if (n == 0) {
    G4Exception("G4MTRunManager::SetPinAffinity", "Run0114", FatalException,
                "Pin affinity must be >0 or <0.");
  }
  pinAffinity = n;
  return;
}

SetSeedOncePerCommunication()

void G4MTRunManager::SetSeedOncePerCommunication ( G4int val )

static

Definition at line 114 of file G4MTRunManager.cc.

{
  seedOncePerCommunication = val;
}

Referenced by G4SubEvtRunManager::Initialize(), G4SubEvtRunManager::InitializeEventLoop(), G4TaskRunManager::InitializeEventLoop(), and G4RunMessenger::SetNewValue().

SetUpAnEvent()

G4bool G4MTRunManager::SetUpAnEvent ( G4Event * evt, G4long & s1, G4long & s2, G4long & s3, G4bool reseedRequired = true )

virtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 572 of file G4MTRunManager.cc.

{
  G4AutoLock l(&setUpEventMutex);
  if (numberOfEventProcessed < numberOfEventToBeProcessed) {
    evt->SetEventID(numberOfEventProcessed);
    if (reseedRequired) {
      G4RNGHelper* helper = G4RNGHelper::GetInstance();
      G4int idx_rndm = nSeedsPerEvent * nSeedsUsed;
      s1 = helper->GetSeed(idx_rndm);
      s2 = helper->GetSeed(idx_rndm + 1);
      if (nSeedsPerEvent == 3) s3 = helper->GetSeed(idx_rndm + 2);
      ++nSeedsUsed;
      if (nSeedsUsed == nSeedsFilled) RefillSeeds();
    }
    ++numberOfEventProcessed;
    return true;
  }
  return false;
}

Referenced by G4WorkerRunManager::GenerateEvent(), G4WorkerSubEvtRunManager::GenerateEvent(), and G4WorkerTaskRunManager::GenerateEvent().

SetUpNEvents()

G4int G4MTRunManager::SetUpNEvents ( G4Event * evt, G4SeedsQueue * seedsQueue, G4bool reseedRequired = true )

virtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 594 of file G4MTRunManager.cc.

{
  G4AutoLock l(&setUpEventMutex);
  if (numberOfEventProcessed < numberOfEventToBeProcessed && !runAborted) {
    G4int nev = eventModulo;
    if (numberOfEventProcessed + nev > numberOfEventToBeProcessed) {
      nev = numberOfEventToBeProcessed - numberOfEventProcessed;
    }
    evt->SetEventID(numberOfEventProcessed);
    if (reseedRequired) {
      G4RNGHelper* helper = G4RNGHelper::GetInstance();
      G4int nevRnd = nev;
      if (seedOncePerCommunication > 0) nevRnd = 1;
      for (G4int i = 0; i < nevRnd; ++i) {
        seedsQueue->push(helper->GetSeed(nSeedsPerEvent * nSeedsUsed));
        seedsQueue->push(helper->GetSeed(nSeedsPerEvent * nSeedsUsed + 1));
        if (nSeedsPerEvent == 3) seedsQueue->push(helper->GetSeed(nSeedsPerEvent * nSeedsUsed + 2));
        ++nSeedsUsed;
        if (nSeedsUsed == nSeedsFilled) RefillSeeds();
      }
    }
    numberOfEventProcessed += nev;
    return nev;
  }
  return 0;
}

Referenced by G4WorkerRunManager::GenerateEvent(), G4WorkerSubEvtRunManager::GenerateEvent(), and G4WorkerTaskRunManager::GenerateEvent().

SetUserAction() [1/6]

void G4MTRunManager::SetUserAction ( G4UserEventAction * userAction )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager.

Definition at line 526 of file G4MTRunManager.cc.

{
  G4Exception("G4MTRunManager::SetUserAction()", "Run0124", FatalException,
              "For multi-threaded version, define G4UserEventAction in "
              "G4VUserActionInitialization.");
}

SetUserAction() [2/6]

void G4MTRunManager::SetUserAction ( G4UserRunAction * userAction )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager.

Definition at line 511 of file G4MTRunManager.cc.

{
  G4RunManager::SetUserAction(userAction);
  if (userAction != nullptr) userAction->SetMaster();
}

Referenced by G4TheMTRayTracer::RestoreUserActions(), and G4TheMTRayTracer::StoreUserActions().

SetUserAction() [3/6]

void G4MTRunManager::SetUserAction ( G4UserStackingAction * userAction )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager.

Definition at line 534 of file G4MTRunManager.cc.

{
  G4Exception("G4MTRunManager::SetUserAction()", "Run0125", FatalException,
              "For multi-threaded version, define G4UserStackingAction in "
              "G4VUserActionInitialization.");
}

SetUserAction() [4/6]

void G4MTRunManager::SetUserAction ( G4UserSteppingAction * userAction )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager.

Definition at line 550 of file G4MTRunManager.cc.

{
  G4Exception("G4MTRunManager::SetUserAction()", "Run0127", FatalException,
              "For multi-threaded version, define G4UserSteppingAction in "
              "G4VUserActionInitialization.");
}

SetUserAction() [5/6]

void G4MTRunManager::SetUserAction ( G4UserTrackingAction * userAction )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager.

Definition at line 542 of file G4MTRunManager.cc.

{
  G4Exception("G4MTRunManager::SetUserAction()", "Run0126", FatalException,
              "For multi-threaded version, define G4UserTrackingAction in "
              "G4VUserActionInitialization.");
}

SetUserAction() [6/6]

void G4MTRunManager::SetUserAction ( G4VUserPrimaryGeneratorAction * userAction )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager.

Definition at line 518 of file G4MTRunManager.cc.

{
  G4Exception("G4MTRunManager::SetUserAction()", "Run0123", FatalException,
              "For multi-threaded version, define G4VUserPrimaryGeneratorAction in "
              "G4VUserActionInitialization.");
}

SetUserInitialization() [1/5]

void G4MTRunManager::SetUserInitialization ( G4UserWorkerInitialization * userInit )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager.

Definition at line 479 of file G4MTRunManager.cc.

{
  userWorkerInitialization = userInit;
}

SetUserInitialization() [2/5]

void G4MTRunManager::SetUserInitialization ( G4UserWorkerThreadInitialization * userInit )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager.

Definition at line 485 of file G4MTRunManager.cc.

{
  userWorkerThreadInitialization = userInit;
}

SetUserInitialization() [3/5]

void G4MTRunManager::SetUserInitialization ( G4VUserActionInitialization * userInit )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager.

Definition at line 491 of file G4MTRunManager.cc.

{
  userActionInitialization = userInit;
  userActionInitialization->BuildForMaster();
}

SetUserInitialization() [4/5]

void G4MTRunManager::SetUserInitialization ( G4VUserDetectorConstruction * userDC )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager.

Definition at line 505 of file G4MTRunManager.cc.

{
  G4RunManager::SetUserInitialization(userDC);
}

SetUserInitialization() [5/5]

void G4MTRunManager::SetUserInitialization ( G4VUserPhysicsList * userPL )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager.

Definition at line 498 of file G4MTRunManager.cc.

{
  G4RunManager::SetUserInitialization(userPL);
  // Needed for MT, to be moved in kernel
}

Referenced by G4TheMTRayTracer::RestoreUserActions(), and G4TheMTRayTracer::StoreUserActions().

StoreRNGStatus()

void G4MTRunManager::StoreRNGStatus ( const G4String & filenamePrefix )

overrideprotectedvirtual

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 202 of file G4MTRunManager.cc.

{
  std::ostringstream os;
  os << randomNumberStatusDir << "G4Master_" << fn << ".rndm";
  G4Random::saveEngineStatus(os.str().c_str());
}

TerminateOneEvent()

void G4MTRunManager::TerminateOneEvent ( )

overridevirtual

Reimplemented from G4RunManager.

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 279 of file G4MTRunManager.cc.

{
  // Nothing to do
}

TerminateWorkers()

void G4MTRunManager::TerminateWorkers ( )

protectedvirtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 622 of file G4MTRunManager.cc.

{
  // Force workers to execute (if any) all UI commands left in the stack
  RequestWorkersProcessCommandsStack();
  // Ask workers to exit
  NewActionRequest(WorkerActionRequest::ENDWORKER);
  // Now join threads.
#ifdef G4MULTITHREADED  // protect here to prevent warning in compilation
  while (!threads.empty()) {
    G4Thread* t = *(threads.begin());
    threads.pop_front();
    userWorkerThreadInitialization->JoinWorker(t);
    delete t;
  }
#endif
  threads.clear();
}

Referenced by ~G4MTRunManager().

ThisWorkerEndEventLoop()

void G4MTRunManager::ThisWorkerEndEventLoop ( )

virtual

Reimplemented in G4TaskRunManager.

Definition at line 683 of file G4MTRunManager.cc.

{
  endOfEventLoopBarrier.ThisWorkerReady();
}

Referenced by G4WorkerRunManager::RunTermination(), G4WorkerSubEvtRunManager::RunTermination(), and G4WorkerTaskRunManager::RunTermination().

ThisWorkerProcessCommandsStackDone()

void G4MTRunManager::ThisWorkerProcessCommandsStackDone ( )

virtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 715 of file G4MTRunManager.cc.

{
  processUIBarrier.ThisWorkerReady();
}

Referenced by G4WorkerRunManager::DoWork(), G4SubEvtRunManager::RequestWorkersProcessCommandsStack(), and G4TaskRunManager::RequestWorkersProcessCommandsStack().

ThisWorkerReady()

void G4MTRunManager::ThisWorkerReady ( )

virtual

Reimplemented in G4TaskRunManager.

Definition at line 669 of file G4MTRunManager.cc.

{
  beginOfEventLoopBarrier.ThisWorkerReady();
}

Referenced by G4WorkerRunManager::RunInitialization(), G4WorkerSubEvtRunManager::RunInitialization(), and G4WorkerTaskRunManager::RunInitialization().

ThisWorkerWaitForNextAction()

G4MTRunManager::WorkerActionRequest G4MTRunManager::ThisWorkerWaitForNextAction ( )

virtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 699 of file G4MTRunManager.cc.

{
  nextActionRequestBarrier.ThisWorkerReady();
  return nextActionRequest;
}

Referenced by G4WorkerRunManager::DoWork().

WaitForEndEventLoopWorkers()

void G4MTRunManager::WaitForEndEventLoopWorkers ( )

protectedvirtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 675 of file G4MTRunManager.cc.

{
  endOfEventLoopBarrier.Wait((G4int)GetNumberActiveThreads());
  beginOfEventLoopBarrier.ResetCounter();
  endOfEventLoopBarrier.ReleaseBarrier();
}

Referenced by RunTermination().

WaitForReadyWorkers()

void G4MTRunManager::WaitForReadyWorkers ( )

protectedvirtual

Reimplemented in G4SubEvtRunManager, and G4TaskRunManager.

Definition at line 661 of file G4MTRunManager.cc.

{
  beginOfEventLoopBarrier.Wait((G4int)GetNumberActiveThreads());
  endOfEventLoopBarrier.ResetCounter();
  beginOfEventLoopBarrier.ReleaseBarrier();
}

Referenced by InitializeEventLoop().

Friends And Related Symbol Documentation

G4RunManagerFactory

friend class G4RunManagerFactory

friend

Definition at line 59 of file G4MTRunManager.hh.

Referenced by G4RunManagerFactory.

Member Data Documentation

beginOfEventLoopBarrier

G4MTBarrier G4MTRunManager::beginOfEventLoopBarrier

protected

Definition at line 266 of file G4MTRunManager.hh.

Referenced by ThisWorkerReady(), WaitForEndEventLoopWorkers(), and WaitForReadyWorkers().

endOfEventLoopBarrier

G4MTBarrier G4MTRunManager::endOfEventLoopBarrier

protected

Definition at line 267 of file G4MTRunManager.hh.

Referenced by ThisWorkerEndEventLoop(), WaitForEndEventLoopWorkers(), and WaitForReadyWorkers().

eventModulo

G4int G4MTRunManager::eventModulo = 1

protected

Definition at line 240 of file G4MTRunManager.hh.

Referenced by G4SubEvtRunManager::ComputeNumberOfTasks(), G4TaskRunManager::ComputeNumberOfTasks(), InitializeEventLoop(), G4TaskRunManager::InitializeEventLoop(), RefillSeeds(), G4SubEvtRunManager::RefillSeeds(), G4TaskRunManager::RefillSeeds(), SetUpNEvents(), and G4TaskRunManager::SetUpNEvents().

eventModuloDef

G4int G4MTRunManager::eventModuloDef = 0

protected

Definition at line 239 of file G4MTRunManager.hh.

Referenced by G4TaskRunManager::ComputeNumberOfTasks(), GetEventModulo(), InitializeEventLoop(), and SetEventModulo().

fMasterRM

G4MTRunManager * G4MTRunManager::fMasterRM = nullptr

staticprotected

Definition at line 235 of file G4MTRunManager.hh.

Referenced by G4MTRunManager(), G4TaskRunManager::G4TaskRunManager(), GetMasterRunManager(), GetMasterRunManagerKernel(), and GetMTMasterRunManagerKernel().

forcedNwokers

G4int G4MTRunManager::forcedNwokers = -1

protected

Definition at line 228 of file G4MTRunManager.hh.

Referenced by G4MTRunManager(), G4TaskRunManager::G4TaskRunManager(), SetNumberOfThreads(), and G4TaskRunManager::SetNumberOfThreads().

masterRNGEngine

CLHEP::HepRandomEngine* G4MTRunManager::masterRNGEngine = nullptr

protected

Definition at line 286 of file G4MTRunManager.hh.

Referenced by G4MTRunManager(), getMasterRandomEngine(), InitializeEventLoop(), and RefillSeeds().

masterScM

G4ScoringManager * G4MTRunManager::masterScM = nullptr

staticprotected

Definition at line 233 of file G4MTRunManager.hh.

Referenced by ConstructScoringWorlds(), G4SubEvtRunManager::ConstructScoringWorlds(), G4TaskRunManager::ConstructScoringWorlds(), G4MTRunManager(), G4TaskRunManager::G4TaskRunManager(), GetMasterScoringManager(), MergeScores(), G4SubEvtRunManager::MergeScores(), and G4TaskRunManager::MergeScores().

masterThreadId

G4ThreadId G4MTRunManager::masterThreadId = G4ThisThread::get_id()

staticprotected

Definition at line 247 of file G4MTRunManager.hh.

Referenced by G4MTRunManager(), and GetMasterThreadId().

MTkernel

G4MTRunManagerKernel* G4MTRunManager::MTkernel = nullptr

protected

Definition at line 288 of file G4MTRunManager.hh.

Referenced by AbortRun(), G4MTRunManager(), and InitializeEventLoop().

nextActionRequest

WorkerActionRequest G4MTRunManager::nextActionRequest = WorkerActionRequest::UNDEFINED

protected

Definition at line 237 of file G4MTRunManager.hh.

Referenced by NewActionRequest(), and ThisWorkerWaitForNextAction().

nextActionRequestBarrier

G4MTBarrier G4MTRunManager::nextActionRequestBarrier

protected

Definition at line 268 of file G4MTRunManager.hh.

Referenced by NewActionRequest(), and ThisWorkerWaitForNextAction().

nSeedsFilled

G4int G4MTRunManager::nSeedsFilled = 0

protected

Definition at line 242 of file G4MTRunManager.hh.

Referenced by InitializeEventLoop(), G4SubEvtRunManager::InitializeEventLoop(), G4TaskRunManager::InitializeEventLoop(), RefillSeeds(), G4SubEvtRunManager::RefillSeeds(), G4TaskRunManager::RefillSeeds(), SetUpAnEvent(), G4TaskRunManager::SetUpAnEvent(), SetUpNEvents(), G4TaskRunManager::SetUpNEvents(), and G4SubEvtRunManager::SetUpSeedsForSubEvent().

nSeedsMax

G4int G4MTRunManager::nSeedsMax = 10000

protected

Definition at line 243 of file G4MTRunManager.hh.

Referenced by G4MTRunManager(), G4TaskRunManager::G4TaskRunManager(), InitializeEventLoop(), G4SubEvtRunManager::InitializeEventLoop(), G4TaskRunManager::InitializeEventLoop(), RefillSeeds(), G4SubEvtRunManager::RefillSeeds(), and G4TaskRunManager::RefillSeeds().

nSeedsPerEvent

G4int G4MTRunManager::nSeedsPerEvent = 2

protected

Definition at line 244 of file G4MTRunManager.hh.

Referenced by G4MTRunManager(), G4TaskRunManager::G4TaskRunManager(), InitializeEventLoop(), G4SubEvtRunManager::InitializeEventLoop(), G4TaskRunManager::InitializeEventLoop(), RefillSeeds(), G4SubEvtRunManager::RefillSeeds(), G4TaskRunManager::RefillSeeds(), SetUpAnEvent(), G4TaskRunManager::SetUpAnEvent(), SetUpNEvents(), G4TaskRunManager::SetUpNEvents(), and G4SubEvtRunManager::SetUpSeedsForSubEvent().

nSeedsUsed

G4int G4MTRunManager::nSeedsUsed = 0

protected

Definition at line 241 of file G4MTRunManager.hh.

Referenced by InitializeEventLoop(), G4SubEvtRunManager::InitializeEventLoop(), G4TaskRunManager::InitializeEventLoop(), SetUpAnEvent(), G4TaskRunManager::SetUpAnEvent(), SetUpNEvents(), G4TaskRunManager::SetUpNEvents(), and G4SubEvtRunManager::SetUpSeedsForSubEvent().

numberOfEventToBeProcessed

G4int G4MTRunManager::numberOfEventToBeProcessed = 0

protected

Definition at line 230 of file G4MTRunManager.hh.

Referenced by G4TaskRunManager::ComputeNumberOfTasks(), G4TaskRunManager::CreateAndStartWorkers(), G4TaskRunManager::G4TaskRunManager(), InitializeEventLoop(), G4SubEvtRunManager::InitializeEventLoop(), G4TaskRunManager::InitializeEventLoop(), RefillSeeds(), G4SubEvtRunManager::RefillSeeds(), G4TaskRunManager::RefillSeeds(), SetUpAnEvent(), G4TaskRunManager::SetUpAnEvent(), SetUpNEvents(), and G4TaskRunManager::SetUpNEvents().

nworkers

G4int G4MTRunManager::nworkers = 2

protected

Definition at line 225 of file G4MTRunManager.hh.

Referenced by CreateAndStartWorkers(), G4MTRunManager(), G4TaskRunManager::G4TaskRunManager(), GetNumberOfThreads(), G4TaskRunManager::GetNumberOfThreads(), InitializeEventLoop(), G4SubEvtRunManager::InitializeEventLoop(), G4TaskRunManager::InitializeThreadPool(), RefillSeeds(), SetNumberOfThreads(), and G4TaskRunManager::SetNumberOfThreads().

pinAffinity

G4int G4MTRunManager::pinAffinity = 0

protected

Definition at line 276 of file G4MTRunManager.hh.

Referenced by GetPinAffinity(), and SetPinAffinity().

processUIBarrier

G4MTBarrier G4MTRunManager::processUIBarrier

protected

Definition at line 269 of file G4MTRunManager.hh.

Referenced by RequestWorkersProcessCommandsStack(), and ThisWorkerProcessCommandsStackDone().

randDbl

G4double* G4MTRunManager::randDbl = nullptr

protected

Definition at line 245 of file G4MTRunManager.hh.

Referenced by G4MTRunManager(), G4TaskRunManager::G4TaskRunManager(), InitializeEventLoop(), G4SubEvtRunManager::InitializeEventLoop(), G4TaskRunManager::InitializeEventLoop(), RefillSeeds(), G4SubEvtRunManager::RefillSeeds(), G4TaskRunManager::RefillSeeds(), and ~G4MTRunManager().

seedOncePerCommunication

G4int G4MTRunManager::seedOncePerCommunication = 0

staticprotected

Definition at line 263 of file G4MTRunManager.hh.

Referenced by InitializeEventLoop(), RefillSeeds(), SeedOncePerCommunication(), SetSeedOncePerCommunication(), and SetUpNEvents().

threads

G4ThreadsList G4MTRunManager::threads

protected

Definition at line 280 of file G4MTRunManager.hh.

Referenced by CreateAndStartWorkers(), GetNumberActiveThreads(), G4SubEvtRunManager::GetNumberActiveThreads(), SetNumberOfThreads(), and TerminateWorkers().

uiCmdsForWorkers

std::vector<G4String> G4MTRunManager::uiCmdsForWorkers

protected

Definition at line 283 of file G4MTRunManager.hh.

Referenced by GetCommandStack(), and PrepareCommandsStack().

---

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

• G4MTRunManager.hh
• G4MTRunManager.cc