edm::StreamSchedule Class Reference

#include <StreamSchedule.h>

Classes
class	SendTerminationSignalIfException

Public Types
typedef std::vector< Worker * >	AllWorkers
typedef std::vector< Path >	NonTrigPaths
typedef std::vector< WorkerInPath >	PathWorkers
typedef std::vector< Path >	TrigPaths
typedef std::shared_ptr < HLTGlobalStatus const >	TrigResConstPtr
typedef std::shared_ptr < HLTGlobalStatus >	TrigResPtr
typedef std::vector< std::string >	vstring
typedef std::shared_ptr< Worker >	WorkerPtr
typedef std::vector< Worker * >	Workers

Public Member Functions
AllWorkers const &	allWorkers () const
	returns the collection of pointers to workers More...
void	availablePaths (std::vector< std::string > &oLabelsToFill) const
	adds to oLabelsToFill the labels for all paths in the process More...
void	beginStream ()
void	clearCounters ()
	Clear all the counters in the trigger report. More...
void	enableEndPaths (bool active)
void	endPaths (std::vector< std::string > &oLabelsToFill) const
	adds to oLabelsToFill the labels for all end paths in the process More...
bool	endPathsEnabled () const
void	endStream ()
std::vector< ModuleDescription const * >	getAllModuleDescriptions () const
void	getTriggerReport (TriggerReport &rep) const
void	moduleDescriptionsInEndPath (std::string const &iEndPathLabel, std::vector< ModuleDescription const * > &descriptions, unsigned int hint) const
void	moduleDescriptionsInPath (std::string const &iPathLabel, std::vector< ModuleDescription const * > &descriptions, unsigned int hint) const
void	modulesInPath (std::string const &iPathLabel, std::vector< std::string > &oLabelsToFill) const
	adds to oLabelsToFill in execution order the labels of all modules in path iPathLabel More...
unsigned int	numberOfUnscheduledModules () const
template<typename T >
void	processOneEvent (typename T::MyPrincipal &principal, EventSetup const &eventSetup, bool cleaningUpAfterException=false)
template<typename T >
void	processOneStream (typename T::MyPrincipal &principal, EventSetup const &eventSetup, bool cleaningUpAfterException=false)
void	replaceModule (maker::ModuleHolder *iMod, std::string const &iLabel)
	clone the type of module with label iLabel but configure with iPSet. More...
StreamID	streamID () const
	StreamSchedule (std::shared_ptr< TriggerResultInserter > inserter, std::shared_ptr< ModuleRegistry >, ParameterSet &proc_pset, service::TriggerNamesService &tns, PreallocationConfiguration const &prealloc, ProductRegistry &pregistry, BranchIDListHelper &branchIDListHelper, ExceptionToActionTable const &actions, std::shared_ptr< ActivityRegistry > areg, std::shared_ptr< ProcessConfiguration > processConfiguration, bool allowEarlyDelete, StreamID streamID, ProcessContext const *processContext)
	StreamSchedule (StreamSchedule const &)=delete
int	totalEvents () const
int	totalEventsFailed () const
int	totalEventsPassed () const
void	triggerPaths (std::vector< std::string > &oLabelsToFill) const

Private Member Functions
ExceptionToActionTable const &	actionTable () const
	returns the action table More...
void	addToAllWorkers (Worker *w)
void	fillEndPath (ParameterSet &proc_pset, ProductRegistry &preg, PreallocationConfiguration const *prealloc, std::shared_ptr< ProcessConfiguration const > processConfiguration, int bitpos, std::string const &name)
void	fillTrigPath (ParameterSet &proc_pset, ProductRegistry &preg, PreallocationConfiguration const *prealloc, std::shared_ptr< ProcessConfiguration const > processConfiguration, int bitpos, std::string const &name, TrigResPtr, vstring *labelsOnTriggerPaths)
void	fillWorkers (ParameterSet &proc_pset, ProductRegistry &preg, PreallocationConfiguration const *prealloc, std::shared_ptr< ProcessConfiguration const > processConfiguration, std::string const &name, bool ignoreFilters, PathWorkers &out, vstring *labelsOnPaths)
void	initializeEarlyDelete (ModuleRegistry &modReg, edm::ParameterSet const &opts, edm::ProductRegistry const &preg, bool allowEarlyDelete)
void	reportSkipped (EventPrincipal const &ep) const
void	resetAll ()
void	resetEarlyDelete ()
TrigResConstPtr	results () const
TrigResPtr &	results ()
template<typename T >
void	runEndPaths (typename T::MyPrincipal const &, EventSetup const &, typename T::Context const *)
template<typename T >
bool	runTriggerPaths (typename T::MyPrincipal const &, EventSetup const &, typename T::Context const *)

