edm::Path Class Reference

#include <Path.h>

Public Types
typedef WorkersInPath::size_type	size_type
typedef hlt::HLTState	State
typedef boost::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, boost::shared_ptr< ActivityRegistry > reg, StreamContext const *streamContext, PathContext::PathType pathType)
	Path (Path const &)
template<typename T >
void	processOneOccurrence (typename T::MyPrincipal &, EventSetup const &, StreamID const &, typename T::Context const *)
void	setEarlyDeleteHelpers (std::map< const Worker *, EarlyDeleteHelper * > const &)
size_type	size () const
State	state () const
std::pair< double, double >	timeCpuReal () const
std::pair< double, double >	timeCpuReal (unsigned int const i) 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
void	useStopwatch ()

Private Member Functions
void	handleEarlyFinish (EventPrincipal &)
void	handleEarlyFinish (RunPrincipal &)
void	handleEarlyFinish (LuminosityBlockPrincipal &)
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_
boost::shared_ptr < ActivityRegistry >	actReg_
int	bitpos_
std::vector< EarlyDeleteHelper * >	earlyDeleteHelpers_
PathContext	pathContext_
State	state_
RunStopwatch::StopwatchPointer	stopwatch_
int	timesExcept_
int	timesFailed_
int	timesPassed_
int	timesRun_
TrigResPtr	trptr_
WorkersInPath	workers_

Detailed Description

Definition at line 42 of file Path.h.

Member Typedef Documentation

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

Definition at line 47 of file Path.h.

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

Definition at line 44 of file Path.h.

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

Definition at line 48 of file Path.h.

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

Definition at line 46 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,
		boost::shared_ptr< ActivityRegistry >	reg,
		StreamContext const *	streamContext,
		PathContext::PathType	pathType
	)

Definition at line 13 of file Path.cc.

References pathContext_, and workers_.

                                           :
    stopwatch_(),
    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 38 of file Path.cc.

References pathContext_, and workers_.

                          :
    stopwatch_(r.stopwatch_),
    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 64 of file Path.h.

References bitpos_.

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

{ return bitpos_; }

void edm::Path::clearCounters

(

)

Definition at line 161 of file Path.cc.

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

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

                      {
    timesRun_ = timesPassed_ = timesFailed_ = timesExcept_ = 0;
    for_all(workers_, boost::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 104 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 92 of file Path.h.

References workers_.

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

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

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

private

Definition at line 194 of file Path.cc.

References earlyDeleteHelpers_.

Referenced by processOneOccurrence().

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

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

inlineprivate

Definition at line 141 of file Path.h.

{}

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

inlineprivate

Definition at line 142 of file Path.h.

{}

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 60 of file Path.cc.

References act_table_, alignCSCRings::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 65 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__(), edm::StreamSchedule::availablePaths(), edm::fillPathSummary(), edm::fillPathTimingSummary(), edm::StreamSchedule::modulesInPath(), and Vispa.Views.PropertyView.Property::valueChanged().

{ return pathContext_.pathName(); }

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

privatedelete

template<typename T >

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

Definition at line 169 of file Path.h.

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

                                                                                              {

    //Create the PathSignalSentry before the RunStopwatch so that
    // we only record the time spent in the path not from the signal
    int nwrwue = -1;
    PathSignalSentry<T> signaler(actReg_.get(), nwrwue, state_, &pathContext_);

    // A RunStopwatch, but only if we are processing an event.
    RunStopwatch stopwatch(T::isEvent_ ? stopwatch_ : RunStopwatch::StopwatchPointer());

    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 143 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 177 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 87 of file Path.h.

References workers_.

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

{ return workers_.size(); }

State edm::Path::state ( ) const

inline

Definition at line 85 of file Path.h.

References state_.

{ return state_; }

std::pair<double, double> edm::Path::timeCpuReal ( ) const

inline

Definition at line 67 of file Path.h.

References stopwatch_.

Referenced by edm::fillModuleInPathTimingSummary(), and edm::fillPathTimingSummary().

                                                {
      if(stopwatch_) {
        return std::pair<double, double>(stopwatch_->cpuTime(), stopwatch_->realTime());
      }
      return std::pair<double, double>(0., 0.);
    }

std::pair<double, double> edm::Path::timeCpuReal ( unsigned int const  i ) const

inline

Definition at line 74 of file Path.h.

References workers_.

                                                                    {
      return workers_.at(i).timeCpuReal();
    }

int edm::Path::timesExcept ( ) const

inline

Definition at line 83 of file Path.h.

References timesExcept_.

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

{ return timesExcept_; }

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

inline

Definition at line 91 of file Path.h.

References workers_.

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

int edm::Path::timesFailed ( ) const

inline

Definition at line 82 of file Path.h.

References timesFailed_.

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

{ return timesFailed_; }

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

inline

Definition at line 90 of file Path.h.

References workers_.

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

int edm::Path::timesPassed ( ) const

inline

Definition at line 81 of file Path.h.

References timesPassed_.

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

{ return timesPassed_; }

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

inline

Definition at line 89 of file Path.h.

References workers_.

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

int edm::Path::timesRun ( ) const

inline

Definition at line 80 of file Path.h.

References timesRun_.

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

{ return timesRun_; }

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

inline

Definition at line 88 of file Path.h.

References workers_.

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

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

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

private

Definition at line 150 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;
    }
  }

void edm::Path::useStopwatch

(

)

Definition at line 167 of file Path.cc.

References stopwatch_, and workers_.

                     {
    stopwatch_.reset(new RunStopwatch::StopwatchPointer::element_type);
    for(WorkersInPath::iterator it=workers_.begin(), itEnd = workers_.end();
        it != itEnd;
        ++it) {
      it->useStopwatch();
    }
  }

Member Data Documentation

ExceptionToActionTable const* edm::Path::act_table_

private

Definition at line 114 of file Path.h.

Referenced by handleWorkerFailure().

boost::shared_ptr<ActivityRegistry> edm::Path::actReg_

private

Definition at line 113 of file Path.h.

Referenced by processOneOccurrence().

int edm::Path::bitpos_

private

Definition at line 111 of file Path.h.

Referenced by bitPosition(), and recordStatus().

std::vector<EarlyDeleteHelper*> edm::Path::earlyDeleteHelpers_

private

Definition at line 117 of file Path.h.

Referenced by handleEarlyFinish(), and setEarlyDeleteHelpers().

PathContext edm::Path::pathContext_

private

Definition at line 119 of file Path.h.

Referenced by handleWorkerFailure(), name(), Path(), and processOneOccurrence().

State edm::Path::state_

private

Definition at line 109 of file Path.h.

Referenced by handleWorkerFailure(), processOneOccurrence(), recordStatus(), state(), and updateCounters().

RunStopwatch::StopwatchPointer edm::Path::stopwatch_

private

Definition at line 103 of file Path.h.

Referenced by processOneOccurrence(), timeCpuReal(), and useStopwatch().

int edm::Path::timesExcept_

private

Definition at line 107 of file Path.h.

Referenced by clearCounters(), handleWorkerFailure(), and timesExcept().

int edm::Path::timesFailed_

private

Definition at line 106 of file Path.h.

Referenced by clearCounters(), timesFailed(), and updateCounters().

int edm::Path::timesPassed_

private

Definition at line 105 of file Path.h.

Referenced by clearCounters(), timesPassed(), and updateCounters().

int edm::Path::timesRun_

private

Definition at line 104 of file Path.h.

Referenced by clearCounters(), processOneOccurrence(), and timesRun().

TrigResPtr edm::Path::trptr_

private

Definition at line 112 of file Path.h.

Referenced by recordStatus().

WorkersInPath edm::Path::workers_

private

Definition at line 116 of file Path.h.

Referenced by clearCounters(), getWorker(), Path(), processOneOccurrence(), size(), timeCpuReal(), timesExcept(), timesFailed(), timesPassed(), timesVisited(), and useStopwatch().