#include <RunManagerMTWorker.h>

Classes
struct	TLSData

Public Member Functions
void	abortEvent ()

void	abortRun (bool softAbort=false)

void	Connect (RunAction *)

void	Connect (EventAction *)

void	Connect (TrackingAction *)

void	Connect (SteppingAction *)

void	endRun ()

SimTrackManager *	GetSimTrackManager ()

std::unique_ptr< G4SimEvent >	produce (const edm::Event &inpevt, const edm::EventSetup &es, RunManagerMT &runManagerMaster)

std::vector< std::shared_ptr< SimProducer > >	producers ()

	RunManagerMTWorker (const edm::ParameterSet &iConfig, edm::ConsumesCollector &&i)

std::vector< SensitiveCaloDetector * > &	sensCaloDetectors ()

std::vector< SensitiveTkDetector * > &	sensTkDetectors ()

G4SimEvent *	simEvent ()

	~RunManagerMTWorker ()

Private Member Functions
G4Event *	generateEvent (const edm::Event &inpevt)

void	initializeRun ()

void	initializeThread (RunManagerMT &runManagerMaster, const edm::EventSetup &es)

void	initializeTLS ()

void	initializeUserActions ()

void	resetGenParticleId (const edm::Event &inpevt)

void	terminateRun ()

Static Private Member Functions
static void	resetTLS ()

Static Private Attributes
static thread_local TLSData *	m_tls { 0 }

Detailed Description

Definition at line 40 of file RunManagerMTWorker.h.

Constructor & Destructor Documentation

RunManagerMTWorker::RunManagerMTWorker	(	const edm::ParameterSet &	iConfig,
		edm::ConsumesCollector &&	i
	)

explicit

Definition at line 150 of file RunManagerMTWorker.cc.

References edm::ParameterSet::getParameter(), initializeTLS(), and m_hasWatchers.

                                                                                                :
   m_generator(iConfig.getParameter<edm::ParameterSet>("Generator")),
   m_InToken(iC.consumes<edm::HepMCProduct>(iConfig.getParameter<edm::ParameterSet>("Generator").getParameter<edm::InputTag>("HepMCProductLabel"))),
   m_theLHCTlinkToken(iC.consumes<edm::LHCTransportLinkContainer>(iConfig.getParameter<edm::InputTag>("theLHCTlinkTag"))),
   m_nonBeam(iConfig.getParameter<bool>("NonBeamEvent")),
   m_pUseMagneticField(iConfig.getParameter<bool>("UseMagneticField")),
   m_EvtMgrVerbosity(iConfig.getUntrackedParameter<int>("G4EventManagerVerbosity",0)),
   m_pField(iConfig.getParameter<edm::ParameterSet>("MagneticField")),
   m_pRunAction(iConfig.getParameter<edm::ParameterSet>("RunAction")),
   m_pEventAction(iConfig.getParameter<edm::ParameterSet>("EventAction")),
   m_pStackingAction(iConfig.getParameter<edm::ParameterSet>("StackingAction")),
   m_pTrackingAction(iConfig.getParameter<edm::ParameterSet>("TrackingAction")),
   m_pSteppingAction(iConfig.getParameter<edm::ParameterSet>("SteppingAction")),
   m_pCustomUIsession(iConfig.getUntrackedParameter<edm::ParameterSet>("CustomUIsession")),
   m_p(iConfig),
   m_simEvent(nullptr),
   m_sVerbose(nullptr)
 {
   std::vector<edm::ParameterSet> watchers = 
     iConfig.getParameter<std::vector<edm::ParameterSet> >("Watchers");
   m_hasWatchers = (watchers.empty()) ? false : true;
   initializeTLS();
 }

RunManagerMTWorker::~RunManagerMTWorker ( )

Definition at line 174 of file RunManagerMTWorker.cc.

References m_tls, resetTLS(), RunManagerMTWorker::TLSData::runTerminated, alignCSCRings::s, and terminateRun().

                                         {
   if(m_tls && !m_tls->runTerminated) { terminateRun(); }
 
   ++n_tls_shutdown_task;
   resetTLS();
 
   {
     //make sure all tasks are done before continuing
     timespec s;
     s.tv_sec=0;
     s.tv_nsec=10000;
     while(n_tls_shutdown_task != 0) { nanosleep(&s,nullptr); }
   }
 }

Member Function Documentation

