#include <Path.h>

Public Types
typedef WorkersInPath::size_type	size_type

typedef hlt::HLTState	State

typedef std::shared_ptr < HLTGlobalStatus >	TrigResPtr

typedef std::vector< WorkerInPath >	WorkersInPath

Public Member Functions
int	bitPosition () const

void	clearCounters ()

Worker const *	getWorker (size_type i) const

std::string const &	name () const

	Path (int bitpos, std::string const &path_name, WorkersInPath const &workers, TrigResPtr trptr, ExceptionToActionTable const &actions, std::shared_ptr< ActivityRegistry > reg, StreamContext const *streamContext, PathContext::PathType pathType)

	Path (Path const &)

template<typename T >
void	processOneOccurrence (typename T::MyPrincipal const &, EventSetup const &, StreamID const &, typename T::Context const *)

void	setEarlyDeleteHelpers (std::map< const Worker , EarlyDeleteHelper > const &)

size_type	size () const

State	state () const

int	timesExcept () const

int	timesExcept (size_type i) const

int	timesFailed () const

int	timesFailed (size_type i) const

int	timesPassed () const

int	timesPassed (size_type i) const

int	timesRun () const

int	timesVisited (size_type i) const

Private Member Functions
void	handleEarlyFinish (EventPrincipal const &)

void	handleEarlyFinish (RunPrincipal const &)

void	handleEarlyFinish (LuminosityBlockPrincipal const &)

bool	handleWorkerFailure (cms::Exception &e, int nwrwue, bool isEvent, bool begin, BranchType branchType, ModuleDescription const &, std::string const &id)

Path const &	operator= (Path const &)=delete

void	recordStatus (int nwrwue, bool isEvent)

void	updateCounters (bool succeed, bool isEvent)

Static Private Member Functions
static void	exceptionContext (cms::Exception &ex, bool isEvent, bool begin, BranchType branchType, ModuleDescription const &, std::string const &id, PathContext const &)

Private Attributes
ExceptionToActionTable const *	act_table_

std::shared_ptr< ActivityRegistry >	actReg_

int	bitpos_

std::vector< EarlyDeleteHelper * >	earlyDeleteHelpers_

PathContext	pathContext_

State	state_

int	timesExcept_

int	timesFailed_

int	timesPassed_

int	timesRun_

TrigResPtr	trptr_

WorkersInPath	workers_

Detailed Description

Definition at line 40 of file Path.h.

Member Typedef Documentation

typedef WorkersInPath::size_type edm::Path::size_type

Definition at line 45 of file Path.h.

typedef hlt::HLTState edm::Path::State

Definition at line 42 of file Path.h.

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

Definition at line 46 of file Path.h.

typedef std::vector<WorkerInPath> edm::Path::WorkersInPath

Definition at line 44 of file Path.h.

Constructor & Destructor Documentation

edm::Path::Path	(	int	bitpos,
		std::string const &	path_name,
		WorkersInPath const &	workers,
		TrigResPtr	trptr,
		ExceptionToActionTable const &	actions,
		std::shared_ptr< ActivityRegistry >	reg,
		StreamContext const *	streamContext,
		PathContext::PathType	pathType
	)

Definition at line 12 of file Path.cc.

References pathContext_, and workers_.

                                            :
     timesRun_(),
     timesPassed_(),
     timesFailed_(),
     timesExcept_(),
     state_(hlt::Ready),
     bitpos_(bitpos),
     trptr_(trptr),
     actReg_(areg),
     act_table_(&actions),
     workers_(workers),
     pathContext_(path_name, streamContext, bitpos, pathType) {
 
     for (auto& workerInPath : workers_) {
       workerInPath.setPathContext(&pathContext_);
     }
   }

edm::Path::Path ( Path const & r )

Definition at line 36 of file Path.cc.

References pathContext_, and workers_.

                           :
     timesRun_(r.timesRun_),
     timesPassed_(r.timesPassed_),
     timesFailed_(r.timesFailed_),
     timesExcept_(r.timesExcept_),
     state_(r.state_),
     bitpos_(r.bitpos_),
     trptr_(r.trptr_),
     actReg_(r.actReg_),
     act_table_(r.act_table_),
     workers_(r.workers_),
     earlyDeleteHelpers_(r.earlyDeleteHelpers_),
     pathContext_(r.pathContext_) {
 
     for (auto& workerInPath : workers_) {
       workerInPath.setPathContext(&pathContext_);
     }
   }

