edm::SubProcess Class Reference

#include <SubProcess.h>

Public Member Functions
void	clearCounters ()
	Clear all the counters in the trigger report. More...
void	closeOutputFiles ()
void	deleteLumiFromCache (ProcessHistoryID const &parentPhID, int runNumber, int lumiNumber)
void	deleteRunFromCache (ProcessHistoryID const &parentPhID, int runNumber)
void	doBeginJob ()
void	doBeginLuminosityBlock (LuminosityBlockPrincipal const &principal, IOVSyncValue const &ts)
void	doBeginRun (RunPrincipal const &principal, IOVSyncValue const &ts)
void	doBeginStream (unsigned int)
void	doEndJob ()
void	doEndLuminosityBlock (LuminosityBlockPrincipal const &principal, IOVSyncValue const &ts, bool cleaningUpAfterException)
void	doEndRun (RunPrincipal const &principal, IOVSyncValue const &ts, bool cleaningUpAfterException)
void	doEndStream (unsigned int)
void	doEvent (EventPrincipal const &principal)
void	doStreamBeginLuminosityBlock (unsigned int iID, LuminosityBlockPrincipal const &principal, IOVSyncValue const &ts)
void	doStreamBeginRun (unsigned int iID, RunPrincipal const &principal, IOVSyncValue const &ts)
void	doStreamEndLuminosityBlock (unsigned int iID, LuminosityBlockPrincipal const &principal, IOVSyncValue const &ts, bool cleaningUpAfterException)
void	doStreamEndRun (unsigned int iID, RunPrincipal const &principal, IOVSyncValue const &ts, bool cleaningUpAfterException)
void	enableEndPaths (bool active)
bool	endPathsEnabled () const
	Return true if end_paths are active, and false if they are inactive. More...
std::vector< ModuleDescription const * >	getAllModuleDescriptions () const
	Return a vector allowing const access to all the ModuleDescriptions for this SubProcess. More...
void	getTriggerReport (TriggerReport &rep) const
SelectedProductsForBranchType const &	keptProducts () const
void	openNewOutputFilesIfNeeded ()
void	openOutputFiles (FileBlock &fb)
SubProcess &	operator= (SubProcess const &)=delete
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 &parameterSet, ParameterSet const &topLevelParameterSet, std::shared_ptr< ProductRegistry const > parentProductRegistry, std::shared_ptr< BranchIDListHelper const > parentBranchIDListHelper, ThinnedAssociationsHelper const &parentThinnedAssociationsHelper, 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 ()

Private Member Functions
void	beginJob ()
void	beginLuminosityBlock (LuminosityBlockPrincipal const &lb, IOVSyncValue const &ts)
void	beginRun (RunPrincipal const &r, IOVSyncValue const &ts)
std::shared_ptr < BranchIDListHelper const >	branchIDListHelper () const
std::shared_ptr < BranchIDListHelper > &	branchIDListHelper ()
std::map< BranchID::value_type, BranchID::value_type > const &	droppedBranchIDToKeptBranchID ()
void	endJob ()
void	endLuminosityBlock (LuminosityBlockPrincipal const &lb, IOVSyncValue const &ts, bool cleaningUpAfterException)
void	endRun (RunPrincipal const &r, IOVSyncValue const &ts, bool cleaningUpAfterException)
void	fixBranchIDListsForEDAliases (std::map< BranchID::value_type, BranchID::value_type > const &droppedBranchIDToKeptBranchID)
bool	hasSubProcesses () const
void	keepThisBranch (BranchDescription const &desc, std::map< BranchID, BranchDescription const * > &trueBranchIDToKeptBranchDesc, std::set< BranchID > &keptProductsInEvent)
void	process (EventPrincipal const &e)
void	propagateProducts (BranchType type, Principal const &parentPrincipal, Principal &principal) const
std::shared_ptr < ThinnedAssociationsHelper const >	thinnedAssociationsHelper () const
std::shared_ptr < ThinnedAssociationsHelper >	thinnedAssociationsHelper ()

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_
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_
edm::propagate_const < std::unique_ptr< std::vector < SubProcess > > >	subProcesses_
edm::propagate_const < std::shared_ptr < ThinnedAssociationsHelper > >	thinnedAssociationsHelper_
bool	wantAllEvents_

Detailed Description

Definition at line 39 of file SubProcess.h.

Constructor & Destructor Documentation

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

Definition at line 37 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(), droppedBranchIDToKeptBranchID_, esp_, edm::ParameterSet::exists(), edm::getAllTriggerNames(), edm::ParameterSet::getUntrackedParameterSet(), hasSubProcesses(), historyAppenders_, historyRunOffset_, cmsHarvester::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::thinnedAssociationsHelper(), thinnedAssociationsHelper(), thinnedAssociationsHelper_, updateBranchIDListHelper(), and wantAllEvents_.

                                                                     :
      serviceToken_(),
      parentPreg_(parentProductRegistry),
      preg_(),
      branchIDListHelper_(),
      act_table_(),
      processConfiguration_(),
      historyLumiOffset_(preallocConfig.numberOfStreams()),
      historyRunOffset_(historyLumiOffset_+preallocConfig.numberOfLuminosityBlocks()),
      processHistoryRegistries_(historyRunOffset_+ preallocConfig.numberOfRuns()),
      historyAppenders_(historyRunOffset_+preallocConfig.numberOfRuns()),
      principalCache_(),
      esp_(),
      schedule_(),
      parentToChildPhID_(),
      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_);
    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
    std::unique_ptr<std::vector<ParameterSet> > subProcessVParameterSet(popSubProcessVParameterSet(*processParameterSet_));
    bool hasSubProcesses = subProcessVParameterSet.get() != nullptr;
  
    ScheduleItems items(*parentProductRegistry, *this);
    actReg_ = items.actReg_;

    ParameterSet const& optionsPset(processParameterSet_->getUntrackedParameterSet("options", ParameterSet()));
    IllegalParameters::setThrowAnException(optionsPset.getUntrackedParameter<bool>("throwIfIllegalParameter", true));

    //initialize the services
    ServiceToken iToken;

    // get any configured services.
    std::unique_ptr<std::vector<ParameterSet> > serviceSets = processParameterSet_->popVParameterSet(std::string("services")); 

    ServiceToken newToken = items.initServices(*serviceSets, *processParameterSet_, token, iLegacy, false);
    parentActReg.connectToSubProcess(*items.actReg_);
    serviceToken_ = items.addCPRandTNS(*processParameterSet_, newToken);


    //make the services available
    ServiceRegistry::Operate operate(serviceToken_);

    // intialize miscellaneous items
    items.initMisc(*processParameterSet_);

    // intialize the event setup provider
    esp_ = esController.makeProvider(*processParameterSet_);

    branchIDListHelper_ = items.branchIDListHelper();
    updateBranchIDListHelper(parentBranchIDListHelper->branchIDLists());

    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();
    //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);
      ep->preModuleDelayedGetSignal_.connect(std::cref(items.actReg_->preModuleEventDelayedGetSignal_));
      ep->postModuleDelayedGetSignal_.connect(std::cref(items.actReg_->postModuleEventDelayedGetSignal_));
      principalCache_.insert(ep);
    }
    if(hasSubProcesses) {
      if(subProcesses_ == nullptr) {
        subProcesses_ = std::make_unique<std::vector<SubProcess> >();
      }
      subProcesses_->reserve(subProcessVParameterSet->size());
      for(auto& subProcessPSet : *subProcessVParameterSet) {
        subProcesses_->emplace_back(subProcessPSet,
                                    topLevelParameterSet,
                                    preg_,
                                    branchIDListHelper(),
                                    *thinnedAssociationsHelper_,
                                    esController,
                                    *items.actReg_,
                                    newToken,
                                    iLegacy,
                                    preallocConfig,
                                    &processContext_);
       }
    }
  }

edm::SubProcess::~SubProcess ( )

virtual

Definition at line 195 of file SubProcess.cc.

{}

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

delete

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

default

Member Function Documentation

void edm::SubProcess::beginJob ( void  )

private

Definition at line 209 of file SubProcess.cc.

References actReg_, droppedBranchIDToKeptBranchID(), relativeConstraints::empty, fixBranchIDListsForEDAliases(), hasSubProcesses(), edm::PathsAndConsumesOfModules::initialize(), cmsPerfStripChart::operate(), pathsAndConsumesOfModules_, preg_, processContext_, schedule_, serviceToken_, and subProcesses_.

Referenced by doBeginJob().

                       {
    if(!droppedBranchIDToKeptBranchID().empty()) {
      fixBranchIDListsForEDAliases(droppedBranchIDToKeptBranchID());
    }
    ServiceRegistry::Operate operate(serviceToken_);
    pathsAndConsumesOfModules_.initialize(schedule_.get(), preg_);
    actReg_->preBeginJobSignal_(pathsAndConsumesOfModules_, processContext_);
    schedule_->beginJob(*preg_);
    if(hasSubProcesses()) {
      for(auto& subProcess : *subProcesses_) {
        subProcess.doBeginJob();
      }
    }
  }

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

