#include <ScheduleItems.h>

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

void	clear ()

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

std::auto_ptr< Schedule >	initSchedule (ParameterSet &parameterSet, ParameterSet const subProcessPSet, 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

	ScheduleItems ()

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

	ScheduleItems (ScheduleItems const &)=delete

Public Attributes
std::unique_ptr < ExceptionToActionTable const >	act_table_

std::shared_ptr< ActivityRegistry >	actReg_

std::shared_ptr < BranchIDListHelper >	branchIDListHelper_

std::shared_ptr < SignallingProductRegistry >	preg_

std::shared_ptr < ProcessConfiguration >	processConfiguration_

std::shared_ptr < ThinnedAssociationsHelper >	thinnedAssociationsHelper_

Detailed Description

Definition at line 26 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) {
       keptBranches.insert(item->branchID());
     }
     SelectedProducts const& keptVectorL = om.keptProducts()[InLumi];
     for(auto const& item : keptVectorL) {
       keptBranches.insert(item->branchID());
     }
     SelectedProducts const& keptVectorE = om.keptProducts()[InEvent];
     for(auto const& item : keptVectorE) {
       keptBranches.insert(item->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 93 of file ScheduleItems.cc.

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

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

                                                                                          {
 
     //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::auto_ptr<ConstProductRegistry>(new 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::auto_ptr<TNS>(new TNS(parameterSet)));
 
     return ServiceRegistry::createContaining(tnsptr,
                                              tempToken,
                                              serviceregistry::kOverlapIsError);
   }

void edm::ScheduleItems::clear ( void )

Definition at line 151 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().

                        {
     actReg_.reset();
     preg_.reset();
     branchIDListHelper_.reset();
     thinnedAssociationsHelper_.reset();
     processConfiguration_.reset();
   }

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

Definition at line 116 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().

                                                     {
     act_table_.reset(new ExceptionToActionTable(parameterSet));
     std::string processName = parameterSet.getParameter<std::string>("@process_name");
     processConfiguration_.reset(new ProcessConfiguration(processName, getReleaseVersion(), getPassID()));
     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::auto_ptr< Schedule > edm::ScheduleItems::initSchedule	(	ParameterSet &	parameterSet,
		ParameterSet const *	subProcessPSet,
		PreallocationConfiguration const &	iAllocConfig,
		ProcessContext const *	processContext
	)

Definition at line 131 of file ScheduleItems.cc.

References act_table_, actReg_, branchIDListHelper_, edm::ServiceRegistry::instance(), preg_, processConfiguration_, Tree_ALCARECO_cff::schedule, and thinnedAssociationsHelper_.

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

                                                                     {
     std::auto_ptr<Schedule> schedule(
         new Schedule(parameterSet,
                      ServiceRegistry::instance().get<service::TriggerNamesService>(),
                      *preg_,
                      *branchIDListHelper_,
                      *thinnedAssociationsHelper_,
                      *act_table_,
                      actReg_,
                      processConfiguration_,
                      subProcessPSet,
                      config,
                      processContext));
     return schedule;
   }

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

Definition at line 71 of file ScheduleItems.cc.

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

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

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