Member Function Documentation

int edm::Path::bitPosition ( ) const

inline

Definition at line 62 of file Path.h.

References bitpos_.

Referenced by edm::fillPathSummary().

62 { return bitpos_; }

edm::Path::bitpos_

int bitpos_

Definition: Path.h:96

void edm::Path::clearCounters ( )

Definition at line 158 of file Path.cc.

References edm::WorkerInPath::clearCounters(), edm::for_all(), timesExcept_, timesFailed_, timesPassed_, timesRun_, and workers_.

Referenced by edm::StreamSchedule::clearCounters().

                       {
     using std::placeholders::_1;
     timesRun_ = timesPassed_ = timesFailed_ = timesExcept_ = 0;
     for_all(workers_, std::bind(&WorkerInPath::clearCounters, _1));
   }

void edm::Path::exceptionContext	(	cms::Exception &	ex,
		bool	isEvent,
		bool	begin,
		BranchType	branchType,
		ModuleDescription const &	desc,
		std::string const &	id,
		PathContext const &	pathContext
	)

staticprivate

Definition at line 101 of file Path.cc.

References cms::Exception::addContext(), edm::InLumi, edm::InRun, edm::ModuleDescription::moduleLabel(), edm::ModuleDescription::moduleName(), and edm::PathContext::pathName().

Referenced by handleWorkerFailure().

                                                          {
     std::ostringstream ost;
     if (isEvent) {
       ost << "Calling event method";
     }
     else if (begin && branchType == InRun) {
       ost << "Calling beginRun";
     }
     else if (begin && branchType == InLumi) {
       ost << "Calling beginLuminosityBlock";
     }
     else if (!begin && branchType == InLumi) {
       ost << "Calling endLuminosityBlock";
     }
     else if (!begin && branchType == InRun) {
       ost << "Calling endRun";
     }
     else {
       // It should be impossible to get here ...
       ost << "Calling unknown function";
     }
     ost << " for module " << desc.moduleName() << "/'" << desc.moduleLabel() << "'";
     ex.addContext(ost.str());
     ost.str("");
     ost << "Running path '" << pathContext.pathName() << "'";
     ex.addContext(ost.str());
     ost.str("");
     ost << "Processing ";
     ost << id;
     ex.addContext(ost.str());
   }

Worker const* edm::Path::getWorker ( size_type i ) const

inline

Definition at line 79 of file Path.h.

References workers_.

Referenced by edm::fillModuleInPathSummary(), and setEarlyDeleteHelpers().

79 { return workers_.at(i).getWorker(); }

i

int i

Definition: DBlmapReader.cc:9

edm::Path::workers_

WorkersInPath workers_

Definition: Path.h:101

void edm::Path::handleEarlyFinish ( EventPrincipal const & iEvent )

private

Definition at line 182 of file Path.cc.

References earlyDeleteHelpers_.

Referenced by processOneOccurrence().

                                                       {
     for(auto helper: earlyDeleteHelpers_) {
       helper->pathFinished(iEvent);
     }
   }

void edm::Path::handleEarlyFinish ( RunPrincipal const & )

inlineprivate

Definition at line 126 of file Path.h.

126 {}

void edm::Path::handleEarlyFinish ( LuminosityBlockPrincipal const & )

inlineprivate

Definition at line 127 of file Path.h.

127 {}

bool edm::Path::handleWorkerFailure	(	cms::Exception &	e,
		int	nwrwue,
		bool	isEvent,
		bool	begin,
		BranchType	branchType,
		ModuleDescription const &	desc,
		std::string const &	id
	)

private

Definition at line 57 of file Path.cc.

References act_table_, mps_fire::action, cms::Exception::addAdditionalInfo(), cms::Exception::category(), edm::Exception::codeToString(), edm::hlt::Exception, exceptionContext(), edm::exception_actions::FailPath, edm::ExceptionToActionTable::find(), pathContext_, edm::printCmsExceptionWarning(), edm::errors::ProductNotFound, recordStatus(), edm::exception_actions::Rethrow, state_, AlCaHLTBitMon_QueryRunRegistry::string, and timesExcept_.

Referenced by processOneOccurrence().

                                                  {
 
     exceptionContext(e, isEvent, begin, branchType, desc, id, pathContext_);
 
     bool should_continue = true;
 
     // there is no support as of yet for specific paths having
     // different exception behavior
     
     // If not processing an event, always rethrow.
     exception_actions::ActionCodes action = (isEvent ? act_table_->find(e.category()) : exception_actions::Rethrow);
     switch(action) {
       case exception_actions::FailPath: {
       should_continue = false;
           edm::printCmsExceptionWarning("FailPath", e);
       break;
       }
       default: {
       if (isEvent) ++timesExcept_;
       state_ = hlt::Exception;
       recordStatus(nwrwue, isEvent);
       if (action == exception_actions::Rethrow) {
         std::string pNF = Exception::codeToString(errors::ProductNotFound);
             if (e.category() == pNF) {
           std::ostringstream ost;
               ost <<  "If you wish to continue processing events after a " << pNF << " exception,\n" <<
           "add \"SkipEvent = cms.untracked.vstring('ProductNotFound')\" to the \"options\" PSet in the configuration.\n";
               e.addAdditionalInfo(ost.str());
             }
       }
           throw;
       }
     }
 
     return should_continue;
   }

std::string const& edm::Path::name ( void ) const

inline

Definition at line 63 of file Path.h.

References pathContext_, and edm::PathContext::pathName().

Referenced by cuy.divideElement::__init__(), cuy.plotElement::__init__(), cuy.additionElement::__init__(), cuy.superimposeElement::__init__(), cuy.graphElement::__init__(), config.CFG::__str__(), edm::StreamSchedule::availablePaths(), validation.Sample::digest(), edm::fillPathSummary(), VIDSelectorBase.VIDSelectorBase::initialize(), edm::StreamSchedule::moduleDescriptionsInEndPath(), edm::StreamSchedule::moduleDescriptionsInPath(), edm::StreamSchedule::modulesInPath(), and Vispa.Views.PropertyView.Property::valueChanged().

63 { return pathContext_.pathName(); }

edm::PathContext::pathName

std::string const & pathName() const

Definition: PathContext.h:37

edm::Path::pathContext_

PathContext pathContext_

Definition: Path.h:104

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

privatedelete

template<typename T >

void edm::Path::processOneOccurrence	(	typename T::MyPrincipal const &	ep,
		EventSetup const &	es,
		StreamID const &	streamID,
		typename T::Context const *	context
	)

Definition at line 154 of file Path.h.

References actReg_, end, handleEarlyFinish(), handleWorkerFailure(), i, pathContext_, edm::hlt::Ready, recordStatus(), state_, timesRun_, updateCounters(), workers_, and edm::convertException::wrap().

                                                                                               {
 
     int nwrwue = -1;
     PathSignalSentry<T> signaler(actReg_.get(), nwrwue, state_, &pathContext_);
 
     if (T::isEvent_) {
       ++timesRun_;
     }
     state_ = hlt::Ready;
 
     // nwrue =  numWorkersRunWithoutUnhandledException
     bool should_continue = true;
 
     for (WorkersInPath::iterator i = workers_.begin(), end = workers_.end();
           i != end && should_continue;
           ++i) {
       ++nwrwue;
       try {
         convertException::wrap([&]() {
           if(T::isEvent_) {
             should_continue = i->runWorker<T>(ep, es, streamID, context);
           } else {
             should_continue = i->runWorker<T>(ep, es, streamID, context);
           }
         });
       }
       catch(cms::Exception& ex) {
         // handleWorkerFailure may throw a new exception.
     std::ostringstream ost;
         ost << ep.id();
         should_continue = handleWorkerFailure(ex, nwrwue, T::isEvent_, T::begin_, T::branchType_,
                                               i->getWorker()->description(), ost.str());
       }
     }
     if (not should_continue) {
       handleEarlyFinish(ep);
     }
     updateCounters(should_continue, T::isEvent_);
     recordStatus(nwrwue, T::isEvent_);
   }

void edm::Path::recordStatus	(	int	nwrwue,
		bool	isEvent
	)

private

Definition at line 140 of file Path.cc.

References bitpos_, state_, and trptr_.

Referenced by handleWorkerFailure(), and processOneOccurrence().

                                              {
     if(isEvent && trptr_) {
       (*trptr_)[bitpos_]=HLTPathStatus(state_, nwrwue);    
     }
   }

void edm::Path::setEarlyDeleteHelpers ( std::map< const Worker *, EarlyDeleteHelper * > const & iWorkerToDeleter )

Definition at line 165 of file Path.cc.

References earlyDeleteHelpers_, newFWLiteAna::found, getWorker(), cmsHarvester::index, size(), and groupFilesInBlocks::temp.

                                                                                               {
     //we use a temp so we can overset the size but then when moving to earlyDeleteHelpers we only
     // have to use the space necessary
     std::vector<EarlyDeleteHelper*> temp;
     temp.reserve(iWorkerToDeleter.size());
     for(unsigned int index=0; index !=size();++index) {
       auto found = iWorkerToDeleter.find(getWorker(index));
       if(found != iWorkerToDeleter.end()) {
         temp.push_back(found->second);
         found->second->addedToPath();
       }
     }
     std::vector<EarlyDeleteHelper*> tempCorrectSize(temp.begin(),temp.end());
     earlyDeleteHelpers_.swap(tempCorrectSize);
   }

size_type edm::Path::size ( void ) const

inline

Definition at line 74 of file Path.h.

References workers_.

Referenced by edm::fillPathSummary(), and setEarlyDeleteHelpers().

74 { return workers_.size(); }

edm::Path::workers_

WorkersInPath workers_

Definition: Path.h:101

State edm::Path::state ( ) const

inline

Definition at line 72 of file Path.h.

References state_.

72 { return state_; }

edm::Path::state_

State state_

Definition: Path.h:94

int edm::Path::timesExcept ( ) const

inline

Definition at line 70 of file Path.h.

References timesExcept_.

Referenced by edm::fillModuleInPathSummary(), and edm::fillPathSummary().

70 { return timesExcept_; }

edm::Path::timesExcept_

int timesExcept_

Definition: Path.h:92

int edm::Path::timesExcept ( size_type i ) const

inline

Definition at line 78 of file Path.h.

References workers_.

78 { return workers_.at(i).timesExcept() ; }

i

int i

Definition: DBlmapReader.cc:9

edm::Path::workers_

WorkersInPath workers_

Definition: Path.h:101

int edm::Path::timesFailed ( ) const

inline

Definition at line 69 of file Path.h.

References timesFailed_.

Referenced by edm::fillModuleInPathSummary(), and edm::fillPathSummary().

69 { return timesFailed_; }

edm::Path::timesFailed_

int timesFailed_

Definition: Path.h:91

int edm::Path::timesFailed ( size_type i ) const

inline

Definition at line 77 of file Path.h.

References workers_.

77 { return workers_.at(i).timesFailed() ; }

i

int i

Definition: DBlmapReader.cc:9

edm::Path::workers_

WorkersInPath workers_

Definition: Path.h:101

int edm::Path::timesPassed ( ) const

inline

Definition at line 68 of file Path.h.

References timesPassed_.

Referenced by edm::fillModuleInPathSummary(), and edm::fillPathSummary().

68 { return timesPassed_; }

edm::Path::timesPassed_

int timesPassed_

Definition: Path.h:90

int edm::Path::timesPassed ( size_type i ) const

inline

Definition at line 76 of file Path.h.

References workers_.

76 { return workers_.at(i).timesPassed() ; }

i

int i

Definition: DBlmapReader.cc:9

edm::Path::workers_

WorkersInPath workers_

Definition: Path.h:101

int edm::Path::timesRun ( ) const

inline

Definition at line 67 of file Path.h.

References timesRun_.

Referenced by edm::fillPathSummary().

67 { return timesRun_; }

edm::Path::timesRun_

int timesRun_

Definition: Path.h:89

int edm::Path::timesVisited ( size_type i ) const

inline

Definition at line 75 of file Path.h.

References workers_.

Referenced by edm::fillModuleInPathSummary().

75 { return workers_.at(i).timesVisited(); }

i

int i

Definition: DBlmapReader.cc:9

edm::Path::workers_

WorkersInPath workers_

Definition: Path.h:101

void edm::Path::updateCounters	(	bool	succeed,
		bool	isEvent
	)

private

Definition at line 147 of file Path.cc.

References edm::hlt::Fail, edm::hlt::Pass, state_, timesFailed_, and timesPassed_.

Referenced by processOneOccurrence().

                                                  {
     if (success) {
       if (isEvent) ++timesPassed_;
       state_ = hlt::Pass;
     } else {
       if(isEvent) ++timesFailed_;
       state_ = hlt::Fail;
     }
   }