#include <SubProcess.h>

Public Member Functions
void	clearCounters ()
	Clear all the counters in the trigger report. More...

void	closeOutputFiles ()

void	deleteLumiFromCache (ProcessHistoryID const &parentPhID, int runNumber, int lumiNumber)

void	deleteRunFromCache (ProcessHistoryID const &parentPhID, int runNumber)

void	doBeginJob ()

void	doBeginLuminosityBlock (LuminosityBlockPrincipal const &principal, IOVSyncValue const &ts)

void	doBeginRun (RunPrincipal const &principal, IOVSyncValue const &ts)

void	doBeginStream (unsigned int)

void	doEndJob ()

void	doEndLuminosityBlock (LuminosityBlockPrincipal const &principal, IOVSyncValue const &ts, bool cleaningUpAfterException)

void	doEndRun (RunPrincipal const &principal, IOVSyncValue const &ts, bool cleaningUpAfterException)

void	doEndStream (unsigned int)

void	doEvent (EventPrincipal const &principal)

void	doStreamBeginLuminosityBlock (unsigned int iID, LuminosityBlockPrincipal const &principal, IOVSyncValue const &ts)

void	doStreamBeginRun (unsigned int iID, RunPrincipal const &principal, IOVSyncValue const &ts)

void	doStreamEndLuminosityBlock (unsigned int iID, LuminosityBlockPrincipal const &principal, IOVSyncValue const &ts, bool cleaningUpAfterException)

void	doStreamEndRun (unsigned int iID, RunPrincipal const &principal, IOVSyncValue const &ts, bool cleaningUpAfterException)

void	enableEndPaths (bool active)

bool	endPathsEnabled () const
	Return true if end_paths are active, and false if they are inactive. More...

std::vector< ModuleDescription const * >	getAllModuleDescriptions () const
	Return a vector allowing const access to all the ModuleDescriptions for this SubProcess. More...

void	getTriggerReport (TriggerReport &rep) const

SelectedProductsForBranchType const &	keptProducts () const

void	openNewOutputFilesIfNeeded ()

void	openOutputFiles (FileBlock &fb)

SubProcess &	operator= (SubProcess const &)=delete

void	postForkReacquireResources (unsigned int iChildIndex, unsigned int iNumberOfChildren)

void	preForkReleaseResources ()

void	respondToCloseInputFile (FileBlock const &fb)

void	respondToOpenInputFile (FileBlock const &fb)

void	selectProducts (ProductRegistry const &preg)

bool	shouldWeCloseOutput () const

	SubProcess (ParameterSet &parameterSet, ParameterSet const &topLevelParameterSet, boost::shared_ptr< ProductRegistry const > parentProductRegistry, boost::shared_ptr< BranchIDListHelper const > parentBranchIDListHelper, eventsetup::EventSetupsController &esController, ActivityRegistry &parentActReg, ServiceToken const &token, serviceregistry::ServiceLegacy iLegacy, PreallocationConfiguration const &preallocConfig, ProcessContext const *parentProcessContext)

	SubProcess (SubProcess const &)=delete

bool	terminate () const

int	totalEvents () const

int	totalEventsFailed () const

int	totalEventsPassed () const
	Return the number of events which have been passed by one or more trigger paths. More...

void	updateBranchIDListHelper (BranchIDLists const &)

void	writeLumi (ProcessHistoryID const &parentPhID, int runNumber, int lumiNumber)

void	writeRun (ProcessHistoryID const &parentPhID, int runNumber)

virtual	~SubProcess ()

Private Member Functions
void	beginJob ()

void	beginLuminosityBlock (LuminosityBlockPrincipal const &lb, IOVSyncValue const &ts)

void	beginRun (RunPrincipal const &r, IOVSyncValue const &ts)

std::map< BranchID::value_type, BranchID::value_type > const &	droppedBranchIDToKeptBranchID ()

void	endJob ()

void	endLuminosityBlock (LuminosityBlockPrincipal const &lb, IOVSyncValue const &ts, bool cleaningUpAfterException)

void	endRun (RunPrincipal const &r, IOVSyncValue const &ts, bool cleaningUpAfterException)

void	fixBranchIDListsForEDAliases (std::map< BranchID::value_type, BranchID::value_type > const &droppedBranchIDToKeptBranchID)

void	process (EventPrincipal const &e)

void	propagateProducts (BranchType type, Principal const &parentPrincipal, Principal &principal) const

Private Attributes
std::unique_ptr < ExceptionToActionTable const >	act_table_

boost::shared_ptr < BranchIDListHelper >	branchIDListHelper_

std::map< BranchID::value_type, BranchID::value_type >	droppedBranchIDToKeptBranchID_

boost::shared_ptr < eventsetup::EventSetupProvider >	esp_

std::vector< HistoryAppender >	historyAppenders_

unsigned int	historyLumiOffset_

unsigned int	historyRunOffset_

SelectedProductsForBranchType	keptProducts_

boost::shared_ptr < ProductRegistry const >	parentPreg_

std::map< ProcessHistoryID, ProcessHistoryID >	parentToChildPhID_

boost::shared_ptr < ProductRegistry const >	preg_

PrincipalCache	principalCache_

boost::shared_ptr < ProcessConfiguration const >	processConfiguration_

ProcessContext	processContext_

std::vector < ProcessHistoryRegistry >	processHistoryRegistries_

std::unique_ptr< ParameterSet >	processParameterSet_

ProductSelector	productSelector_

ProductSelectorRules	productSelectorRules_

std::auto_ptr< Schedule >	schedule_

ParameterSetID	selector_config_id_

detail::TriggerResultsBasedEventSelector	selectors_

ServiceToken	serviceToken_

std::auto_ptr< SubProcess >	subProcess_

bool	wantAllEvents_

Detailed Description

Definition at line 35 of file SubProcess.h.

Constructor & Destructor Documentation