Private Attributes
std::shared_ptr< ActivityRegistry >	actReg_
std::vector< std::pair < BranchID, unsigned int > >	earlyDeleteBranchToCount_
std::vector< EarlyDeleteHelper >	earlyDeleteHelpers_
std::vector< unsigned int >	earlyDeleteHelperToBranchIndicies_
vstring	empty_trig_path_names_
std::vector< int >	empty_trig_paths_
vstring	end_path_name_list_
TrigPaths	end_paths_
volatile bool	endpathsAreActive_
unsigned int	number_of_unscheduled_modules_
edm::propagate_const< TrigResPtr >	results_
edm::propagate_const< WorkerPtr >	results_inserter_
StreamContext	streamContext_
StreamID	streamID_
int	total_events_
int	total_passed_
vstring	trig_name_list_
TrigPaths	trig_paths_
WorkerManager	workerManager_

Detailed Description

Definition at line 139 of file StreamSchedule.h.

Member Typedef Documentation

typedef std::vector<Worker*> edm::StreamSchedule::AllWorkers

Definition at line 147 of file StreamSchedule.h.

typedef std::vector<Path> edm::StreamSchedule::NonTrigPaths

Definition at line 143 of file StreamSchedule.h.

typedef std::vector<WorkerInPath> edm::StreamSchedule::PathWorkers

Definition at line 151 of file StreamSchedule.h.

typedef std::vector<Path> edm::StreamSchedule::TrigPaths

Definition at line 142 of file StreamSchedule.h.

typedef std::shared_ptr<HLTGlobalStatus const> edm::StreamSchedule::TrigResConstPtr

Definition at line 145 of file StreamSchedule.h.

typedef std::shared_ptr<HLTGlobalStatus> edm::StreamSchedule::TrigResPtr

Definition at line 144 of file StreamSchedule.h.

typedef std::vector<std::string> edm::StreamSchedule::vstring

Definition at line 141 of file StreamSchedule.h.

typedef std::shared_ptr<Worker> edm::StreamSchedule::WorkerPtr

Definition at line 146 of file StreamSchedule.h.

typedef std::vector<Worker*> edm::StreamSchedule::Workers

Definition at line 149 of file StreamSchedule.h.

Constructor & Destructor Documentation

edm::StreamSchedule::StreamSchedule	(	std::shared_ptr< TriggerResultInserter >	inserter,
		std::shared_ptr< ModuleRegistry >	modReg,
		ParameterSet &	proc_pset,
		service::TriggerNamesService &	tns,
		PreallocationConfiguration const &	prealloc,
		ProductRegistry &	pregistry,
		BranchIDListHelper &	branchIDListHelper,
		ExceptionToActionTable const &	actions,
		std::shared_ptr< ActivityRegistry >	areg,
		std::shared_ptr< ProcessConfiguration >	processConfiguration,
		bool	allowEarlyDelete,
		StreamID	streamID,
		ProcessContext const *	processContext
	)

Definition at line 133 of file StreamSchedule.cc.

edm::StreamSchedule::StreamSchedule ( StreamSchedule const &  )

delete

Member Function Documentation

ExceptionToActionTable const& edm::StreamSchedule::actionTable ( ) const

inlineprivate

returns the action table

Definition at line 285 of file StreamSchedule.h.

void edm::StreamSchedule::addToAllWorkers ( Worker *  w )

private

Definition at line 725 of file StreamSchedule.cc.

AllWorkers const& edm::StreamSchedule::allWorkers ( ) const

inline

returns the collection of pointers to workers

Definition at line 253 of file StreamSchedule.h.

void edm::StreamSchedule::availablePaths

(

std::vector< std::string > &

oLabelsToFill

)

const

adds to oLabelsToFill the labels for all paths in the process

Definition at line 545 of file StreamSchedule.cc.

void edm::StreamSchedule::beginStream

(

)

Definition at line 507 of file StreamSchedule.cc.

void edm::StreamSchedule::clearCounters

(

)

Clear all the counters in the trigger report.

Definition at line 711 of file StreamSchedule.cc.

void edm::StreamSchedule::enableEndPaths

(

bool

active

)

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

Definition at line 639 of file StreamSchedule.cc.

void edm::StreamSchedule::endPaths

(

std::vector< std::string > &

oLabelsToFill

)

const

adds to oLabelsToFill the labels for all end paths in the process

Definition at line 559 of file StreamSchedule.cc.

bool edm::StreamSchedule::endPathsEnabled

(

)

const

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

Definition at line 644 of file StreamSchedule.cc.

void edm::StreamSchedule::endStream

(

)

Definition at line 511 of file StreamSchedule.cc.

void edm::StreamSchedule::fillEndPath ( ParameterSet &  proc_pset, ProductRegistry &  preg, PreallocationConfiguration const *  prealloc, std::shared_ptr< ProcessConfiguration const >  processConfiguration, int  bitpos, std::string const &  name  )

private

Definition at line 487 of file StreamSchedule.cc.

void edm::StreamSchedule::fillTrigPath ( ParameterSet &  proc_pset, ProductRegistry &  preg, PreallocationConfiguration const *  prealloc, std::shared_ptr< ProcessConfiguration const >  processConfiguration, int  bitpos, std::string const &  name, TrigResPtr  trptr, vstring *  labelsOnTriggerPaths  )

private

Definition at line 461 of file StreamSchedule.cc.

void edm::StreamSchedule::fillWorkers ( ParameterSet &  proc_pset, ProductRegistry &  preg, PreallocationConfiguration const *  prealloc, std::shared_ptr< ProcessConfiguration const >  processConfiguration, std::string const &  name, bool  ignoreFilters, PathWorkers &  out, vstring *  labelsOnPaths  )

private

Definition at line 402 of file StreamSchedule.cc.

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

(

)

const

Return a vector allowing const access to all the ModuleDescriptions for this StreamSchedule. *** N.B. *** Ownership of the ModuleDescriptions is not *** passed to the caller. Do not call delete on these *** pointers!

Definition at line 533 of file StreamSchedule.cc.

void edm::StreamSchedule::getTriggerReport

(

TriggerReport &

rep

)

const

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

Definition at line 699 of file StreamSchedule.cc.

void edm::StreamSchedule::initializeEarlyDelete ( ModuleRegistry &  modReg, edm::ParameterSet const &  opts, edm::ProductRegistry const &  preg, bool  allowEarlyDelete  )

private

Definition at line 247 of file StreamSchedule.cc.

void edm::StreamSchedule::moduleDescriptionsInEndPath	(	std::string const &	iEndPathLabel,
		std::vector< ModuleDescription const * > &	descriptions,
		unsigned int	hint
	)		const

Definition at line 610 of file StreamSchedule.cc.

void edm::StreamSchedule::moduleDescriptionsInPath	(	std::string const &	iPathLabel,
		std::vector< ModuleDescription const * > &	descriptions,
		unsigned int	hint
	)		const

Definition at line 581 of file StreamSchedule.cc.

void edm::StreamSchedule::modulesInPath	(	std::string const &	iPathLabel,
		std::vector< std::string > &	oLabelsToFill
	)		const

adds to oLabelsToFill in execution order the labels of all modules in path iPathLabel

Definition at line 564 of file StreamSchedule.cc.

unsigned int edm::StreamSchedule::numberOfUnscheduledModules ( ) const

inline

Definition at line 257 of file StreamSchedule.h.

template<typename T >

void edm::StreamSchedule::processOneEvent	(	typename T::MyPrincipal &	principal,
		EventSetup const &	eventSetup,
		bool	cleaningUpAfterException = false
	)

Definition at line 375 of file StreamSchedule.h.

template<typename T >

void edm::StreamSchedule::processOneStream	(	typename T::MyPrincipal &	principal,
		EventSetup const &	eventSetup,
		bool	cleaningUpAfterException = false
	)

Definition at line 442 of file StreamSchedule.h.

void edm::StreamSchedule::replaceModule	(	maker::ModuleHolder *	iMod,
		std::string const &	iLabel
	)

clone the type of module with label iLabel but configure with iPSet.

Definition at line 515 of file StreamSchedule.cc.

void edm::StreamSchedule::reportSkipped ( EventPrincipal const &  ep ) const

inlineprivate

Definition at line 369 of file StreamSchedule.h.

void edm::StreamSchedule::resetAll ( )

private

Definition at line 720 of file StreamSchedule.cc.

void edm::StreamSchedule::resetEarlyDelete ( )

private

Definition at line 730 of file StreamSchedule.cc.

TrigResConstPtr edm::StreamSchedule::results ( ) const

inlineprivate

Definition at line 326 of file StreamSchedule.h.

TrigResPtr& edm::StreamSchedule::results ( )

inlineprivate

Definition at line 327 of file StreamSchedule.h.

template<typename T >

void edm::StreamSchedule::runEndPaths ( typename T::MyPrincipal const &  ep, EventSetup const &  es, typename T::Context const *  context  )

private

Definition at line 487 of file StreamSchedule.h.

template<typename T >

bool edm::StreamSchedule::runTriggerPaths ( typename T::MyPrincipal const &  ep, EventSetup const &  es, typename T::Context const *  context  )

private

Definition at line 478 of file StreamSchedule.h.

StreamID edm::StreamSchedule::streamID ( ) const

inline

Definition at line 182 of file StreamSchedule.h.

int edm::StreamSchedule::totalEvents ( ) const

inline

Return the number of events this StreamSchedule has tried to process (inclues both successes and failures, including failures due to exceptions during processing).

Definition at line 218 of file StreamSchedule.h.

int edm::StreamSchedule::totalEventsFailed ( ) const

inline

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

Definition at line 230 of file StreamSchedule.h.

int edm::StreamSchedule::totalEventsPassed ( ) const

inline

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

Definition at line 224 of file StreamSchedule.h.

void edm::StreamSchedule::triggerPaths

(

std::vector< std::string > &

oLabelsToFill

)

const

adds to oLabelsToFill the labels for all trigger paths in the process this is different from availablePaths because it includes the empty paths so matches the entries in TriggerResults exactly.

Definition at line 554 of file StreamSchedule.cc.

Member Data Documentation

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

private

Definition at line 330 of file StreamSchedule.h.

std::vector<std::pair<BranchID,unsigned int> > edm::StreamSchedule::earlyDeleteBranchToCount_

private

Definition at line 346 of file StreamSchedule.h.

std::vector<EarlyDeleteHelper> edm::StreamSchedule::earlyDeleteHelpers_

private

Definition at line 356 of file StreamSchedule.h.

std::vector<unsigned int> edm::StreamSchedule::earlyDeleteHelperToBranchIndicies_

private

Definition at line 353 of file StreamSchedule.h.

vstring edm::StreamSchedule::empty_trig_path_names_

private

Definition at line 341 of file StreamSchedule.h.

std::vector<int> edm::StreamSchedule::empty_trig_paths_

private

Definition at line 340 of file StreamSchedule.h.

vstring edm::StreamSchedule::end_path_name_list_

private

Definition at line 333 of file StreamSchedule.h.

TrigPaths edm::StreamSchedule::end_paths_

private

Definition at line 339 of file StreamSchedule.h.

volatile bool edm::StreamSchedule::endpathsAreActive_

private

Definition at line 364 of file StreamSchedule.h.

unsigned int edm::StreamSchedule::number_of_unscheduled_modules_

private

Definition at line 360 of file StreamSchedule.h.

edm::propagate_const<TrigResPtr> edm::StreamSchedule::results_

private

Definition at line 335 of file StreamSchedule.h.

edm::propagate_const<WorkerPtr> edm::StreamSchedule::results_inserter_

private

Definition at line 337 of file StreamSchedule.h.

StreamContext edm::StreamSchedule::streamContext_

private

Definition at line 363 of file StreamSchedule.h.

StreamID edm::StreamSchedule::streamID_

private

Definition at line 362 of file StreamSchedule.h.

int edm::StreamSchedule::total_events_

private

Definition at line 358 of file StreamSchedule.h.

int edm::StreamSchedule::total_passed_

private

Definition at line 359 of file StreamSchedule.h.

vstring edm::StreamSchedule::trig_name_list_

private

Definition at line 332 of file StreamSchedule.h.

TrigPaths edm::StreamSchedule::trig_paths_

private

Definition at line 338 of file StreamSchedule.h.

WorkerManager edm::StreamSchedule::workerManager_

private

Definition at line 329 of file StreamSchedule.h.