private

Definition at line 450 of file SubProcess.cc.

References printConversionInfo::aux, edm::LuminosityBlockPrincipal::aux(), esp_, hasSubProcesses(), 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().

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

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

private

Definition at line 374 of file SubProcess.cc.

References printConversionInfo::aux, edm::RunPrincipal::aux(), esp_, hasSubProcesses(), 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().

                                                                            {
    auto aux = std::make_shared<RunAuxiliary>(principal.aux());
    aux->setProcessHistoryID(principal.processHistoryID());
    auto rpp = std::make_shared<RunPrincipal>(aux, preg_, *processConfiguration_, &(historyAppenders_[historyRunOffset_+principal.index()]),principal.index());
    auto & processHistoryRegistry = processHistoryRegistries_[historyRunOffset_+principal.index()];
    processHistoryRegistry.registerProcessHistory(principal.processHistory());
    rpp->fillRunPrincipal(processHistoryRegistry, principal.reader());
    principalCache_.insert(rpp);

    ProcessHistoryID const& parentInputReducedPHID = principal.reducedProcessHistoryID();
    ProcessHistoryID const& inputReducedPHID       = rpp->reducedProcessHistoryID();

    parentToChildPhID_.insert(std::make_pair(parentInputReducedPHID,inputReducedPHID));

    RunPrincipal& rp = *principalCache_.runPrincipalPtr();
    propagateProducts(InRun, principal, rp);
    typedef OccurrenceTraits<RunPrincipal, BranchActionGlobalBegin> Traits;
    schedule_->processOneGlobal<Traits>(rp, esp_->eventSetupForInstance(ts));
    if(hasSubProcesses()) {
      for(auto& subProcess : *subProcesses_) {
        subProcess.doBeginRun(rp, ts);
      }
    }
  }

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

inlineprivate

Definition at line 290 of file SubProcess.h.

References branchIDListHelper_, and edm::get_underlying_safe().

Referenced by SubProcess().

{return get_underlying_safe(branchIDListHelper_);}

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

inlineprivate

Definition at line 291 of file SubProcess.h.

References branchIDListHelper_, and edm::get_underlying_safe().

{return get_underlying_safe(branchIDListHelper_);}

void edm::SubProcess::clearCounters ( )

inline

Clear all the counters in the trigger report.

Definition at line 257 of file SubProcess.h.

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

                         {
      ServiceRegistry::Operate operate(serviceToken_);
      schedule_->clearCounters();
      if(hasSubProcesses()) {
        for(auto& subProcess : *subProcesses_) {
          subProcess.clearCounters();
        }
      }
    }

void edm::SubProcess::closeOutputFiles ( )

inline

Definition at line 103 of file SubProcess.h.

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

                            {
      ServiceRegistry::Operate operate(serviceToken_);
      schedule_->closeOutputFiles();
      if(hasSubProcesses()) {
        for(auto& subProcess : *subProcesses_) {
          subProcess.closeOutputFiles();
        }
      }
    }

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

Definition at line 503 of file SubProcess.cc.

References assert(), edm::PrincipalCache::deleteLumi(), hasSubProcesses(), parentToChildPhID_, principalCache_, and subProcesses_.

                                                                                                   {
    std::map<ProcessHistoryID, ProcessHistoryID>::const_iterator it = parentToChildPhID_.find(parentPhID);
    assert(it != parentToChildPhID_.end());
    principalCache_.deleteLumi(it->second, runNumber, lumiNumber);
    if(hasSubProcesses()) {
      for(auto& subProcess : *subProcesses_) {
        subProcess.deleteLumiFromCache(it->second, runNumber, lumiNumber);
      }
    }
  }

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

Definition at line 432 of file SubProcess.cc.

References assert(), edm::PrincipalCache::deleteRun(), hasSubProcesses(), parentToChildPhID_, principalCache_, and subProcesses_.

                                                                                  {
    std::map<ProcessHistoryID, ProcessHistoryID>::const_iterator it = parentToChildPhID_.find(parentPhID);
    assert(it != parentToChildPhID_.end());
    principalCache_.deleteRun(it->second, runNumber);
    if(hasSubProcesses()) {
      for(auto& subProcess : *subProcesses_) {
        subProcess.deleteRunFromCache(it->second, runNumber);
      }
    }
  }

void edm::SubProcess::doBeginJob