edm::SubProcess::SubProcess	(	ParameterSet &	parameterSet,
		ParameterSet const &	topLevelParameterSet,
		boost::shared_ptr< ProductRegistry const >	parentProductRegistry,
		boost::shared_ptr< BranchIDListHelper const >	parentBranchIDListHelper,
		eventsetup::EventSetupsController &	esController,
		ActivityRegistry &	parentActReg,
		ServiceToken const &	token,
		serviceregistry::ServiceLegacy	iLegacy,
		PreallocationConfiguration const &	preallocConfig,
		ProcessContext const *	parentProcessContext
	)

Definition at line 35 of file SubProcess.cc.

References act_table_, branchIDListHelper_, edm::detail::configureEventSelector(), edm::ActivityRegistry::connectToSubProcess(), esp_, edm::ParameterSet::exists(), edm::getAllTriggerNames(), edm::ParameterSet::getUntrackedParameterSet(), historyAppenders_, historyRunOffset_, cmsHarvester::index, edm::PrincipalCache::insert(), edm::eventsetup::EventSetupsController::makeProvider(), LaserTracksInput_cfi::maxEvents, edm::PreallocationConfiguration::numberOfStreams(), cmsPerfStripChart::operate(), edm::ParameterSet::popParameterSet(), edm::popSubProcessParameterSet(), preg_, principalCache_, processConfiguration_, processContext_, processHistoryRegistries_, processParameterSet_, edm::ParameterSet::registerIt(), edm::detail::registerProperSelectionInfo(), schedule_, selector_config_id_, selectors_, selectProducts(), serviceToken_, edm::PrincipalCache::setNumberOfConcurrentPrincipals(), edm::ProcessContext::setParentProcessContext(), edm::ProcessContext::setProcessConfiguration(), edm::PrincipalCache::setProcessHistoryRegistry(), edm::IllegalParameters::setThrowAnException(), AlCaHLTBitMon_QueryRunRegistry::string, subProcess_, updateBranchIDListHelper(), and wantAllEvents_.

                                                                      :
       serviceToken_(),
       parentPreg_(parentProductRegistry),
       preg_(),
       branchIDListHelper_(),
       act_table_(),
       processConfiguration_(),
       historyLumiOffset_(preallocConfig.numberOfStreams()),
       historyRunOffset_(historyLumiOffset_+preallocConfig.numberOfLuminosityBlocks()),
       processHistoryRegistries_(historyRunOffset_+ preallocConfig.numberOfRuns()),
       historyAppenders_(historyRunOffset_+preallocConfig.numberOfRuns()),
       principalCache_(),
       esp_(),
       schedule_(),
       parentToChildPhID_(),
       subProcess_(),
       processParameterSet_(),
       productSelectorRules_(parameterSet, "outputCommands", "OutputModule"),
       productSelector_(),
       wantAllEvents_(true) {
   
     //Setup the event selection
     Service<service::TriggerNamesService> tns;
     
     ParameterSet selectevents =
     parameterSet.getUntrackedParameterSet("SelectEvents", ParameterSet());
     
     selectevents.registerIt(); // Just in case this PSet is not registered
     wantAllEvents_ = detail::configureEventSelector(selectevents,
                                                     tns->getProcessName(),
                                                     getAllTriggerNames(),
                                                     selectors_);
     std::map<std::string, std::vector<std::pair<std::string, int> > > outputModulePathPositions;
     selector_config_id_ = detail::registerProperSelectionInfo(selectevents,
                                                               "",
                                                               outputModulePathPositions,
                                                               parentProductRegistry->anyProductProduced());
     selectProducts(*parentProductRegistry);
 
     std::string const maxEvents("maxEvents");
     std::string const maxLumis("maxLuminosityBlocks");
 
     processParameterSet_.reset(parameterSet.popParameterSet(std::string("process")).release()); 
 
     // if this process has a maxEvents or maxLuminosityBlocks parameter set, remove them.
     if(processParameterSet_->exists(maxEvents)) {
       processParameterSet_->popParameterSet(maxEvents);
     }
     if(processParameterSet_->exists(maxLumis)) {
       processParameterSet_->popParameterSet(maxLumis);
     }
 
     // if the top level process has a maxEvents or maxLuminosityBlocks parameter set, add them to this process.
     if(topLevelParameterSet.exists(maxEvents)) {
       processParameterSet_->addUntrackedParameter<ParameterSet>(maxEvents, topLevelParameterSet.getUntrackedParameterSet(maxEvents));
     }
     if(topLevelParameterSet.exists(maxLumis)) {
       processParameterSet_->addUntrackedParameter<ParameterSet>(maxLumis, topLevelParameterSet.getUntrackedParameterSet(maxLumis));
     }
 
     // If this process has a subprocess, pop the subprocess parameter set out of the process parameter set
 
     boost::shared_ptr<ParameterSet> subProcessParameterSet(popSubProcessParameterSet(*processParameterSet_).release());
   
     ScheduleItems items(*parentProductRegistry, *this);
 
     ParameterSet const& optionsPset(processParameterSet_->getUntrackedParameterSet("options", ParameterSet()));
     IllegalParameters::setThrowAnException(optionsPset.getUntrackedParameter<bool>("throwIfIllegalParameter", true));
 
     //initialize the services
     ServiceToken iToken;
 
     // get any configured services.
     std::auto_ptr<std::vector<ParameterSet> > serviceSets = processParameterSet_->popVParameterSet(std::string("services")); 
 
     ServiceToken newToken = items.initServices(*serviceSets, *processParameterSet_, token, iLegacy, false);
     parentActReg.connectToSubProcess(*items.actReg_);
     serviceToken_ = items.addCPRandTNS(*processParameterSet_, newToken);
 
 
     //make the services available
     ServiceRegistry::Operate operate(serviceToken_);
 
     // intialize miscellaneous items
     items.initMisc(*processParameterSet_);
 
     // intialize the event setup provider
     esp_ = esController.makeProvider(*processParameterSet_);
 
     branchIDListHelper_ = items.branchIDListHelper_;
     updateBranchIDListHelper(parentBranchIDListHelper->branchIDLists());
 
     // intialize the Schedule
     schedule_ = items.initSchedule(*processParameterSet_,subProcessParameterSet.get(),preallocConfig,&processContext_);
 
     // set the items
     act_table_ = std::move(items.act_table_);
     preg_.reset(items.preg_.release());
     //CMS-THREADING this only works since Run/Lumis are synchronous so when principalCache asks for
     // the reducedProcessHistoryID from a full ProcessHistoryID that registry will not be in use by
     // another thread. We really need to change how this is done in the PrincipalCache.
     principalCache_.setProcessHistoryRegistry(processHistoryRegistries_[historyRunOffset_]);
 
 
     processConfiguration_ = items.processConfiguration_;
     processContext_.setProcessConfiguration(processConfiguration_.get());
     processContext_.setParentProcessContext(parentProcessContext);
 
     principalCache_.setNumberOfConcurrentPrincipals(preallocConfig);
     for(unsigned int index = 0; index < preallocConfig.numberOfStreams(); ++index) {
       boost::shared_ptr<EventPrincipal> ep(new EventPrincipal(preg_,
                                                               branchIDListHelper_,
                                                               *processConfiguration_,
                                                               &(historyAppenders_[index]),
                                                               index));
       ep->preModuleDelayedGetSignal_.connect(std::cref(items.actReg_->preModuleEventDelayedGetSignal_));
       ep->postModuleDelayedGetSignal_.connect(std::cref(items.actReg_->postModuleEventDelayedGetSignal_));
       principalCache_.insert(ep);
     }
     if(subProcessParameterSet) {
       subProcess_.reset(new SubProcess(*subProcessParameterSet,
                                        topLevelParameterSet,
                                        preg_,
                                        branchIDListHelper_,
                                        esController,
                                        *items.actReg_,
                                        newToken,
                                        iLegacy,
                                        preallocConfig,
                                        &processContext_));
     }
   }

