#include <SubProcess.h>

Inheritance diagram for edm::SubProcess:

Public Types
using	ProcessBlockType = PrincipalCache::ProcessBlockType

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

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

void	clearProcessBlockPrincipal (ProcessBlockType)

void	closeOutputFiles ()

void	deleteLumiFromCache (LuminosityBlockPrincipal &)

void	deleteRunFromCache (ProcessHistoryID const &parentPhID, int runNumber)

void	doBeginJob ()

void	doBeginLuminosityBlockAsync (WaitingTaskHolder iHolder, LumiTransitionInfo const &iTransitionInfo)

template<typename Traits >
void	doBeginProcessBlockAsync (WaitingTaskHolder iHolder, ProcessBlockTransitionInfo const &iTransitionInfo)

template<>
void	doBeginProcessBlockAsync (WaitingTaskHolder iHolder, ProcessBlockTransitionInfo const &iTransitionInfo)

template<>
void	doBeginProcessBlockAsync (WaitingTaskHolder iHolder, ProcessBlockTransitionInfo const &iTransitionInfo)

void	doBeginRunAsync (WaitingTaskHolder iHolder, RunTransitionInfo const &iTransitionInfo)

void	doBeginStream (unsigned int)

void	doEndJob ()

void	doEndLuminosityBlockAsync (WaitingTaskHolder iHolder, LumiTransitionInfo const &iTransitionInfo, bool cleaningUpAfterException)

void	doEndProcessBlockAsync (WaitingTaskHolder iHolder, ProcessBlockTransitionInfo const &iTransitionInfo, bool cleaningUpAfterException)

void	doEndRunAsync (WaitingTaskHolder iHolder, RunTransitionInfo const &iTransitionInfo, bool cleaningUpAfterException)

void	doEndStream (unsigned int)

void	doEventAsync (WaitingTaskHolder iHolder, EventPrincipal const &principal, std::vector< std::shared_ptr< const EventSetupImpl >> const *)

void	doStreamBeginLuminosityBlockAsync (WaitingTaskHolder iHolder, unsigned int iID, LumiTransitionInfo const &)

void	doStreamBeginRunAsync (WaitingTaskHolder iHolder, unsigned int iID, RunTransitionInfo const &)

void	doStreamEndLuminosityBlockAsync (WaitingTaskHolder iHolder, unsigned int iID, LumiTransitionInfo const &, bool cleaningUpAfterException)

void	doStreamEndRunAsync (WaitingTaskHolder iHolder, unsigned int iID, RunTransitionInfo const &, 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	openOutputFiles (FileBlock &fb)

SubProcess &	operator= (SubProcess &&)=delete

SubProcess &	operator= (SubProcess const &)=delete

void	respondToCloseInputFile (FileBlock const &fb)

void	respondToOpenInputFile (FileBlock const &fb)

void	selectProducts (ProductRegistry const &preg, ThinnedAssociationsHelper const &parentThinnedAssociationsHelper, std::map< BranchID, bool > &keepAssociation)

bool	shouldWeCloseOutput () const

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

	SubProcess (SubProcess &&)=default

	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	writeLumiAsync (WaitingTaskHolder, LuminosityBlockPrincipal &)

void	writeProcessBlockAsync (edm::WaitingTaskHolder task, ProcessBlockType)

void	writeRunAsync (WaitingTaskHolder, ProcessHistoryID const &parentPhID, int runNumber, MergeableRunProductMetadata const *)

	~SubProcess () override

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase &&)=default

	EDConsumerBase (EDConsumerBase const &)=delete

ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const

std::vector< ESProxyIndex > const &	esGetTokenIndicesVector (edm::Transition iTrans) const

std::vector< ESRecordIndex > const &	esGetTokenRecordIndicesVector (edm::Transition iTrans) const

ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

std::vector< ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const

EDConsumerBase &	operator= (EDConsumerBase &&)=default

EDConsumerBase const &	operator= (EDConsumerBase const &)=delete

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

virtual	~EDConsumerBase () noexcept(false)

Private Member Functions
void	beginJob ()

std::shared_ptr< BranchIDListHelper > &	branchIDListHelper ()

std::shared_ptr< BranchIDListHelper const >	branchIDListHelper () const

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

void	endJob ()

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

void	keepThisBranch (BranchDescription const &desc, std::map< BranchID, BranchDescription const * > &trueBranchIDToKeptBranchDesc, std::set< BranchID > &keptProductsInEvent)

void	processAsync (WaitingTaskHolder iHolder, EventPrincipal const &e, std::vector< std::shared_ptr< const EventSetupImpl >> const *)

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

std::shared_ptr< ThinnedAssociationsHelper >	thinnedAssociationsHelper ()

std::shared_ptr< ThinnedAssociationsHelper const >	thinnedAssociationsHelper () const

Private Attributes
std::unique_ptr< ExceptionToActionTable const >	act_table_

std::shared_ptr< ActivityRegistry >	actReg_

edm::propagate_const< std::shared_ptr< BranchIDListHelper > >	branchIDListHelper_

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

edm::propagate_const< std::shared_ptr< eventsetup::EventSetupProvider > >	esp_

std::vector< HistoryAppender >	historyAppenders_

unsigned int	historyLumiOffset_

unsigned int	historyRunOffset_

std::vector< std::shared_ptr< LuminosityBlockPrincipal > >	inUseLumiPrincipals_

SelectedProductsForBranchType	keptProducts_

std::shared_ptr< ProductRegistry const >	parentPreg_

std::map< ProcessHistoryID, ProcessHistoryID >	parentToChildPhID_

PathsAndConsumesOfModules	pathsAndConsumesOfModules_

std::shared_ptr< ProductRegistry const >	preg_

PrincipalCache	principalCache_

std::shared_ptr< ProcessConfiguration const >	processConfiguration_

ProcessContext	processContext_

std::vector< ProcessHistoryRegistry >	processHistoryRegistries_

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

ProductSelector	productSelector_

ProductSelectorRules	productSelectorRules_

edm::propagate_const< std::unique_ptr< Schedule > >	schedule_

ParameterSetID	selector_config_id_

detail::TriggerResultsBasedEventSelector	selectors_

ServiceToken	serviceToken_

std::vector< SubProcess >	subProcesses_

edm::propagate_const< std::shared_ptr< SubProcessParentageHelper > >	subProcessParentageHelper_

edm::propagate_const< std::shared_ptr< ThinnedAssociationsHelper > >	thinnedAssociationsHelper_

bool	wantAllEvents_

Additional Inherited Members
Protected Member Functions inherited from edm::EDConsumerBase
EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B >	consumes (edm::InputTag tag) noexcept

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

template<Transition Tr = Transition::Event>
constexpr auto	esConsumes () noexcept

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)

template<Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag tag) noexcept

template<Transition Tr = Transition::Event>
ESGetTokenGeneric	esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
	Used with EventSetupRecord::doGet. More...

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

Detailed Description

Definition at line 50 of file SubProcess.h.

Member Typedef Documentation

◆ ProcessBlockType

using edm::SubProcess::ProcessBlockType = PrincipalCache::ProcessBlockType

Definition at line 125 of file SubProcess.h.

Constructor & Destructor Documentation

◆ SubProcess() [1/3]

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

Definition at line 48 of file SubProcess.cc.

       : EDConsumerBase(),
         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_(),
         subProcesses_(),
         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_, consumesCollector());
     std::map<std::string, std::vector<std::pair<std::string, int>>> outputModulePathPositions;
     selector_config_id_ = detail::registerProperSelectionInfo(
         selectevents, "", outputModulePathPositions, parentProductRegistry->anyProductProduced());
  
     std::map<BranchID, bool> keepAssociation;
     selectProducts(*parentProductRegistry, parentThinnedAssociationsHelper, keepAssociation);
  
     std::string const maxEvents("maxEvents");
     std::string const maxLumis("maxLuminosityBlocks");
  
     // propagate_const<T> has no reset() function
     processParameterSet_ =
         std::unique_ptr<ParameterSet>(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 there are subprocesses, pop the subprocess parameter sets out of the process parameter set
     auto subProcessVParameterSet = popSubProcessVParameterSet(*processParameterSet_);
     bool hasSubProcesses = subProcessVParameterSet.size() != 0ull;
  
     // Validates the parameters in the 'options', 'maxEvents', and 'maxLuminosityBlocks'
     // top level parameter sets. Default values are also set in here if the
     // parameters were not explicitly set.
     validateTopLevelParameterSets(processParameterSet_.get());
  
     ScheduleItems items(*parentProductRegistry, *this);
     actReg_ = items.actReg_;
  
     //initialize the services
     ServiceToken iToken;
  
     // get any configured services.
     auto 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_, actReg_.get());
  
     branchIDListHelper_ = items.branchIDListHelper();
     updateBranchIDListHelper(parentBranchIDListHelper->branchIDLists());
  
     thinnedAssociationsHelper_ = items.thinnedAssociationsHelper();
     thinnedAssociationsHelper_->updateFromParentProcess(
         parentThinnedAssociationsHelper, keepAssociation, droppedBranchIDToKeptBranchID_);
  
     // intialize the Schedule
     schedule_ = items.initSchedule(*processParameterSet_, hasSubProcesses, preallocConfig, &processContext_);
  
     // set the items
     act_table_ = std::move(items.act_table_);
     preg_ = items.preg();
  
     subProcessParentageHelper_ = items.subProcessParentageHelper();
     subProcessParentageHelper_->update(parentSubProcessParentageHelper, *parentProductRegistry);
  
     //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) {
       auto ep = std::make_shared<EventPrincipal>(preg_,
                                                  branchIDListHelper(),
                                                  thinnedAssociationsHelper(),
                                                  *processConfiguration_,
                                                  &(historyAppenders_[index]),
                                                  index,
                                                  false /*not primary process*/);
       principalCache_.insert(ep);
     }
     for (unsigned int index = 0; index < preallocConfig.numberOfLuminosityBlocks(); ++index) {
       auto lbpp = std::make_unique<LuminosityBlockPrincipal>(
           preg_, *processConfiguration_, &(historyAppenders_[historyLumiOffset_ + index]), index, false);
       principalCache_.insert(std::move(lbpp));
     }
  
     {
       auto pb = std::make_unique<ProcessBlockPrincipal>(preg_, *processConfiguration_, false);
       principalCache_.insert(std::move(pb));
  
       auto pbForInput = std::make_unique<ProcessBlockPrincipal>(preg_, *processConfiguration_, false);
       principalCache_.insertForInput(std::move(pbForInput));
     }
  
     inUseLumiPrincipals_.resize(preallocConfig.numberOfLuminosityBlocks());
  
     subProcesses_.reserve(subProcessVParameterSet.size());
     for (auto& subProcessPSet : subProcessVParameterSet) {
       subProcesses_.emplace_back(subProcessPSet,
                                  topLevelParameterSet,
                                  preg_,
                                  branchIDListHelper(),
                                  *thinnedAssociationsHelper_,
                                  *subProcessParentageHelper_,
                                  esController,
                                  *items.actReg_,
                                  newToken,
                                  iLegacy,
                                  preallocConfig,
                                  &processContext_);
     }
   }

References act_table_, actReg_, branchIDListHelper(), branchIDListHelper_, edm::detail::configureEventSelector(), edm::ActivityRegistry::connectToSubProcess(), edm::EDConsumerBase::consumesCollector(), droppedBranchIDToKeptBranchID_, SiStripBadComponentsDQMServiceTemplate_cfg::ep, esp_, edm::ParameterSet::exists(), edm::getAllTriggerNames(), edm::ParameterSet::getUntrackedParameterSet(), historyAppenders_, historyLumiOffset_, historyRunOffset_, edm::PrincipalCache::insert(), edm::PrincipalCache::insertForInput(), inUseLumiPrincipals_, mps_monitormerge::items, edm::eventsetup::EventSetupsController::makeProvider(), Data_TkAlMinBias_Run2018C_PromptReco_v3_cff::maxEvents, eostools::move(), edm::PreallocationConfiguration::numberOfLuminosityBlocks(), edm::PreallocationConfiguration::numberOfStreams(), edm::parameterSet(), edm::ParameterSet::popParameterSet(), edm::popSubProcessVParameterSet(), 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(), AlCaHLTBitMon_QueryRunRegistry::string, subProcesses_, subProcessParentageHelper_, thinnedAssociationsHelper(), thinnedAssociationsHelper_, unpackBuffers-CaloStage2::token, updateBranchIDListHelper(), edm::validateTopLevelParameterSets(), and wantAllEvents_.

◆ ~SubProcess()

edm::SubProcess::~SubProcess ( )

override

Definition at line 221 of file SubProcess.cc.

221 {}

◆ SubProcess() [2/3]

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

delete

◆ SubProcess() [3/3]

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

default

Member Function Documentation

◆ beginJob()

void edm::SubProcess::beginJob ( void )

private

Definition at line 227 of file SubProcess.cc.

                             {
     // If event selection is being used, the SubProcess class reads TriggerResults
     // object(s) in the parent process from the event. This next call is needed for
     // getByToken to work properly. Normally, this is done by the worker, but since
     // a SubProcess is not a module, it has no worker.
     updateLookup(InEvent, *parentPreg_->productLookup(InEvent), false);
  
     if (!droppedBranchIDToKeptBranchID().empty()) {
       fixBranchIDListsForEDAliases(droppedBranchIDToKeptBranchID());
     }
     ServiceRegistry::Operate operate(serviceToken_);
     schedule_->convertCurrentProcessAlias(processConfiguration_->processName());
     pathsAndConsumesOfModules_.initialize(schedule_.get(), preg_);
     //NOTE: this may throw
     checkForModuleDependencyCorrectness(pathsAndConsumesOfModules_, false);
     actReg_->preBeginJobSignal_(pathsAndConsumesOfModules_, processContext_);
     schedule_->beginJob(*preg_, esp_->recordsToProxyIndices());
     for_all(subProcesses_, [](auto& subProcess) { subProcess.doBeginJob(); });
   }

References actReg_, edm::checkForModuleDependencyCorrectness(), droppedBranchIDToKeptBranchID(), esp_, fixBranchIDListsForEDAliases(), edm::for_all(), edm::InEvent, edm::PathsAndConsumesOfModules::initialize(), parentPreg_, pathsAndConsumesOfModules_, preg_, processConfiguration_, processContext_, schedule_, serviceToken_, subProcesses_, and edm::EDConsumerBase::updateLookup().

Referenced by doBeginJob().

◆ branchIDListHelper() [1/2]

std::shared_ptr<BranchIDListHelper>& edm::SubProcess::branchIDListHelper ( )

inlineprivate

Definition at line 266 of file SubProcess.h.

266 { return get_underlying_safe(branchIDListHelper_); }

References branchIDListHelper_, and edm::get_underlying_safe().

◆ branchIDListHelper() [2/2]

std::shared_ptr<BranchIDListHelper const> edm::SubProcess::branchIDListHelper ( ) const

inlineprivate

Definition at line 263 of file SubProcess.h.

                                                                        {
       return get_underlying_safe(branchIDListHelper_);
     }

References branchIDListHelper_, and edm::get_underlying_safe().

Referenced by SubProcess().

◆ clearCounters()

void edm::SubProcess::clearCounters ( )

inline

Clear all the counters in the trigger report.

Definition at line 239 of file SubProcess.h.

                          {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->clearCounters();
       for_all(subProcesses_, [](auto& subProcess) { subProcess.clearCounters(); });
     }

References edm::for_all(), schedule_, serviceToken_, and subProcesses_.

◆ clearProcessBlockPrincipal()

void edm::SubProcess::clearProcessBlockPrincipal ( ProcessBlockType processBlockType )

Definition at line 555 of file SubProcess.cc.

                                                                                {
     ProcessBlockPrincipal& processBlockPrincipal = principalCache_.processBlockPrincipal(processBlockType);
     processBlockPrincipal.clearPrincipal();
     for (auto& s : subProcesses_) {
       s.clearProcessBlockPrincipal(processBlockType);
     }
   }

References edm::Principal::clearPrincipal(), principalCache_, edm::PrincipalCache::processBlockPrincipal(), alignCSCRings::s, and subProcesses_.

◆ closeOutputFiles()

void edm::SubProcess::closeOutputFiles ( )

inline

Definition at line 138 of file SubProcess.h.

                             {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->closeOutputFiles();
       for_all(subProcesses_, [](auto& subProcess) { subProcess.closeOutputFiles(); });
     }

References edm::for_all(), schedule_, serviceToken_, and subProcesses_.

◆ deleteLumiFromCache()

void edm::SubProcess::deleteLumiFromCache ( LuminosityBlockPrincipal & principal )

Definition at line 617 of file SubProcess.cc.

                                                                           {
     //release from list but stay around till end of routine
     auto lb = std::move(inUseLumiPrincipals_[principal.index()]);
     for (auto& s : subProcesses_) {
       s.deleteLumiFromCache(*lb);
     }
     lb->clearPrincipal();
   }

References edm::LuminosityBlockPrincipal::index(), inUseLumiPrincipals_, eostools::move(), alignCSCRings::s, and subProcesses_.

◆ deleteRunFromCache()

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

Definition at line 546 of file SubProcess.cc.

                                                                                        {
     std::map<ProcessHistoryID, ProcessHistoryID>::const_iterator it = parentToChildPhID_.find(parentPhID);
     assert(it != parentToChildPhID_.end());
     auto const& childPhID = it->second;
     principalCache_.deleteRun(childPhID, runNumber);
     for_all(subProcesses_,
             [&childPhID, runNumber](auto& subProcess) { subProcess.deleteRunFromCache(childPhID, runNumber); });
   }

References cms::cuda::assert(), edm::PrincipalCache::deleteRun(), edm::for_all(), parentToChildPhID_, principalCache_, convertSQLiteXML::runNumber, and subProcesses_.

◆ doBeginJob()

void edm::SubProcess::doBeginJob ( )

Definition at line 223 of file SubProcess.cc.

223 { this->beginJob(); }

References beginJob().

◆ doBeginLuminosityBlockAsync()

void edm::SubProcess::doBeginLuminosityBlockAsync	(	WaitingTaskHolder	iHolder,
		LumiTransitionInfo const &	iTransitionInfo
	)

Definition at line 563 of file SubProcess.cc.

                                                                                                                    {
     ServiceRegistry::Operate operate(serviceToken_);
  
     LuminosityBlockPrincipal const& parentPrincipal = iTransitionInfo.principal();
     auto aux = parentPrincipal.aux();
     aux.setProcessHistoryID(parentPrincipal.processHistoryID());
     auto lbpp = principalCache_.getAvailableLumiPrincipalPtr();
     lbpp->setAux(aux);
     auto& processHistoryRegistry = processHistoryRegistries_[historyLumiOffset_ + lbpp->index()];
     inUseLumiPrincipals_[parentPrincipal.index()] = lbpp;
     processHistoryRegistry.registerProcessHistory(parentPrincipal.processHistory());
     lbpp->fillLuminosityBlockPrincipal(&parentPrincipal.processHistory(), parentPrincipal.reader());
     lbpp->setRunPrincipal(principalCache_.runPrincipalPtr());
     LuminosityBlockPrincipal& lbp = *lbpp;
     propagateProducts(InLumi, parentPrincipal, lbp);
  
     std::vector<std::shared_ptr<const EventSetupImpl>> const* eventSetupImpls = iTransitionInfo.eventSetupImpls();
     LumiTransitionInfo transitionInfo(lbp, *((*eventSetupImpls)[esp_->subProcessIndex()]), eventSetupImpls);
     using Traits = OccurrenceTraits<LuminosityBlockPrincipal, BranchActionGlobalBegin>;
     beginGlobalTransitionAsync<Traits>(std::move(iHolder), *schedule_, transitionInfo, serviceToken_, subProcesses_);
   }

References printConversionInfo::aux, edm::LuminosityBlockPrincipal::aux(), esp_, edm::LumiTransitionInfo::eventSetupImpls(), edm::PrincipalCache::getAvailableLumiPrincipalPtr(), historyLumiOffset_, edm::LuminosityBlockPrincipal::index(), edm::InLumi, inUseLumiPrincipals_, eostools::move(), edm::LumiTransitionInfo::principal(), principalCache_, edm::Principal::processHistory(), edm::Principal::processHistoryID(), processHistoryRegistries_, propagateProducts(), edm::Principal::reader(), edm::PrincipalCache::runPrincipalPtr(), schedule_, serviceToken_, and subProcesses_.

Referenced by edm::subProcessDoGlobalBeginTransitionAsync().

◆ doBeginProcessBlockAsync() [1/3]

template<typename Traits >

void edm::SubProcess::doBeginProcessBlockAsync	(	WaitingTaskHolder	iHolder,
		ProcessBlockTransitionInfo const &	iTransitionInfo
	)

Referenced by edm::subProcessDoGlobalBeginTransitionAsync().

◆ doBeginProcessBlockAsync() [2/3]

template<>

void edm::SubProcess::doBeginProcessBlockAsync	(	WaitingTaskHolder	iHolder,
		ProcessBlockTransitionInfo const &	iTransitionInfo
	)

Definition at line 413 of file SubProcess.cc.

                                                                                     {
     ServiceRegistry::Operate operate(serviceToken_);
  
     ProcessBlockPrincipal& processBlockPrincipal = principalCache_.inputProcessBlockPrincipal();
     ProcessBlockPrincipal const& parentPrincipal = iTransitionInfo.principal();
     processBlockPrincipal.fillProcessBlockPrincipal(parentPrincipal.processName(), parentPrincipal.reader());
     propagateProducts(InProcess, parentPrincipal, processBlockPrincipal);
  
     ProcessBlockTransitionInfo transitionInfo(processBlockPrincipal);
     using Traits = OccurrenceTraits<ProcessBlockPrincipal, BranchActionProcessBlockInput>;
     beginGlobalTransitionAsync<Traits>(std::move(iHolder), *schedule_, transitionInfo, serviceToken_, subProcesses_);
   }

References edm::ProcessBlockPrincipal::fillProcessBlockPrincipal(), edm::InProcess, eostools::move(), edm::ProcessBlockPrincipal::processName(), and edm::Principal::reader().

◆ doBeginProcessBlockAsync() [3/3]

template<>

void edm::SubProcess::doBeginProcessBlockAsync	(	WaitingTaskHolder	iHolder,
		ProcessBlockTransitionInfo const &	iTransitionInfo
	)

Definition at line 428 of file SubProcess.cc.

                                                                                     {
     ServiceRegistry::Operate operate(serviceToken_);
  
     ProcessBlockPrincipal& processBlockPrincipal = principalCache_.processBlockPrincipal();
     ProcessBlockPrincipal const& parentPrincipal = iTransitionInfo.principal();
     processBlockPrincipal.fillProcessBlockPrincipal(processConfiguration_->processName());
     propagateProducts(InProcess, parentPrincipal, processBlockPrincipal);
  
     ProcessBlockTransitionInfo transitionInfo(processBlockPrincipal);
     using Traits = OccurrenceTraits<ProcessBlockPrincipal, BranchActionGlobalBegin>;
     beginGlobalTransitionAsync<Traits>(std::move(iHolder), *schedule_, transitionInfo, serviceToken_, subProcesses_);
   }

References edm::ProcessBlockPrincipal::fillProcessBlockPrincipal(), edm::InProcess, and eostools::move().

◆ doBeginRunAsync()

void edm::SubProcess::doBeginRunAsync	(	WaitingTaskHolder	iHolder,
		RunTransitionInfo const &	iTransitionInfo
	)

Definition at line 455 of file SubProcess.cc.

                                                                                                       {
     ServiceRegistry::Operate operate(serviceToken_);
  
     RunPrincipal const& parentPrincipal = iTransitionInfo.principal();
     auto aux = std::make_shared<RunAuxiliary>(parentPrincipal.aux());
     aux->setProcessHistoryID(parentPrincipal.processHistoryID());
     auto rpp = std::make_shared<RunPrincipal>(aux,
                                               preg_,
                                               *processConfiguration_,
                                               &(historyAppenders_[historyRunOffset_ + parentPrincipal.index()]),
                                               parentPrincipal.index(),
                                               false);
     auto& processHistoryRegistry = processHistoryRegistries_[historyRunOffset_ + parentPrincipal.index()];
     processHistoryRegistry.registerProcessHistory(parentPrincipal.processHistory());
     rpp->fillRunPrincipal(processHistoryRegistry, parentPrincipal.reader());
     principalCache_.insert(rpp);
  
     ProcessHistoryID const& parentInputReducedPHID = parentPrincipal.reducedProcessHistoryID();
     ProcessHistoryID const& inputReducedPHID = rpp->reducedProcessHistoryID();
  
     parentToChildPhID_.insert(std::make_pair(parentInputReducedPHID, inputReducedPHID));
  
     RunPrincipal& rp = *principalCache_.runPrincipalPtr();
     propagateProducts(InRun, parentPrincipal, rp);
  
     RunTransitionInfo transitionInfo(rp, esp_->eventSetupImpl());
     using Traits = OccurrenceTraits<RunPrincipal, BranchActionGlobalBegin>;
     beginGlobalTransitionAsync<Traits>(std::move(iHolder), *schedule_, transitionInfo, serviceToken_, subProcesses_);
   }

References printConversionInfo::aux, edm::RunPrincipal::aux(), esp_, historyAppenders_, historyRunOffset_, edm::RunPrincipal::index(), edm::InRun, edm::PrincipalCache::insert(), eostools::move(), parentToChildPhID_, preg_, edm::RunTransitionInfo::principal(), principalCache_, processConfiguration_, edm::Principal::processHistory(), edm::Principal::processHistoryID(), processHistoryRegistries_, propagateProducts(), edm::Principal::reader(), edm::RunPrincipal::reducedProcessHistoryID(), edm::PrincipalCache::runPrincipalPtr(), schedule_, serviceToken_, and subProcesses_.

Referenced by edm::subProcessDoGlobalBeginTransitionAsync().

◆ doBeginStream()

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

Definition at line 626 of file SubProcess.cc.

                                                  {
     ServiceRegistry::Operate operate(serviceToken_);
     schedule_->beginStream(iID);
     for_all(subProcesses_, [iID](auto& subProcess) { subProcess.doBeginStream(iID); });
   }

References edm::for_all(), schedule_, serviceToken_, and subProcesses_.

◆ doEndJob()

void edm::SubProcess::doEndJob ( )

Definition at line 225 of file SubProcess.cc.

225 { endJob(); }

References endJob().

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

◆ doEndLuminosityBlockAsync()

void edm::SubProcess::doEndLuminosityBlockAsync	(	WaitingTaskHolder	iHolder,
		LumiTransitionInfo const &	iTransitionInfo,
		bool	cleaningUpAfterException
	)

Definition at line 585 of file SubProcess.cc.

                                                                             {
     LuminosityBlockPrincipal const& parentPrincipal = iTransitionInfo.principal();
     LuminosityBlockPrincipal& lbp = *inUseLumiPrincipals_[parentPrincipal.index()];
     propagateProducts(InLumi, parentPrincipal, lbp);
  
     std::vector<std::shared_ptr<const EventSetupImpl>> const* eventSetupImpls = iTransitionInfo.eventSetupImpls();
     LumiTransitionInfo transitionInfo(lbp, *((*eventSetupImpls)[esp_->subProcessIndex()]), eventSetupImpls);
     using Traits = OccurrenceTraits<LuminosityBlockPrincipal, BranchActionGlobalEnd>;
     endGlobalTransitionAsync<Traits>(
         std::move(iHolder), *schedule_, transitionInfo, serviceToken_, subProcesses_, cleaningUpAfterException);
   }

References esp_, edm::LumiTransitionInfo::eventSetupImpls(), edm::LuminosityBlockPrincipal::index(), edm::InLumi, inUseLumiPrincipals_, eostools::move(), edm::LumiTransitionInfo::principal(), propagateProducts(), schedule_, serviceToken_, and subProcesses_.

Referenced by edm::subProcessDoGlobalEndTransitionAsync().

◆ doEndProcessBlockAsync()

void edm::SubProcess::doEndProcessBlockAsync	(	WaitingTaskHolder	iHolder,
		ProcessBlockTransitionInfo const &	iTransitionInfo,
		bool	cleaningUpAfterException
	)

Definition at line 442 of file SubProcess.cc.

                                                                          {
     ProcessBlockPrincipal& processBlockPrincipal = principalCache_.processBlockPrincipal();
     ProcessBlockPrincipal const& parentPrincipal = iTransitionInfo.principal();
     propagateProducts(InProcess, parentPrincipal, processBlockPrincipal);
  
     ProcessBlockTransitionInfo transitionInfo(processBlockPrincipal);
     using Traits = OccurrenceTraits<ProcessBlockPrincipal, BranchActionGlobalEnd>;
     endGlobalTransitionAsync<Traits>(
         std::move(iHolder), *schedule_, transitionInfo, serviceToken_, subProcesses_, cleaningUpAfterException);
   }

References edm::InProcess, eostools::move(), edm::ProcessBlockTransitionInfo::principal(), principalCache_, edm::PrincipalCache::processBlockPrincipal(), propagateProducts(), schedule_, serviceToken_, and subProcesses_.

Referenced by edm::subProcessDoGlobalEndTransitionAsync().

◆ doEndRunAsync()

void edm::SubProcess::doEndRunAsync	(	WaitingTaskHolder	iHolder,
		RunTransitionInfo const &	iTransitionInfo,
		bool	cleaningUpAfterException
	)

Definition at line 485 of file SubProcess.cc.

                                                                 {
     RunPrincipal const& parentPrincipal = iTransitionInfo.principal();
     RunPrincipal& rp = *principalCache_.runPrincipalPtr();
     propagateProducts(InRun, parentPrincipal, rp);
  
     RunTransitionInfo transitionInfo(rp, esp_->eventSetupImpl());
     using Traits = OccurrenceTraits<RunPrincipal, BranchActionGlobalEnd>;
     endGlobalTransitionAsync<Traits>(
         std::move(iHolder), *schedule_, transitionInfo, serviceToken_, subProcesses_, cleaningUpAfterException);
   }

References esp_, edm::InRun, eostools::move(), edm::RunTransitionInfo::principal(), principalCache_, propagateProducts(), edm::PrincipalCache::runPrincipalPtr(), schedule_, serviceToken_, and subProcesses_.

Referenced by edm::subProcessDoGlobalEndTransitionAsync().

◆ doEndStream()

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

Definition at line 632 of file SubProcess.cc.

                                                {
     ServiceRegistry::Operate operate(serviceToken_);
     schedule_->endStream(iID);
     for_all(subProcesses_, [iID](auto& subProcess) { subProcess.doEndStream(iID); });
   }

References edm::for_all(), schedule_, serviceToken_, and subProcesses_.

◆ doEventAsync()

void edm::SubProcess::doEventAsync	(	WaitingTaskHolder	iHolder,
		EventPrincipal const &	principal,
		std::vector< std::shared_ptr< const EventSetupImpl >> const *	iEventSetupImpls
	)

Definition at line 339 of file SubProcess.cc.

                                                                                                         {
     ServiceRegistry::Operate operate(serviceToken_);
     /* BEGIN relevant bits from OutputModule::doEvent */
     if (!wantAllEvents_) {
       EventForOutput e(ep, ModuleDescription(), nullptr);
       e.setConsumer(this);
       if (!selectors_.wantEvent(e)) {
         return;
       }
     }
     processAsync(std::move(iHolder), ep, iEventSetupImpls);
     /* END relevant bits from OutputModule::doEvent */
   }

References MillePedeFileConverter_cfg::e, SiStripBadComponentsDQMServiceTemplate_cfg::ep, eostools::move(), processAsync(), selectors_, serviceToken_, wantAllEvents_, and edm::detail::TriggerResultsBasedEventSelector::wantEvent().

◆ doStreamBeginLuminosityBlockAsync()

void edm::SubProcess::doStreamBeginLuminosityBlockAsync	(	WaitingTaskHolder	iHolder,
		unsigned int	iID,
		LumiTransitionInfo const &	iTransitionInfo
	)

Definition at line 660 of file SubProcess.cc.

                                                                                                 {
     using Traits = OccurrenceTraits<LuminosityBlockPrincipal, BranchActionStreamBegin>;
  
     LuminosityBlockPrincipal& lbp = *inUseLumiPrincipals_[iTransitionInfo.principal().index()];
     std::vector<std::shared_ptr<const EventSetupImpl>> const* eventSetupImpls = iTransitionInfo.eventSetupImpls();
     LumiTransitionInfo transitionInfo(lbp, *((*eventSetupImpls)[esp_->subProcessIndex()]), eventSetupImpls);
     beginStreamTransitionAsync<Traits>(
         std::move(iHolder), *schedule_, id, transitionInfo, serviceToken_, subProcesses_);
   }

References esp_, edm::LumiTransitionInfo::eventSetupImpls(), edm::LuminosityBlockPrincipal::index(), inUseLumiPrincipals_, eostools::move(), edm::LumiTransitionInfo::principal(), schedule_, serviceToken_, and subProcesses_.

Referenced by edm::subProcessDoStreamBeginTransitionAsync().

◆ doStreamBeginRunAsync()

void edm::SubProcess::doStreamBeginRunAsync	(	WaitingTaskHolder	iHolder,
		unsigned int	iID,
		RunTransitionInfo const &
	)

Definition at line 638 of file SubProcess.cc.

                                                                                                              {
     using Traits = OccurrenceTraits<RunPrincipal, BranchActionStreamBegin>;
  
     RunPrincipal& rp = *principalCache_.runPrincipalPtr();
  
     RunTransitionInfo transitionInfo(rp, esp_->eventSetupImpl());
     beginStreamTransitionAsync<Traits>(
         std::move(iHolder), *schedule_, id, transitionInfo, serviceToken_, subProcesses_);
   }

References esp_, eostools::move(), principalCache_, edm::PrincipalCache::runPrincipalPtr(), schedule_, serviceToken_, and subProcesses_.

Referenced by edm::subProcessDoStreamBeginTransitionAsync().

◆ doStreamEndLuminosityBlockAsync()

void edm::SubProcess::doStreamEndLuminosityBlockAsync	(	WaitingTaskHolder	iHolder,
		unsigned int	iID,
		LumiTransitionInfo const &	iTransitionInfo,
		bool	cleaningUpAfterException
	)

Definition at line 672 of file SubProcess.cc.

                                                                                   {
     LuminosityBlockPrincipal& lbp = *inUseLumiPrincipals_[iTransitionInfo.principal().index()];
     using Traits = OccurrenceTraits<LuminosityBlockPrincipal, BranchActionStreamEnd>;
     std::vector<std::shared_ptr<const EventSetupImpl>> const* eventSetupImpls = iTransitionInfo.eventSetupImpls();
     LumiTransitionInfo transitionInfo(lbp, *((*eventSetupImpls)[esp_->subProcessIndex()]), eventSetupImpls);
     endStreamTransitionAsync<Traits>(
         std::move(iHolder), *schedule_, id, transitionInfo, serviceToken_, subProcesses_, cleaningUpAfterException);
   }

References esp_, edm::LumiTransitionInfo::eventSetupImpls(), edm::LuminosityBlockPrincipal::index(), inUseLumiPrincipals_, eostools::move(), edm::LumiTransitionInfo::principal(), schedule_, serviceToken_, and subProcesses_.

Referenced by edm::subProcessDoStreamEndTransitionAsync().

◆ doStreamEndRunAsync()

void edm::SubProcess::doStreamEndRunAsync	(	WaitingTaskHolder	iHolder,
		unsigned int	iID,
		RunTransitionInfo const &	,
		bool	cleaningUpAfterException
	)

Definition at line 648 of file SubProcess.cc.

                                                                       {
     RunPrincipal& rp = *principalCache_.runPrincipalPtr();
     using Traits = OccurrenceTraits<RunPrincipal, BranchActionStreamEnd>;
  
     RunTransitionInfo transitionInfo(rp, esp_->eventSetupImpl());
     endStreamTransitionAsync<Traits>(
         std::move(iHolder), *schedule_, id, transitionInfo, serviceToken_, subProcesses_, cleaningUpAfterException);
   }

References esp_, eostools::move(), principalCache_, edm::PrincipalCache::runPrincipalPtr(), schedule_, serviceToken_, and subProcesses_.

Referenced by edm::subProcessDoStreamEndTransitionAsync().

◆ droppedBranchIDToKeptBranchID()

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

inlineprivate

Definition at line 259 of file SubProcess.h.

                                                                                           {
       return droppedBranchIDToKeptBranchID_;
     }

References droppedBranchIDToKeptBranchID_.

Referenced by beginJob(), and fixBranchIDListsForEDAliases().

◆ enableEndPaths()

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 204 of file SubProcess.h.

                                      {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->enableEndPaths(active);
       for_all(subProcesses_, [active](auto& subProcess) { subProcess.enableEndPaths(active); });
     }

References edm::for_all(), schedule_, serviceToken_, and subProcesses_.

◆ endJob()

void edm::SubProcess::endJob ( void )

private

Definition at line 247 of file SubProcess.cc.

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

References HltBtagPostValidation_cff::c, schedule_, serviceToken_, and subProcesses_.

Referenced by doEndJob().

◆ endPathsEnabled()

bool edm::SubProcess::endPathsEnabled ( ) const

inline

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

Definition at line 211 of file SubProcess.h.

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

References schedule_, and serviceToken_.

◆ fixBranchIDListsForEDAliases()

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

private

Definition at line 321 of file SubProcess.cc.

                                                                                            {
     // 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;
         }
       }
     }
     for_all(subProcesses_, [&droppedBranchIDToKeptBranchID](auto& subProcess) {
       subProcess.fixBranchIDListsForEDAliases(droppedBranchIDToKeptBranchID);
     });
   }

References branchIDListHelper_, droppedBranchIDToKeptBranchID(), edm::for_all(), and subProcesses_.

Referenced by beginJob().

◆ getAllModuleDescriptions()

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!

◆ getTriggerReport()

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 218 of file SubProcess.h.

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

References cuy::rep, schedule_, and serviceToken_.

◆ keepThisBranch()

void edm::SubProcess::keepThisBranch	(	BranchDescription const &	desc,
		std::map< BranchID, BranchDescription const * > &	trueBranchIDToKeptBranchDesc,
		std::set< BranchID > &	keptProductsInEvent
	)

private

Definition at line 302 of file SubProcess.cc.

                                                                          {
     ProductSelector::checkForDuplicateKeptBranch(desc, trueBranchIDToKeptBranchDesc);
  
     if (desc.branchType() == InEvent) {
       if (desc.produced()) {
         keptProductsInEvent.insert(desc.originalBranchID());
       } else {
         keptProductsInEvent.insert(desc.branchID());
       }
     }
     EDGetToken token = consumes(TypeToGet{desc.unwrappedTypeID(), PRODUCT_TYPE},
                                 InputTag{desc.moduleLabel(), desc.productInstanceName(), desc.processName()});
  
     // Now put it in the list of selected branches.
     keptProducts_[desc.branchType()].push_back(std::make_pair(&desc, token));
   }

References edm::ProductSelector::checkForDuplicateKeptBranch(), edm::EDConsumerBase::consumes(), submitPVResolutionJobs::desc, edm::InEvent, keptProducts_, edm::PRODUCT_TYPE, and unpackBuffers-CaloStage2::token.

Referenced by selectProducts().

◆ keptProducts()

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

inline

Definition at line 77 of file SubProcess.h.

77 { return keptProducts_; }

References keptProducts_.

Referenced by propagateProducts(), and edm::ScheduleItems::ScheduleItems().

◆ openOutputFiles()

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

inline

Definition at line 145 of file SubProcess.h.

                                         {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->openOutputFiles(fb);
       for_all(subProcesses_, [&fb](auto& subProcess) { subProcess.openOutputFiles(fb); });
     }

References benchmark_cfg::fb, edm::for_all(), schedule_, serviceToken_, and subProcesses_.

◆ operator=() [1/2]

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

delete

◆ operator=() [2/2]

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

delete

◆ processAsync()

void edm::SubProcess::processAsync	(	WaitingTaskHolder	iHolder,
		EventPrincipal const &	e,
		std::vector< std::shared_ptr< const EventSetupImpl >> const *	iEventSetupImpls
	)

private

Definition at line 355 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);
     bool deepCopyRetriever = false;
     ep.fillEventPrincipal(
         aux,
         &principal.processHistory(),
         std::move(esids),
         std::move(bli),
         *(principal.productProvenanceRetrieverPtr()),  //NOTE: this transfers the per product provenance
         principal.reader(),
         deepCopyRetriever);
     ep.setLuminosityBlockPrincipal(inUseLumiPrincipals_[principal.luminosityBlockPrincipal().index()].get());
     propagateProducts(InEvent, principal, ep);
  
     WaitingTaskHolder finalizeEventTask(
         make_waiting_task(tbb::task::allocate_root(), [&ep, iHolder](std::exception_ptr const* iPtr) mutable {
           ep.clearEventPrincipal();
           if (iPtr) {
             iHolder.doneWaiting(*iPtr);
           } else {
             iHolder.doneWaiting(std::exception_ptr());
           }
         }));
     WaitingTaskHolder afterProcessTask;
     if (subProcesses_.empty()) {
       afterProcessTask = std::move(finalizeEventTask);
     } else {
       afterProcessTask = WaitingTaskHolder(
           make_waiting_task(tbb::task::allocate_root(),
                             [this, &ep, finalizeEventTask, iEventSetupImpls](std::exception_ptr const* iPtr) mutable {
                               if (not iPtr) {
                                 for (auto& subProcess : boost::adaptors::reverse(subProcesses_)) {
                                   subProcess.doEventAsync(finalizeEventTask, ep, iEventSetupImpls);
                                 }
                               } else {
                                 finalizeEventTask.doneWaiting(*iPtr);
                               }
                             }));
     }
     EventTransitionInfo info(ep, *((*iEventSetupImpls)[esp_->subProcessIndex()]));
     schedule_->processOneEventAsync(std::move(afterProcessTask), ep.streamID().value(), info, serviceToken_);
   }

References edm::ProductRegistry::anyProductProduced(), printConversionInfo::aux, edm::EventPrincipal::aux(), branchIDListHelper_, edm::EventPrincipal::branchListIndexes(), edm::WaitingTaskHolder::doneWaiting(), SiStripBadComponentsDQMServiceTemplate_cfg::ep, esp_, edm::PrincipalCache::eventPrincipal(), edm::EventPrincipal::eventSelectionIDs(), edm::LuminosityBlockPrincipal::index(), edm::InEvent, info(), inUseLumiPrincipals_, edm::EventPrincipal::luminosityBlockPrincipal(), edm::make_waiting_task(), eostools::move(), principalCache_, edm::Principal::processHistory(), edm::Principal::processHistoryID(), processHistoryRegistries_, edm::EventPrincipal::productProvenanceRetrieverPtr(), edm::Principal::productRegistry(), propagateProducts(), edm::Principal::reader(), groupFilesInBlocks::reverse, schedule_, selector_config_id_, serviceToken_, edm::EventPrincipal::streamID(), subProcesses_, edm::StreamID::value(), and wantAllEvents_.

Referenced by doEventAsync().

◆ propagateProducts()

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

private

Definition at line 684 of file SubProcess.cc.

                                                                                                                   {
     SelectedProducts const& keptVector = keptProducts()[type];
     for (auto const& item : keptVector) {
       BranchDescription const& desc = *item.first;
       ProductResolverBase const* parentProductResolver = parentPrincipal.getProductResolver(desc.branchID());
       if (parentProductResolver != nullptr) {
         ProductResolverBase* productResolver = principal.getModifiableProductResolver(desc.branchID());
         if (productResolver != nullptr) {
           //Propagate the per event(run)(lumi)(processBlock) data for this product to the subprocess.
           productResolver->connectTo(*parentProductResolver, &parentPrincipal);
         }
       }
     }
   }

References edm::ProductResolverBase::connectTo(), submitPVResolutionJobs::desc, edm::Principal::getModifiableProductResolver(), edm::Principal::getProductResolver(), B2GTnPMonitor_cfi::item, and keptProducts().

Referenced by doBeginLuminosityBlockAsync(), doBeginRunAsync(), doEndLuminosityBlockAsync(), doEndProcessBlockAsync(), doEndRunAsync(), and processAsync().

◆ respondToCloseInputFile()

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

inline

Definition at line 157 of file SubProcess.h.

                                                       {
       ServiceRegistry::Operate operate(serviceToken_);
       schedule_->respondToCloseInputFile(fb);
       for_all(subProcesses_, [&fb](auto& subProcess) { subProcess.respondToCloseInputFile(fb); });
     }

References benchmark_cfg::fb, edm::for_all(), schedule_, serviceToken_, and subProcesses_.

◆ respondToOpenInputFile()

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

Definition at line 706 of file SubProcess.cc.

                                                              {
     ServiceRegistry::Operate operate(serviceToken_);
     schedule_->respondToOpenInputFile(fb);
     for_all(subProcesses_, [&fb](auto& subProcess) { subProcess.respondToOpenInputFile(fb); });
   }

References benchmark_cfg::fb, edm::for_all(), schedule_, serviceToken_, and subProcesses_.

◆ selectProducts()

void edm::SubProcess::selectProducts	(	ProductRegistry const &	preg,
		ThinnedAssociationsHelper const &	parentThinnedAssociationsHelper,
		std::map< BranchID, bool > &	keepAssociation
	)

Definition at line 260 of file SubProcess.cc.

                                                                            {
     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;
     std::vector<BranchDescription const*> associationDescriptions;
     std::set<BranchID> keptProductsInEvent;
  
     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 (desc.unwrappedType() == typeid(ThinnedAssociation)) {
         associationDescriptions.push_back(&desc);
       } else if (productSelector_.selected(desc)) {
         keepThisBranch(desc, trueBranchIDToKeptBranchDesc, keptProductsInEvent);
       }
     }
  
     parentThinnedAssociationsHelper.selectAssociationProducts(
         associationDescriptions, keptProductsInEvent, keepAssociation);
  
     for (auto association : associationDescriptions) {
       if (keepAssociation[association->branchID()]) {
         keepThisBranch(*association, trueBranchIDToKeptBranchDesc, keptProductsInEvent);
       }
     }
  
     // Now fill in a mapping needed in the case that a branch was dropped while its EDAlias was kept.
     ProductSelector::fillDroppedToKept(preg, trueBranchIDToKeptBranchDesc, droppedBranchIDToKeptBranchID_);
   }

References edm::ProductRegistry::allBranchDescriptions(), submitPVResolutionJobs::desc, droppedBranchIDToKeptBranchID_, edm::ProductSelector::fillDroppedToKept(), edm::ProductSelector::initialize(), edm::ProductSelector::initialized(), keepThisBranch(), edm::ProductRegistry::productList(), productSelector_, productSelectorRules_, edm::ThinnedAssociationsHelper::selectAssociationProducts(), and edm::ProductSelector::selected().

Referenced by SubProcess().

◆ shouldWeCloseOutput()

bool edm::SubProcess::shouldWeCloseOutput ( ) const

inline

Definition at line 164 of file SubProcess.h.

                                      {
       ServiceRegistry::Operate operate(serviceToken_);
       if (schedule_->shouldWeCloseOutput()) {
         return true;
       }
       for (auto const& subProcess : subProcesses_) {
         if (subProcess.shouldWeCloseOutput()) {
           return true;
         }
       }
       return false;
     }

References schedule_, serviceToken_, and subProcesses_.

◆ terminate()

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 225 of file SubProcess.h.

                            {
       ServiceRegistry::Operate operate(serviceToken_);
       if (schedule_->terminate()) {
         return true;
       }
       for (auto const& subProcess : subProcesses_) {
         if (subProcess.terminate()) {
           return true;
         }
       }
       return false;
     }

References schedule_, serviceToken_, and subProcesses_.

◆ thinnedAssociationsHelper() [1/2]

std::shared_ptr<ThinnedAssociationsHelper> edm::SubProcess::thinnedAssociationsHelper ( )

inlineprivate

Definition at line 270 of file SubProcess.h.

                                                                          {
       return get_underlying_safe(thinnedAssociationsHelper_);
     }

References edm::get_underlying_safe(), and thinnedAssociationsHelper_.

◆ thinnedAssociationsHelper() [2/2]

std::shared_ptr<ThinnedAssociationsHelper const> edm::SubProcess::thinnedAssociationsHelper ( ) const

inlineprivate

Definition at line 267 of file SubProcess.h.

                                                                                      {
       return get_underlying_safe(thinnedAssociationsHelper_);
     }

References edm::get_underlying_safe(), and thinnedAssociationsHelper_.

Referenced by SubProcess().

◆ totalEvents()

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 187 of file SubProcess.h.

187 { return schedule_->totalEvents(); }

References schedule_.

◆ totalEventsFailed()

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 197 of file SubProcess.h.

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

References schedule_, and serviceToken_.

◆ totalEventsPassed()

int edm::SubProcess::totalEventsPassed ( ) const

inline

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

Definition at line 190 of file SubProcess.h.

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

References schedule_, and serviceToken_.

◆ updateBranchIDListHelper()

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

Definition at line 699 of file SubProcess.cc.

                                                                               {
     branchIDListHelper_->updateFromParent(branchIDLists);
     for_all(subProcesses_,
             [this](auto& subProcess) { subProcess.updateBranchIDListHelper(branchIDListHelper_->branchIDLists()); });
   }

References branchIDListHelper_, edm::for_all(), and subProcesses_.

Referenced by SubProcess().

◆ writeLumiAsync()

void edm::SubProcess::writeLumiAsync	(	WaitingTaskHolder	task,
		LuminosityBlockPrincipal &	principal
	)

Definition at line 599 of file SubProcess.cc.

                                                                                              {
     ServiceRegistry::Operate operate(serviceToken_);
  
     auto l = inUseLumiPrincipals_[principal.index()];
     auto subTasks =
         edm::make_waiting_task(tbb::task::allocate_root(), [this, l, task](std::exception_ptr const* iExcept) mutable {
           if (iExcept) {
             task.doneWaiting(*iExcept);
           } else {
             ServiceRegistry::Operate operateWriteLumi(serviceToken_);
             for (auto& s : subProcesses_) {
               s.writeLumiAsync(task, *l);
             }
           }
         });
     schedule_->writeLumiAsync(WaitingTaskHolder(subTasks), *l, &processContext_, actReg_.get());
   }

References actReg_, edm::LuminosityBlockPrincipal::index(), inUseLumiPrincipals_, cmsLHEtoEOSManager::l, edm::make_waiting_task(), processContext_, alignCSCRings::s, schedule_, serviceToken_, subProcesses_, and TrackValidation_cff::task.

◆ writeProcessBlockAsync()

void edm::SubProcess::writeProcessBlockAsync	(	edm::WaitingTaskHolder	task,
		ProcessBlockType	processBlockType
	)

Definition at line 498 of file SubProcess.cc.

                                                                                                       {
     ServiceRegistry::Operate operate(serviceToken_);
  
     auto subTasks = edm::make_waiting_task(tbb::task::allocate_root(),
                                            [this, task, processBlockType](std::exception_ptr const* iExcept) mutable {
                                              if (iExcept) {
                                                task.doneWaiting(*iExcept);
                                              } else {
                                                ServiceRegistry::Operate operate(serviceToken_);
                                                for (auto& s : subProcesses_) {
                                                  s.writeProcessBlockAsync(task, processBlockType);
                                                }
                                              }
                                            });
     schedule_->writeProcessBlockAsync(WaitingTaskHolder(subTasks),
                                       principalCache_.processBlockPrincipal(processBlockType),
                                       &processContext_,
                                       actReg_.get());
   }

References actReg_, edm::make_waiting_task(), principalCache_, edm::PrincipalCache::processBlockPrincipal(), processContext_, alignCSCRings::s, schedule_, serviceToken_, subProcesses_, and TrackValidation_cff::task.

◆ writeRunAsync()

void edm::SubProcess::writeRunAsync	(	edm::WaitingTaskHolder	task,
		ProcessHistoryID const &	parentPhID,
		int	runNumber,
		MergeableRunProductMetadata const *	mergeableRunProductMetadata
	)

Definition at line 518 of file SubProcess.cc.

                                                                                                  {
     ServiceRegistry::Operate operate(serviceToken_);
     std::map<ProcessHistoryID, ProcessHistoryID>::const_iterator it = parentToChildPhID_.find(parentPhID);
     assert(it != parentToChildPhID_.end());
     auto const& childPhID = it->second;
  
     auto subTasks = edm::make_waiting_task(
         tbb::task::allocate_root(),
         [this, childPhID, runNumber, task, mergeableRunProductMetadata](std::exception_ptr const* iExcept) mutable {
           if (iExcept) {
             task.doneWaiting(*iExcept);
           } else {
             ServiceRegistry::Operate operateWriteRun(serviceToken_);
             for (auto& s : subProcesses_) {
               s.writeRunAsync(task, childPhID, runNumber, mergeableRunProductMetadata);
             }
           }
         });
     schedule_->writeRunAsync(WaitingTaskHolder(subTasks),
                              principalCache_.runPrincipal(childPhID, runNumber),
                              &processContext_,
                              actReg_.get(),
                              mergeableRunProductMetadata);
   }

References actReg_, cms::cuda::assert(), edm::make_waiting_task(), parentToChildPhID_, principalCache_, processContext_, convertSQLiteXML::runNumber, edm::PrincipalCache::runPrincipal(), alignCSCRings::s, schedule_, serviceToken_, subProcesses_, and TrackValidation_cff::task.

Member Data Documentation

◆ act_table_

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

private

Definition at line 281 of file SubProcess.h.

Referenced by SubProcess().

◆ actReg_

std::shared_ptr<ActivityRegistry> edm::SubProcess::actReg_

private

Definition at line 274 of file SubProcess.h.

Referenced by beginJob(), SubProcess(), writeLumiAsync(), writeProcessBlockAsync(), and writeRunAsync().

◆ branchIDListHelper_

edm::propagate_const<std::shared_ptr<BranchIDListHelper> > edm::SubProcess::branchIDListHelper_

private

Definition at line 278 of file SubProcess.h.

Referenced by branchIDListHelper(), fixBranchIDListsForEDAliases(), processAsync(), SubProcess(), and updateBranchIDListHelper().

◆ droppedBranchIDToKeptBranchID_

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

private

Definition at line 315 of file SubProcess.h.

Referenced by droppedBranchIDToKeptBranchID(), selectProducts(), and SubProcess().

◆ esp_

edm::propagate_const<std::shared_ptr<eventsetup::EventSetupProvider> > edm::SubProcess::esp_

private

Definition at line 294 of file SubProcess.h.

Referenced by beginJob(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), doEndLuminosityBlockAsync(), doEndRunAsync(), doStreamBeginLuminosityBlockAsync(), doStreamBeginRunAsync(), doStreamEndLuminosityBlockAsync(), doStreamEndRunAsync(), processAsync(), and SubProcess().

◆ historyAppenders_

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

private

Definition at line 290 of file SubProcess.h.

Referenced by doBeginRunAsync(), and SubProcess().

◆ historyLumiOffset_

unsigned int edm::SubProcess::historyLumiOffset_

private

Definition at line 287 of file SubProcess.h.

Referenced by doBeginLuminosityBlockAsync(), and SubProcess().

◆ historyRunOffset_

unsigned int edm::SubProcess::historyRunOffset_

private

Definition at line 288 of file SubProcess.h.

Referenced by doBeginRunAsync(), and SubProcess().

◆ inUseLumiPrincipals_

std::vector<std::shared_ptr<LuminosityBlockPrincipal> > edm::SubProcess::inUseLumiPrincipals_

private

Definition at line 293 of file SubProcess.h.

Referenced by deleteLumiFromCache(), doBeginLuminosityBlockAsync(), doEndLuminosityBlockAsync(), doStreamBeginLuminosityBlockAsync(), doStreamEndLuminosityBlockAsync(), processAsync(), SubProcess(), and writeLumiAsync().

◆ keptProducts_

SelectedProductsForBranchType edm::SubProcess::keptProducts_

private

Definition at line 304 of file SubProcess.h.

Referenced by keepThisBranch(), and keptProducts().

◆ parentPreg_

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

private

Definition at line 276 of file SubProcess.h.

Referenced by beginJob().

◆ parentToChildPhID_

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

private

Definition at line 296 of file SubProcess.h.

Referenced by deleteRunFromCache(), doBeginRunAsync(), and writeRunAsync().

◆ pathsAndConsumesOfModules_

PathsAndConsumesOfModules edm::SubProcess::pathsAndConsumesOfModules_

private

Definition at line 284 of file SubProcess.h.

Referenced by beginJob().

◆ preg_

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

private

Definition at line 277 of file SubProcess.h.

Referenced by beginJob(), doBeginRunAsync(), and SubProcess().

◆ principalCache_

PrincipalCache edm::SubProcess::principalCache_

private

Definition at line 291 of file SubProcess.h.

Referenced by clearProcessBlockPrincipal(), deleteRunFromCache(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), doEndProcessBlockAsync(), doEndRunAsync(), doStreamBeginRunAsync(), doStreamEndRunAsync(), processAsync(), SubProcess(), writeProcessBlockAsync(), and writeRunAsync().

◆ processConfiguration_

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

private

Definition at line 282 of file SubProcess.h.

Referenced by beginJob(), doBeginRunAsync(), and SubProcess().

◆ processContext_

ProcessContext edm::SubProcess::processContext_

private

Definition at line 283 of file SubProcess.h.

Referenced by beginJob(), SubProcess(), writeLumiAsync(), writeProcessBlockAsync(), and writeRunAsync().

◆ processHistoryRegistries_

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

private

Definition at line 289 of file SubProcess.h.

Referenced by doBeginLuminosityBlockAsync(), doBeginRunAsync(), processAsync(), and SubProcess().

◆ processParameterSet_

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

private

Definition at line 298 of file SubProcess.h.

Referenced by SubProcess().

◆ productSelector_

ProductSelector edm::SubProcess::productSelector_

private

Definition at line 306 of file SubProcess.h.

Referenced by selectProducts().

◆ productSelectorRules_

ProductSelectorRules edm::SubProcess::productSelectorRules_

private

Definition at line 305 of file SubProcess.h.

Referenced by selectProducts().

◆ schedule_

edm::propagate_const<std::unique_ptr<Schedule> > edm::SubProcess::schedule_

private

Definition at line 295 of file SubProcess.h.

Referenced by Config.Process::_insertPaths(), Config.Process::_replaceInSchedule(), beginJob(), clearCounters(), closeOutputFiles(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), doBeginStream(), doEndLuminosityBlockAsync(), doEndProcessBlockAsync(), doEndRunAsync(), doEndStream(), doStreamBeginLuminosityBlockAsync(), doStreamBeginRunAsync(), doStreamEndLuminosityBlockAsync(), doStreamEndRunAsync(), Config.Process::dumpPython(), enableEndPaths(), endJob(), endPathsEnabled(), getTriggerReport(), openOutputFiles(), processAsync(), Config.Process::prune(), Config.Process::resolve(), respondToCloseInputFile(), respondToOpenInputFile(), shouldWeCloseOutput(), Config.Process::splitPython(), SubProcess(), terminate(), totalEvents(), totalEventsFailed(), totalEventsPassed(), writeLumiAsync(), writeProcessBlockAsync(), and writeRunAsync().

◆ selector_config_id_

ParameterSetID edm::SubProcess::selector_config_id_

private

Definition at line 310 of file SubProcess.h.

Referenced by processAsync(), and SubProcess().

◆ selectors_

detail::TriggerResultsBasedEventSelector edm::SubProcess::selectors_

mutableprivate

Definition at line 311 of file SubProcess.h.

Referenced by doEventAsync(), and SubProcess().

◆ serviceToken_

◆ subProcesses_

std::vector<SubProcess> edm::SubProcess::subProcesses_

private

Definition at line 297 of file SubProcess.h.

Referenced by beginJob(), clearCounters(), clearProcessBlockPrincipal(), closeOutputFiles(), deleteLumiFromCache(), deleteRunFromCache(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), doBeginStream(), doEndLuminosityBlockAsync(), doEndProcessBlockAsync(), doEndRunAsync(), doEndStream(), doStreamBeginLuminosityBlockAsync(), doStreamBeginRunAsync(), doStreamEndLuminosityBlockAsync(), doStreamEndRunAsync(), Config.Process::dumpConfig(), Config.Process::dumpPython(), enableEndPaths(), endJob(), fixBranchIDListsForEDAliases(), openOutputFiles(), processAsync(), respondToCloseInputFile(), respondToOpenInputFile(), shouldWeCloseOutput(), Config.Process::splitPython(), SubProcess(), terminate(), updateBranchIDListHelper(), writeLumiAsync(), writeProcessBlockAsync(), and writeRunAsync().

◆ subProcessParentageHelper_

edm::propagate_const<std::shared_ptr<SubProcessParentageHelper> > edm::SubProcess::subProcessParentageHelper_

private

Definition at line 280 of file SubProcess.h.

Referenced by SubProcess().

◆ thinnedAssociationsHelper_

edm::propagate_const<std::shared_ptr<ThinnedAssociationsHelper> > edm::SubProcess::thinnedAssociationsHelper_

private

Definition at line 279 of file SubProcess.h.

Referenced by SubProcess(), and thinnedAssociationsHelper().

◆ wantAllEvents_

bool edm::SubProcess::wantAllEvents_

private

Definition at line 309 of file SubProcess.h.

Referenced by doEventAsync(), processAsync(), and SubProcess().

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ ProcessBlockType

Constructor & Destructor Documentation

◆ SubProcess() [1/3]

◆ ~SubProcess()

◆ SubProcess() [2/3]

◆ SubProcess() [3/3]

Member Function Documentation

◆ beginJob()

◆ branchIDListHelper() [1/2]

◆ branchIDListHelper() [2/2]

◆ clearCounters()

◆ clearProcessBlockPrincipal()

◆ closeOutputFiles()

◆ deleteLumiFromCache()

◆ deleteRunFromCache()

◆ doBeginJob()

◆ doBeginLuminosityBlockAsync()

◆ doBeginProcessBlockAsync() [1/3]

◆ doBeginProcessBlockAsync() [2/3]

◆ doBeginProcessBlockAsync() [3/3]

◆ doBeginRunAsync()

◆ doBeginStream()

◆ doEndJob()

◆ doEndLuminosityBlockAsync()

◆ doEndProcessBlockAsync()

◆ doEndRunAsync()

◆ doEndStream()

◆ doEventAsync()

◆ doStreamBeginLuminosityBlockAsync()

◆ doStreamBeginRunAsync()

◆ doStreamEndLuminosityBlockAsync()

◆ doStreamEndRunAsync()

◆ droppedBranchIDToKeptBranchID()

◆ enableEndPaths()

◆ endJob()

◆ endPathsEnabled()

◆ fixBranchIDListsForEDAliases()

◆ getAllModuleDescriptions()

◆ getTriggerReport()

◆ keepThisBranch()

◆ keptProducts()

◆ openOutputFiles()

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ processAsync()

◆ propagateProducts()

◆ respondToCloseInputFile()

◆ respondToOpenInputFile()

◆ selectProducts()

◆ shouldWeCloseOutput()

◆ terminate()

◆ thinnedAssociationsHelper() [1/2]

◆ thinnedAssociationsHelper() [2/2]

◆ totalEvents()

◆ totalEventsFailed()

◆ totalEventsPassed()

◆ updateBranchIDListHelper()

◆ writeLumiAsync()

◆ writeProcessBlockAsync()

◆ writeRunAsync()

Member Data Documentation

◆ act_table_

◆ actReg_

◆ branchIDListHelper_

◆ droppedBranchIDToKeptBranchID_

◆ esp_

◆ historyAppenders_

◆ historyLumiOffset_

◆ historyRunOffset_

◆ inUseLumiPrincipals_

◆ keptProducts_

◆ parentPreg_

◆ parentToChildPhID_