#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 | doBeginLuminosityBlockAsync (WaitingTaskHolder iHolder, LuminosityBlockPrincipal const &principal, IOVSyncValue const &ts) |
void | doBeginRun (RunPrincipal const &principal, IOVSyncValue const &ts) |
void | doBeginRunAsync (WaitingTaskHolder iHolder, 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 | doEventAsync (WaitingTaskHolder iHolder, EventPrincipal const &principal) |
void | doStreamBeginLuminosityBlock (unsigned int iID, LuminosityBlockPrincipal const &principal, IOVSyncValue const &ts) |
void | doStreamBeginLuminosityBlockAsync (WaitingTaskHolder iHolder, unsigned int iID, LuminosityBlockPrincipal const &principal, IOVSyncValue const &ts) |
void | doStreamBeginRun (unsigned int iID, RunPrincipal const &principal, IOVSyncValue const &ts) |
void | doStreamBeginRunAsync (WaitingTaskHolder iHolder, unsigned int iID, RunPrincipal const &principal, IOVSyncValue const &ts) |
void | doStreamEndLuminosityBlock (unsigned int iID, LuminosityBlockPrincipal const &principal, IOVSyncValue const &ts, bool cleaningUpAfterException) |
void | doStreamEndLuminosityBlockAsync (WaitingTaskHolder iHolder, 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 | doStreamEndRunAsync (WaitingTaskHolder iHolder, 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 |
SubProcess & | operator= (SubProcess &&)=default |
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, ThinnedAssociationsHelper const &parentThinnedAssociationsHelper, std::map< BranchID, bool > &keepAssociation) |
bool | shouldWeCloseOutput () const |
SubProcess (ParameterSet ¶meterSet, 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 const &)=delete | |
SubProcess (SubProcess &&)=default | |
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 () |
Public Member Functions inherited from edm::EDConsumerBase | |
std::vector< ConsumesInfo > | consumesInfo () const |
EDConsumerBase () | |
EDConsumerBase (EDConsumerBase const &)=delete | |
EDConsumerBase (EDConsumerBase &&)=default | |
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 const & | operator= (EDConsumerBase const &)=delete |
EDConsumerBase & | operator= (EDConsumerBase &&)=default |
bool | registeredToConsume (ProductResolverIndex, bool, BranchType) const |
bool | registeredToConsumeMany (TypeID const &, BranchType) const |
void | updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet) |
virtual | ~EDConsumerBase () noexcept(false) |
Additional Inherited Members | |
Public Types inherited from edm::EDConsumerBase | |
typedef ProductLabels | Labels |
Protected Member Functions inherited from edm::EDConsumerBase | |
template<typename ProductType , BranchType B = InEvent> | |
EDGetTokenT< ProductType > | consumes (edm::InputTag const &tag) |
EDGetToken | consumes (const TypeToGet &id, edm::InputTag const &tag) |
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 ProductType , BranchType B = InEvent> | |
EDGetTokenT< ProductType > | mayConsume (edm::InputTag const &tag) |
EDGetToken | mayConsume (const TypeToGet &id, edm::InputTag const &tag) |
template<BranchType B> | |
EDGetToken | mayConsume (const TypeToGet &id, edm::InputTag const &tag) |
Definition at line 43 of file SubProcess.h.
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 44 of file SubProcess.cc.
References edm::ScheduleItems::act_table_, act_table_, edm::ScheduleItems::actReg_, actReg_, edm::ScheduleItems::addCPRandTNS(), edm::ScheduleItems::branchIDListHelper(), branchIDListHelper(), branchIDListHelper_, edm::detail::configureEventSelector(), edm::ActivityRegistry::connectToSubProcess(), edm::EDConsumerBase::consumesCollector(), droppedBranchIDToKeptBranchID_, esp_, edm::ParameterSet::exists(), edm::getAllTriggerNames(), edm::ParameterSet::getUntrackedParameterSet(), historyAppenders_, historyRunOffset_, diffTreeTool::index, edm::ScheduleItems::initMisc(), edm::ScheduleItems::initSchedule(), edm::ScheduleItems::initServices(), edm::PrincipalCache::insert(), mps_monitormerge::items, edm::eventsetup::EventSetupsController::makeProvider(), Data_TkAlMuonIsolated_Run2015B_PromptReco_v1_cff::maxEvents, eostools::move(), edm::PreallocationConfiguration::numberOfStreams(), cmsPerfStripChart::operate(), edm::ParameterSet::popParameterSet(), edm::popSubProcessVParameterSet(), edm::ScheduleItems::preg(), preg_, principalCache_, edm::ScheduleItems::processConfiguration(), 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, subProcesses_, edm::ScheduleItems::subProcessParentageHelper(), subProcessParentageHelper_, edm::ScheduleItems::thinnedAssociationsHelper(), thinnedAssociationsHelper(), thinnedAssociationsHelper_, ull, updateBranchIDListHelper(), and wantAllEvents_.
|
virtual |
Definition at line 205 of file SubProcess.cc.
|
delete |
|
default |
|
private |
Definition at line 219 of file SubProcess.cc.
References actReg_, edm::checkForModuleDependencyCorrectness(), droppedBranchIDToKeptBranchID(), fixBranchIDListsForEDAliases(), edm::for_all(), edm::InEvent, edm::PathsAndConsumesOfModules::initialize(), cmsPerfStripChart::operate(), parentPreg_, pathsAndConsumesOfModules_, preg_, processContext_, schedule_, serviceToken_, subProcesses_, and edm::EDConsumerBase::updateLookup().
Referenced by doBeginJob().
|
private |
Definition at line 509 of file SubProcess.cc.
References printConversionInfo::aux, edm::LuminosityBlockPrincipal::aux(), esp_, edm::for_all(), historyAppenders_, historyLumiOffset_, edm::LuminosityBlockPrincipal::index(), edm::InLumi, edm::PrincipalCache::insert(), edm::PrincipalCache::lumiPrincipalPtr(), preg_, principalCache_, processConfiguration_, edm::Principal::processHistory(), edm::Principal::processHistoryID(), processHistoryRegistries_, propagateProducts(), edm::Principal::reader(), edm::PrincipalCache::runPrincipalPtr(), schedule_, and subProcesses_.
Referenced by doBeginLuminosityBlock().
|
private |
Definition at line 416 of file SubProcess.cc.
References printConversionInfo::aux, edm::RunPrincipal::aux(), esp_, edm::for_all(), historyAppenders_, historyRunOffset_, edm::RunPrincipal::index(), edm::InRun, edm::PrincipalCache::insert(), parentToChildPhID_, preg_, principalCache_, processConfiguration_, edm::Principal::processHistory(), edm::Principal::processHistoryID(), processHistoryRegistries_, propagateProducts(), edm::Principal::reader(), edm::RunPrincipal::reducedProcessHistoryID(), edm::PrincipalCache::runPrincipalPtr(), schedule_, and subProcesses_.
Referenced by doBeginRun().
|
inlineprivate |
Definition at line 275 of file SubProcess.h.
References edm::get_underlying_safe().
Referenced by SubProcess().
|
inlineprivate |
Definition at line 276 of file SubProcess.h.
References edm::get_underlying_safe().
|
inline |
Clear all the counters in the trigger report.
Definition at line 250 of file SubProcess.h.
References bk::beginJob(), MillePedeFileConverter_cfg::e, Ecal2004TBTDCRanges_v1_cff::endRun, edm::for_all(), cmsPerfStripChart::operate(), and alignCSCRings::r.
|
inline |
Definition at line 128 of file SubProcess.h.
References edm::for_all(), and cmsPerfStripChart::operate().
void edm::SubProcess::deleteLumiFromCache | ( | ProcessHistoryID const & | parentPhID, |
int | runNumber, | ||
int | lumiNumber | ||
) |
Definition at line 576 of file SubProcess.cc.
References edm::PrincipalCache::deleteLumi(), edm::for_all(), parentToChildPhID_, principalCache_, and subProcesses_.
void edm::SubProcess::deleteRunFromCache | ( | ProcessHistoryID const & | parentPhID, |
int | runNumber | ||
) |
Definition at line 494 of file SubProcess.cc.
References edm::PrincipalCache::deleteRun(), edm::for_all(), parentToChildPhID_, principalCache_, and subProcesses_.
void edm::SubProcess::doBeginJob | ( | ) |
void edm::SubProcess::doBeginLuminosityBlock | ( | LuminosityBlockPrincipal const & | principal, |
IOVSyncValue const & | ts | ||
) |
Definition at line 503 of file SubProcess.cc.
References beginLuminosityBlock(), cmsPerfStripChart::operate(), and serviceToken_.
void edm::SubProcess::doBeginLuminosityBlockAsync | ( | WaitingTaskHolder | iHolder, |
LuminosityBlockPrincipal const & | principal, | ||
IOVSyncValue const & | ts | ||
) |
Definition at line 526 of file SubProcess.cc.
References printConversionInfo::aux, edm::LuminosityBlockPrincipal::aux(), esp_, historyAppenders_, historyLumiOffset_, edm::LuminosityBlockPrincipal::index(), edm::InLumi, edm::PrincipalCache::insert(), edm::PrincipalCache::lumiPrincipalPtr(), eostools::move(), cmsPerfStripChart::operate(), preg_, principalCache_, processConfiguration_, edm::Principal::processHistory(), edm::Principal::processHistoryID(), processHistoryRegistries_, propagateProducts(), edm::Principal::reader(), edm::PrincipalCache::runPrincipalPtr(), schedule_, serviceToken_, and subProcesses_.
Referenced by edm::subProcessDoGlobalBeginTransitionAsync().
void edm::SubProcess::doBeginRun | ( | RunPrincipal const & | principal, |
IOVSyncValue const & | ts | ||
) |
Definition at line 410 of file SubProcess.cc.
References beginRun(), cmsPerfStripChart::operate(), and serviceToken_.
void edm::SubProcess::doBeginRunAsync | ( | WaitingTaskHolder | iHolder, |
RunPrincipal const & | principal, | ||
IOVSyncValue const & | ts | ||
) |
Definition at line 438 of file SubProcess.cc.
References printConversionInfo::aux, edm::RunPrincipal::aux(), esp_, historyAppenders_, historyRunOffset_, edm::RunPrincipal::index(), edm::InRun, edm::PrincipalCache::insert(), eostools::move(), cmsPerfStripChart::operate(), parentToChildPhID_, preg_, 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().
void edm::SubProcess::doBeginStream | ( | unsigned int | iID | ) |
Definition at line 585 of file SubProcess.cc.
References edm::for_all(), cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcesses_.
void edm::SubProcess::doEndJob | ( | ) |
Definition at line 213 of file SubProcess.cc.
References endJob().
Referenced by edm::EventProcessor::endJob().
void edm::SubProcess::doEndLuminosityBlock | ( | LuminosityBlockPrincipal const & | principal, |
IOVSyncValue const & | ts, | ||
bool | cleaningUpAfterException | ||
) |
Definition at line 549 of file SubProcess.cc.
References endLuminosityBlock(), cmsPerfStripChart::operate(), and serviceToken_.
void edm::SubProcess::doEndRun | ( | RunPrincipal const & | principal, |
IOVSyncValue const & | ts, | ||
bool | cleaningUpAfterException | ||
) |
Definition at line 467 of file SubProcess.cc.
References endRun(), cmsPerfStripChart::operate(), and serviceToken_.
void edm::SubProcess::doEndStream | ( | unsigned int | iID | ) |
Definition at line 592 of file SubProcess.cc.
References edm::for_all(), cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcesses_.
void edm::SubProcess::doEventAsync | ( | WaitingTaskHolder | iHolder, |
EventPrincipal const & | principal | ||
) |
Definition at line 333 of file SubProcess.cc.
References MillePedeFileConverter_cfg::e, eostools::move(), cmsPerfStripChart::operate(), processAsync(), selectors_, serviceToken_, edm::OccurrenceForOutput::setConsumer(), wantAllEvents_, and edm::detail::TriggerResultsBasedEventSelector::wantEvent().
void edm::SubProcess::doStreamBeginLuminosityBlock | ( | unsigned int | iID, |
LuminosityBlockPrincipal const & | principal, | ||
IOVSyncValue const & | ts | ||
) |
Definition at line 657 of file SubProcess.cc.
References esp_, edm::for_all(), hcalTTPDigis_cfi::id, edm::PrincipalCache::lumiPrincipalPtr(), cmsPerfStripChart::operate(), principalCache_, schedule_, serviceToken_, and subProcesses_.
void edm::SubProcess::doStreamBeginLuminosityBlockAsync | ( | WaitingTaskHolder | iHolder, |
unsigned int | iID, | ||
LuminosityBlockPrincipal const & | principal, | ||
IOVSyncValue const & | ts | ||
) |
Definition at line 667 of file SubProcess.cc.
References esp_, hcalTTPDigis_cfi::id, edm::PrincipalCache::lumiPrincipalPtr(), eostools::move(), cmsPerfStripChart::operate(), principalCache_, schedule_, serviceToken_, and subProcesses_.
Referenced by edm::subProcessDoStreamBeginTransitionAsync().
void edm::SubProcess::doStreamBeginRun | ( | unsigned int | iID, |
RunPrincipal const & | principal, | ||
IOVSyncValue const & | ts | ||
) |
Definition at line 599 of file SubProcess.cc.
References esp_, edm::for_all(), hcalTTPDigis_cfi::id, cmsPerfStripChart::operate(), principalCache_, edm::PrincipalCache::runPrincipalPtr(), schedule_, serviceToken_, and subProcesses_.
void edm::SubProcess::doStreamBeginRunAsync | ( | WaitingTaskHolder | iHolder, |
unsigned int | iID, | ||
RunPrincipal const & | principal, | ||
IOVSyncValue const & | ts | ||
) |
Definition at line 609 of file SubProcess.cc.
References esp_, hcalTTPDigis_cfi::id, eostools::move(), cmsPerfStripChart::operate(), principalCache_, edm::PrincipalCache::runPrincipalPtr(), schedule_, serviceToken_, and subProcesses_.
Referenced by edm::subProcessDoStreamBeginTransitionAsync().
void edm::SubProcess::doStreamEndLuminosityBlock | ( | unsigned int | iID, |
LuminosityBlockPrincipal const & | principal, | ||
IOVSyncValue const & | ts, | ||
bool | cleaningUpAfterException | ||
) |
Definition at line 687 of file SubProcess.cc.
References esp_, edm::for_all(), hcalTTPDigis_cfi::id, edm::PrincipalCache::lumiPrincipalPtr(), cmsPerfStripChart::operate(), principalCache_, schedule_, serviceToken_, and subProcesses_.
void edm::SubProcess::doStreamEndLuminosityBlockAsync | ( | WaitingTaskHolder | iHolder, |
unsigned int | iID, | ||
LuminosityBlockPrincipal const & | principal, | ||
IOVSyncValue const & | ts, | ||
bool | cleaningUpAfterException | ||
) |
Definition at line 698 of file SubProcess.cc.
References esp_, hcalTTPDigis_cfi::id, edm::PrincipalCache::lumiPrincipalPtr(), eostools::move(), cmsPerfStripChart::operate(), principalCache_, schedule_, serviceToken_, and subProcesses_.
Referenced by edm::subProcessDoStreamEndTransitionAsync().
void edm::SubProcess::doStreamEndRun | ( | unsigned int | iID, |
RunPrincipal const & | principal, | ||
IOVSyncValue const & | ts, | ||
bool | cleaningUpAfterException | ||
) |
Definition at line 629 of file SubProcess.cc.
References esp_, edm::for_all(), hcalTTPDigis_cfi::id, cmsPerfStripChart::operate(), principalCache_, edm::PrincipalCache::runPrincipalPtr(), schedule_, serviceToken_, and subProcesses_.
void edm::SubProcess::doStreamEndRunAsync | ( | WaitingTaskHolder | iHolder, |
unsigned int | iID, | ||
RunPrincipal const & | principal, | ||
IOVSyncValue const & | ts, | ||
bool | cleaningUpAfterException | ||
) |
Definition at line 640 of file SubProcess.cc.
References esp_, hcalTTPDigis_cfi::id, eostools::move(), cmsPerfStripChart::operate(), principalCache_, edm::PrincipalCache::runPrincipalPtr(), schedule_, serviceToken_, and subProcesses_.
Referenced by edm::subProcessDoStreamEndTransitionAsync().
|
inlineprivate |
Definition at line 271 of file SubProcess.h.
Referenced by beginJob().
|
inline |
Turn end_paths "off" if "active" is false; Turn end_paths "on" if "active" is true.
Definition at line 215 of file SubProcess.h.
References edm::for_all(), and cmsPerfStripChart::operate().
|
private |
Definition at line 239 of file SubProcess.cc.
References EnergyCorrector::c, edm::ExceptionCollector::call(), edm::ExceptionCollector::hasThrown(), cmsPerfStripChart::operate(), edm::ExceptionCollector::rethrow(), schedule_, serviceToken_, and subProcesses_.
Referenced by doEndJob().
|
private |
Definition at line 555 of file SubProcess.cc.
References esp_, edm::for_all(), edm::InLumi, edm::PrincipalCache::lumiPrincipalPtr(), principalCache_, propagateProducts(), schedule_, edm::Principal::setAtEndTransition(), edm::LuminosityBlockPrincipal::setComplete(), and subProcesses_.
Referenced by doEndLuminosityBlock().
|
inline |
Return true if end_paths are active, and false if they are inactive.
Definition at line 222 of file SubProcess.h.
References cmsPerfStripChart::operate().
|
private |
Definition at line 473 of file SubProcess.cc.
References esp_, edm::for_all(), edm::InRun, principalCache_, propagateProducts(), edm::PrincipalCache::runPrincipalPtr(), schedule_, edm::Principal::setAtEndTransition(), edm::RunPrincipal::setComplete(), and subProcesses_.
Referenced by doEndRun().
|
private |
Definition at line 318 of file SubProcess.cc.
References branchIDListHelper_, edm::for_all(), and subProcesses_.
Referenced by beginJob().
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!
|
inline |
Return the trigger report information on paths, modules-in-path, modules-in-endpath, and modules.
Definition at line 229 of file SubProcess.h.
References cmsPerfStripChart::operate().
|
private |
Definition at line 294 of file SubProcess.cc.
References edm::BranchDescription::branchID(), edm::BranchDescription::branchType(), edm::ProductSelector::checkForDuplicateKeptBranch(), edm::EDConsumerBase::consumes(), edm::InEvent, keptProducts_, edm::BranchDescription::moduleLabel(), edm::BranchDescription::originalBranchID(), edm::BranchDescription::processName(), edm::BranchDescription::produced(), edm::PRODUCT_TYPE, edm::BranchDescription::productInstanceName(), and edm::BranchDescription::unwrappedTypeID().
Referenced by selectProducts().
|
inline |
Definition at line 70 of file SubProcess.h.
References cmsRelvalreport::principal(), and convertSQLiteXML::runNumber.
Referenced by propagateProducts(), and edm::ScheduleItems::ScheduleItems().
|
inline |
Definition at line 135 of file SubProcess.h.
References edm::for_all(), and cmsPerfStripChart::operate().
|
inline |
Definition at line 142 of file SubProcess.h.
References benchmark_cfg::fb, edm::for_all(), and cmsPerfStripChart::operate().
|
delete |
|
default |
|
inline |
Definition at line 180 of file SubProcess.h.
References edm::for_all(), and cmsPerfStripChart::operate().
|
inline |
Definition at line 174 of file SubProcess.h.
References edm::for_all(), and cmsPerfStripChart::operate().
|
private |
Definition at line 349 of file SubProcess.cc.
References edm::ProductRegistry::anyProductProduced(), printConversionInfo::aux, edm::EventPrincipal::aux(), branchIDListHelper_, edm::EventPrincipal::branchListIndexes(), edm::EventPrincipal::clearEventPrincipal(), edm::WaitingTaskHolder::doneWaiting(), esp_, edm::PrincipalCache::eventPrincipal(), edm::EventPrincipal::eventSelectionIDs(), edm::EventPrincipal::fillEventPrincipal(), edm::InEvent, edm::PrincipalCache::lumiPrincipalPtr(), 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_, edm::EventPrincipal::setLuminosityBlockPrincipal(), edm::EventPrincipal::streamID(), subProcesses_, edm::StreamID::value(), and wantAllEvents_.
Referenced by doEventAsync().
|
private |
Definition at line 716 of file SubProcess.cc.
References edm::BranchDescription::branchID(), edm::ProductResolverBase::connectTo(), edm::Principal::getModifiableProductResolver(), edm::Principal::getProductResolver(), and keptProducts().
Referenced by beginLuminosityBlock(), beginRun(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), endLuminosityBlock(), endRun(), and processAsync().
|
inline |
Definition at line 154 of file SubProcess.h.
References edm::for_all(), and cmsPerfStripChart::operate().
void edm::SubProcess::respondToOpenInputFile | ( | FileBlock const & | fb | ) |
Definition at line 739 of file SubProcess.cc.
References edm::for_all(), cmsPerfStripChart::operate(), schedule_, serviceToken_, and subProcesses_.
void edm::SubProcess::selectProducts | ( | ProductRegistry const & | preg, |
ThinnedAssociationsHelper const & | parentThinnedAssociationsHelper, | ||
std::map< BranchID, bool > & | keepAssociation | ||
) |
Definition at line 252 of file SubProcess.cc.
References edm::ProductRegistry::allBranchDescriptions(), TrackValidation_cff::association, droppedBranchIDToKeptBranchID_, edm::ProductSelector::fillDroppedToKept(), edm::ProductSelector::initialize(), edm::ProductSelector::initialized(), keepThisBranch(), edm::BranchDescription::present(), edm::BranchDescription::produced(), edm::ProductRegistry::productList(), productSelector_, productSelectorRules_, edm::ThinnedAssociationsHelper::selectAssociationProducts(), edm::ProductSelector::selected(), edm::BranchDescription::transient(), and edm::BranchDescription::unwrappedType().
Referenced by SubProcess().
|
inline |
Definition at line 161 of file SubProcess.h.
References cmsPerfStripChart::operate().
|
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 236 of file SubProcess.h.
References cmsPerfStripChart::operate().
|
inlineprivate |
Definition at line 277 of file SubProcess.h.
References edm::get_underlying_safe().
Referenced by SubProcess().
|
inlineprivate |
Definition at line 278 of file SubProcess.h.
References edm::get_underlying_safe().
|
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 196 of file SubProcess.h.
|
inline |
Return the number of events that have not passed any trigger. (N.B. totalEventsFailed() + totalEventsPassed() == totalEvents()
Definition at line 208 of file SubProcess.h.
References cmsPerfStripChart::operate().
|
inline |
Return the number of events which have been passed by one or more trigger paths.
Definition at line 201 of file SubProcess.h.
References cmsPerfStripChart::operate().
void edm::SubProcess::updateBranchIDListHelper | ( | BranchIDLists const & | branchIDLists | ) |
Definition at line 732 of file SubProcess.cc.
References branchIDListHelper_, edm::for_all(), and subProcesses_.
Referenced by SubProcess().
void edm::SubProcess::writeLumi | ( | ProcessHistoryID const & | parentPhID, |
int | runNumber, | ||
int | lumiNumber | ||
) |
Definition at line 566 of file SubProcess.cc.
References edm::for_all(), edm::PrincipalCache::lumiPrincipal(), cmsPerfStripChart::operate(), parentToChildPhID_, principalCache_, processContext_, schedule_, serviceToken_, and subProcesses_.
void edm::SubProcess::writeRun | ( | ProcessHistoryID const & | parentPhID, |
int | runNumber | ||
) |
Definition at line 484 of file SubProcess.cc.
References edm::for_all(), cmsPerfStripChart::operate(), parentToChildPhID_, principalCache_, processContext_, edm::PrincipalCache::runPrincipal(), schedule_, serviceToken_, and subProcesses_.
|
private |
Definition at line 287 of file SubProcess.h.
Referenced by SubProcess().
|
private |
Definition at line 280 of file SubProcess.h.
Referenced by beginJob(), and SubProcess().
|
private |
Definition at line 284 of file SubProcess.h.
Referenced by fixBranchIDListsForEDAliases(), processAsync(), SubProcess(), and updateBranchIDListHelper().
|
private |
Definition at line 319 of file SubProcess.h.
Referenced by selectProducts(), and SubProcess().
|
private |
Definition at line 298 of file SubProcess.h.
Referenced by beginLuminosityBlock(), beginRun(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), doStreamBeginLuminosityBlock(), doStreamBeginLuminosityBlockAsync(), doStreamBeginRun(), doStreamBeginRunAsync(), doStreamEndLuminosityBlock(), doStreamEndLuminosityBlockAsync(), doStreamEndRun(), doStreamEndRunAsync(), endLuminosityBlock(), endRun(), processAsync(), and SubProcess().
|
private |
Definition at line 296 of file SubProcess.h.
Referenced by beginLuminosityBlock(), beginRun(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), and SubProcess().
|
private |
Definition at line 293 of file SubProcess.h.
Referenced by beginLuminosityBlock(), and doBeginLuminosityBlockAsync().
|
private |
Definition at line 294 of file SubProcess.h.
Referenced by beginRun(), doBeginRunAsync(), and SubProcess().
|
private |
Definition at line 308 of file SubProcess.h.
Referenced by keepThisBranch().
|
private |
Definition at line 282 of file SubProcess.h.
Referenced by beginJob().
|
private |
Definition at line 300 of file SubProcess.h.
Referenced by beginRun(), deleteLumiFromCache(), deleteRunFromCache(), doBeginRunAsync(), writeLumi(), and writeRun().
|
private |
Definition at line 290 of file SubProcess.h.
Referenced by beginJob().
|
private |
Definition at line 283 of file SubProcess.h.
Referenced by beginJob(), beginLuminosityBlock(), beginRun(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), and SubProcess().
|
private |
Definition at line 297 of file SubProcess.h.
Referenced by beginLuminosityBlock(), beginRun(), deleteLumiFromCache(), deleteRunFromCache(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), doStreamBeginLuminosityBlock(), doStreamBeginLuminosityBlockAsync(), doStreamBeginRun(), doStreamBeginRunAsync(), doStreamEndLuminosityBlock(), doStreamEndLuminosityBlockAsync(), doStreamEndRun(), doStreamEndRunAsync(), endLuminosityBlock(), endRun(), processAsync(), SubProcess(), writeLumi(), and writeRun().
|
private |
Definition at line 288 of file SubProcess.h.
Referenced by beginLuminosityBlock(), beginRun(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), and SubProcess().
|
private |
Definition at line 289 of file SubProcess.h.
Referenced by beginJob(), SubProcess(), writeLumi(), and writeRun().
|
private |
Definition at line 295 of file SubProcess.h.
Referenced by beginLuminosityBlock(), beginRun(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), processAsync(), and SubProcess().
|
private |
Definition at line 302 of file SubProcess.h.
Referenced by SubProcess().
|
private |
Definition at line 310 of file SubProcess.h.
Referenced by selectProducts().
|
private |
Definition at line 309 of file SubProcess.h.
Referenced by selectProducts().
|
private |
Definition at line 299 of file SubProcess.h.
Referenced by Config.Process::_insertPaths(), Config.Process::_replaceInSchedule(), beginJob(), beginLuminosityBlock(), beginRun(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), doBeginStream(), doEndStream(), doStreamBeginLuminosityBlock(), doStreamBeginLuminosityBlockAsync(), doStreamBeginRun(), doStreamBeginRunAsync(), doStreamEndLuminosityBlock(), doStreamEndLuminosityBlockAsync(), doStreamEndRun(), doStreamEndRunAsync(), Config.Process::dumpPython(), endJob(), endLuminosityBlock(), endRun(), processAsync(), Config.Process::prune(), respondToOpenInputFile(), SubProcess(), writeLumi(), and writeRun().
|
private |
Definition at line 314 of file SubProcess.h.
Referenced by processAsync(), and SubProcess().
|
mutableprivate |
Definition at line 315 of file SubProcess.h.
Referenced by doEventAsync(), and SubProcess().
|
private |
Definition at line 281 of file SubProcess.h.
Referenced by beginJob(), doBeginLuminosityBlock(), doBeginLuminosityBlockAsync(), doBeginRun(), doBeginRunAsync(), doBeginStream(), doEndLuminosityBlock(), doEndRun(), doEndStream(), doEventAsync(), doStreamBeginLuminosityBlock(), doStreamBeginLuminosityBlockAsync(), doStreamBeginRun(), doStreamBeginRunAsync(), doStreamEndLuminosityBlock(), doStreamEndLuminosityBlockAsync(), doStreamEndRun(), doStreamEndRunAsync(), endJob(), respondToOpenInputFile(), SubProcess(), writeLumi(), and writeRun().
|
private |
Definition at line 301 of file SubProcess.h.
Referenced by beginJob(), beginLuminosityBlock(), beginRun(), deleteLumiFromCache(), deleteRunFromCache(), doBeginLuminosityBlockAsync(), doBeginRunAsync(), doBeginStream(), doEndStream(), doStreamBeginLuminosityBlock(), doStreamBeginLuminosityBlockAsync(), doStreamBeginRun(), doStreamBeginRunAsync(), doStreamEndLuminosityBlock(), doStreamEndLuminosityBlockAsync(), doStreamEndRun(), doStreamEndRunAsync(), Config.Process::dumpConfig(), Config.Process::dumpPython(), endJob(), endLuminosityBlock(), endRun(), fixBranchIDListsForEDAliases(), processAsync(), respondToOpenInputFile(), SubProcess(), updateBranchIDListHelper(), writeLumi(), and writeRun().
|
private |
Definition at line 286 of file SubProcess.h.
Referenced by SubProcess().
|
private |
Definition at line 285 of file SubProcess.h.
Referenced by SubProcess().
|
private |
Definition at line 313 of file SubProcess.h.
Referenced by doEventAsync(), processAsync(), and SubProcess().