edm::SubProcess::~SubProcess ( )

virtual

Definition at line 177 of file SubProcess.cc.

177 {}

edm::SubProcess::SubProcess ( SubProcess const & )

delete

Member Function Documentation

void edm::SubProcess::beginJob ( void )

private

Definition at line 191 of file SubProcess.cc.

References droppedBranchIDToKeptBranchID(), relativeConstraints::empty, fixBranchIDListsForEDAliases(), cmsPerfStripChart::operate(), preg_, schedule_, serviceToken_, and subProcess_.

Referenced by doBeginJob().

                        {
     if(!droppedBranchIDToKeptBranchID().empty()) {
       fixBranchIDListsForEDAliases(droppedBranchIDToKeptBranchID());
     }
     ServiceRegistry::Operate operate(serviceToken_);
     schedule_->beginJob(*preg_);
     if(subProcess_.get()) subProcess_->doBeginJob();
   }

void edm::SubProcess::beginLuminosityBlock	(	LuminosityBlockPrincipal const &	lb,
		IOVSyncValue const &	ts
	)

private

Definition at line 395 of file SubProcess.cc.

References printConversionInfo::aux, edm::LuminosityBlockPrincipal::aux(), edm::LuminosityBlockPrincipal::index(), edm::InLumi, edm::Principal::processHistory(), edm::Principal::processHistoryID(), and edm::Principal::reader().

                                                                                                     {
     boost::shared_ptr<LuminosityBlockAuxiliary> aux(new LuminosityBlockAuxiliary(principal.aux()));
     aux->setProcessHistoryID(principal.processHistoryID());
     boost::shared_ptr<LuminosityBlockPrincipal> lbpp(new LuminosityBlockPrincipal(aux, preg_, *processConfiguration_, &(historyAppenders_[historyLumiOffset_+principal.index()]),principal.index()));
     auto & processHistoryRegistry = processHistoryRegistries_[historyLumiOffset_+principal.index()];
     processHistoryRegistry.registerProcessHistory(principal.processHistory());
     lbpp->fillLuminosityBlockPrincipal(processHistoryRegistry, principal.reader());
     lbpp->setRunPrincipal(principalCache_.runPrincipalPtr());
     principalCache_.insert(lbpp);
     LuminosityBlockPrincipal& lbp = *principalCache_.lumiPrincipalPtr();
     propagateProducts(InLumi, principal, lbp);
     typedef OccurrenceTraits<LuminosityBlockPrincipal, BranchActionGlobalBegin> Traits;
     schedule_->processOneGlobal<Traits>(lbp, esp_->eventSetupForInstance(ts));
     if(subProcess_.get()) subProcess_->doBeginLuminosityBlock(lbp, ts);
   }

void edm::SubProcess::beginRun	(	RunPrincipal const &	r,
		IOVSyncValue const &	ts
	)

private

Definition at line 335 of file SubProcess.cc.

References printConversionInfo::aux, edm::RunPrincipal::aux(), edm::RunPrincipal::index(), edm::InRun, edm::Principal::processHistory(), edm::Principal::processHistoryID(), edm::Principal::reader(), and edm::RunPrincipal::reducedProcessHistoryID().

                                                                             {
     boost::shared_ptr<RunAuxiliary> aux(new RunAuxiliary(principal.aux()));
     aux->setProcessHistoryID(principal.processHistoryID());
     boost::shared_ptr<RunPrincipal> rpp(new RunPrincipal(aux, preg_, *processConfiguration_, &(historyAppenders_[historyRunOffset_+principal.index()]),principal.index()));
     auto & processHistoryRegistry = processHistoryRegistries_[historyRunOffset_+principal.index()];
     processHistoryRegistry.registerProcessHistory(principal.processHistory());
     rpp->fillRunPrincipal(processHistoryRegistry, principal.reader());
     principalCache_.insert(rpp);
 
     ProcessHistoryID const& parentInputReducedPHID = principal.reducedProcessHistoryID();
     ProcessHistoryID const& inputReducedPHID       = rpp->reducedProcessHistoryID();
 
     parentToChildPhID_.insert(std::make_pair(parentInputReducedPHID,inputReducedPHID));
 
     RunPrincipal& rp = *principalCache_.runPrincipalPtr();
     propagateProducts(InRun, principal, rp);
     typedef OccurrenceTraits<RunPrincipal, BranchActionGlobalBegin> Traits;
     schedule_->processOneGlobal<Traits>(rp, esp_->eventSetupForInstance(ts));
     if(subProcess_.get()) subProcess_->doBeginRun(rp, ts);
   }

void edm::SubProcess::clearCounters ( )

inline

Clear all the counters in the trigger report.

Definition at line 199 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcess_.

                          {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->clearCounters();
       if(subProcess_.get()) subProcess_->clearCounters();
     }

void edm::SubProcess::closeOutputFiles ( )

inline

Definition at line 93 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcess_.

                             {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->closeOutputFiles();
       if(subProcess_.get()) subProcess_->closeOutputFiles();
     }

void edm::SubProcess::deleteLumiFromCache	(	ProcessHistoryID const &	parentPhID,
		int	runNumber,
		int	lumiNumber
	)

Definition at line 436 of file SubProcess.cc.

                                                                                                    {
     std::map<ProcessHistoryID, ProcessHistoryID>::const_iterator it = parentToChildPhID_.find(parentPhID);
     assert(it != parentToChildPhID_.end());
     principalCache_.deleteLumi(it->second, runNumber, lumiNumber);
       if(subProcess_.get()) subProcess_->deleteLumiFromCache(it->second, runNumber, lumiNumber);
   }

void edm::SubProcess::deleteRunFromCache	(	ProcessHistoryID const &	parentPhID,
		int	runNumber
	)

Definition at line 381 of file SubProcess.cc.

                                                                                   {
     std::map<ProcessHistoryID, ProcessHistoryID>::const_iterator it = parentToChildPhID_.find(parentPhID);
     assert(it != parentToChildPhID_.end());
     principalCache_.deleteRun(it->second, runNumber);
     if(subProcess_.get()) subProcess_->deleteRunFromCache(it->second, runNumber);
   }

void edm::SubProcess::doBeginJob ( )

Definition at line 180 of file SubProcess.cc.

References beginJob().

                          {
     this->beginJob();
   }

void edm::SubProcess::doBeginLuminosityBlock	(	LuminosityBlockPrincipal const &	principal,
		IOVSyncValue const &	ts
	)

Definition at line 389 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                                                                                       {
     ServiceRegistry::Operate operate(serviceToken_);
     beginLuminosityBlock(principal,ts);
   }

void edm::SubProcess::doBeginRun	(	RunPrincipal const &	principal,
		IOVSyncValue const &	ts
	)

Definition at line 329 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                                                               {
     ServiceRegistry::Operate operate(serviceToken_);
     beginRun(principal,ts);
   }

void edm::SubProcess::doBeginStream ( unsigned int iID )

Definition at line 444 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                             {
     ServiceRegistry::Operate operate(serviceToken_);
     schedule_->beginStream(iID);
     if(subProcess_.get()) subProcess_->doBeginStream(iID);
   }

void edm::SubProcess::doEndJob ( )

Definition at line 185 of file SubProcess.cc.

References endJob().

Referenced by edm::EventProcessor::endJob().

                        {
     endJob();
   }

void edm::SubProcess::doEndLuminosityBlock	(	LuminosityBlockPrincipal const &	principal,
		IOVSyncValue const &	ts,
		bool	cleaningUpAfterException
	)

Definition at line 412 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                                                                                                                    {
     ServiceRegistry::Operate operate(serviceToken_);
     endLuminosityBlock(principal,ts,cleaningUpAfterException);
   }

void edm::SubProcess::doEndRun	(	RunPrincipal const &	principal,
		IOVSyncValue const &	ts,
		bool	cleaningUpAfterException
	)

Definition at line 357 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                                                                                            {
     ServiceRegistry::Operate operate(serviceToken_);
     endRun(principal,ts,cleaningUpAfterException);
   }

void edm::SubProcess::doEndStream ( unsigned int iID )

Definition at line 451 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                           {
     ServiceRegistry::Operate operate(serviceToken_);
     schedule_->endStream(iID);
     if(subProcess_.get()) subProcess_->doEndStream(iID);
   }

void edm::SubProcess::doEvent ( EventPrincipal const & principal )

Definition at line 282 of file SubProcess.cc.

References cmsPerfStripChart::operate(), and LaserDQM_cfg::process.

                                               {
     ServiceRegistry::Operate operate(serviceToken_);
     /* BEGIN relevant bits from OutputModule::doEvent */
     detail::TRBESSentry products_sentry(selectors_);
     
     
     if(!wantAllEvents_) {
       // use module description and const_cast unless interface to
       // event is changed to just take a const EventPrincipal
       if(!selectors_.wantEvent(ep, nullptr)) {
         return;
       }
     }
     process(ep);
     /* END relevant bits from OutputModule::doEvent */
   }

void edm::SubProcess::doStreamBeginLuminosityBlock	(	unsigned int	iID,
		LuminosityBlockPrincipal const &	principal,
		IOVSyncValue const &	ts
	)

Definition at line 480 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                                                                                                              {
     ServiceRegistry::Operate operate(serviceToken_);
     {
       LuminosityBlockPrincipal& lbp = *principalCache_.lumiPrincipalPtr();
       typedef OccurrenceTraits<LuminosityBlockPrincipal, BranchActionStreamBegin> Traits;
       schedule_->processOneStream<Traits>(id,lbp, esp_->eventSetupForInstance(ts));
       if(subProcess_.get()) subProcess_->doStreamBeginLuminosityBlock(id,lbp, ts);
     }
   }