(

)

Definition at line 198 of file SubProcess.cc.

References beginJob().

                         {
    this->beginJob();
  }

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

Definition at line 444 of file SubProcess.cc.

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

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

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

Definition at line 368 of file SubProcess.cc.

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

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

void edm::SubProcess::doBeginStream

(

unsigned int

iID

)

Definition at line 515 of file SubProcess.cc.

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

                                            {
    ServiceRegistry::Operate operate(serviceToken_);
    schedule_->beginStream(iID);
    if(hasSubProcesses()) {
      for(auto& subProcess : *subProcesses_) {
        subProcess.doBeginStream(iID);
      }
    }
  }

void edm::SubProcess::doEndJob

(

)

Definition at line 203 of file SubProcess.cc.

References endJob().

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

                       {
    endJob();
  }

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

Definition at line 471 of file SubProcess.cc.

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

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

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

Definition at line 400 of file SubProcess.cc.

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

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

void edm::SubProcess::doEndStream

(

unsigned int

iID

)

Definition at line 526 of file SubProcess.cc.

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

                                          {
    ServiceRegistry::Operate operate(serviceToken_);
    schedule_->endStream(iID);
    if(hasSubProcesses()) {
      for(auto& subProcess : *subProcesses_) {
        subProcess.doEndStream(iID);
      }
    }
  }

void edm::SubProcess::doEvent

(

EventPrincipal const &

principal

)

Definition at line 320 of file SubProcess.cc.

References cmsPerfStripChart::operate(), process(), selectors_, serviceToken_, wantAllEvents_, and edm::detail::TriggerResultsBasedEventSelector::wantEvent().

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

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

Definition at line 567 of file SubProcess.cc.

References esp_, hasSubProcesses(), edm::PrincipalCache::lumiPrincipalPtr(), cmsPerfStripChart::operate(), principalCache_, schedule_, serviceToken_, and subProcesses_.

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

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

Definition at line 537 of file SubProcess.cc.

References esp_, hasSubProcesses(), cmsPerfStripChart::operate(), principalCache_, edm::PrincipalCache::runPrincipalPtr(), schedule_, serviceToken_, and subProcesses_.

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

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

Definition at line 582 of file SubProcess.cc.

References esp_, hasSubProcesses(), edm::PrincipalCache::lumiPrincipalPtr(), cmsPerfStripChart::operate(), principalCache_, schedule_, serviceToken_, and subProcesses_.

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

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

Definition at line 552 of file SubProcess.cc.

References esp_, hasSubProcesses(), cmsPerfStripChart::operate(), principalCache_, edm::PrincipalCache::runPrincipalPtr(), schedule_, serviceToken_, and subProcesses_.

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

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

inlineprivate

Definition at line 282 of file SubProcess.h.

References droppedBranchIDToKeptBranchID_.

Referenced by beginJob().

                                                                                          {
      return droppedBranchIDToKeptBranchID_;
    }

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

inline

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

Definition at line 216 of file SubProcess.h.

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

                                     {
      ServiceRegistry::Operate operate(serviceToken_);
      schedule_->enableEndPaths(active);
      if(hasSubProcesses()) {
        for(auto& subProcess : *subProcesses_) {
          subProcess.enableEndPaths(active);
        }
      }
    }

void edm::SubProcess::endJob ( void  )

private

Definition at line 225 of file SubProcess.cc.

References EnergyCorrector::c, edm::ExceptionCollector::call(), hasSubProcesses(), edm::ExceptionCollector::hasThrown(), cmsPerfStripChart::operate(), edm::ExceptionCollector::rethrow(), schedule_, serviceToken_, and subProcesses_.

Referenced by doEndJob().

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

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

private

Definition at line 477 of file SubProcess.cc.

References esp_, hasSubProcesses(), edm::InLumi, edm::PrincipalCache::lumiPrincipalPtr(), principalCache_, propagateProducts(), schedule_, and subProcesses_.

Referenced by doEndLuminosityBlock().

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

bool edm::SubProcess::endPathsEnabled ( ) const

inline

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

Definition at line 227 of file SubProcess.h.

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

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

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

private

Definition at line 406 of file SubProcess.cc.

References esp_, hasSubProcesses(), edm::InRun, principalCache_, propagateProducts(), edm::PrincipalCache::runPrincipalPtr(), schedule_, and subProcesses_.

Referenced by doEndRun().

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

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

private

Definition at line 301 of file SubProcess.cc.

References branchIDListHelper_, hasSubProcesses(), and subProcesses_.

Referenced by beginJob().

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

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

(

)

const

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

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

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

inline

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

Definition at line 234 of file SubProcess.h.

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

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

bool edm::SubProcess::hasSubProcesses ( ) const

inlineprivate

Definition at line 286 of file SubProcess.h.

References subProcesses_.

Referenced by beginJob(), beginLuminosityBlock(), beginRun(), clearCounters(), closeOutputFiles(), deleteLumiFromCache(), deleteRunFromCache(), doBeginStream(), doEndStream(), doStreamBeginLuminosityBlock(), doStreamBeginRun(), doStreamEndLuminosityBlock(), doStreamEndRun(), enableEndPaths(), endJob(), endLuminosityBlock(), endRun(), fixBranchIDListsForEDAliases(), openNewOutputFilesIfNeeded(), openOutputFiles(), postForkReacquireResources(), preForkReleaseResources(), process(), respondToCloseInputFile(), respondToOpenInputFile(), shouldWeCloseOutput(), SubProcess(), terminate(), updateBranchIDListHelper(), writeLumi(), and writeRun().

                                 {
      return subProcesses_.get() != nullptr && !subProcesses_->empty();
    }

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

private

Definition at line 282 of file SubProcess.cc.

References edm::BranchDescription::branchID(), edm::BranchDescription::branchType(), edm::ProductSelector::checkForDuplicateKeptBranch(), edm::InEvent, keptProducts_, edm::BranchDescription::originalBranchID(), and edm::BranchDescription::produced().

Referenced by selectProducts().

                                                                         {

    ProductSelector::checkForDuplicateKeptBranch(desc,
                                                 trueBranchIDToKeptBranchDesc);

    if(desc.branchType() == InEvent) {
      if(desc.produced()) {
        keptProductsInEvent.insert(desc.originalBranchID());
      } else {
        keptProductsInEvent.insert(desc.branchID());
      }
    }
    // Now put it in the list of selected branches.
    keptProducts_[desc.branchType()].push_back(&desc);
  }

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

inline

Definition at line 65 of file SubProcess.h.

References keptProducts_.

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

{return keptProducts_;}

void edm::SubProcess::openNewOutputFilesIfNeeded ( )

inline

Definition at line 114 of file SubProcess.h.

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

                                      {
      ServiceRegistry::Operate operate(serviceToken_);
      schedule_->openNewOutputFilesIfNeeded();
      if(hasSubProcesses()) {
        for(auto& subProcess : *subProcesses_) {
          subProcess.openNewOutputFilesIfNeeded();
        }
      }
    }

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

inline

Definition at line 125 of file SubProcess.h.

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

                                        {
      ServiceRegistry::Operate operate(serviceToken_);
      schedule_->openOutputFiles(fb);
      if(hasSubProcesses()) {
        for(auto& subProcess : *subProcesses_) {
          subProcess.openOutputFiles(fb);
        }
      }
    }

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

delete

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

default

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

inline

Definition at line 177 of file SubProcess.h.

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

                                                                                              {
      ServiceRegistry::Operate operate(serviceToken_);
      schedule_->postForkReacquireResources(iChildIndex, iNumberOfChildren);
      if(hasSubProcesses()) {
        for(auto& subProcess : *subProcesses_) {
          subProcess.postForkReacquireResources(iChildIndex, iNumberOfChildren);
        }
      }
    }

void edm::SubProcess::preForkReleaseResources ( )

inline

Definition at line 167 of file SubProcess.h.

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

                                   {
      ServiceRegistry::Operate operate(serviceToken_);
      schedule_->preForkReleaseResources();
      if(hasSubProcesses()) {
        for(auto& subProcess : *subProcesses_) {
          subProcess.preForkReleaseResources();
        }
      }
    }

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

private

Definition at line 335 of file SubProcess.cc.

References edm::ProductRegistry::anyProductProduced(), printConversionInfo::aux, edm::EventPrincipal::aux(), branchIDListHelper_, edm::EventPrincipal::branchListIndexes(), edm::EventPrincipal::clearEventPrincipal(), esp_, edm::PrincipalCache::eventPrincipal(), edm::EventPrincipal::eventSelectionIDs(), edm::EventPrincipal::fillEventPrincipal(), hasSubProcesses(), edm::InEvent, edm::PrincipalCache::lumiPrincipalPtr(), eostools::move(), principalCache_, edm::Principal::processHistory(), edm::Principal::processHistoryID(), processHistoryRegistries_, edm::EventPrincipal::productProvenanceRetrieverPtr(), edm::Principal::productRegistry(), propagateProducts(), edm::Principal::reader(), schedule_, selector_config_id_, edm::EventPrincipal::setLuminosityBlockPrincipal(), edm::EventPrincipal::streamID(), subProcesses_, edm::StreamID::value(), and wantAllEvents_.

Referenced by ConfigBuilder.ConfigBuilder::addExtraStream(), ConfigBuilder.ConfigBuilder::completeInputCommand(), doEvent(), ConfigBuilder.ConfigBuilder::doNotInlineEventContent(), Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::dumpPython(), ConfigBuilder.ConfigBuilder.PrintAllModules::leave(), Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::open(), Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::outputEventContent(), ConfigBuilder.ConfigBuilder::prepare_HLT(), ConfigBuilder.ConfigBuilder::prepare_LHE(), ConfigBuilder.ConfigBuilder::prepare_PATFILTER(), ConfigBuilder.ConfigBuilder::prepare_VALIDATION(), ConfigBuilder.ConfigBuilder::renameHLTprocessInSequence(), ConfigBuilder.ConfigBuilder::renameInputTagsInSequence(), ConfigBuilder.ConfigBuilder::scheduleSequence(), Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::setProcess(), and Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::setProperty().

                                                     {
    EventAuxiliary aux(principal.aux());
    aux.setProcessHistoryID(principal.processHistoryID());

    EventSelectionIDVector esids{principal.eventSelectionIDs()};
    if (principal.productRegistry().anyProductProduced() || !wantAllEvents_) {
      esids.push_back(selector_config_id_);
    }

    EventPrincipal& ep = principalCache_.eventPrincipal(principal.streamID().value());
    auto & processHistoryRegistry = processHistoryRegistries_[principal.streamID().value()];
    processHistoryRegistry.registerProcessHistory(principal.processHistory());
    BranchListIndexes bli(principal.branchListIndexes());
    branchIDListHelper_->fixBranchListIndexes(bli);
    ep.fillEventPrincipal(aux,
                          processHistoryRegistry,
                          std::move(esids),
                          std::move(bli),
                          *(principal.productProvenanceRetrieverPtr()),//NOTE: this transfers the per product provenance
                          principal.reader());
    ep.setLuminosityBlockPrincipal(principalCache_.lumiPrincipalPtr());
    propagateProducts(InEvent, principal, ep);
    typedef OccurrenceTraits<EventPrincipal, BranchActionStreamBegin> Traits;
    schedule_->processOneEvent<Traits>(ep.streamID().value(),ep, esp_->eventSetup());
    if(hasSubProcesses()) {
      for(auto& subProcess : *subProcesses_) {
        subProcess.doEvent(ep);
      }
    }
    ep.clearEventPrincipal();
  }

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

private

Definition at line 598 of file SubProcess.cc.

References edm::ProductData::connectTo(), edm::Principal::getModifiableProductHolder(), edm::Principal::getProductHolder(), keptProducts(), edm::ProductHolderBase::productData(), edm::ProductHolderBase::productUnavailable(), and fireworks::void.

Referenced by beginLuminosityBlock(), beginRun(), endLuminosityBlock(), endRun(), and process().

                                                                                                             {
    SelectedProducts const& keptVector = keptProducts()[type];
    for(auto const& item : keptVector) {
      ProductHolderBase const* parentProductHolder = parentPrincipal.getProductHolder(item->branchID());
      if(parentProductHolder != nullptr) {
        ProductData const& parentData = parentProductHolder->productData();
        ProductHolderBase* productHolder = principal.getModifiableProductHolder(item->branchID());
        if(productHolder != nullptr) {
          ProductData& thisData = productHolder->productData();
          //Propagate the per event(run)(lumi) data for this product to the subprocess.
          //First, the product itself.
          thisData.connectTo(parentData);
          // Sets unavailable flag, if known that product is not available
          (void)productHolder->productUnavailable();
        }
      }
    }
  }

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

inline

Definition at line 141 of file SubProcess.h.

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

                                                      {
      ServiceRegistry::Operate operate(serviceToken_);
      schedule_->respondToCloseInputFile(fb);
      if(hasSubProcesses()) {
        for(auto& subProcess : *subProcesses_) {
          subProcess.respondToCloseInputFile(fb);
        }
      }
    }

void edm::SubProcess::respondToOpenInputFile

(

FileBlock const &

fb

)

Definition at line 628 of file SubProcess.cc.

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

                                                        {
    ServiceRegistry::Operate operate(serviceToken_);
    schedule_->respondToOpenInputFile(fb);
    if(hasSubProcesses()) {
      for(auto& subProcess : *subProcesses_) {
        subProcess.respondToOpenInputFile(fb);
      }
    }
  }

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

Definition at line 240 of file SubProcess.cc.

References edm::ProductRegistry::allBranchDescriptions(), 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().

                                                                      {
    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_);
  }

bool edm::SubProcess::shouldWeCloseOutput ( ) const

inline

Definition at line 152 of file SubProcess.h.

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

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

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

inline

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

Definition at line 241 of file SubProcess.h.

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

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

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

inlineprivate

Definition at line 292 of file SubProcess.h.

References edm::get_underlying_safe(), and thinnedAssociationsHelper_.

Referenced by SubProcess().

{return get_underlying_safe(thinnedAssociationsHelper_);}

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

inlineprivate

Definition at line 293 of file SubProcess.h.

References edm::get_underlying_safe(), and thinnedAssociationsHelper_.

{return get_underlying_safe(thinnedAssociationsHelper_);}

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

References schedule_.

                            {
      return schedule_->totalEvents();
    }

int edm::SubProcess::totalEventsFailed ( ) const

inline

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

Definition at line 209 of file SubProcess.h.

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

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

int edm::SubProcess::totalEventsPassed ( ) const

inline

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

Definition at line 202 of file SubProcess.h.

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

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

void edm::SubProcess::updateBranchIDListHelper

(

BranchIDLists const &

branchIDLists

)

Definition at line 617 of file SubProcess.cc.

References branchIDListHelper_, hasSubProcesses(), and subProcesses_.

Referenced by SubProcess().

                                                                              {
    branchIDListHelper_->updateFromParent(branchIDLists);
    if(hasSubProcesses()) {
      for(auto& subProcess : *subProcesses_) {
        subProcess.updateBranchIDListHelper(branchIDListHelper_->branchIDLists());
      }
    }
  }

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

Definition at line 490 of file SubProcess.cc.

References assert(), hasSubProcesses(), edm::PrincipalCache::lumiPrincipal(), cmsPerfStripChart::operate(), parentToChildPhID_, principalCache_, processContext_, schedule_, serviceToken_, and subProcesses_.

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

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

Definition at line 419 of file SubProcess.cc.

References assert(), hasSubProcesses(), cmsPerfStripChart::operate(), parentToChildPhID_, principalCache_, processContext_, edm::PrincipalCache::runPrincipal(), schedule_, serviceToken_, and subProcesses_.

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

Member Data Documentation

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

private

Definition at line 301 of file SubProcess.h.

Referenced by SubProcess().

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

private

Definition at line 295 of file SubProcess.h.

Referenced by beginJob(), and SubProcess().

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

private

Definition at line 299 of file SubProcess.h.

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

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

private

Definition at line 334 of file SubProcess.h.

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

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

private

Definition at line 312 of file SubProcess.h.

Referenced by beginLuminosityBlock(), beginRun(), doStreamBeginLuminosityBlock(), doStreamBeginRun(), doStreamEndLuminosityBlock(), doStreamEndRun(), endLuminosityBlock(), endRun(), process(), and SubProcess().

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

private

Definition at line 310 of file SubProcess.h.

Referenced by beginLuminosityBlock(), beginRun(), and SubProcess().

unsigned int edm::SubProcess::historyLumiOffset_

private

Definition at line 307 of file SubProcess.h.

Referenced by beginLuminosityBlock().

unsigned int edm::SubProcess::historyRunOffset_

private

Definition at line 308 of file SubProcess.h.

Referenced by beginRun(), and SubProcess().

SelectedProductsForBranchType edm::SubProcess::keptProducts_

private

Definition at line 322 of file SubProcess.h.

Referenced by keepThisBranch(), and keptProducts().

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

private

Definition at line 297 of file SubProcess.h.

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

private

Definition at line 314 of file SubProcess.h.

Referenced by beginRun(), deleteLumiFromCache(), deleteRunFromCache(), writeLumi(), and writeRun().

PathsAndConsumesOfModules edm::SubProcess::pathsAndConsumesOfModules_

private

Definition at line 304 of file SubProcess.h.

Referenced by beginJob().

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

private

Definition at line 298 of file SubProcess.h.

Referenced by beginJob(), beginLuminosityBlock(), beginRun(), and SubProcess().

PrincipalCache edm::SubProcess::principalCache_

private

Definition at line 311 of file SubProcess.h.

Referenced by beginLuminosityBlock(), beginRun(), deleteLumiFromCache(), deleteRunFromCache(), doStreamBeginLuminosityBlock(), doStreamBeginRun(), doStreamEndLuminosityBlock(), doStreamEndRun(), endLuminosityBlock(), endRun(), process(), SubProcess(), writeLumi(), and writeRun().

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

private

Definition at line 302 of file SubProcess.h.

Referenced by beginLuminosityBlock(), beginRun(), and SubProcess().

ProcessContext edm::SubProcess::processContext_

private

Definition at line 303 of file SubProcess.h.

Referenced by beginJob(), SubProcess(), writeLumi(), and writeRun().

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

private

Definition at line 309 of file SubProcess.h.

Referenced by beginLuminosityBlock(), beginRun(), process(), and SubProcess().

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

private

Definition at line 316 of file SubProcess.h.

Referenced by SubProcess().

ProductSelector edm::SubProcess::productSelector_

private

Definition at line 324 of file SubProcess.h.

Referenced by selectProducts().

ProductSelectorRules edm::SubProcess::productSelectorRules_

private

Definition at line 323 of file SubProcess.h.

Referenced by selectProducts().

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

private

Definition at line 313 of file SubProcess.h.

Referenced by Config.Process::_insertPaths(), beginJob(), beginLuminosityBlock(), beginRun(), clearCounters(), closeOutputFiles(), doBeginStream(), doEndStream(), doStreamBeginLuminosityBlock(), doStreamBeginRun(), doStreamEndLuminosityBlock(), doStreamEndRun(), enableEndPaths(), endJob(), endLuminosityBlock(), endPathsEnabled(), endRun(), getTriggerReport(), openNewOutputFilesIfNeeded(), openOutputFiles(), postForkReacquireResources(), preForkReleaseResources(), process(), Config.Process::prune(), respondToCloseInputFile(), respondToOpenInputFile(), shouldWeCloseOutput(), SubProcess(), terminate(), totalEvents(), totalEventsFailed(), totalEventsPassed(), writeLumi(), and writeRun().

ParameterSetID edm::SubProcess::selector_config_id_

private

Definition at line 329 of file SubProcess.h.

Referenced by process(), and SubProcess().

detail::TriggerResultsBasedEventSelector edm::SubProcess::selectors_

mutableprivate

Definition at line 330 of file SubProcess.h.

Referenced by doEvent(), and SubProcess().

ServiceToken edm::SubProcess::serviceToken_

private

Definition at line 296 of file SubProcess.h.

Referenced by beginJob(), clearCounters(), closeOutputFiles(), doBeginLuminosityBlock(), doBeginRun(), doBeginStream(), doEndLuminosityBlock(), doEndRun(), doEndStream(), doEvent(), doStreamBeginLuminosityBlock(), doStreamBeginRun(), doStreamEndLuminosityBlock(), doStreamEndRun(), enableEndPaths(), endJob(), endPathsEnabled(), getTriggerReport(), openNewOutputFilesIfNeeded(), openOutputFiles(), postForkReacquireResources(), preForkReleaseResources(), respondToCloseInputFile(), respondToOpenInputFile(), shouldWeCloseOutput(), SubProcess(), terminate(), totalEventsFailed(), totalEventsPassed(), writeLumi(), and writeRun().

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

private

Definition at line 315 of file SubProcess.h.

Referenced by beginJob(), beginLuminosityBlock(), beginRun(), clearCounters(), closeOutputFiles(), deleteLumiFromCache(), deleteRunFromCache(), doBeginStream(), doEndStream(), doStreamBeginLuminosityBlock(), doStreamBeginRun(), doStreamEndLuminosityBlock(), doStreamEndRun(), Config.Process::dumpConfig(), Config.Process::dumpPython(), enableEndPaths(), endJob(), endLuminosityBlock(), endRun(), fixBranchIDListsForEDAliases(), hasSubProcesses(), openNewOutputFilesIfNeeded(), openOutputFiles(), postForkReacquireResources(), preForkReleaseResources(), process(), respondToCloseInputFile(), respondToOpenInputFile(), shouldWeCloseOutput(), SubProcess(), terminate(), updateBranchIDListHelper(), writeLumi(), and writeRun().

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

private

Definition at line 300 of file SubProcess.h.

Referenced by SubProcess(), and thinnedAssociationsHelper().

bool edm::SubProcess::wantAllEvents_

private

Definition at line 328 of file SubProcess.h.

Referenced by doEvent(), process(), and SubProcess().