#include <G4MTRunManager.hh>

Inheritance diagram for G4MTRunManager:

Public Types
enum class	WorkerActionRequest { UNDEFINED , NEXTITERATION , PROCESSUI , ENDWORKER }

using	ProfilerConfig = G4ProfilerConfig< G4ProfileType::Run >

typedef std::map< G4int, G4VPhysicalVolume * >	masterWorlds_t

Public Types inherited from G4RunManager
enum	RMType { sequentialRM , masterRM , workerRM }

using	ProfilerConfig = G4ProfilerConfig< G4ProfileType::Run >

Public Member Functions
	G4MTRunManager ()

virtual	~G4MTRunManager ()

virtual void	SetNumberOfThreads (G4int n)

virtual G4int	GetNumberOfThreads () const

void	SetPinAffinity (G4int n=1)

G4int	GetPinAffinity () const

virtual void	Initialize ()

virtual void	InitializeEventLoop (G4int n_event, const char *macroFile=0, G4int n_select=-1)

virtual void	InitializeThreadPool ()

virtual void	TerminateOneEvent ()

virtual void	ProcessOneEvent (G4int i_event)

virtual void	ConstructScoringWorlds ()

virtual void	RunTermination ()

virtual G4bool	SetUpAnEvent (G4Event *, long &s1, long &s2, long &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

virtual void	SetUserInitialization (G4VUserPhysicsList *userPL)

virtual void	SetUserInitialization (G4VUserDetectorConstruction *userDC)

virtual void	SetUserInitialization (G4UserWorkerInitialization *userInit)

virtual void	SetUserInitialization (G4UserWorkerThreadInitialization *userInit)

virtual void	SetUserInitialization (G4VUserActionInitialization *userInit)

virtual void	SetUserAction (G4UserRunAction *userAction)

virtual void	SetUserAction (G4VUserPrimaryGeneratorAction *userAction)

virtual void	SetUserAction (G4UserEventAction *userAction)

virtual void	SetUserAction (G4UserStackingAction *userAction)

virtual void	SetUserAction (G4UserTrackingAction *userAction)

virtual void	SetUserAction (G4UserSteppingAction *userAction)

void	MergeScores (const G4ScoringManager *localScoringManager)

void	MergeRun (const G4Run *localRun)

virtual void	RequestWorkersProcessCommandsStack ()

virtual void	ThisWorkerProcessCommandsStackDone ()

virtual WorkerActionRequest	ThisWorkerWaitForNextAction ()

void	SetEventModulo (G4int i=1)

G4int	GetEventModulo () const

virtual void	AbortRun (G4bool softAbort=false)

virtual void	AbortEvent ()

Public Member Functions inherited from G4RunManager
	G4RunManager ()

virtual	~G4RunManager ()

virtual void	BeamOn (G4int n_event, const char *macroFile=0, G4int n_select=-1)

virtual void	Initialize ()

virtual void	DefineWorldVolume (G4VPhysicalVolume *worldVol, G4bool topologyIsChanged=true)

virtual void	AbortRun (G4bool softAbort=false)

virtual void	AbortEvent ()

virtual void	InitializeGeometry ()

virtual void	InitializePhysics ()

virtual G4bool	ConfirmBeamOnCondition ()

virtual void	RunInitialization ()

virtual void	DoEventLoop (G4int n_event, const char *macroFile=0, G4int n_select=-1)

virtual void	RunTermination ()

virtual void	InitializeEventLoop (G4int n_event, const char *macroFile=0, G4int n_select=-1)

virtual void	ProcessOneEvent (G4int i_event)

virtual void	TerminateOneEvent ()

virtual void	TerminateEventLoop ()

virtual G4Event *	GenerateEvent (G4int i_event)

virtual void	AnalyzeEvent (G4Event *anEvent)

virtual void	ConfigureProfilers (const std::vector< std::string > &args={})

void	ConfigureProfilers (int argc, char **argv)

virtual void	SetNumberOfThreads (G4int)

virtual G4int	GetNumberOfThreads () const

void	DumpRegion (const G4String &rname) const

void	DumpRegion (G4Region *region=0) const

virtual void	rndmSaveThisRun ()

virtual void	rndmSaveThisEvent ()

virtual void	RestoreRandomNumberStatus (const G4String &fileN)

virtual void	SetUserInitialization (G4VUserDetectorConstruction *userInit)

virtual void	SetUserInitialization (G4VUserPhysicsList *userInit)

virtual void	SetUserInitialization (G4VUserActionInitialization *userInit)

virtual void	SetUserInitialization (G4UserWorkerInitialization *userInit)

virtual void	SetUserInitialization (G4UserWorkerThreadInitialization *userInit)

virtual void	SetUserAction (G4UserRunAction *userAction)

virtual void	SetUserAction (G4VUserPrimaryGeneratorAction *userAction)

virtual void	SetUserAction (G4UserEventAction *userAction)

virtual void	SetUserAction (G4UserStackingAction *userAction)

virtual void	SetUserAction (G4UserTrackingAction *userAction)

virtual void	SetUserAction (G4UserSteppingAction *userAction)

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)

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	GeometryHasBeenModified (G4bool prop=true)