void edm::SubProcess::doStreamBeginRun	(	unsigned int	iID,
		RunPrincipal const &	principal,
		IOVSyncValue const &	ts
	)

Definition at line 458 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                                                                                      {
     ServiceRegistry::Operate operate(serviceToken_);
     {
       RunPrincipal& rp = *principalCache_.runPrincipalPtr();
       typedef OccurrenceTraits<RunPrincipal, BranchActionStreamBegin> Traits;
       schedule_->processOneStream<Traits>(id,rp, esp_->eventSetupForInstance(ts));
       if(subProcess_.get()) subProcess_->doStreamBeginRun(id,rp, ts);
     }
   }

void edm::SubProcess::doStreamEndLuminosityBlock	(	unsigned int	iID,
		LuminosityBlockPrincipal const &	principal,
		IOVSyncValue const &	ts,
		bool	cleaningUpAfterException
	)

Definition at line 491 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                                                                                                                                           {
     ServiceRegistry::Operate operate(serviceToken_);
     {
       LuminosityBlockPrincipal& lbp = *principalCache_.lumiPrincipalPtr();
       typedef OccurrenceTraits<LuminosityBlockPrincipal, BranchActionStreamEnd> Traits;
       schedule_->processOneStream<Traits>(id,lbp, esp_->eventSetupForInstance(ts),cleaningUpAfterException);
       if(subProcess_.get()) subProcess_->doStreamEndLuminosityBlock(id,lbp, ts,cleaningUpAfterException);
     }
   }

void edm::SubProcess::doStreamEndRun	(	unsigned int	iID,
		RunPrincipal const &	principal,
		IOVSyncValue const &	ts,
		bool	cleaningUpAfterException
	)

Definition at line 469 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                                                                                                                   {
     ServiceRegistry::Operate operate(serviceToken_);
     {
       RunPrincipal& rp = *principalCache_.runPrincipalPtr();
       typedef OccurrenceTraits<RunPrincipal, BranchActionStreamEnd> Traits;
       schedule_->processOneStream<Traits>(id,rp, esp_->eventSetupForInstance(ts),cleaningUpAfterException);
       if(subProcess_.get()) subProcess_->doStreamEndRun(id,rp, ts,cleaningUpAfterException);
     }
   }

std::map<BranchID::value_type, BranchID::value_type> const& edm::SubProcess::droppedBranchIDToKeptBranchID ( )

inlineprivate

Definition at line 217 of file SubProcess.h.

References droppedBranchIDToKeptBranchID_.

Referenced by beginJob().

                                                                                           {
       return droppedBranchIDToKeptBranchID_;
     }

void edm::SubProcess::enableEndPaths ( bool active )

inline

Turn end_paths "off" if "active" is false; Turn end_paths "on" if "active" is true.

Definition at line 172 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcess_.

                                      {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->enableEndPaths(active);
       if(subProcess_.get()) subProcess_->enableEndPaths(active);
     }

void edm::SubProcess::endJob ( void )

private

Definition at line 201 of file SubProcess.cc.

References trackerHits::c, edm::ExceptionCollector::call(), cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcess_.

Referenced by doEndJob().

                      {
     ServiceRegistry::Operate operate(serviceToken_);
     ExceptionCollector c("Multiple exceptions were thrown while executing endJob. An exception message follows for each.");
     schedule_->endJob(c);
     if(subProcess_.get()) c.call([this](){ this->subProcess_->doEndJob();});
     if(c.hasThrown()) {
       c.rethrow();
     }
   }

void edm::SubProcess::endLuminosityBlock	(	LuminosityBlockPrincipal const &	lb,
		IOVSyncValue const &	ts,
		bool	cleaningUpAfterException
	)

private

Definition at line 418 of file SubProcess.cc.

References edm::InLumi.

                                                                                                                                  {
     LuminosityBlockPrincipal& lbp = *principalCache_.lumiPrincipalPtr();
     propagateProducts(InLumi, principal, lbp);
     typedef OccurrenceTraits<LuminosityBlockPrincipal, BranchActionGlobalEnd> Traits;
     schedule_->processOneGlobal<Traits>(lbp, esp_->eventSetupForInstance(ts), cleaningUpAfterException);
     if(subProcess_.get()) subProcess_->doEndLuminosityBlock(lbp, ts, cleaningUpAfterException);
   }

bool edm::SubProcess::endPathsEnabled ( ) const

inline

Return true if end_paths are active, and false if they are inactive.

Definition at line 179 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, and serviceToken_.

                                  {
       ServiceRegistry::Operate operate(serviceToken_);
       return schedule_->endPathsEnabled();
     }

void edm::SubProcess::endRun	(	RunPrincipal const &	r,
		IOVSyncValue const &	ts,
		bool	cleaningUpAfterException
	)

private

Definition at line 363 of file SubProcess.cc.

References edm::InRun.

                                                                                                          {
     RunPrincipal& rp = *principalCache_.runPrincipalPtr();
     propagateProducts(InRun, principal, rp);
     typedef OccurrenceTraits<RunPrincipal, BranchActionGlobalEnd> Traits;
     schedule_->processOneGlobal<Traits>(rp, esp_->eventSetupForInstance(ts), cleaningUpAfterException);
     if(subProcess_.get()) subProcess_->doEndRun(rp, ts, cleaningUpAfterException);
   }

void edm::SubProcess::fixBranchIDListsForEDAliases ( std::map< BranchID::value_type, BranchID::value_type > const & droppedBranchIDToKeptBranchID )

private

Definition at line 267 of file SubProcess.cc.

References getDQMSummary::iter.

Referenced by beginJob().

                                                                                                                               {
     // Check for branches dropped while an EDAlias was kept.
     // Replace BranchID of each dropped branch with that of the kept alias.
     for(BranchIDList& branchIDList : branchIDListHelper_->mutableBranchIDLists()) {
       for(BranchID::value_type& branchID : branchIDList) {
         std::map<BranchID::value_type, BranchID::value_type>::const_iterator iter = droppedBranchIDToKeptBranchID.find(branchID);
         if(iter != droppedBranchIDToKeptBranchID.end()) {
           branchID = iter->second;
         }
       }
     }
     if(subProcess_.get()) subProcess_->fixBranchIDListsForEDAliases(droppedBranchIDToKeptBranchID);
   }

