G4MTRunManager Class Reference

#include <G4MTRunManager.hh>

Inheritance diagram for G4MTRunManager:

Collaboration diagram for G4MTRunManager:

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

Public Member Functions
	G4MTRunManager ()
virtual	~G4MTRunManager ()
void	SetNumberOfThreads (G4int n)
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	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 ()
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	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=0, 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=0) const
virtual void	rndmSaveThisRun ()
virtual void	rndmSaveThisEvent ()
virtual void	RestoreRandomNumberStatus (const G4String &fileN)
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	RestoreRndmEachEvent (G4bool)

Static Public Member Functions
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 Member Functions
virtual G4bool	InitializeSeeds (G4int)
virtual void	PrepareCommandsStack ()
virtual void	StoreRNGStatus (const G4String &filenamePrefix)
virtual void	CreateAndStartWorkers ()
virtual void	WaitForReadyWorkers ()
virtual void	WaitForEndEventLoopWorkers ()
virtual void	TerminateWorkers ()
virtual void	NewActionRequest (WorkerActionRequest newRequest)
void	RefillSeeds ()
Protected Member Functions inherited from G4RunManager
void	CleanUpPreviousEvents ()
void	CleanUpUnnecessaryEvents (G4int keepNEvents)
void	StackPreviousEvent (G4Event *anEvent)
	G4RunManager (RMType rmType)
void	UpdateScoring ()
virtual void	DeleteUserInitializations ()

Protected Attributes
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
RMType	runManagerType

Static Protected Attributes
static G4int	seedOncePerCommunication = 0
Static Protected Attributes inherited from G4RunManager
static G4bool	fGeometryHasBeenDestroyed = false

Detailed Description

Definition at line 51 of file G4MTRunManager.hh.

Member Typedef Documentation

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

Definition at line 159 of file G4MTRunManager.hh.

Member Enumeration Documentation

enum G4MTRunManager::WorkerActionRequest

strong

Enumerator
UNDEFINED
NEXTITERATION
PROCESSUI
ENDWORKER

Definition at line 198 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

(

)

Definition at line 77 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;
    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 dynamicly 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 = 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;
      }
    }
}

Here is the call graph for this function:

G4MTRunManager::~G4MTRunManager ( )

virtual

Definition at line 153 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;
}

Here is the call graph for this function:

Member Function Documentation

void G4MTRunManager::AbortEvent ( )

virtual

Reimplemented from G4RunManager.

Definition at line 569 of file G4MTRunManager.cc.

{
  // nothing to do in the master thread
}

void G4MTRunManager::AbortRun ( G4bool  softAbort = false )

virtual

Reimplemented from G4RunManager.

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

Here is the call graph for this function:

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

inlinestatic

Definition at line 162 of file G4MTRunManager.hh.

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

Here is the caller graph for this function:

void G4MTRunManager::ConstructScoringWorlds ( )

virtual

Reimplemented from G4RunManager.

Definition at line 389 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++;
    }
}

Here is the call graph for this function:

void G4MTRunManager::CreateAndStartWorkers ( )

protectedvirtual

Definition at line 235 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 ( 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);
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::vector< G4String > G4MTRunManager::GetCommandStack

(

)

Definition at line 229 of file G4MTRunManager.cc.

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

Here is the caller graph for this function:

G4int G4MTRunManager::GetEventModulo ( ) const

inline

Definition at line 233 of file G4MTRunManager.hh.

{ return eventModuloDef; }

Here is the caller graph for this function:

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

inline

Definition at line 163 of file G4MTRunManager.hh.

{ return masterRNGEngine; }

Here is the caller graph for this function:

G4MTRunManager * G4MTRunManager::GetMasterRunManager ( )

static

Definition at line 58 of file G4MTRunManager.cc.

{
    return fMasterRM;
}

Here is the caller graph for this function:

G4RunManagerKernel * G4MTRunManager::GetMasterRunManagerKernel ( )

static

Definition at line 67 of file G4MTRunManager.cc.

{
    return fMasterRM->kernel;
}

Here is the caller graph for this function:

static G4ScoringManager* G4MTRunManager::GetMasterScoringManager ( )

inlinestatic

Definition at line 160 of file G4MTRunManager.hh.

{ return masterScM; }

Here is the caller graph for this function:

static masterWorlds_t& G4MTRunManager::GetMasterWorlds ( )

inlinestatic

Definition at line 161 of file G4MTRunManager.hh.

{ return masterWorlds; }

Here is the caller graph for this function:

G4MTRunManagerKernel * G4MTRunManager::GetMTMasterRunManagerKernel ( )

static

Definition at line 72 of file G4MTRunManager.cc.

{
    return fMasterRM->MTkernel;
}

size_t G4MTRunManager::GetNumberActiveThreads ( ) const

inline

Definition at line 104 of file G4MTRunManager.hh.

{ return threads.size(); }

Here is the caller graph for this function:

G4int G4MTRunManager::GetNumberOfThreads ( ) const

inline

Definition at line 57 of file G4MTRunManager.hh.

{ return nworkers; }

G4int G4MTRunManager::GetPinAffinity ( ) const

inline

Definition at line 59 of file G4MTRunManager.hh.

{ return pinAffinity; }

Here is the caller graph for this function:

void G4MTRunManager::Initialize ( void  )

virtual

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

Reimplemented from G4RunManager.

Definition at line 195 of file G4MTRunManager.cc.

{
    G4RunManager::Initialize();

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

Here is the call graph for this function:

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

virtual

Reimplemented from G4RunManager.

Definition at line 256 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();
}

Here is the call graph for this function:

virtual G4bool G4MTRunManager::InitializeSeeds ( G4int  )

inlineprotectedvirtual

Definition at line 93 of file G4MTRunManager.hh.

{ return false; };

Here is the caller graph for this function:

void G4MTRunManager::MergeRun

(

const G4Run *

localRun

)

Definition at line 475 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::MergeScores

(

const G4ScoringManager *

localScoringManager

)

Definition at line 469 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

Here is the caller graph for this function:

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

protectedvirtual

Definition at line 594 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();
}

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::PrepareCommandsStack ( )

protectedvirtual

Definition at line 218 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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::ProcessOneEvent ( G4int  i_event )

virtual

Reimplemented from G4RunManager.

Definition at line 209 of file G4MTRunManager.cc.

{
    //Nothing to do
}

void G4MTRunManager::RefillSeeds ( )

protected

Definition at line 352 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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::RequestWorkersProcessCommandsStack ( )

virtual

Definition at line 607 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::RunTermination ( )

virtual

Reimplemented from G4RunManager.

Definition at line 376 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();
}

Here is the call graph for this function:

static G4int G4MTRunManager::SeedOncePerCommunication ( )

inlinestatic

Definition at line 256 of file G4MTRunManager.hh.

{ return seedOncePerCommunication; }

Here is the caller graph for this function:

void G4MTRunManager::SetEventModulo ( G4int  i = 1 )

inline

Definition at line 232 of file G4MTRunManager.hh.

{ eventModuloDef = i; }

void G4MTRunManager::SetNumberOfThreads

(

G4int

n

)

Definition at line 170 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;
    }
}

Here is the call graph for this function:

void G4MTRunManager::SetPinAffinity

(

G4int

n = 1

)

Definition at line 617 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

static void G4MTRunManager::SetSeedOncePerCommunication ( G4int  val )

inlinestatic

Definition at line 257 of file G4MTRunManager.hh.

{ seedOncePerCommunication = val; }

Here is the caller graph for this function:

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

virtual

Definition at line 481 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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

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

virtual

Definition at line 503 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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::SetUserAction ( G4UserRunAction *  userAction )

virtual

Reimplemented from G4RunManager.

Definition at line 433 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::SetUserAction ( G4VUserPrimaryGeneratorAction *  userAction )

virtual

Reimplemented from G4RunManager.

Definition at line 439 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

void G4MTRunManager::SetUserAction ( G4UserEventAction *  userAction )

virtual

Reimplemented from G4RunManager.

Definition at line 445 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

void G4MTRunManager::SetUserAction ( G4UserStackingAction *  userAction )

virtual

Reimplemented from G4RunManager.

Definition at line 451 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

void G4MTRunManager::SetUserAction ( G4UserTrackingAction *  userAction )

virtual

Reimplemented from G4RunManager.

Definition at line 457 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

void G4MTRunManager::SetUserAction ( G4UserSteppingAction *  userAction )

virtual

Reimplemented from G4RunManager.

Definition at line 463 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

void G4MTRunManager::SetUserInitialization ( G4VUserPhysicsList *  userPL )

virtual

Reimplemented from G4RunManager.

Definition at line 422 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::SetUserInitialization ( G4VUserDetectorConstruction *  userDC )

virtual

Reimplemented from G4RunManager.

Definition at line 428 of file G4MTRunManager.cc.

{
    G4RunManager::SetUserInitialization(userDC);
}

Here is the call graph for this function:

void G4MTRunManager::SetUserInitialization ( G4UserWorkerInitialization *  userInit )

virtual

Reimplemented from G4RunManager.

Definition at line 406 of file G4MTRunManager.cc.

{
  userWorkerInitialization = userInit;
}

void G4MTRunManager::SetUserInitialization ( G4UserWorkerThreadInitialization *  userInit )

virtual

Reimplemented from G4RunManager.

Definition at line 411 of file G4MTRunManager.cc.

{
  userWorkerThreadInitialization = userInit;
}

void G4MTRunManager::SetUserInitialization ( G4VUserActionInitialization *  userInit )

virtual

Reimplemented from G4RunManager.

Definition at line 416 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

void G4MTRunManager::StoreRNGStatus ( const G4String &  filenamePrefix )

protectedvirtual

Reimplemented from G4RunManager.

Definition at line 163 of file G4MTRunManager.cc.

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

void G4MTRunManager::TerminateOneEvent ( )

virtual

Reimplemented from G4RunManager.

Definition at line 213 of file G4MTRunManager.cc.

{
    //Nothing to do
}

void G4MTRunManager::TerminateWorkers ( )

protectedvirtual

Definition at line 533 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);
        //G4THREADJOIN(*t);
        delete t;
    }
#endif
    threads.clear();
}

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::ThisWorkerEndEventLoop ( )

virtual

Definition at line 590 of file G4MTRunManager.cc.

                                            {
  endOfEventLoopBarrier.ThisWorkerReady();
}

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::ThisWorkerProcessCommandsStackDone ( )

virtual

Definition at line 614 of file G4MTRunManager.cc.

                                                        {
  processUIBarrier.ThisWorkerReady();
}

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::ThisWorkerReady ( )

virtual

Definition at line 580 of file G4MTRunManager.cc.

                                     {
  beginOfEventLoopBarrier.ThisWorkerReady();
}

Here is the call graph for this function:

Here is the caller graph for this function:

G4MTRunManager::WorkerActionRequest G4MTRunManager::ThisWorkerWaitForNextAction ( )

virtual

Definition at line 602 of file G4MTRunManager.cc.

                                                                              {
  nextActionRequestBarrier.ThisWorkerReady();
  return nextActionRequest;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::WaitForEndEventLoopWorkers ( )

protectedvirtual

Definition at line 584 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

Here is the caller graph for this function:

void G4MTRunManager::WaitForReadyWorkers ( )

protectedvirtual

Definition at line 574 of file G4MTRunManager.cc.

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

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

G4MTBarrier G4MTRunManager::beginOfEventLoopBarrier

protected

Definition at line 260 of file G4MTRunManager.hh.

G4MTBarrier G4MTRunManager::endOfEventLoopBarrier

protected

Definition at line 261 of file G4MTRunManager.hh.

G4int G4MTRunManager::eventModulo

protected

Definition at line 222 of file G4MTRunManager.hh.

G4int G4MTRunManager::eventModuloDef

protected

Definition at line 221 of file G4MTRunManager.hh.

WorkerActionRequest G4MTRunManager::nextActionRequest

protected

Definition at line 217 of file G4MTRunManager.hh.

G4MTBarrier G4MTRunManager::nextActionRequestBarrier

protected

Definition at line 262 of file G4MTRunManager.hh.

G4int G4MTRunManager::nSeedsFilled

protected

Definition at line 224 of file G4MTRunManager.hh.

G4int G4MTRunManager::nSeedsMax

protected

Definition at line 225 of file G4MTRunManager.hh.

G4int G4MTRunManager::nSeedsPerEvent

protected

Definition at line 226 of file G4MTRunManager.hh.

G4int G4MTRunManager::nSeedsUsed

protected

Definition at line 223 of file G4MTRunManager.hh.

G4int G4MTRunManager::numberOfEventToBeProcessed

protected

Definition at line 140 of file G4MTRunManager.hh.

G4MTBarrier G4MTRunManager::processUIBarrier

protected

Definition at line 263 of file G4MTRunManager.hh.

double* G4MTRunManager::randDbl

protected

Definition at line 227 of file G4MTRunManager.hh.

G4int G4MTRunManager::seedOncePerCommunication = 0

staticprotected

Definition at line 240 of file G4MTRunManager.hh.

---

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

• geant4.10.03.p01/source/run/include/G4MTRunManager.hh
• geant4.10.03.p01/source/run/src/G4MTRunManager.cc