void RunManagerMTWorker::abortEvent ( )

Definition at line 545 of file RunManagerMTWorker.cc.

References RunManagerMTWorker::TLSData::currentEvent, RunManagerMTWorker::TLSData::kernel, m_tls, TrackingAction::PostUserTrackingAction(), RunManagerMTWorker::TLSData::runTerminated, and lumiQTWidget::t.

Referenced by SimRunInterface::abortEvent(), and abortRun().

                                     {
   if(m_tls->runTerminated) { return; }
   G4Track* t = m_tls->kernel->GetEventManager()->GetTrackingManager()->GetTrack();
   t->SetTrackStatus(fStopAndKill) ;
 
   // CMS-specific act
   //
   TrackingAction* uta =
     static_cast<TrackingAction *>(m_tls->kernel->GetEventManager()->GetUserTrackingAction());
   uta->PostUserTrackingAction(t) ;
 
   m_tls->currentEvent->SetEventAborted();
   m_tls->kernel->GetEventManager()->GetStackManager()->clear();
   m_tls->kernel->GetEventManager()->GetTrackingManager()->EventAborted();
 }

void RunManagerMTWorker::abortRun ( bool softAbort = false )

Definition at line 561 of file RunManagerMTWorker.cc.

References abortEvent(), RunManagerMTWorker::TLSData::currentRun, m_tls, and terminateRun().

Referenced by SimRunInterface::abortRun().

                                                 {
   if (!softAbort) { abortEvent(); }
   m_tls->currentRun = nullptr;
   terminateRun();
 }

void RunManagerMTWorker::Connect ( RunAction * runAction )

Definition at line 397 of file RunManagerMTWorker.cc.

References sim_act::Signaler< T >::connect(), RunAction::m_beginOfRunSignal, RunAction::m_endOfRunSignal, m_tls, and RunManagerMTWorker::TLSData::registry.

Referenced by SimRunInterface::Connect(), and initializeUserActions().

 {
   runAction->m_beginOfRunSignal.connect(m_tls->registry->beginOfRunSignal_);
   runAction->m_endOfRunSignal.connect(m_tls->registry->endOfRunSignal_);
 }

void RunManagerMTWorker::Connect ( EventAction * eventAction )

Definition at line 403 of file RunManagerMTWorker.cc.

References sim_act::Signaler< T >::connect(), EventAction::m_beginOfEventSignal, EventAction::m_endOfEventSignal, m_tls, and RunManagerMTWorker::TLSData::registry.

 {
   eventAction->m_beginOfEventSignal.connect(m_tls->registry->beginOfEventSignal_);
   eventAction->m_endOfEventSignal.connect(m_tls->registry->endOfEventSignal_);
 }

void RunManagerMTWorker::Connect ( TrackingAction * trackingAction )

Definition at line 409 of file RunManagerMTWorker.cc.

References sim_act::Signaler< T >::connect(), TrackingAction::m_beginOfTrackSignal, TrackingAction::m_endOfTrackSignal, m_tls, and RunManagerMTWorker::TLSData::registry.

 {
   trackingAction->m_beginOfTrackSignal.connect(m_tls->registry->beginOfTrackSignal_);
   trackingAction->m_endOfTrackSignal.connect(m_tls->registry->endOfTrackSignal_);
 }

void RunManagerMTWorker::Connect ( SteppingAction * steppingAction )

Definition at line 415 of file RunManagerMTWorker.cc.

References sim_act::Signaler< T >::connect(), SteppingAction::m_g4StepSignal, m_tls, and RunManagerMTWorker::TLSData::registry.

 {
   steppingAction->m_g4StepSignal.connect(m_tls->registry->g4StepSignal_);
 }

void RunManagerMTWorker::endRun ( )

Definition at line 215 of file RunManagerMTWorker.cc.

References terminateRun().

                                 {
   terminateRun();
 }

G4Event * RunManagerMTWorker::generateEvent ( const edm::Event & inpevt )

private

Definition at line 567 of file RunManagerMTWorker.cc.

References RunManagerMTWorker::TLSData::currentEvent, edm::EventID::event(), runTauDisplay::evtid, edm::Event::getByToken(), edm::HepMCProduct::GetEvent(), Generator::HepMC2G4(), edm::EventBase::id(), m_generator, m_InToken, m_nonBeam, m_simEvent, m_tls, Generator::nonBeamEvent2G4(), resetGenParticleId(), and Generator::setGenEvent().