std::vector<ModuleDescription const*> edm::SubProcess::getAllModuleDescriptions ( ) const

Return a vector allowing const access to all the ModuleDescriptions for this SubProcess.

*** N.B. *** Ownership of the ModuleDescriptions is not *** passed to the caller. Do not call delete on these *** pointers!

void edm::SubProcess::getTriggerReport ( TriggerReport & rep ) const

inline

Return the trigger report information on paths, modules-in-path, modules-in-endpath, and modules.

Definition at line 186 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, and serviceToken_.

                                                     {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->getTriggerReport(rep);
     }

SelectedProductsForBranchType const& edm::SubProcess::keptProducts ( ) const

inline

Definition at line 55 of file SubProcess.h.

References keptProducts_.

Referenced by edm::ScheduleItems::ScheduleItems().

55 {return keptProducts_;}

edm::SubProcess::keptProducts_

SelectedProductsForBranchType keptProducts_

Definition: SubProcess.h:246

void edm::SubProcess::openNewOutputFilesIfNeeded ( )

inline

Definition at line 100 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcess_.

                                       {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->openNewOutputFilesIfNeeded();
       if(subProcess_.get()) subProcess_->openNewOutputFilesIfNeeded();
     }

void edm::SubProcess::openOutputFiles ( FileBlock & fb )

inline

Definition at line 107 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcess_.

                                         {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->openOutputFiles(fb);
       if(subProcess_.get()) subProcess_->openOutputFiles(fb);
     }

SubProcess& edm::SubProcess::operator= ( SubProcess const & )

delete

void edm::SubProcess::postForkReacquireResources	(	unsigned int	iChildIndex,
		unsigned int	iNumberOfChildren
	)

inline

Definition at line 137 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcess_.

                                                                                               {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->postForkReacquireResources(iChildIndex, iNumberOfChildren);
       if(subProcess_.get()) subProcess_->postForkReacquireResources(iChildIndex, iNumberOfChildren);
     }

void edm::SubProcess::preForkReleaseResources ( )

inline

Definition at line 131 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcess_.

                                    {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->preForkReleaseResources();
       if(subProcess_.get()) subProcess_->preForkReleaseResources();
     }

void edm::SubProcess::process ( EventPrincipal const & e )

private

Definition at line 300 of file SubProcess.cc.

                                                      {
     EventAuxiliary aux(principal.aux());
     aux.setProcessHistoryID(principal.processHistoryID());
 
     EventSelectionIDVector esids{principal.eventSelectionIDs()};
     if (principal.productRegistry().anyProductProduced() || !wantAllEvents_) {
       esids.push_back(selector_config_id_);
     }
 
     EventPrincipal& ep = principalCache_.eventPrincipal(principal.streamID().value());
     auto & processHistoryRegistry = processHistoryRegistries_[principal.streamID().value()];
     processHistoryRegistry.registerProcessHistory(principal.processHistory());
     BranchListIndexes bli(principal.branchListIndexes());
     branchIDListHelper_->fixBranchListIndexes(bli);
     ep.fillEventPrincipal(aux,
                           processHistoryRegistry,
                           std::move(esids),
                           std::move(bli),
                           *(principal.productProvenanceRetrieverPtr()),//NOTE: this transfers the per product provenance
                           principal.reader());
     ep.setLuminosityBlockPrincipal(principalCache_.lumiPrincipalPtr());
     propagateProducts(InEvent, principal, ep);
     typedef OccurrenceTraits<EventPrincipal, BranchActionStreamBegin> Traits;
     schedule_->processOneEvent<Traits>(ep.streamID().value(),ep, esp_->eventSetup());
     if(subProcess_.get()) subProcess_->doEvent(ep);
     ep.clearEventPrincipal();
   }

void edm::SubProcess::propagateProducts	(	BranchType	type,
		Principal const &	parentPrincipal,
		Principal &	principal
	)		const

private

Definition at line 503 of file SubProcess.cc.

References edm::Principal::getProductHolder(), edm::Provenance::processHistory(), edm::ProductHolderBase::productData(), edm::Provenance::productID(), edm::Provenance::productProvenance(), edm::Provenance::productProvenanceValid(), edm::ProductHolderBase::productUnavailable(), edm::ProductData::prov_, edm::Provenance::resetProductProvenance(), edm::Provenance::setProcessHistory(), edm::Provenance::setProductID(), edm::Provenance::setProductProvenance(), edm::Provenance::setStore(), edm::Provenance::store(), and edm::ProductData::wrapper_.

                                                                                                              {
     SelectedProducts const& keptVector = keptProducts()[type];
     for(auto const& item : keptVector) {
       ProductHolderBase const* parentProductHolder = parentPrincipal.getProductHolder(item->branchID());
       if(parentProductHolder != nullptr) {
         ProductData const& parentData = parentProductHolder->productData();
         ProductHolderBase const* productHolder = principal.getProductHolder(item->branchID());
         if(productHolder != nullptr) {
           ProductData& thisData = const_cast<ProductData&>(productHolder->productData());
           //Propagate the per event(run)(lumi) data for this product to the subprocess.
           //First, the product itself.
           thisData.wrapper_ = parentData.wrapper_;
           // Then the product ID and the ProcessHistory 
           thisData.prov_.setProductID(parentData.prov_.productID());
           thisData.prov_.setProcessHistory(parentData.prov_.processHistory());
           // Then the store, in case the product needs reading in a subprocess.
           thisData.prov_.setStore(parentData.prov_.store());
           // And last, the other per event provenance.
           if(parentData.prov_.productProvenanceValid()) {
             thisData.prov_.setProductProvenance(*parentData.prov_.productProvenance());
           } else {
             thisData.prov_.resetProductProvenance();
           }
           // Sets unavailable flag, if known that product is not available
           (void)productHolder->productUnavailable();
         }
       }
     }
   }

