#include <ScheduleItems.h>

Classes
class	MadeModules

Public Member Functions
ServiceToken	addCPRandTNS (ParameterSet const &parameterSet, ServiceToken const &token)

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

std::shared_ptr< BranchIDListHelper > &	branchIDListHelper ()

std::unique_ptr< Schedule >	finishSchedule (MadeModules, ParameterSet &parameterSet, service::TriggerNamesService const &tns, bool hasSubprocesses, PreallocationConfiguration const &iAllocConfig, ProcessContext const *, ProcessBlockHelperBase &processBlockHelper)

std::shared_ptr< CommonParams >	initMisc (ParameterSet &parameterSet)

MadeModules	initModules (ParameterSet &parameterSet, service::TriggerNamesService const &tns, PreallocationConfiguration const &iAllocConfig, ProcessContext const , ModuleTypeResolverMaker const typeResolverMaker)

std::unique_ptr< Schedule >	initSchedule (ParameterSet &parameterSet, bool hasSubprocesses, PreallocationConfiguration const &iAllocConfig, ProcessContext const , ModuleTypeResolverMaker const , ProcessBlockHelperBase &processBlockHelper)

ServiceToken	initServices (std::vector< ParameterSet > &servicePSets, ParameterSet &processPSet, ServiceToken const &iToken, serviceregistry::ServiceLegacy iLegacy, bool associate)

ScheduleItems &	operator= (ScheduleItems const &)=delete

std::shared_ptr< SignallingProductRegistry const >	preg () const

std::shared_ptr< SignallingProductRegistry > &	preg ()

std::shared_ptr< ProcessConfiguration const >	processConfiguration () const

std::shared_ptr< ProcessConfiguration > &	processConfiguration ()

	ScheduleItems ()

	ScheduleItems (ProductRegistry const &preg, SubProcess const &om, SubProcessBlockHelper &subProcessBlockHelper, ProcessBlockHelperBase const &parentProcessBlockHelper)

	ScheduleItems (ScheduleItems const &)=delete

std::shared_ptr< SubProcessParentageHelper > &	subProcessParentageHelper ()

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

std::shared_ptr< ThinnedAssociationsHelper > &	thinnedAssociationsHelper ()

Public Attributes
std::unique_ptr< ExceptionToActionTable const >	act_table_

std::shared_ptr< ActivityRegistry >	actReg_

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

edm::propagate_const< std::shared_ptr< SignallingProductRegistry > >	preg_

edm::propagate_const< std::shared_ptr< ProcessConfiguration > >	processConfiguration_

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

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

Detailed Description

Definition at line 34 of file ScheduleItems.h.

Constructor & Destructor Documentation

◆ ScheduleItems() [1/3]

edm::ScheduleItems::ScheduleItems ( )

Definition at line 33 of file ScheduleItems.cc.

       : actReg_(std::make_shared<ActivityRegistry>()),
         preg_(std::make_shared<SignallingProductRegistry>()),
         branchIDListHelper_(std::make_shared<BranchIDListHelper>()),
         thinnedAssociationsHelper_(std::make_shared<ThinnedAssociationsHelper>()),
         subProcessParentageHelper_(),
         act_table_(),
         processConfiguration_() {}

◆ ScheduleItems() [2/3]

edm::ScheduleItems::ScheduleItems	(	ProductRegistry const &	preg,
		SubProcess const &	om,
		SubProcessBlockHelper &	subProcessBlockHelper,
		ProcessBlockHelperBase const &	parentProcessBlockHelper
	)

Definition at line 42 of file ScheduleItems.cc.

References submitPVResolutionJobs::desc, edm::InEvent, edm::InLumi, edm::InProcess, edm::InRun, B2GTnPMonitor_cfi::item, edm::SubProcess::keptProducts(), preg_, dumpMFGeometry_cfg::prod, and edm::SubProcessBlockHelper::updateFromParentProcess().

       : actReg_(std::make_shared<ActivityRegistry>()),
         preg_(std::make_shared<SignallingProductRegistry>(preg)),
         branchIDListHelper_(std::make_shared<BranchIDListHelper>()),
         thinnedAssociationsHelper_(std::make_shared<ThinnedAssociationsHelper>()),
         subProcessParentageHelper_(std::make_shared<SubProcessParentageHelper>()),
         act_table_(),
         processConfiguration_() {
     for (auto& item : preg_->productListUpdator()) {
       BranchDescription& prod = item.second;
       prod.setOnDemand(false);
       prod.setProduced(false);
     }
 
     // Mark dropped branches as dropped in the product registry.
     std::set<BranchID> keptBranches;
     SelectedProducts const& keptVectorP = om.keptProducts()[InProcess];
     for (auto const& item : keptVectorP) {
       BranchDescription const& desc = *item.first;
       keptBranches.insert(desc.branchID());
     }
     SelectedProducts const& keptVectorR = om.keptProducts()[InRun];
     for (auto const& item : keptVectorR) {
       BranchDescription const& desc = *item.first;
       keptBranches.insert(desc.branchID());
     }
     SelectedProducts const& keptVectorL = om.keptProducts()[InLumi];
     for (auto const& item : keptVectorL) {
       BranchDescription const& desc = *item.first;
       keptBranches.insert(desc.branchID());
     }
     SelectedProducts const& keptVectorE = om.keptProducts()[InEvent];
     for (auto const& item : keptVectorE) {
       BranchDescription const& desc = *item.first;
       keptBranches.insert(desc.branchID());
     }
     for (auto& item : preg_->productListUpdator()) {
       BranchDescription& prod = item.second;
       if (keptBranches.find(prod.branchID()) == keptBranches.end()) {
         prod.setDropped(true);
       }
     }
     subProcessBlockHelper.updateFromParentProcess(parentProcessBlockHelper, *preg_);
   }

◆ ScheduleItems() [3/3]

edm::ScheduleItems::ScheduleItems ( ScheduleItems const & )

delete

Member Function Documentation

◆ addCPRandTNS()

ServiceToken edm::ScheduleItems::addCPRandTNS	(	ParameterSet const &	parameterSet,
		ServiceToken const &	token
	)

Definition at line 110 of file ScheduleItems.cc.

References edm::ServiceRegistry::createContaining(), edm::serviceregistry::kOverlapIsError, edm::parameterSet(), and unpackBuffers-CaloStage2::token.

                                                                                                       {
     //add the ProductRegistry as a service ONLY for the construction phase
     typedef serviceregistry::ServiceWrapper<ConstProductRegistry> w_CPR;
     auto reg = std::make_shared<w_CPR>(std::make_unique<ConstProductRegistry>(*preg_));
     ServiceToken tempToken(ServiceRegistry::createContaining(reg, token, serviceregistry::kOverlapIsError));
 
     // the next thing is ugly: pull out the trigger path pset and
     // create a service and extra token for it
 
     typedef service::TriggerNamesService TNS;
     typedef serviceregistry::ServiceWrapper<TNS> w_TNS;
 
     auto tnsptr = std::make_shared<w_TNS>(std::make_unique<TNS>(parameterSet));
 
     return ServiceRegistry::createContaining(tnsptr, tempToken, serviceregistry::kOverlapIsError);
   }

◆ branchIDListHelper() [1/2]

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

inline

Definition at line 87 of file ScheduleItems.h.

References branchIDListHelper_, and edm::get_underlying_safe().

                                                                        {
       return get_underlying_safe(branchIDListHelper_);
     }

◆ branchIDListHelper() [2/2]

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

inline

Definition at line 90 of file ScheduleItems.h.

References branchIDListHelper_, and edm::get_underlying_safe().

90 { return get_underlying_safe(branchIDListHelper_); }

edm::get_underlying_safe

constexpr std::shared_ptr< T > & get_underlying_safe(propagate_const< std::shared_ptr< T >> &iP)

Definition: get_underlying_safe.h:41

edm::ScheduleItems::branchIDListHelper_

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

Definition: ScheduleItems.h:107

◆ finishSchedule()

std::unique_ptr< Schedule > edm::ScheduleItems::finishSchedule	(	MadeModules	madeModules,
		ParameterSet &	parameterSet,
		service::TriggerNamesService const &	tns,
		bool	hasSubprocesses,
		PreallocationConfiguration const &	iAllocConfig,
		ProcessContext const *	processContext,
		ProcessBlockHelperBase &	processBlockHelper
	)

Definition at line 193 of file ScheduleItems.cc.

References actReg_, branchIDListHelper_, DMR_cfg::config, edm::ScheduleItems::MadeModules::m_schedule, eostools::move(), edm::parameterSet(), preg_, processConfiguration(), subProcessParentageHelper_, and thinnedAssociationsHelper_.

                                                                                                       {
     auto sched = std::move(madeModules.m_schedule);
     sched->finishSetup(parameterSet,
                        tns,
                        *preg_,
                        *branchIDListHelper_,
                        processBlockHelper,
                        *thinnedAssociationsHelper_,
                        subProcessParentageHelper_ ? subProcessParentageHelper_.get() : nullptr,
                        actReg_,
                        processConfiguration(),
                        hasSubprocesses,
                        config,
                        processContext);
     return sched;
   }

◆ initMisc()

std::shared_ptr< CommonParams > edm::ScheduleItems::initMisc ( ParameterSet & parameterSet )

Definition at line 127 of file ScheduleItems.cc.

References act_table_, trackingPlots::common, edm::ParameterSet::getParameter(), edm::getPassID(), edm::getReleaseVersion(), edm::ParameterSet::getUntrackedParameter(), edm::ParameterSet::getUntrackedParameterSet(), edm::ResourceInformation::initializeAcceleratorTypes(), edm::Service< T >::isAvailable(), edm::parameterSet(), processConfiguration_, SimL1EmulatorRepack_CalouGT_cff::processName, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                 {
     edm::Service<edm::ResourceInformation> resourceInformationService;
     if (resourceInformationService.isAvailable()) {
       auto const& selectedAccelerators =
           parameterSet.getUntrackedParameter<std::vector<std::string>>("@selected_accelerators");
       resourceInformationService->initializeAcceleratorTypes(selectedAccelerators);
     }
 
     act_table_ = std::make_unique<ExceptionToActionTable>(parameterSet);
     std::string processName = parameterSet.getParameter<std::string>("@process_name");
     processConfiguration_ = std::make_shared<ProcessConfiguration>(
         processName, getReleaseVersion(), getPassID());  // propagate_const<T> has no reset() function
     auto common = std::make_shared<CommonParams>(
         parameterSet.getUntrackedParameterSet("maxEvents").getUntrackedParameter<int>("input"),
         parameterSet.getUntrackedParameterSet("maxLuminosityBlocks").getUntrackedParameter<int>("input"),
         parameterSet.getUntrackedParameterSet("maxSecondsUntilRampdown").getUntrackedParameter<int>("input"));
     return common;
   }

◆ initModules()

ScheduleItems::MadeModules edm::ScheduleItems::initModules	(	ParameterSet &	parameterSet,
		service::TriggerNamesService const &	tns,
		PreallocationConfiguration const &	iAllocConfig,
		ProcessContext const *	processContext,
		ModuleTypeResolverMaker const *	typeResolverMaker
	)

Definition at line 177 of file ScheduleItems.cc.

References act_table_, actReg_, edm::parameterSet(), preg_, and processConfiguration().

                                                                                                           {
     return MadeModules(std::make_unique<Schedule>(parameterSet,
                                                   tns,
                                                   *preg_,
                                                   *act_table_,
                                                   actReg_,
                                                   processConfiguration(),
                                                   config,
                                                   processContext,
                                                   typeResolverMaker));
   }

◆ initSchedule()

std::unique_ptr< Schedule > edm::ScheduleItems::initSchedule	(	ParameterSet &	parameterSet,
		bool	hasSubprocesses,
		PreallocationConfiguration const &	iAllocConfig,
		ProcessContext const *	processContext,
		ModuleTypeResolverMaker const *	typeResolverMaker,
		ProcessBlockHelperBase &	processBlockHelper
	)

Definition at line 146 of file ScheduleItems.cc.

References act_table_, actReg_, branchIDListHelper_, DMR_cfg::config, edm::ServiceRegistry::get(), edm::ServiceRegistry::instance(), edm::parameterSet(), preg_, processConfiguration(), runTheMatrix::ret, subProcessParentageHelper_, and thinnedAssociationsHelper_.

                                                                                                     {
     auto& tns = ServiceRegistry::instance().get<service::TriggerNamesService>();
     auto ret = std::make_unique<Schedule>(parameterSet,
                                           tns,
                                           *preg_,
                                           *act_table_,
                                           actReg_,
                                           processConfiguration(),
                                           config,
                                           processContext,
                                           typeResolverMaker);
     ret->finishSetup(parameterSet,
                      tns,
                      *preg_,
                      *branchIDListHelper_,
                      processBlockHelper,
                      *thinnedAssociationsHelper_,
                      subProcessParentageHelper_ ? subProcessParentageHelper_.get() : nullptr,
                      actReg_,
                      processConfiguration(),
                      hasSubprocesses,
                      config,
                      processContext);
     return ret;
   }

◆ initServices()

ServiceToken edm::ScheduleItems::initServices	(	std::vector< ParameterSet > &	servicePSets,
		ParameterSet &	processPSet,
		ServiceToken const &	iToken,
		serviceregistry::ServiceLegacy	iLegacy,
		bool	associate
	)

Definition at line 90 of file ScheduleItems.cc.

References actReg_, edm::ParameterSet::addParameter(), edm::ServiceRegistry::createSet(), B2GTnPMonitor_cfi::item, edm::parameterSet(), AlCaHLTBitMon_QueryRunRegistry::string, and unpackBuffers-CaloStage2::token.

                                                            {
     //create the services
     ServiceToken token(ServiceRegistry::createSet(pServiceSets, iToken, iLegacy, associate));
 
     //see if any of the Services have to have their PSets stored
     for (auto const& item : pServiceSets) {
       if (item.exists("@save_config")) {
         parameterSet.addParameter(item.getParameter<std::string>("@service_type"), item);
       }
     }
     // Copy slots that hold all the registered callback functions like
     // PostBeginJob into an ActivityRegistry
     token.copySlotsTo(*actReg_);
     return token;
   }

◆ operator=()

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

delete

◆ preg() [1/2]

std::shared_ptr<SignallingProductRegistry const> edm::ScheduleItems::preg ( ) const

inline

Definition at line 85 of file ScheduleItems.h.

References edm::get_underlying_safe(), and preg_.

85 { return get_underlying_safe(preg_); }

edm::ScheduleItems::preg_

edm::propagate_const< std::shared_ptr< SignallingProductRegistry > > preg_

Definition: ScheduleItems.h:106

edm::get_underlying_safe

constexpr std::shared_ptr< T > & get_underlying_safe(propagate_const< std::shared_ptr< T >> &iP)

Definition: get_underlying_safe.h:41

◆ preg() [2/2]

std::shared_ptr<SignallingProductRegistry>& edm::ScheduleItems::preg ( )

inline

Definition at line 86 of file ScheduleItems.h.

References edm::get_underlying_safe(), and preg_.

86 { return get_underlying_safe(preg_); }

edm::ScheduleItems::preg_

edm::propagate_const< std::shared_ptr< SignallingProductRegistry > > preg_

Definition: ScheduleItems.h:106

edm::get_underlying_safe

constexpr std::shared_ptr< T > & get_underlying_safe(propagate_const< std::shared_ptr< T >> &iP)

Definition: get_underlying_safe.h:41

◆ processConfiguration() [1/2]

std::shared_ptr<ProcessConfiguration const> edm::ScheduleItems::processConfiguration ( ) const

inline

Definition at line 100 of file ScheduleItems.h.

References edm::get_underlying_safe(), and processConfiguration_.

Referenced by finishSchedule(), initModules(), and initSchedule().

                                                                            {
       return get_underlying_safe(processConfiguration_);
     }

◆ processConfiguration() [2/2]

std::shared_ptr<ProcessConfiguration>& edm::ScheduleItems::processConfiguration ( )

inline

Definition at line 103 of file ScheduleItems.h.

References edm::get_underlying_safe(), and processConfiguration_.

103 { return get_underlying_safe(processConfiguration_); }

edm::get_underlying_safe

constexpr std::shared_ptr< T > & get_underlying_safe(propagate_const< std::shared_ptr< T >> &iP)

Definition: get_underlying_safe.h:41

edm::ScheduleItems::processConfiguration_

edm::propagate_const< std::shared_ptr< ProcessConfiguration > > processConfiguration_

Definition: ScheduleItems.h:111

◆ subProcessParentageHelper()

std::shared_ptr<SubProcessParentageHelper>& edm::ScheduleItems::subProcessParentageHelper ( )

inline

Definition at line 97 of file ScheduleItems.h.

References edm::get_underlying_safe(), and subProcessParentageHelper_.

                                                                           {
       return get_underlying_safe(subProcessParentageHelper_);
     }

◆ thinnedAssociationsHelper() [1/2]

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

inline

Definition at line 91 of file ScheduleItems.h.

References edm::get_underlying_safe(), and thinnedAssociationsHelper_.

                                                                                      {
       return get_underlying_safe(thinnedAssociationsHelper_);
     }

◆ thinnedAssociationsHelper() [2/2]

std::shared_ptr<ThinnedAssociationsHelper>& edm::ScheduleItems::thinnedAssociationsHelper ( )

inline

Definition at line 94 of file ScheduleItems.h.

References edm::get_underlying_safe(), and thinnedAssociationsHelper_.

                                                                           {
       return get_underlying_safe(thinnedAssociationsHelper_);
     }

Member Data Documentation

◆ act_table_

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

Definition at line 110 of file ScheduleItems.h.

Referenced by initMisc(), initModules(), and initSchedule().

◆ actReg_

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

Definition at line 105 of file ScheduleItems.h.

Referenced by finishSchedule(), initModules(), initSchedule(), and initServices().

◆ branchIDListHelper_

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

Definition at line 107 of file ScheduleItems.h.

Referenced by branchIDListHelper(), finishSchedule(), and initSchedule().

◆ preg_

edm::propagate_const<std::shared_ptr<SignallingProductRegistry> > edm::ScheduleItems::preg_

Definition at line 106 of file ScheduleItems.h.

Referenced by finishSchedule(), initModules(), initSchedule(), preg(), and ScheduleItems().

◆ processConfiguration_

edm::propagate_const<std::shared_ptr<ProcessConfiguration> > edm::ScheduleItems::processConfiguration_

Definition at line 111 of file ScheduleItems.h.

Referenced by initMisc(), and processConfiguration().

◆ subProcessParentageHelper_

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

Definition at line 109 of file ScheduleItems.h.

Referenced by finishSchedule(), initSchedule(), and subProcessParentageHelper().

◆ thinnedAssociationsHelper_

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

Definition at line 108 of file ScheduleItems.h.

Referenced by finishSchedule(), initSchedule(), and thinnedAssociationsHelper().

Classes

Public Member Functions

Public Attributes

Detailed Description

Constructor & Destructor Documentation

◆ ScheduleItems() [1/3]

◆ ScheduleItems() [2/3]

◆ ScheduleItems() [3/3]

Member Function Documentation

◆ addCPRandTNS()

◆ branchIDListHelper() [1/2]

◆ branchIDListHelper() [2/2]

◆ finishSchedule()

◆ initMisc()

◆ initModules()

◆ initSchedule()

◆ initServices()

◆ operator=()

◆ preg() [1/2]

◆ preg() [2/2]

◆ processConfiguration() [1/2]

◆ processConfiguration() [2/2]

◆ subProcessParentageHelper()

◆ thinnedAssociationsHelper() [1/2]

◆ thinnedAssociationsHelper() [2/2]

Member Data Documentation

◆ act_table_

◆ actReg_

◆ branchIDListHelper_

◆ preg_

◆ processConfiguration_

◆ subProcessParentageHelper_

◆ thinnedAssociationsHelper_