void	ReinitializeGeometry (G4bool destroyFirst=false, G4bool prop=true)

void	PhysicsHasBeenModified ()

void	CutOffHasBeenModified ()

void	ReOptimizeMotherOf (G4VPhysicalVolume *)

void	ReOptimize (G4LogicalVolume *)

void	SetVerboseLevel (G4int vl)

G4int	GetVerboseLevel () const

G4int	GetPrintProgress ()

void	SetPrintProgress (G4int i)

void	SetGeometryToBeOptimized (G4bool vl)

G4bool	GetGeometryToBeOptimized ()

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

G4String	GetSelectMacro () const

void	SetDCtable (G4DCtable *DCtbl)

RMType	GetRunManagerType () const

virtual void	ConstructScoringWorlds ()

virtual void	RestoreRndmEachEvent (G4bool)

void	GeometryDirectlyUpdated (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 G4ThreadId	GetMasterTheadId ()

Static Public Member Functions inherited from G4RunManager
static G4RunManager *	GetRunManager ()

static G4bool	IfGeometryHasBeenDestroyed ()

Protected Member Functions
virtual G4bool	InitializeSeeds (G4int)

virtual void	PrepareCommandsStack ()

virtual void	StoreRNGStatus (const G4String &filenamePrefix)

virtual void	rndmSaveThisRun ()

virtual void	rndmSaveThisEvent ()

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
void	CleanUpPreviousEvents ()

void	CleanUpUnnecessaryEvents (G4int keepNEvents)

void	StackPreviousEvent (G4Event *anEvent)

	G4RunManager (RMType rmType)

virtual void	StoreRNGStatus (const G4String &filenamePrefix)

void	UpdateScoring ()

virtual void	DeleteUserInitializations ()

Protected Attributes
G4int	nworkers

G4int	forcedNwokers

G4int	numberOfEventToBeProcessed

WorkerActionRequest	nextActionRequest

G4int	eventModuloDef

G4int	eventModulo

G4int	nSeedsUsed

G4int	nSeedsFilled

G4int	nSeedsMax

G4int	nSeedsPerEvent

double *	randDbl

G4MTBarrier	beginOfEventLoopBarrier

G4MTBarrier	endOfEventLoopBarrier

G4MTBarrier	nextActionRequestBarrier

G4MTBarrier	processUIBarrier

Protected Attributes inherited from G4RunManager
G4RunManagerKernel *	kernel

G4EventManager *	eventManager

G4VUserDetectorConstruction *	userDetector

G4VUserPhysicsList *	physicsList

G4VUserActionInitialization *	userActionInitialization

G4UserWorkerInitialization *	userWorkerInitialization

G4UserWorkerThreadInitialization *	userWorkerThreadInitialization

G4UserRunAction *	userRunAction

G4VUserPrimaryGeneratorAction *	userPrimaryGeneratorAction

G4UserEventAction *	userEventAction

G4UserStackingAction *	userStackingAction

G4UserTrackingAction *	userTrackingAction

G4UserSteppingAction *	userSteppingAction

G4bool	geometryInitialized

G4bool	physicsInitialized

G4bool	runAborted

G4bool	initializedAtLeastOnce

G4bool	geometryToBeOptimized

G4int	runIDCounter

G4int	verboseLevel

G4int	printModulo

G4Timer *	timer

G4DCtable *	DCtable

G4Run *	currentRun

G4Event *	currentEvent

std::list< G4Event * > *	previousEvents

G4int	n_perviousEventsToBeStored

G4int	numberOfEventToBeProcessed

G4bool	storeRandomNumberStatus

G4int	storeRandomNumberStatusToG4Event

G4String	randomNumberStatusDir

G4String	randomNumberStatusForThisRun

G4String	randomNumberStatusForThisEvent

G4bool	rngStatusEventsFlag

G4VPhysicalVolume *	currentWorld

G4int	nParallelWorlds

G4String	msgText

G4int	n_select_msg

G4int	numberOfEventProcessed

G4String	selectMacro

G4bool	fakeRun

G4bool	isScoreNtupleWriter

RMType	runManagerType

G4bool	geometryDirectlyUpdated

Static Protected Attributes
static G4MTRUN_DLL G4ScoringManager *	masterScM = 0

static G4MTRUN_DLL masterWorlds_t	masterWorlds

static G4MTRUN_DLL G4MTRunManager *	fMasterRM = 0

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 53 of file G4MTRunManager.hh.

Member Typedef Documentation

◆ masterWorlds_t

typedef std::map<G4int, G4VPhysicalVolume*> G4MTRunManager::masterWorlds_t

Definition at line 178 of file G4MTRunManager.hh.

◆ ProfilerConfig

using G4MTRunManager::ProfilerConfig = G4ProfilerConfig<G4ProfileType::Run>

Definition at line 59 of file G4MTRunManager.hh.

Member Enumeration Documentation

◆ WorkerActionRequest

enum class G4MTRunManager::WorkerActionRequest

strong

Enumerator
UNDEFINED
NEXTITERATION
PROCESSUI
ENDWORKER

Definition at line 227 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 104 of file G4MTRunManager.cc.

  : G4RunManager(masterRM)
  , nworkers(2)
  , forcedNwokers(-1)
  , pinAffinity(0)
  , masterRNGEngine(0)
  , nextActionRequest(WorkerActionRequest::UNDEFINED)
  , eventModuloDef(0)
  , eventModulo(1)
  , nSeedsUsed(0)
  , nSeedsFilled(0)
  , nSeedsMax(10000)
  , nSeedsPerEvent(2)
{
  if(fMasterRM)
  {
    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();
 
  numberOfEventToBeProcessed = 0;
  randDbl                    = new double[nSeedsPerEvent * nSeedsMax];
 
  char* env = std::getenv("G4FORCENUMBEROFTHREADS");
  if(env)
  {
    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;
      G4cout << "### Number of threads is forced to " << forcedNwokers
             << " by Environment variable G4FORCENUMBEROFTHREADS." << G4endl;
    }
  }
}

◆ ~G4MTRunManager()

G4MTRunManager::~G4MTRunManager ( )

virtual

Definition at line 195 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 ( )

virtual

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 702 of file G4MTRunManager.cc.

{
  // nothing to do in the master thread
}

◆ AbortRun()

void G4MTRunManager::AbortRun ( G4bool softAbort = false )

virtual

virtual void ResetNavigator() const;

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 686 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 88 of file G4MTRunManager.cc.

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

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

◆ ConstructScoringWorlds()

void G4MTRunManager::ConstructScoringWorlds ( )

virtual

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 499 of file G4MTRunManager.cc.

{
  masterScM = G4ScoringManager::GetScoringManagerIfExist();
  // Call base class stuff...
  G4RunManager::ConstructScoringWorlds();
 
  masterWorlds.clear();
  size_t nWorlds =
    G4TransportationManager::GetTransportationManager()->GetNoWorlds();
  std::vector<G4VPhysicalVolume*>::iterator itrW =
    G4TransportationManager::GetTransportationManager()->GetWorldsIterator();
  for(size_t iWorld = 0; iWorld < nWorlds; iWorld++)
  {
    addWorld(iWorld, *itrW);
    itrW++;
  }
}

◆ CreateAndStartWorkers()

void G4MTRunManager::CreateAndStartWorkers ( )

protectedvirtual

Reimplemented in G4TaskRunManager.

Definition at line 314 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.size() == 0)
  {
    {
      // for consistency with G4TaskRunManager
      std::stringstream msg;
      msg << "--> G4MTRunManager::CreateAndStartWorkers() --> "
          << "Initializing workers...";
 
      std::stringstream ss;
      ss.fill('=');
      ss << std::setw(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
      G4WorkerThread* 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 308 of file G4MTRunManager.cc.

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

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

◆ GetEventModulo()

G4int G4MTRunManager::GetEventModulo ( ) const

inline

Definition at line 263 of file G4MTRunManager.hh.

263{ return eventModuloDef; }

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

◆ getMasterRandomEngine()

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

inline

Definition at line 183 of file G4MTRunManager.hh.

  {
    return masterRNGEngine;
  }

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

◆ GetMasterRunManager()

G4MTRunManager * G4MTRunManager::GetMasterRunManager ( )

static

Definition at line 61 of file G4MTRunManager.cc.

{
  ////////#ifdef G4MULTITHREADED
  return fMasterRM;
  ////////#else
  ////////    return G4RunManager::GetRunManager();
  ////////#endif
}

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

◆ GetMasterRunManagerKernel()

G4RunManagerKernel * G4MTRunManager::GetMasterRunManagerKernel ( )

static

Definition at line 70 of file G4MTRunManager.cc.

{
  return fMasterRM->kernel;
}

Referenced by G4WorkerRunManager::InitializeGeometry().

◆ GetMasterScoringManager()

G4ScoringManager * G4MTRunManager::GetMasterScoringManager ( )

static

Definition at line 79 of file G4MTRunManager.cc.

{
  return masterScM;
}

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

◆ GetMasterTheadId()

static G4ThreadId G4MTRunManager::GetMasterTheadId ( )

static

◆ GetMasterThreadId()

G4ThreadId G4MTRunManager::GetMasterThreadId ( )

static

Definition at line 92 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 84 of file G4MTRunManager.cc.

{
  return masterWorlds;
}

Referenced by G4RunManagerKernel::WorkerDefineWorldVolume(), and G4RunManagerKernel::WorkerUpdateWorldVolume().

◆ GetMTMasterRunManagerKernel()

G4MTRunManagerKernel * G4MTRunManager::GetMTMasterRunManagerKernel ( )

static

Definition at line 75 of file G4MTRunManager.cc.

{
  return fMasterRM->MTkernel;
}

◆ GetNumberActiveThreads()

virtual size_t G4MTRunManager::GetNumberActiveThreads ( ) const

inlinevirtual

Reimplemented in G4TaskRunManager.

Definition at line 120 of file G4MTRunManager.hh.

120{ return threads.size(); }

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

◆ GetNumberOfThreads()

virtual G4int G4MTRunManager::GetNumberOfThreads ( ) const

inlinevirtual

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 66 of file G4MTRunManager.hh.

66{ return nworkers; }

◆ GetPinAffinity()

G4int G4MTRunManager::GetPinAffinity ( ) const

inline

Definition at line 68 of file G4MTRunManager.hh.

68{ return pinAffinity; }

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

◆ Initialize()

void G4MTRunManager::Initialize ( )

virtual

G4UImanager::GetUIpointer()->SetIgnoreCmdNotFound(true);

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 272 of file G4MTRunManager.cc.

{
  G4RunManager::Initialize();
 
  // make sure all worker threads are set up.
  BeamOn(0);
  SetRunIDCounter(0);
  /// G4UImanager::GetUIpointer()->SetIgnoreCmdNotFound(true);
}

◆ InitializeEventLoop()

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

virtual

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 353 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 != 0)
    {
      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 =
        int(std::sqrt(double(numberOfEventToBeProcessed / nworkers)));
      if(eventModulo < 1)
        eventModulo = 1;
    }
    if(InitializeSeeds(n_event) == false && 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 == 0)
  {
    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 G4TaskRunManager.

Definition at line 107 of file G4MTRunManager.hh.

107{ return false; };

Referenced by InitializeEventLoop().

◆ InitializeThreadPool()

virtual void G4MTRunManager::InitializeThreadPool ( )

inlinevirtual

Reimplemented in G4TaskRunManager.

Definition at line 75 of file G4MTRunManager.hh.

75{}

◆ MergeRun()

void G4MTRunManager::MergeRun ( const G4Run * localRun )

Definition at line 597 of file G4MTRunManager.cc.

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

Referenced by G4WorkerRunManager::MergePartialResults().

◆ MergeScores()

void G4MTRunManager::MergeScores ( const G4ScoringManager * localScoringManager )

Definition at line 590 of file G4MTRunManager.cc.

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

Referenced by G4WorkerRunManager::MergePartialResults().

◆ NewActionRequest()

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

protectedvirtual

Reimplemented in G4TaskRunManager.

Definition at line 731 of file G4MTRunManager.cc.

{
  nextActionRequestBarrier.Wait(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 295 of file G4MTRunManager.cc.

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

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

◆ ProcessOneEvent()

void G4MTRunManager::ProcessOneEvent ( G4int i_event )

virtual

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 286 of file G4MTRunManager.cc.

{
  // Nothing to do
}

◆ RefillSeeds()

void G4MTRunManager::RefillSeeds ( )

protectedvirtual

Reimplemented in G4TaskRunManager.

Definition at line 459 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;
  // G4cout<<"helper->Refill() for "<<nFill<<" events."<<G4endl;
}

Referenced by SetUpAnEvent(), and SetUpNEvents().

◆ RequestWorkersProcessCommandsStack()

void G4MTRunManager::RequestWorkersProcessCommandsStack ( )

virtual

Reimplemented in G4TaskRunManager.

Definition at line 748 of file G4MTRunManager.cc.

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

Referenced by G4RunMessenger::SetNewValue(), and TerminateWorkers().

◆ rndmSaveThisEvent()

void G4MTRunManager::rndmSaveThisEvent ( )

protectedvirtual

Reimplemented from G4RunManager.

Definition at line 241 of file G4MTRunManager.cc.

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

◆ rndmSaveThisRun()

void G4MTRunManager::rndmSaveThisRun ( )

protectedvirtual

Reimplemented from G4RunManager.

Definition at line 212 of file G4MTRunManager.cc.

{
  G4int runNumber = 0;
  if(currentRun) 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;
  }
 
  G4String fileIn = randomNumberStatusDir + "G4Worker_currentRun.rndm";
 
  std::ostringstream os;
  os << "run" << runNumber << ".rndm" << '\0';
  G4String fileOut = randomNumberStatusDir + os.str();
 
#ifdef WIN32
  G4String copCmd = "/control/shell copy " + fileIn + " " + fileOut;
#else
  G4String copCmd = "/control/shell cp " + fileIn + " " + fileOut;
#endif
  G4UImanager::GetUIpointer()->ApplyCommand(copCmd);
  if(verboseLevel > 0)
  { G4cout << fileIn << " is copied to " << fileOut << G4endl; }
}

◆ RunTermination()

void G4MTRunManager::RunTermination ( )

virtual

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 486 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 95 of file G4MTRunManager.cc.

{
  return seedOncePerCommunication;
}

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

◆ SetEventModulo()

void G4MTRunManager::SetEventModulo ( G4int i = 1 )

inline

Definition at line 262 of file G4MTRunManager.hh.

262{ eventModuloDef = i; }

◆ SetNumberOfThreads()

void G4MTRunManager::SetNumberOfThreads ( G4int n )

virtual

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 247 of file G4MTRunManager.cc.

{
  if(threads.size() != 0)
  {
    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 760 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 99 of file G4MTRunManager.cc.

{
  seedOncePerCommunication = val;
}

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

◆ SetUpAnEvent()

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

virtual

Reimplemented in G4TaskRunManager.

Definition at line 604 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(), and G4WorkerTaskRunManager::GenerateEvent().

◆ SetUpNEvents()

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

virtual

Reimplemented in G4TaskRunManager.

Definition at line 629 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(int 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(), and G4WorkerTaskRunManager::GenerateEvent().

◆ SetUserAction() [1/6]

void G4MTRunManager::SetUserAction ( G4UserEventAction * userAction )

virtual

Reimplemented from G4RunManager.

Definition at line 562 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 )

virtual

Reimplemented from G4RunManager.

Definition at line 546 of file G4MTRunManager.cc.

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

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

◆ SetUserAction() [3/6]

void G4MTRunManager::SetUserAction ( G4UserStackingAction * userAction )

virtual

Reimplemented from G4RunManager.

Definition at line 569 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 )

virtual

Reimplemented from G4RunManager.

Definition at line 583 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 )

virtual

Reimplemented from G4RunManager.

Definition at line 576 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 )

virtual

Reimplemented from G4RunManager.

Definition at line 553 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 )

virtual

Reimplemented from G4RunManager.

Definition at line 517 of file G4MTRunManager.cc.

{
  userWorkerInitialization = userInit;
}

◆ SetUserInitialization() [2/5]

void G4MTRunManager::SetUserInitialization ( G4UserWorkerThreadInitialization * userInit )

virtual

Reimplemented from G4RunManager.

Definition at line 522 of file G4MTRunManager.cc.

{
  userWorkerThreadInitialization = userInit;
}

◆ SetUserInitialization() [3/5]

void G4MTRunManager::SetUserInitialization ( G4VUserActionInitialization * userInit )

virtual

Reimplemented from G4RunManager.

Definition at line 528 of file G4MTRunManager.cc.

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

◆ SetUserInitialization() [4/5]

void G4MTRunManager::SetUserInitialization ( G4VUserDetectorConstruction * userDC )

virtual

Reimplemented from G4RunManager.

Definition at line 541 of file G4MTRunManager.cc.

{
  G4RunManager::SetUserInitialization(userDC);
}

◆ SetUserInitialization() [5/5]

void G4MTRunManager::SetUserInitialization ( G4VUserPhysicsList * userPL )

virtual

Reimplemented from G4RunManager.

Definition at line 535 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 )

protectedvirtual

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 205 of file G4MTRunManager.cc.

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

◆ TerminateOneEvent()

void G4MTRunManager::TerminateOneEvent ( )

virtual

Reimplemented from G4RunManager.

Reimplemented in G4TaskRunManager.

Definition at line 290 of file G4MTRunManager.cc.

{
  // Nothing to do
}

◆ TerminateWorkers()

void G4MTRunManager::TerminateWorkers ( )

protectedvirtual

Reimplemented in G4TaskRunManager.

Definition at line 664 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);
  // finalize profiler before shutting down the threads
  G4Profiler::Finalize();
  // 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);
    // G4THREADJOIN(*t);
    delete t;
  }
#endif
  threads.clear();
}

Referenced by ~G4MTRunManager().

◆ ThisWorkerEndEventLoop()

void G4MTRunManager::ThisWorkerEndEventLoop ( )

virtual

Reimplemented in G4TaskRunManager.

Definition at line 726 of file G4MTRunManager.cc.

{
  endOfEventLoopBarrier.ThisWorkerReady();
}

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

◆ ThisWorkerProcessCommandsStackDone()

void G4MTRunManager::ThisWorkerProcessCommandsStackDone ( )

virtual

Reimplemented in G4TaskRunManager.

Definition at line 756 of file G4MTRunManager.cc.

{
  processUIBarrier.ThisWorkerReady();
}

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

◆ ThisWorkerReady()

void G4MTRunManager::ThisWorkerReady ( )

virtual

Reimplemented in G4TaskRunManager.

Definition at line 714 of file G4MTRunManager.cc.

{
  beginOfEventLoopBarrier.ThisWorkerReady();
}

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

◆ ThisWorkerWaitForNextAction()

G4MTRunManager::WorkerActionRequest G4MTRunManager::ThisWorkerWaitForNextAction ( )

virtual

Reimplemented in G4TaskRunManager.

Definition at line 742 of file G4MTRunManager.cc.

{
  nextActionRequestBarrier.ThisWorkerReady();
  return nextActionRequest;
}

Referenced by G4WorkerRunManager::DoWork().

◆ WaitForEndEventLoopWorkers()

void G4MTRunManager::WaitForEndEventLoopWorkers ( )

protectedvirtual

Reimplemented in G4TaskRunManager.

Definition at line 719 of file G4MTRunManager.cc.

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

Referenced by RunTermination().

◆ WaitForReadyWorkers()

void G4MTRunManager::WaitForReadyWorkers ( )

protectedvirtual

Reimplemented in G4TaskRunManager.

Definition at line 707 of file G4MTRunManager.cc.

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

Referenced by InitializeEventLoop().

Friends And Related Function Documentation

◆ G4RunManagerFactory

friend class G4RunManagerFactory

friend

Definition at line 55 of file G4MTRunManager.hh.

Member Data Documentation

◆ beginOfEventLoopBarrier

G4MTBarrier G4MTRunManager::beginOfEventLoopBarrier

protected

Definition at line 293 of file G4MTRunManager.hh.

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

◆ endOfEventLoopBarrier

G4MTBarrier G4MTRunManager::endOfEventLoopBarrier

protected

Definition at line 294 of file G4MTRunManager.hh.

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

◆ eventModulo

G4int G4MTRunManager::eventModulo

protected

Definition at line 252 of file G4MTRunManager.hh.

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

◆ eventModuloDef

G4int G4MTRunManager::eventModuloDef

protected

Definition at line 251 of file G4MTRunManager.hh.

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

◆ fMasterRM

G4MTRunManager * G4MTRunManager::fMasterRM = 0

staticprotected

Definition at line 193 of file G4MTRunManager.hh.

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

◆ forcedNwokers

G4int G4MTRunManager::forcedNwokers

protected

Definition at line 131 of file G4MTRunManager.hh.

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

◆ masterScM

G4ScoringManager * G4MTRunManager::masterScM = 0

staticprotected

Definition at line 190 of file G4MTRunManager.hh.

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

◆ masterThreadId

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

staticprotected

Definition at line 270 of file G4MTRunManager.hh.

Referenced by G4MTRunManager(), and GetMasterThreadId().

◆ masterWorlds

G4MTRunManager::masterWorlds_t G4MTRunManager::masterWorlds

staticprotected

Initial value:

=

G4MTRunManager::masterWorlds_t()

G4MTRunManager::masterWorlds_t

std::map< G4int, G4VPhysicalVolume * > masterWorlds_t

Definition: G4MTRunManager.hh:178

Definition at line 191 of file G4MTRunManager.hh.

Referenced by addWorld(), ConstructScoringWorlds(), G4TaskRunManager::ConstructScoringWorlds(), and GetMasterWorlds().

◆ nextActionRequest

WorkerActionRequest G4MTRunManager::nextActionRequest

protected

Definition at line 247 of file G4MTRunManager.hh.

Referenced by NewActionRequest(), and ThisWorkerWaitForNextAction().

◆ nextActionRequestBarrier

G4MTBarrier G4MTRunManager::nextActionRequestBarrier

protected

Definition at line 295 of file G4MTRunManager.hh.

Referenced by NewActionRequest(), and ThisWorkerWaitForNextAction().

◆ nSeedsFilled

G4int G4MTRunManager::nSeedsFilled

protected

Definition at line 254 of file G4MTRunManager.hh.

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

◆ nSeedsMax

G4int G4MTRunManager::nSeedsMax

protected

Definition at line 255 of file G4MTRunManager.hh.

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

◆ nSeedsPerEvent

G4int G4MTRunManager::nSeedsPerEvent

protected

Definition at line 256 of file G4MTRunManager.hh.

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

◆ nSeedsUsed

G4int G4MTRunManager::nSeedsUsed

protected

Definition at line 253 of file G4MTRunManager.hh.

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

◆ numberOfEventToBeProcessed

G4int G4MTRunManager::numberOfEventToBeProcessed

protected

Definition at line 159 of file G4MTRunManager.hh.

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

◆ nworkers

G4int G4MTRunManager::nworkers

protected

Definition at line 129 of file G4MTRunManager.hh.

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

◆ processUIBarrier

G4MTBarrier G4MTRunManager::processUIBarrier

protected

Definition at line 296 of file G4MTRunManager.hh.

Referenced by RequestWorkersProcessCommandsStack(), and ThisWorkerProcessCommandsStackDone().

◆ randDbl

double* G4MTRunManager::randDbl

protected

Definition at line 257 of file G4MTRunManager.hh.

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

◆ seedOncePerCommunication

G4int G4MTRunManager::seedOncePerCommunication = 0

staticprotected

Definition at line 271 of file G4MTRunManager.hh.

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

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

Public Types

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Static Protected Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ masterWorlds_t

◆ ProfilerConfig

Member Enumeration Documentation

◆ WorkerActionRequest

Constructor & Destructor Documentation

◆ G4MTRunManager()

◆ ~G4MTRunManager()

Member Function Documentation

◆ AbortEvent()

◆ AbortRun()

◆ addWorld()

◆ ConstructScoringWorlds()

◆ CreateAndStartWorkers()

◆ GetCommandStack()

◆ GetEventModulo()

◆ getMasterRandomEngine()

◆ GetMasterRunManager()

◆ GetMasterRunManagerKernel()

◆ GetMasterScoringManager()

◆ GetMasterTheadId()

◆ GetMasterThreadId()

◆ GetMasterWorlds()

◆ GetMTMasterRunManagerKernel()

◆ GetNumberActiveThreads()

◆ GetNumberOfThreads()

◆ GetPinAffinity()

◆ Initialize()

◆ InitializeEventLoop()

◆ InitializeSeeds()

◆ InitializeThreadPool()

◆ MergeRun()

◆ MergeScores()

◆ NewActionRequest()

◆ PrepareCommandsStack()

◆ ProcessOneEvent()

◆ RefillSeeds()

◆ RequestWorkersProcessCommandsStack()

◆ rndmSaveThisEvent()

◆ rndmSaveThisRun()

◆ RunTermination()

◆ SeedOncePerCommunication()

◆ SetEventModulo()

◆ SetNumberOfThreads()

◆ SetPinAffinity()

◆ SetSeedOncePerCommunication()

◆ SetUpAnEvent()

◆ SetUpNEvents()

◆ SetUserAction() [1/6]

◆ SetUserAction() [2/6]

◆ SetUserAction() [3/6]

◆ SetUserAction() [4/6]

◆ SetUserAction() [5/6]

◆ SetUserAction() [6/6]

◆ SetUserInitialization() [1/5]

◆ SetUserInitialization() [2/5]

◆ SetUserInitialization() [3/5]

◆ SetUserInitialization() [4/5]

◆ SetUserInitialization() [5/5]

◆ StoreRNGStatus()

◆ TerminateOneEvent()

◆ TerminateWorkers()

◆ ThisWorkerEndEventLoop()

◆ ThisWorkerProcessCommandsStackDone()

◆ ThisWorkerReady()

◆ ThisWorkerWaitForNextAction()

◆ WaitForEndEventLoopWorkers()

◆ WaitForReadyWorkers()

Friends And Related Function Documentation

◆ G4RunManagerFactory

Member Data Documentation

◆ beginOfEventLoopBarrier