void edm::SubProcess::respondToCloseInputFile ( FileBlock const & fb )

inline

Definition at line 119 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcess_.

                                                       {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->respondToCloseInputFile(fb);
       if(subProcess_.get()) subProcess_->respondToCloseInputFile(fb);
     }

void edm::SubProcess::respondToOpenInputFile ( FileBlock const & fb )

Definition at line 542 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                                         {
     ServiceRegistry::Operate operate(serviceToken_);
     schedule_->respondToOpenInputFile(fb);
     if(subProcess_.get()) subProcess_->respondToOpenInputFile(fb);
   }

void edm::SubProcess::selectProducts ( ProductRegistry const & preg )

Definition at line 212 of file SubProcess.cc.

References edm::ProductRegistry::allBranchDescriptions(), edm::BranchDescription::branchID(), edm::BranchDescription::branchType(), edm::errors::Configuration, edm::hlt::Exception, edm::BranchID::id(), edm::BranchDescription::isAlias(), getDQMSummary::iter, edm::BranchDescription::originalBranchID(), edm::BranchDescription::present(), edm::BranchDescription::produced(), edm::ProductRegistry::productList(), and edm::BranchDescription::transient().

Referenced by SubProcess().

                                                         {
     if(productSelector_.initialized()) return;
     productSelector_.initialize(productSelectorRules_, preg.allBranchDescriptions());
     
     // TODO: See if we can collapse keptProducts_ and productSelector_ into a
     // single object. See the notes in the header for ProductSelector
     // for more information.
     
     std::map<BranchID, BranchDescription const*> trueBranchIDToKeptBranchDesc;
     
     for(auto const& it : preg.productList()) {
       BranchDescription const& desc = it.second;
       if(desc.transient()) {
         // if the class of the branch is marked transient, output nothing
       } else if(!desc.present() && !desc.produced()) {
         // else if the branch containing the product has been previously dropped,
         // output nothing
       } else if(productSelector_.selected(desc)) {
         // else if the branch has been selected, put it in the list of selected branches.
         if(desc.produced()) {
           // First we check if an equivalent branch has already been selected due to an EDAlias.
           // We only need the check for products produced in this process.
           BranchID const& trueBranchID = desc.originalBranchID();
           std::map<BranchID, BranchDescription const*>::const_iterator iter = trueBranchIDToKeptBranchDesc.find(trueBranchID);
           if(iter != trueBranchIDToKeptBranchDesc.end()) {
             throw edm::Exception(errors::Configuration, "Duplicate Output Selection")
             << "Two (or more) equivalent branches have been selected for output.\n"
             << "#1: " << BranchKey(desc) << "\n"
             << "#2: " << BranchKey(*iter->second) << "\n"
             << "Please drop at least one of them.\n";
           }
           trueBranchIDToKeptBranchDesc.insert(std::make_pair(trueBranchID, &desc));
         }
         // Now put it in the list of selected branches.
         keptProducts_[desc.branchType()].push_back(&desc);
       }
     }
     // Now fill in a mapping needed in the case that a branch was dropped while its EDAlias was kept.
     for(auto const& it : preg.productList()) {
       BranchDescription const& desc = it.second;
       if(!desc.produced() || desc.isAlias()) continue;
       BranchID const& branchID = desc.branchID();
       std::map<BranchID, BranchDescription const*>::const_iterator iter = trueBranchIDToKeptBranchDesc.find(branchID);
       if(iter != trueBranchIDToKeptBranchDesc.end()) {
         // This branch, produced in this process, or an alias of it, was persisted.
         BranchID const& keptBranchID = iter->second->branchID();
         if(keptBranchID != branchID) {
           // An EDAlias branch was persisted.
           droppedBranchIDToKeptBranchID_.insert(std::make_pair(branchID.id(), keptBranchID.id()));
         }
       }
     }
   }

bool edm::SubProcess::shouldWeCloseOutput ( ) const

inline

Definition at line 126 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcess_.

                                      {
       ServiceRegistry::Operate operate(serviceToken_);
       return schedule_->shouldWeCloseOutput() || (subProcess_.get() ? subProcess_->shouldWeCloseOutput() : false);
     }

bool edm::SubProcess::terminate ( void ) const

inline

Return whether each output module has reached its maximum count. If there is a subprocess, get this information from the subprocess.

Definition at line 193 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcess_.

                            {
       ServiceRegistry::Operate operate(serviceToken_);
       return subProcess_.get() ? subProcess_->terminate() : schedule_->terminate();
     }

int edm::SubProcess::totalEvents ( ) const

inline

Return the number of events this SubProcess has tried to process (inclues both successes and failures, including failures due to exceptions during processing).

Definition at line 153 of file SubProcess.h.

References schedule_.

                             {
       return schedule_->totalEvents();
     }

int edm::SubProcess::totalEventsFailed ( ) const

inline