Referenced by produce().

                                                                   {
   m_tls->currentEvent.reset();
   m_simEvent=nullptr;
 
   // 64 bits event ID in CMSSW converted into Geant4 event ID
   G4int evtid = (G4int)inpevt.id().event();
   G4Event * evt = new G4Event(evtid);
 
   edm::Handle<edm::HepMCProduct> HepMCEvt;
 
   inpevt.getByToken(m_InToken, HepMCEvt);
 
   m_generator.setGenEvent(HepMCEvt->GetEvent());
 
   // required to reset the GenParticle Id for particles transported
   // along the beam pipe
   // to their original value for SimTrack creation
   resetGenParticleId( inpevt );
 
   if (!m_nonBeam) 
     {
       m_generator.HepMC2G4(HepMCEvt->GetEvent(),evt);
     }
   else 
     {
       m_generator.nonBeamEvent2G4(HepMCEvt->GetEvent(),evt);
     }
 
   return evt;
 }

SimTrackManager * RunManagerMTWorker::GetSimTrackManager ( )

Definition at line 420 of file RunManagerMTWorker.cc.

References initializeTLS(), m_tls, and RunManagerMTWorker::TLSData::trackManager.

Referenced by SimRunInterface::SimRunInterface().

                                                         {
   initializeTLS();
   return m_tls->trackManager.get();
 }

void RunManagerMTWorker::initializeRun ( )

private

Definition at line 437 of file RunManagerMTWorker.cc.

References RunManagerMTWorker::TLSData::currentRun, m_tls, and RunManagerMTWorker::TLSData::userRunAction.

Referenced by produce().

                                        {
   m_tls->currentRun = new G4Run();
   G4StateManager::GetStateManager()->SetNewState(G4State_GeomClosed);
   if (m_tls->userRunAction) { m_tls->userRunAction->BeginOfRunAction(m_tls->currentRun); }
 }

void RunManagerMTWorker::initializeThread	(	RunManagerMT &	runManagerMaster,
		const edm::EventSetup &	es
	)

private

Definition at line 240 of file RunManagerMTWorker.cc.

References RunManagerMT::catalog(), mps_check::command, edm::errors::Configuration, AttachSD::create(), g4SimHits_cfi::CustomUIsession, Exception, g, RunManagerMT::G4Commands(), ecalTB2006H4_GenSimDigiReco_cfg::G4cout, edm::EventSetup::get(), edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameter(), DDDWorld::GetWorldVolumeForWorker(), GeV, initializeTLS(), initializeUserActions(), RunManagerMTWorker::TLSData::kernel, m_p, m_pCustomUIsession, m_pField, m_pUseMagneticField, m_sVerbose, m_tls, RunManagerMT::physicsListForWorker(), edm::ESHandle< T >::product(), RunManagerMTWorker::TLSData::registry, RunManagerMTWorker::TLSData::sensCaloDets, RunManagerMTWorker::TLSData::sensTkDets, AlCaHLTBitMon_QueryRunRegistry::string, pfDeepBoostedJetPreprocessParams_cfi::sv, RunManagerMTWorker::TLSData::trackManager, RunManagerMTWorker::TLSData::UIsession, DDDWorld::WorkerSetAsWorld(), and RunManagerMT::world().

Referenced by produce().

                                                                                                  {
   // I guess everything initialized here should be in thread_local storage
   initializeTLS();
 
   int thisID = getThreadIndex();
 
   edm::LogVerbatim("SimG4CoreApplication")
     << "RunManagerMTWorker::initializeThread " << thisID;
 
   // Initialize per-thread output
   G4Threading::G4SetThreadId( thisID );
   G4UImanager::GetUIpointer()->SetUpForAThread( thisID );
   const std::string& uitype = m_pCustomUIsession.getUntrackedParameter<std::string>("Type");
   if(uitype == "MessageLogger") {
     m_tls->UIsession.reset(new CustomUIsession());
   }
   else if(uitype == "MessageLoggerThreadPrefix") {
     m_tls->UIsession.reset(new CustomUIsessionThreadPrefix(m_pCustomUIsession.getUntrackedParameter<std::string>("ThreadPrefix"), thisID));
   }
   else if(uitype == "FilePerThread") {
     m_tls->UIsession.reset(new CustomUIsessionToFile(m_pCustomUIsession.getUntrackedParameter<std::string>("ThreadFile"), thisID));
   }
   else {
     throw edm::Exception(edm::errors::Configuration) 
       << "Invalid value of CustomUIsession.Type '" << uitype 
       << "', valid are MessageLogger, MessageLoggerThreadPrefix, FilePerThread";
   }
 
   // Initialize worker part of shared resources (geometry, physics)
   G4WorkerThread::BuildGeometryAndPhysicsVector();
 
   // Create worker run manager
   m_tls->kernel.reset(G4WorkerRunManagerKernel::GetRunManagerKernel());
   if(!m_tls->kernel) { m_tls->kernel.reset(new G4WorkerRunManagerKernel()); }
 
   // Define G4 exception handler
   G4StateManager::GetStateManager()->SetExceptionHandler(new ExceptionHandler());
 
   // Set the geometry for the worker, share from master
   DDDWorld::WorkerSetAsWorld(runManagerMaster.world().GetWorldVolumeForWorker());
 
   // we need the track manager now
   m_tls->trackManager.reset(new SimTrackManager());
 
   // Get DDCompactView, or would it be better to get the object from
   // runManagerMaster instead of EventSetup in here?
   edm::ESTransientHandle<DDCompactView> pDD;
   es.get<IdealGeometryRecord>().get(pDD);
 
   // setup the magnetic field
   if (m_pUseMagneticField)
     {
       const GlobalPoint g(0.,0.,0.);
 
       edm::ESHandle<MagneticField> pMF;
       es.get<IdealMagneticFieldRecord>().get(pMF);
 
       sim::FieldBuilder fieldBuilder(pMF.product(), m_pField);
       CMSFieldManager* fieldManager = new CMSFieldManager();
       G4TransportationManager * tM =
     G4TransportationManager::GetTransportationManager();
       tM->SetFieldManager(fieldManager);
       fieldBuilder.build( fieldManager, tM->GetPropagatorInField());
     }
 
   // attach sensitive detector
   AttachSD attach;
   auto  sensDets =
     attach.create(*pDD, runManagerMaster.catalog(), m_p,
                   m_tls->trackManager.get(),
                   *(m_tls->registry.get()));
 
   m_tls->sensTkDets.swap(sensDets.first);
   m_tls->sensCaloDets.swap(sensDets.second);
 
   edm::LogVerbatim("SimG4CoreApplication")
     << " RunManagerMTWorker: Sensitive Detector building finished; found "
     << m_tls->sensTkDets.size() << " Tk type Producers, and "
     << m_tls->sensCaloDets.size() << " Calo type producers ";
 
   // Set the physics list for the worker, share from master
   PhysicsList *physicsList = runManagerMaster.physicsListForWorker();
 
   edm::LogVerbatim("SimG4CoreApplication") 
     << "RunManagerMTWorker: start initialisation of PhysicsList for the thread";
 
   // Geant4 UI commands in PreInit state
   if(!runManagerMaster.G4Commands().empty()) {
     G4cout << "RunManagerMTWorker: Requested UI commands: " << G4endl;
     for(const std::string& command: runManagerMaster.G4Commands()) {
       G4cout << "          " << command << G4endl;
       G4UImanager::GetUIpointer()->ApplyCommand(command);
     }
   }
   G4StateManager::GetStateManager()->SetNewState(G4State_Init);
 
   physicsList->InitializeWorker();
   m_tls->kernel->SetPhysics(physicsList);
   m_tls->kernel->InitializePhysics();
 
   const bool kernelInit = m_tls->kernel->RunInitialization();
   if(!kernelInit) {
     throw edm::Exception(edm::errors::Configuration)
       << "RunManagerMTWorker: Geant4 kernel initialization failed";
   }
   //tell all interesting parties that we are beginning the job
   BeginOfJob aBeginOfJob(&es);
   m_tls->registry->beginOfJobSignal_(&aBeginOfJob);
 
   G4int sv = m_p.getParameter<int>("SteppingVerbosity");
   G4double elim = m_p.getParameter<double>("StepVerboseThreshold")*CLHEP::GeV;
   std::vector<int> ve = m_p.getParameter<std::vector<int> >("VerboseEvents");
   std::vector<int> vn = m_p.getParameter<std::vector<int> >("VertexNumber");
   std::vector<int> vt = m_p.getParameter<std::vector<int> >("VerboseTracks");
 
   if(sv > 0) {
     m_sVerbose.reset(new CMSSteppingVerbose(sv, elim, ve, vn, vt));
   }
   initializeUserActions();
 
   edm::LogVerbatim("SimG4CoreApplication")
     << "RunManagerMTWorker::initializeThread done for the thread " << thisID;
 
   G4StateManager::GetStateManager()->SetNewState(G4State_Idle);
 }

void RunManagerMTWorker::initializeTLS ( )

private

Definition at line 219 of file RunManagerMTWorker.cc.

References edm::errors::Configuration, createWatchers(), Exception, m_hasWatchers, m_p, m_tls, RunManagerMTWorker::TLSData::producers, RunManagerMTWorker::TLSData::registry, and RunManagerMTWorker::TLSData::watchers.

Referenced by GetSimTrackManager(), initializeThread(), producers(), RunManagerMTWorker(), sensCaloDetectors(), and sensTkDetectors().

                                        {
   if(m_tls) { return; }
   
   m_tls = new TLSData() ;
   m_tls->registry.reset(new SimActivityRegistry());
 
   edm::Service<SimActivityRegistry> otherRegistry;
   //Look for an outside SimActivityRegistry
   // this is used by the visualization code
   int thisID = getThreadIndex();
   if(otherRegistry){
     m_tls->registry->connect(*otherRegistry);
     if(thisID > 0) {
       throw edm::Exception(edm::errors::Configuration) << "SimActivityRegistry service (i.e. visualization) is not supported for more than 1 thread. If this use case is needed, RunManagerMTWorker has to be updated.";
     }
   }
   if(m_hasWatchers) {
     createWatchers(m_p, m_tls->registry.get(), m_tls->watchers, m_tls->producers, thisID);
   }
 }

void RunManagerMTWorker::initializeUserActions ( )

private

Definition at line 366 of file RunManagerMTWorker.cc.

References Connect(), g4SimHits_cfi::EventAction, RunManagerMTWorker::TLSData::kernel, m_EvtMgrVerbosity, m_hasWatchers, m_pEventAction, m_pRunAction, m_pStackingAction, m_pSteppingAction, m_pTrackingAction, m_sVerbose, m_tls, g4SimHits_cfi::RunAction, RunManagerMTWorker::TLSData::runInterface, CastorDigiValidation::StackingAction, CastorDigiValidation::SteppingAction, g4SimHits_cfi::TrackingAction, RunManagerMTWorker::TLSData::trackManager, and RunManagerMTWorker::TLSData::userRunAction.

Referenced by initializeThread().

                                                {
   m_tls->runInterface.reset(new SimRunInterface(this, false));
   m_tls->userRunAction.reset(new RunAction(m_pRunAction, 
                        m_tls->runInterface.get(),false));
   m_tls->userRunAction->SetMaster(false);
   Connect(m_tls->userRunAction.get());
 
   G4EventManager * eventManager = m_tls->kernel->GetEventManager();
   eventManager->SetVerboseLevel(m_EvtMgrVerbosity);
 
   EventAction * userEventAction =
     new EventAction(m_pEventAction, m_tls->runInterface.get(), 
             m_tls->trackManager.get(), m_sVerbose.get());
   Connect(userEventAction);
   eventManager->SetUserAction(userEventAction);
 
   TrackingAction* userTrackingAction =
     new TrackingAction(userEventAction, m_pTrackingAction, m_sVerbose.get());
   Connect(userTrackingAction);
   eventManager->SetUserAction(userTrackingAction);
 
   SteppingAction* userSteppingAction =
     new SteppingAction(userEventAction,m_pSteppingAction,m_sVerbose.get(),m_hasWatchers); 
   Connect(userSteppingAction);
   eventManager->SetUserAction(userSteppingAction);
 
   eventManager->SetUserAction(new StackingAction(userTrackingAction,
                          m_pStackingAction,m_sVerbose.get()));
 
 }

std::unique_ptr< G4SimEvent > RunManagerMTWorker::produce	(	const edm::Event &	inpevt,
		const edm::EventSetup &	es,
		RunManagerMT &	runManagerMaster
	)

Definition at line 460 of file RunManagerMTWorker.cc.

References RunManagerMTWorker::TLSData::currentEvent, RunManagerMTWorker::TLSData::currentRunNumber, edm::EventID::event(), Generator::eventWeight(), generateEvent(), Generator::genEvent(), Generator::genVertex(), G4SimEvent::hepEvent(), edm::EventBase::id(), initializeRun(), initializeThread(), RunManagerMTWorker::TLSData::kernel, LogDebug, m_generator, m_simEvent, m_tls, nullptr, edm::EventID::run(), RunManagerMTWorker::TLSData::runInterface, RunManagerMTWorker::TLSData::runTerminated, sd, edm::second(), RunManagerMTWorker::TLSData::sensCaloDets, simEvent(), edm::Event::streamID(), terminateRun(), and RunManagerMTWorker::TLSData::threadInitialized.

                                                             {
   // The initialization and begin/end run is a bit convoluted due to
   // - Geant4 deals per-thread
   // - OscarMTProducer deals per-stream
   // and framework/TBB is free to schedule work in streams to the
   // threads as it likes.
   //
   // We have to do the per-thread initialization, and per-thread
   // per-run initialization here by ourselves. 
 
   if(!(m_tls && m_tls->threadInitialized)) {
     LogDebug("SimG4CoreApplication") 
       << "RunManagerMTWorker::produce(): stream " 
       << inpevt.streamID() << " thread " << getThreadIndex() << " initializing";
     initializeThread(runManagerMaster, es);
     m_tls->threadInitialized = true;
   }
   // Initialize run
   if(inpevt.id().run() != m_tls->currentRunNumber) {
     if(m_tls->currentRunNumber != 0 && !m_tls->runTerminated) {
       // If previous run in this thread was not terminated via endRun() call, terminate it now
       terminateRun();
     }
     initializeRun();
     m_tls->currentRunNumber = inpevt.id().run();
   }
   m_tls->runInterface->setRunManagerMTWorker(this); // For UserActions
 
   m_tls->currentEvent.reset(generateEvent(inpevt));
 
   auto simEvent =std::make_unique<G4SimEvent>();
   m_simEvent = simEvent.get();
   m_simEvent->hepEvent(m_generator.genEvent());
   m_simEvent->weight(m_generator.eventWeight());
   if (m_generator.genVertex() != nullptr ) {
     auto genVertex = m_generator.genVertex();
     m_simEvent->collisionPoint(
       math::XYZTLorentzVectorD(genVertex->x()/centimeter,
                    genVertex->y()/centimeter,
                    genVertex->z()/centimeter,
                    genVertex->t()/second));
   }
   if (m_tls->currentEvent->GetNumberOfPrimaryVertex()==0) {
     std::stringstream ss;
     ss << "RunManagerMTWorker::produce(): event " << inpevt.id().event()
        << " with no G4PrimaryVertices \n" ;
     throw SimG4Exception(ss.str());
 
   } else {
     if(!m_tls->kernel) {
       std::stringstream ss;
       ss << " RunManagerMT::produce(): "
      << " no G4WorkerRunManagerKernel yet for thread index" 
      << getThreadIndex() << ", id " << std::hex 
      << std::this_thread::get_id() << " \n";
       throw SimG4Exception(ss.str());
     }
 
     edm::LogVerbatim("SimG4CoreApplication")
       << " RunManagerMTWorker::produce: start Event " << inpevt.id().event() 
       << " stream id " << inpevt.streamID()
       << " thread index " << getThreadIndex()
       << " of weight " << m_simEvent->weight()
       << " with " << m_simEvent->nTracks() << " tracks and " 
       << m_simEvent->nVertices()
       << " vertices, generated by " << m_simEvent->nGenParts() << " particles ";
 
     m_tls->kernel->GetEventManager()->ProcessOneEvent(m_tls->currentEvent.get());
 
     edm::LogVerbatim("SimG4CoreApplication")
       << " RunManagerMTWorker::produce: ended Event " << inpevt.id().event(); 
   } 
 
   //remove memory only needed during event processing
   m_tls->currentEvent.reset();
 
   for(auto& sd: m_tls->sensCaloDets ) {
     sd->reset();
   }
 
   m_simEvent=nullptr;
   return simEvent;
 }

std::vector< std::shared_ptr< SimProducer > > RunManagerMTWorker::producers ( )

Definition at line 432 of file RunManagerMTWorker.cc.

References initializeTLS(), m_tls, and RunManagerMTWorker::TLSData::producers.

                                                                      {
   initializeTLS();
   return m_tls->producers;
 }

void RunManagerMTWorker::resetGenParticleId ( const edm::Event & inpevt )

private

Definition at line 598 of file RunManagerMTWorker.cc.

References edm::Event::getByToken(), edm::HandleBase::isValid(), m_theLHCTlinkToken, m_tls, edm::Handle< T >::product(), and RunManagerMTWorker::TLSData::trackManager.

Referenced by generateEvent().

 {
   edm::Handle<edm::LHCTransportLinkContainer> theLHCTlink;
   inpevt.getByToken( m_theLHCTlinkToken, theLHCTlink );
   if ( theLHCTlink.isValid() ) {
     m_tls->trackManager->setLHCTransportLink( theLHCTlink.product() );
   }
 }

void RunManagerMTWorker::resetTLS ( )

staticprivate

Definition at line 189 of file RunManagerMTWorker.cc.

References KineDebug3::count(), m_tls, edm::make_functor_task(), alignCSCRings::s, and TrackValidation_cff::task.

Referenced by ~RunManagerMTWorker().

                                   {
   delete m_tls;
   m_tls=nullptr;
 
   if(active_tlsdata != 0 and not tls_shutdown_timeout) {
     ++n_tls_shutdown_task;
     //need to run tasks on each thread which has set the tls
     auto task = edm::make_functor_task(tbb::task::allocate_root(), [] () {
         resetTLS();
       });
     tbb::task::enqueue(*task);
     timespec s;
     s.tv_sec=0;
     s.tv_nsec=10000;
     //we do not want this thread to be used for a new task since it
     // has already cleared its structures. In order to fill all TBB
     // threads we wait for all TLSes to clear
     int count = 0;
     while(active_tlsdata.load() != 0 and ++count < 1000) { nanosleep(&s,nullptr);}
     if(count >= 1000) {
       tls_shutdown_timeout=true;
     }
   }
   --n_tls_shutdown_task;
 }

std::vector< SensitiveCaloDetector * > & RunManagerMTWorker::sensCaloDetectors ( )

Definition at line 428 of file RunManagerMTWorker.cc.

References initializeTLS(), m_tls, and RunManagerMTWorker::TLSData::sensCaloDets.

                                                                          {
   initializeTLS();
   return m_tls->sensCaloDets; 
 }

std::vector< SensitiveTkDetector * > & RunManagerMTWorker::sensTkDetectors ( )

Definition at line 424 of file RunManagerMTWorker.cc.

References initializeTLS(), m_tls, and RunManagerMTWorker::TLSData::sensTkDets.

                                                                      {
   initializeTLS();
   return m_tls->sensTkDets; 
 }

G4SimEvent* RunManagerMTWorker::simEvent ( )

inline

Definition at line 53 of file RunManagerMTWorker.h.

References particleFlowRecHitECAL_cfi::producers.

Referenced by produce(), and SimRunInterface::simEvent().

53 { return m_simEvent; }

RunManagerMTWorker::m_simEvent

G4SimEvent * m_simEvent

Definition: RunManagerMTWorker.h:99

void RunManagerMTWorker::terminateRun ( )

private

Definition at line 443 of file RunManagerMTWorker.cc.

References RunManagerMTWorker::TLSData::currentEvent, RunManagerMTWorker::TLSData::currentRun, RunManagerMTWorker::TLSData::kernel, m_simEvent, m_tls, RunManagerMTWorker::TLSData::runTerminated, and RunManagerMTWorker::TLSData::userRunAction.

Referenced by abortRun(), endRun(), RunManagerMT::physicsListForWorker(), produce(), and ~RunManagerMTWorker().

                                       {
   if(!m_tls || m_tls->runTerminated) { return; }
   if(m_tls->userRunAction) {
     m_tls->userRunAction->EndOfRunAction(m_tls->currentRun);
     m_tls->userRunAction.reset();
   }
   m_tls->currentEvent.reset();
   m_simEvent=nullptr;
 
   if(m_tls->kernel) {
     m_tls->kernel->RunTermination();
   }
 
   m_tls->runTerminated = true;
 }

Member Data Documentation

int RunManagerMTWorker::m_EvtMgrVerbosity

private

Definition at line 84 of file RunManagerMTWorker.h.

Referenced by initializeUserActions().

Generator RunManagerMTWorker::m_generator

private

Definition at line 77 of file RunManagerMTWorker.h.

Referenced by generateEvent(), and produce().

bool RunManagerMTWorker::m_hasWatchers

private

Definition at line 83 of file RunManagerMTWorker.h.

Referenced by initializeTLS(), initializeUserActions(), and RunManagerMTWorker().

edm::EDGetTokenT<edm::HepMCProduct> RunManagerMTWorker::m_InToken

private

Definition at line 78 of file RunManagerMTWorker.h.

Referenced by generateEvent().

bool RunManagerMTWorker::m_nonBeam

private

Definition at line 81 of file RunManagerMTWorker.h.

Referenced by generateEvent().

edm::ParameterSet RunManagerMTWorker::m_p

private

Definition at line 93 of file RunManagerMTWorker.h.

Referenced by initializeThread(), and initializeTLS().

edm::ParameterSet RunManagerMTWorker::m_pCustomUIsession

private

Definition at line 92 of file RunManagerMTWorker.h.

Referenced by initializeThread().

edm::ParameterSet RunManagerMTWorker::m_pEventAction

private

Definition at line 88 of file RunManagerMTWorker.h.

Referenced by initializeUserActions().

edm::ParameterSet RunManagerMTWorker::m_pField

private

Definition at line 86 of file RunManagerMTWorker.h.

Referenced by initializeThread().

edm::ParameterSet RunManagerMTWorker::m_pRunAction

private

Definition at line 87 of file RunManagerMTWorker.h.

Referenced by initializeUserActions().

edm::ParameterSet RunManagerMTWorker::m_pStackingAction

private

Definition at line 89 of file RunManagerMTWorker.h.

Referenced by initializeUserActions().

edm::ParameterSet RunManagerMTWorker::m_pSteppingAction

private

Definition at line 91 of file RunManagerMTWorker.h.

Referenced by initializeUserActions().

edm::ParameterSet RunManagerMTWorker::m_pTrackingAction

private

Definition at line 90 of file RunManagerMTWorker.h.

Referenced by initializeUserActions().

bool RunManagerMTWorker::m_pUseMagneticField

private

Definition at line 82 of file RunManagerMTWorker.h.

Referenced by initializeThread().

G4SimEvent* RunManagerMTWorker::m_simEvent

private

Definition at line 99 of file RunManagerMTWorker.h.

Referenced by generateEvent(), produce(), and terminateRun().

std::unique_ptr<CMSSteppingVerbose> RunManagerMTWorker::m_sVerbose

private

Definition at line 100 of file RunManagerMTWorker.h.

Referenced by initializeThread(), and initializeUserActions().

edm::EDGetTokenT<edm::LHCTransportLinkContainer> RunManagerMTWorker::m_theLHCTlinkToken

private

Definition at line 79 of file RunManagerMTWorker.h.

Referenced by resetGenParticleId().

thread_local RunManagerMTWorker::TLSData * RunManagerMTWorker::m_tls { 0 }

staticprivate

Definition at line 95 of file RunManagerMTWorker.h.

Referenced by abortEvent(), abortRun(), Connect(), generateEvent(), GetSimTrackManager(), initializeRun(), initializeThread(), initializeTLS(), initializeUserActions(), produce(), producers(), resetGenParticleId(), resetTLS(), sensCaloDetectors(), sensTkDetectors(), terminateRun(), ~RunManagerMTWorker(), and RunManagerMTWorker::TLSData::~TLSData().

Private Attributes
int	m_EvtMgrVerbosity

Generator	m_generator

bool	m_hasWatchers

edm::EDGetTokenT< edm::HepMCProduct >	m_InToken

bool	m_nonBeam

edm::ParameterSet	m_p

edm::ParameterSet	m_pCustomUIsession

edm::ParameterSet	m_pEventAction

edm::ParameterSet	m_pField

edm::ParameterSet	m_pRunAction

edm::ParameterSet	m_pStackingAction

edm::ParameterSet	m_pSteppingAction

edm::ParameterSet	m_pTrackingAction

bool	m_pUseMagneticField

G4SimEvent *	m_simEvent

std::unique_ptr< CMSSteppingVerbose >	m_sVerbose

edm::EDGetTokenT< edm::LHCTransportLinkContainer >	m_theLHCTlinkToken

Classes

Public Member Functions

Private Member Functions

Static Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation