edm::ScheduleItems Struct Reference

#include <ScheduleItems.h>

Public Member Functions
ServiceToken	addCPRandTNS (ParameterSet const &parameterSet, ServiceToken const &token)
std::shared_ptr < BranchIDListHelper const >	branchIDListHelper () const
std::shared_ptr < BranchIDListHelper > &	branchIDListHelper ()
void	clear ()
std::shared_ptr< CommonParams >	initMisc (ParameterSet &parameterSet)
std::unique_ptr< Schedule >	initSchedule (ParameterSet &parameterSet, bool hasSubprocesses, PreallocationConfiguration const &iAllocConfig, ProcessContext const *)
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)
	ScheduleItems (ScheduleItems const &)=delete
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 < ThinnedAssociationsHelper > >	thinnedAssociationsHelper_

Detailed Description

Definition at line 27 of file ScheduleItems.h.

Constructor & Destructor Documentation

edm::ScheduleItems::ScheduleItems

(

)

Definition at line 25 of file ScheduleItems.cc.

                               :
      actReg_(new ActivityRegistry),
      preg_(new SignallingProductRegistry),
      branchIDListHelper_(new BranchIDListHelper),
      thinnedAssociationsHelper_(new ThinnedAssociationsHelper),
      act_table_(),
      processConfiguration_() {
  }

edm::ScheduleItems::ScheduleItems	(	ProductRegistry const &	preg,
		SubProcess const &	om
	)

Definition at line 34 of file ScheduleItems.cc.

References edm::BranchDescription::branchID(), edm::InEvent, edm::InLumi, edm::InRun, edm::SubProcess::keptProducts(), preg_, parseEventContent::prod, edm::BranchDescription::setDropped(), edm::BranchDescription::setOnDemand(), and edm::BranchDescription::setProduced().

                                                                                :
      actReg_(new ActivityRegistry),
      preg_(new SignallingProductRegistry(preg)),
      branchIDListHelper_(new BranchIDListHelper),
      thinnedAssociationsHelper_(new ThinnedAssociationsHelper),
      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& 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);
      }
    }
  }

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

delete

Member Function Documentation

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

Definition at line 96 of file ScheduleItems.cc.

References edm::ServiceRegistry::createContaining(), edm::serviceregistry::kOverlapIsError, and edm::parameterSet().

Referenced by edm::EventProcessor::init(), and edm::SubProcess::SubProcess().

                                                                                         {

    //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);
  }

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

inline

Definition at line 59 of file ScheduleItems.h.

References branchIDListHelper_, and edm::get_underlying_safe().

Referenced by edm::EventProcessor::init(), and edm::SubProcess::SubProcess().

{return get_underlying_safe(branchIDListHelper_);}

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

inline

Definition at line 60 of file ScheduleItems.h.

References branchIDListHelper_, and edm::get_underlying_safe().

{return get_underlying_safe(branchIDListHelper_);}

void edm::ScheduleItems::clear

(

void

)

Definition at line 153 of file ScheduleItems.cc.

References actReg_, branchIDListHelper_, preg_, processConfiguration_, and thinnedAssociationsHelper_.

Referenced by Vispa.Views.WidgetView.WidgetView::closeEvent(), Vispa.Views.BoxDecayView.BoxDecayView::closeEvent(), Vispa.Share.FindAlgorithm.FindAlgorithm::findUsingFindDialog(), Vispa.Views.LineDecayView.LineDecayView::setDataObjects(), Vispa.Views.WidgetView.WidgetView::setDataObjects(), Vispa.Views.TreeView.TreeView::updateContent(), Vispa.Views.TableView.TableView::updateContent(), Vispa.Views.BoxDecayView.BoxDecayView::updateContent(), and Vispa.Views.PropertyView.PropertyView::updateContent().

                       {
    // propagate_const<T> has no reset() function
    actReg_ = nullptr;
    preg_ = nullptr;
    branchIDListHelper_ = nullptr;
    thinnedAssociationsHelper_ = nullptr;
    processConfiguration_ = nullptr;
  }

std::shared_ptr< CommonParams > edm::ScheduleItems::initMisc

(

ParameterSet &

parameterSet

)

Definition at line 119 of file ScheduleItems.cc.

References act_table_, edm::ParameterSet::getParameter(), edm::getPassID(), edm::getReleaseVersion(), edm::ParameterSet::getUntrackedParameter(), edm::ParameterSet::getUntrackedParameterSet(), processConfiguration_, FSQHLTOfflineSource_cfi::processName, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by edm::EventProcessor::init(), and edm::SubProcess::SubProcess().

                                                    {
    act_table_.reset(new 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", ParameterSet()).getUntrackedParameter<int>("input", -1),
                                parameterSet.getUntrackedParameterSet(
                                   "maxLuminosityBlocks", ParameterSet()).getUntrackedParameter<int>("input", -1),
                                parameterSet.getUntrackedParameterSet(
                                   "maxSecondsUntilRampdown", ParameterSet()).getUntrackedParameter<int>("input", -1));
    return common;
  }

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

Definition at line 134 of file ScheduleItems.cc.

References act_table_, actReg_, branchIDListHelper_, mps_alisetup::config, edm::ServiceRegistry::get(), edm::ServiceRegistry::instance(), edm::parameterSet(), preg_, processConfiguration(), and thinnedAssociationsHelper_.

Referenced by edm::EventProcessor::init(), and edm::SubProcess::SubProcess().

                                                                    {
    return std::make_unique<Schedule>(
                     parameterSet,
                     ServiceRegistry::instance().get<service::TriggerNamesService>(),
                     *preg_,
                     *branchIDListHelper_,
                     *thinnedAssociationsHelper_,
                     *act_table_,
                     actReg_,
                     processConfiguration(),
                     hasSubprocesses,
                     config,
                     processContext);
  }

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

Definition at line 74 of file ScheduleItems.cc.

References actReg_, edm::ParameterSet::addParameter(), edm::ServiceToken::copySlotsTo(), edm::ServiceRegistry::createSet(), AlCaHLTBitMon_QueryRunRegistry::string, and unpackBuffers-CaloStage2::token.

Referenced by edm::EventProcessor::init(), and edm::SubProcess::SubProcess().

                                             {

    //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;
  }

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

delete

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

inline

Definition at line 57 of file ScheduleItems.h.

References edm::get_underlying_safe(), and preg_.

Referenced by edm::EventProcessor::init(), and edm::SubProcess::SubProcess().

{return get_underlying_safe(preg_);}

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

inline

Definition at line 58 of file ScheduleItems.h.

References edm::get_underlying_safe(), and preg_.

{return get_underlying_safe(preg_);}

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

inline

Definition at line 63 of file ScheduleItems.h.

References edm::get_underlying_safe(), and processConfiguration_.

Referenced by edm::EventProcessor::init(), initSchedule(), and edm::SubProcess::SubProcess().

{return get_underlying_safe(processConfiguration_);}

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

inline

Definition at line 64 of file ScheduleItems.h.

References edm::get_underlying_safe(), and processConfiguration_.

{return get_underlying_safe(processConfiguration_);}

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

inline

Definition at line 61 of file ScheduleItems.h.

References edm::get_underlying_safe(), and thinnedAssociationsHelper_.

Referenced by edm::EventProcessor::init(), and edm::SubProcess::SubProcess().

{return get_underlying_safe(thinnedAssociationsHelper_);}

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

inline

Definition at line 62 of file ScheduleItems.h.

References edm::get_underlying_safe(), and thinnedAssociationsHelper_.

{return get_underlying_safe(thinnedAssociationsHelper_);}

Member Data Documentation

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

Definition at line 70 of file ScheduleItems.h.

Referenced by edm::EventProcessor::init(), initMisc(), initSchedule(), and edm::SubProcess::SubProcess().

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

Definition at line 66 of file ScheduleItems.h.

Referenced by clear(), edm::EventProcessor::init(), initSchedule(), initServices(), and edm::SubProcess::SubProcess().

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

Definition at line 68 of file ScheduleItems.h.

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

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

Definition at line 67 of file ScheduleItems.h.

Referenced by clear(), initSchedule(), preg(), and ScheduleItems().

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

Definition at line 71 of file ScheduleItems.h.

Referenced by clear(), initMisc(), and processConfiguration().

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

Definition at line 69 of file ScheduleItems.h.

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