Return the number of events that have not passed any trigger. (N.B. totalEventsFailed() + totalEventsPassed() == totalEvents()

Definition at line 165 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, and serviceToken_.

                                   {
       ServiceRegistry::Operate operate(serviceToken_);
       return schedule_->totalEventsFailed();
     }

int edm::SubProcess::totalEventsPassed ( ) const

inline

Return the number of events which have been passed by one or more trigger paths.

Definition at line 158 of file SubProcess.h.

References cmsPerfStripChart::operate(), schedule_, and serviceToken_.

                                   {
       ServiceRegistry::Operate operate(serviceToken_);
       return schedule_->totalEventsPassed();
     }

void edm::SubProcess::updateBranchIDListHelper ( BranchIDLists const & branchIDLists )

Definition at line 533 of file SubProcess.cc.

Referenced by SubProcess().

                                                                               {
     branchIDListHelper_->updateFromParent(branchIDLists);
     if(subProcess_.get()) {
       subProcess_->updateBranchIDListHelper(branchIDListHelper_->branchIDLists());
     }
   }

void edm::SubProcess::writeLumi	(	ProcessHistoryID const &	parentPhID,
		int	runNumber,
		int	lumiNumber
	)

Definition at line 427 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                                                                          {
     ServiceRegistry::Operate operate(serviceToken_);
     std::map<ProcessHistoryID, ProcessHistoryID>::const_iterator it = parentToChildPhID_.find(parentPhID);
     assert(it != parentToChildPhID_.end());
     schedule_->writeLumi(principalCache_.lumiPrincipal(it->second, runNumber, lumiNumber), &processContext_);
     if(subProcess_.get()) subProcess_->writeLumi(it->second, runNumber, lumiNumber);
   }

void edm::SubProcess::writeRun	(	ProcessHistoryID const &	parentPhID,
		int	runNumber
	)

Definition at line 372 of file SubProcess.cc.

References cmsPerfStripChart::operate().

                                                                         {
     ServiceRegistry::Operate operate(serviceToken_);
     std::map<ProcessHistoryID, ProcessHistoryID>::const_iterator it = parentToChildPhID_.find(parentPhID);
     assert(it != parentToChildPhID_.end());
     schedule_->writeRun(principalCache_.runPrincipal(it->second, runNumber), &processContext_);
     if(subProcess_.get()) subProcess_->writeRun(it->second, runNumber);
   }

Member Data Documentation

std::unique_ptr<ExceptionToActionTable const> edm::SubProcess::act_table_

private

Definition at line 226 of file SubProcess.h.

Referenced by SubProcess().

boost::shared_ptr<BranchIDListHelper> edm::SubProcess::branchIDListHelper_

private

Definition at line 225 of file SubProcess.h.

Referenced by SubProcess().

std::map<BranchID::value_type, BranchID::value_type> edm::SubProcess::droppedBranchIDToKeptBranchID_

private

Definition at line 258 of file SubProcess.h.

Referenced by droppedBranchIDToKeptBranchID().

boost::shared_ptr<eventsetup::EventSetupProvider> edm::SubProcess::esp_

private

Definition at line 236 of file SubProcess.h.

Referenced by SubProcess().

std::vector<HistoryAppender> edm::SubProcess::historyAppenders_

private

Definition at line 234 of file SubProcess.h.

Referenced by SubProcess().

unsigned int edm::SubProcess::historyLumiOffset_

private

Definition at line 231 of file SubProcess.h.

unsigned int edm::SubProcess::historyRunOffset_

private

Definition at line 232 of file SubProcess.h.

Referenced by SubProcess().

SelectedProductsForBranchType edm::SubProcess::keptProducts_

private

Definition at line 246 of file SubProcess.h.

Referenced by keptProducts().

boost::shared_ptr<ProductRegistry const> edm::SubProcess::parentPreg_

private

Definition at line 223 of file SubProcess.h.

std::map<ProcessHistoryID, ProcessHistoryID> edm::SubProcess::parentToChildPhID_

private

Definition at line 238 of file SubProcess.h.

boost::shared_ptr<ProductRegistry const> edm::SubProcess::preg_

private

Definition at line 224 of file SubProcess.h.

Referenced by beginJob(), and SubProcess().

PrincipalCache edm::SubProcess::principalCache_

private

Definition at line 235 of file SubProcess.h.

Referenced by SubProcess().

boost::shared_ptr<ProcessConfiguration const> edm::SubProcess::processConfiguration_

private

Definition at line 227 of file SubProcess.h.

Referenced by SubProcess().

ProcessContext edm::SubProcess::processContext_

private

Definition at line 228 of file SubProcess.h.

Referenced by SubProcess().

std::vector<ProcessHistoryRegistry> edm::SubProcess::processHistoryRegistries_

private

Definition at line 233 of file SubProcess.h.

Referenced by SubProcess().

std::unique_ptr<ParameterSet> edm::SubProcess::processParameterSet_

private

Definition at line 240 of file SubProcess.h.

Referenced by SubProcess().

ProductSelector edm::SubProcess::productSelector_

private

Definition at line 248 of file SubProcess.h.

ProductSelectorRules edm::SubProcess::productSelectorRules_

private

Definition at line 247 of file SubProcess.h.

std::auto_ptr<Schedule> edm::SubProcess::schedule_

private

ParameterSetID edm::SubProcess::selector_config_id_

private

Definition at line 253 of file SubProcess.h.

Referenced by SubProcess().

detail::TriggerResultsBasedEventSelector edm::SubProcess::selectors_

mutableprivate

Definition at line 254 of file SubProcess.h.

Referenced by SubProcess().

ServiceToken edm::SubProcess::serviceToken_

private

Definition at line 222 of file SubProcess.h.

Referenced by beginJob(), clearCounters(), closeOutputFiles(), enableEndPaths(), endJob(), endPathsEnabled(), getTriggerReport(), openNewOutputFilesIfNeeded(), openOutputFiles(), postForkReacquireResources(), preForkReleaseResources(), respondToCloseInputFile(), shouldWeCloseOutput(), SubProcess(), terminate(), totalEventsFailed(), and totalEventsPassed().

std::auto_ptr<SubProcess> edm::SubProcess::subProcess_

private

Definition at line 239 of file SubProcess.h.

Referenced by beginJob(), clearCounters(), closeOutputFiles(), Config.Process::dumpConfig(), Config.Process::dumpPython(), enableEndPaths(), endJob(), openNewOutputFilesIfNeeded(), openOutputFiles(), postForkReacquireResources(), preForkReleaseResources(), respondToCloseInputFile(), shouldWeCloseOutput(), SubProcess(), and terminate().

bool edm::SubProcess::wantAllEvents_

private

Definition at line 252 of file SubProcess.h.

Referenced by SubProcess().

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation