|
|
|
#include <Worker.h>
| enum edm::Worker::State |
| edm::Worker::Worker | ( | ModuleDescription const & | iMD, |
| WorkerParams const & | iWP | ||
| ) |
Definition at line 37 of file Worker.cc.
:
stopwatch_(),
timesRun_(),
timesVisited_(),
timesPassed_(),
timesFailed_(),
timesExcept_(),
state_(Ready),
md_(iMD),
actions_(iWP.actions_),
cached_exception_(),
actReg_()
{
}
| void edm::Worker::beginJob | ( | void | ) |
Definition at line 60 of file Worker.cc.
References actReg_, edm::errors::BadAlloc, edm::errors::BadExceptionType, trackerHits::c, cached_exception_, description(), ExpressReco_HICollisions_FallBack::e, exception, Exception, implBeginJob(), md_, asciidump::s, state_, edm::errors::StdException, edm::errors::Unknown, and workerType().
Referenced by edm::Schedule::beginJob(), and edm::Schedule::changeModule().
{
try {
ModuleBeginJobSignalSentry cpp(actReg_.get(), md_);
implBeginJob();
}
catch(cms::Exception& e) {
LogError("BeginJob")
<< "A cms::Exception is going through " << workerType() << ":\n";
state_ = Exception;
e << "A cms::Exception is going through " << workerType() << ":\n";
exceptionContext(md_, e);
throw;
}
catch(std::bad_alloc& bda) {
LogError("BeginJob")
<< "A std::bad_alloc is going through " << workerType() << ":\n"
<< description() << "\n";
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::BadAlloc));
*cached_exception_
<< "A std::bad_alloc exception occurred during a call to the module ";
exceptionContext(md_, *cached_exception_)
<< "The job has probably exhausted the virtual memory available to the process.\n";
throw *cached_exception_;
}
catch(std::exception& e) {
LogError("BeginJob")
<< "A std::exception is going through " << workerType() << ":\n"
<< description() << "\n";
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::StdException));
*cached_exception_
<< "A std::exception occurred during a call to the module ";
exceptionContext(md_, *cached_exception_) << "and cannot be repropagated.\n"
<< "Previous information:\n" << e.what();
throw *cached_exception_;
}
catch(std::string& s) {
LogError("BeginJob")
<< "module caught a std::string during endJob\n";
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::BadExceptionType, "std::string"));
*cached_exception_
<< "A std::string thrown as an exception occurred during a call to the module ";
exceptionContext(md_, *cached_exception_) << "and cannot be repropagated.\n"
<< "Previous information:\n string = " << s;
throw *cached_exception_;
}
catch(char const* c) {
LogError("BeginJob")
<< "module caught a const char* during endJob\n";
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::BadExceptionType, "const char *"));
*cached_exception_
<< "A const char* thrown as an exception occurred during a call to the module ";
exceptionContext(md_, *cached_exception_) << "and cannot be repropagated.\n"
<< "Previous information:\n const char* = " << c << "\n";
throw *cached_exception_;
}
catch(...) {
LogError("BeginJob")
<< "An unknown Exception occurred in\n" << description() << "\n";
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::Unknown, "repeated"));
*cached_exception_
<< "An unknown occurred during a previous call to the module ";
exceptionContext(md_, *cached_exception_) << "and cannot be repropagated.\n";
throw *cached_exception_;
}
}
| void edm::Worker::clearCounters | ( | ) | [inline] |
Definition at line 73 of file Worker.h.
References timesExcept_, timesFailed_, timesPassed_, timesRun_, and timesVisited_.
Referenced by edm::Schedule::clearCounters().
{
timesRun_ = timesVisited_ = timesPassed_ = timesFailed_ = timesExcept_ = 0;
}
| ModuleDescription const* edm::Worker::descPtr | ( | ) | const [inline] |
| ModuleDescription const& edm::Worker::description | ( | ) | const [inline] |
Definition at line 63 of file Worker.h.
References md_.
Referenced by edm::UnscheduledCallProducer::addWorker(), beginJob(), edm::Schedule::changeModule(), endJob(), edm::fillModuleInPathSummary(), edm::Schedule::fillWorkers(), edm::fillWorkerSummaryAux(), edm::WorkerMaker< T >::implSwapModule(), and edm::WorkerT< OutputModule >::setModule().
{return md_;}
| bool edm::Worker::doWork | ( | typename T::MyPrincipal & | ep, |
| EventSetup const & | c, | ||
| CurrentProcessingContext const * | cpc, | ||
| CPUTimer *const | timer | ||
| ) |
Definition at line 162 of file Worker.h.
References alignmentValidation::action, actions_, actReg_, edm::errors::BadAlloc, edm::errors::BadExceptionType, trackerHits::c, cached_exception_, ExpressReco_HICollisions_FallBack::e, exception, Exception, Fail, edm::actions::FailModule, edm::actions::FailPath, edm::ActionTable::find(), edm::actions::IgnoreCompletely, implDoBegin(), implDoEnd(), edm::CurrentProcessingContext::isEndPath(), edm::CurrentProcessingContext::isUnscheduled(), md_, edm::errors::OtherCMS, Pass, Ready, edm::actions::Rethrow, cms::Exception::rootCause(), asciidump::s, edm::actions::SkipEvent, state_, edm::errors::StdException, stopwatch_, timesExcept_, timesFailed_, timesPassed_, timesRun_, timesVisited_, edm::errors::Unknown, and cms::Exception::what().
Referenced by edm::WorkerInPath::runWorker().
{
// A RunStopwatch, but only if we are processing an event.
RunDualStopwatches stopwatch(T::isEvent_ ? stopwatch_ : RunStopwatch::StopwatchPointer(),
iTimer);
if (T::isEvent_) {
++timesVisited_;
}
bool rc = false;
switch(state_) {
case Ready: break;
case Pass: return true;
case Fail: return false;
case Exception: {
// rethrow the cached exception again
// It seems impossible to
// get here a second time until a cms::Exception has been
// thrown prviously.
LogWarning("repeat") << "A module has been invoked a second "
<< "time even though it caught an "
<< "exception during the previous "
<< "invocation.\n"
<< "This may be an indication of a "
<< "configuration problem.\n";
cached_exception_->raise();
}
}
if (T::isEvent_) ++timesRun_;
try {
ModuleSignalSentry<T> cpp(actReg_.get(), md_);
if (T::begin_) {
rc = implDoBegin(ep, es, cpc);
} else {
rc = implDoEnd(ep, es, cpc);
}
if (rc) {
state_ = Pass;
if (T::isEvent_) ++timesPassed_;
} else {
state_ = Fail;
if (T::isEvent_) ++timesFailed_;
}
}
catch(cms::Exception& e) {
// NOTE: the warning printed as a result of ignoring or failing
// a module will only be printed during the full true processing
// pass of this module
// Get the action corresponding to this exception. However, if processing
// something other than an event (e.g. run, lumi) always rethrow.
actions::ActionCodes action = (T::isEvent_ ? actions_->find(e.rootCause()) : actions::Rethrow);
// If we are processing an endpath and the module was scheduled, treat SkipEvent or FailPath
// as FailModule, so any subsequent OutputModules are still run.
// For unscheduled modules only treat FailPath as a FailModule but still allow SkipEvent to throw
if (cpc && cpc->isEndPath()) {
if ((action == actions::SkipEvent && !cpc->isUnscheduled()) ||
action == actions::FailPath) action = actions::FailModule;
}
switch(action) {
case actions::IgnoreCompletely: {
rc = true;
++timesPassed_;
state_ = Pass;
LogWarning("IgnoreCompletely")
<< "Module ignored an exception\n"
<< e.what() << "\n";
break;
}
case actions::FailModule: {
rc = true;
LogWarning("FailModule")
<< "Module failed due to an exception\n"
<< e.what() << "\n";
++timesFailed_;
state_ = Fail;
break;
}
default: {
// we should not need to include the event/run/module names
// the exception because the error logger will pick this
// up automatically. I'm leaving it in until this is
// verified
// here we simply add a small amount of data to the
// exception to add some context, we could have rethrown
// it as something else and embedded with this exception
// as an argument to the constructor.
if (T::isEvent_) ++timesExcept_;
state_ = Exception;
e << "cms::Exception going through module ";
exceptionContext(md_, ep, e);
edm::Exception *edmEx = dynamic_cast<edm::Exception *>(&e);
if (edmEx) {
cached_exception_.reset(new edm::Exception(*edmEx));
} else {
cached_exception_.reset(new edm::Exception(errors::OtherCMS, std::string(), e));
}
throw;
}
}
}
catch(std::bad_alloc& bda) {
if (T::isEvent_) ++timesExcept_;
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::BadAlloc));
*cached_exception_
<< "A std::bad_alloc exception occurred during a call to the module ";
exceptionContext(md_, ep, *cached_exception_)
<< "The job has probably exhausted the virtual memory available to the process.\n";
cached_exception_->raise();
}
catch(std::exception& e) {
if (T::isEvent_) ++timesExcept_;
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::StdException));
*cached_exception_
<< "A std::exception occurred during a call to the module ";
exceptionContext(md_, ep, *cached_exception_) << "and cannot be repropagated.\n"
<< "Previous information:\n" << e.what();
cached_exception_->raise();
}
catch(std::string& s) {
if (T::isEvent_) ++timesExcept_;
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::BadExceptionType, "std::string"));
*cached_exception_
<< "A std::string thrown as an exception occurred during a call to the module ";
exceptionContext(md_, ep, *cached_exception_) << "and cannot be repropagated.\n"
<< "Previous information:\n string = " << s;
cached_exception_->raise();
}
catch(char const* c) {
if (T::isEvent_) ++timesExcept_;
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::BadExceptionType, "const char *"));
*cached_exception_
<< "A const char* thrown as an exception occurred during a call to the module ";
exceptionContext(md_, ep, *cached_exception_) << "and cannot be repropagated.\n"
<< "Previous information:\n const char* = " << c << "\n";
cached_exception_->raise();
}
catch(...) {
if (T::isEvent_) ++timesExcept_;
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::Unknown, "repeated"));
*cached_exception_
<< "An unknown occurred during a previous call to the module ";
exceptionContext(md_, ep, *cached_exception_) << "and cannot be repropagated.\n";
cached_exception_->raise();
}
return rc;
}
| void edm::Worker::endJob | ( | void | ) |
Definition at line 132 of file Worker.cc.
References actReg_, edm::errors::BadAlloc, edm::errors::BadExceptionType, trackerHits::c, cached_exception_, description(), ExpressReco_HICollisions_FallBack::e, exception, Exception, implEndJob(), md_, asciidump::s, state_, edm::errors::StdException, edm::errors::Unknown, and workerType().
{
try {
ModuleEndJobSignalSentry cpp(actReg_.get(), md_);
implEndJob();
}
catch(cms::Exception& e) {
LogError("EndJob")
<< "A cms::Exception is going through " << workerType() << ":\n";
state_ = Exception;
e << "A cms::Exception is going through " << workerType() << ":\n";
exceptionContext(md_, e);
throw;
}
catch(std::bad_alloc& bda) {
LogError("EndJob")
<< "A std::bad_alloc is going through " << workerType() << ":\n"
<< description() << "\n";
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::BadAlloc));
*cached_exception_
<< "A std::bad_alloc exception occurred during a call to the module ";
exceptionContext(md_, *cached_exception_)
<< "The job has probably exhausted the virtual memory available to the process.\n";
throw *cached_exception_;
}
catch(std::exception& e) {
LogError("EndJob")
<< "A std::exception is going through " << workerType() << ":\n"
<< description() << "\n";
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::StdException));
*cached_exception_
<< "A std::exception occurred during a call to the module ";
exceptionContext(md_, *cached_exception_) << "and cannot be repropagated.\n"
<< "Previous information:\n" << e.what();
throw *cached_exception_;
}
catch(std::string& s) {
LogError("EndJob")
<< "module caught a std::string during endJob\n";
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::BadExceptionType, "std::string"));
*cached_exception_
<< "A std::string thrown as an exception occurred during a call to the module ";
exceptionContext(md_, *cached_exception_) << "and cannot be repropagated.\n"
<< "Previous information:\n string = " << s;
throw *cached_exception_;
}
catch(char const* c) {
LogError("EndJob")
<< "module caught a const char* during endJob\n";
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::BadExceptionType, "const char *"));
*cached_exception_
<< "A const char* thrown as an exception occurred during a call to the module ";
exceptionContext(md_, *cached_exception_) << "and cannot be repropagated.\n"
<< "Previous information:\n const char* = " << c << "\n";
throw *cached_exception_;
}
catch(...) {
LogError("EndJob")
<< "An unknown Exception occurred in\n" << description() << "\n";
state_ = Exception;
cached_exception_.reset(new edm::Exception(errors::Unknown, "repeated"));
*cached_exception_
<< "An unknown occurred during a previous call to the module ";
exceptionContext(md_, *cached_exception_) << "and cannot be repropagated.\n";
throw *cached_exception_;
}
}
| virtual void edm::Worker::implBeginJob | ( | ) | [protected, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
Referenced by beginJob().
| virtual bool edm::Worker::implDoBegin | ( | EventPrincipal & | , |
| EventSetup const & | c, | ||
| CurrentProcessingContext const * | cpc | ||
| ) | [protected, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
Referenced by doWork().
| virtual bool edm::Worker::implDoBegin | ( | RunPrincipal & | rp, |
| EventSetup const & | c, | ||
| CurrentProcessingContext const * | cpc | ||
| ) | [protected, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
| virtual bool edm::Worker::implDoBegin | ( | LuminosityBlockPrincipal & | lbp, |
| EventSetup const & | c, | ||
| CurrentProcessingContext const * | cpc | ||
| ) | [protected, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
| virtual bool edm::Worker::implDoEnd | ( | EventPrincipal & | , |
| EventSetup const & | c, | ||
| CurrentProcessingContext const * | cpc | ||
| ) | [protected, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
Referenced by doWork().
| virtual bool edm::Worker::implDoEnd | ( | RunPrincipal & | rp, |
| EventSetup const & | c, | ||
| CurrentProcessingContext const * | cpc | ||
| ) | [protected, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
| virtual bool edm::Worker::implDoEnd | ( | LuminosityBlockPrincipal & | lbp, |
| EventSetup const & | c, | ||
| CurrentProcessingContext const * | cpc | ||
| ) | [protected, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
| virtual void edm::Worker::implEndJob | ( | ) | [protected, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
Referenced by endJob().
| virtual void edm::Worker::implPostForkReacquireResources | ( | unsigned int | iChildIndex, |
| unsigned int | iNumberOfChildren | ||
| ) | [private, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
Referenced by postForkReacquireResources().
| virtual void edm::Worker::implPreForkReleaseResources | ( | ) | [private, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
Referenced by preForkReleaseResources().
| virtual void edm::Worker::implRespondToCloseInputFile | ( | FileBlock const & | fb | ) | [private, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
Referenced by respondToCloseInputFile().
| virtual void edm::Worker::implRespondToCloseOutputFiles | ( | FileBlock const & | fb | ) | [private, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
Referenced by respondToCloseOutputFiles().
| virtual void edm::Worker::implRespondToOpenInputFile | ( | FileBlock const & | fb | ) | [private, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
Referenced by respondToOpenInputFile().
| virtual void edm::Worker::implRespondToOpenOutputFiles | ( | FileBlock const & | fb | ) | [private, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
Referenced by respondToOpenOutputFiles().
| void edm::Worker::postForkReacquireResources | ( | unsigned int | iChildIndex, |
| unsigned int | iNumberOfChildren | ||
| ) | [inline] |
Definition at line 59 of file Worker.h.
References implPostForkReacquireResources().
Referenced by edm::Schedule::postForkReacquireResources().
{implPostForkReacquireResources(iChildIndex, iNumberOfChildren);}
| void edm::Worker::preForkReleaseResources | ( | ) | [inline] |
Definition at line 58 of file Worker.h.
References implPreForkReleaseResources().
Referenced by edm::Schedule::preForkReleaseResources().
| void edm::Worker::reset | ( | void | ) | [inline] |
| void edm::Worker::respondToCloseInputFile | ( | FileBlock const & | fb | ) | [inline] |
Definition at line 54 of file Worker.h.
References implRespondToCloseInputFile().
Referenced by edm::Schedule::respondToCloseInputFile().
| void edm::Worker::respondToCloseOutputFiles | ( | FileBlock const & | fb | ) | [inline] |
Definition at line 56 of file Worker.h.
References implRespondToCloseOutputFiles().
Referenced by edm::Schedule::respondToCloseOutputFiles().
| void edm::Worker::respondToOpenInputFile | ( | FileBlock const & | fb | ) | [inline] |
Definition at line 53 of file Worker.h.
References implRespondToOpenInputFile().
Referenced by edm::Schedule::respondToOpenInputFile().
| void edm::Worker::respondToOpenOutputFiles | ( | FileBlock const & | fb | ) | [inline] |
Definition at line 55 of file Worker.h.
References implRespondToOpenOutputFiles().
Referenced by edm::Schedule::respondToOpenOutputFiles().
| void edm::Worker::setActivityRegistry | ( | boost::shared_ptr< ActivityRegistry > | areg | ) |
| State edm::Worker::state | ( | ) | const [inline] |
| std::pair<double, double> edm::Worker::timeCpuReal | ( | ) | const [inline] |
Definition at line 69 of file Worker.h.
References stopwatch_.
{
return std::pair<double, double>(stopwatch_->cpuTime(), stopwatch_->realTime());
}
| int edm::Worker::timesExcept | ( | ) | const [inline] |
Definition at line 83 of file Worker.h.
References timesExcept_.
Referenced by edm::fillWorkerSummaryAux().
{ return timesExcept_; }
| int edm::Worker::timesFailed | ( | ) | const [inline] |
Definition at line 82 of file Worker.h.
References timesFailed_.
Referenced by edm::fillWorkerSummaryAux().
{ return timesFailed_; }
| int edm::Worker::timesPass | ( | ) | const [inline] |
Definition at line 86 of file Worker.h.
References timesPassed().
{ return timesPassed(); } // for backward compatibility only - to be removed soon
| int edm::Worker::timesPassed | ( | ) | const [inline] |
Definition at line 81 of file Worker.h.
References timesPassed_.
Referenced by edm::fillWorkerSummaryAux(), and timesPass().
{ return timesPassed_; }
| int edm::Worker::timesRun | ( | ) | const [inline] |
Definition at line 79 of file Worker.h.
References timesRun_.
Referenced by edm::fillWorkerSummaryAux().
{ return timesRun_; }
| int edm::Worker::timesVisited | ( | ) | const [inline] |
Definition at line 80 of file Worker.h.
References timesVisited_.
Referenced by edm::fillWorkerSummaryAux().
{ return timesVisited_; }
| void edm::Worker::useStopwatch | ( | ) |
Definition at line 204 of file Worker.cc.
References stopwatch_.
Referenced by edm::Schedule::addToAllWorkers().
{
stopwatch_.reset(new RunStopwatch::StopwatchPointer::element_type);
}
| virtual std::string edm::Worker::workerType | ( | ) | const [protected, pure virtual] |
Implemented in edm::WorkerT< T >, and edm::WorkerT< OutputModule >.
Referenced by beginJob(), and endJob().
ActionTable const* edm::Worker::actions_ [private] |
boost::shared_ptr<ActivityRegistry> edm::Worker::actReg_ [private] |
Definition at line 127 of file Worker.h.
Referenced by beginJob(), doWork(), endJob(), and setActivityRegistry().
boost::shared_ptr<edm::Exception> edm::Worker::cached_exception_ [private] |
Definition at line 125 of file Worker.h.
Referenced by beginJob(), doWork(), and endJob().
ModuleDescription edm::Worker::md_ [private] |
Definition at line 123 of file Worker.h.
Referenced by beginJob(), descPtr(), description(), doWork(), and endJob().
State edm::Worker::state_ [private] |
Definition at line 114 of file Worker.h.
Referenced by doWork(), timeCpuReal(), and useStopwatch().
int edm::Worker::timesExcept_ [private] |
Definition at line 120 of file Worker.h.
Referenced by clearCounters(), doWork(), and timesExcept().
int edm::Worker::timesFailed_ [private] |
Definition at line 119 of file Worker.h.
Referenced by clearCounters(), doWork(), and timesFailed().
int edm::Worker::timesPassed_ [private] |
Definition at line 118 of file Worker.h.
Referenced by clearCounters(), doWork(), and timesPassed().
int edm::Worker::timesRun_ [private] |
Definition at line 116 of file Worker.h.
Referenced by clearCounters(), doWork(), and timesRun().
int edm::Worker::timesVisited_ [private] |
Definition at line 117 of file Worker.h.
Referenced by clearCounters(), doWork(), and timesVisited().
1.7.3