#include <Worker.h>

Inheritance diagram for edm::Worker:

Public Types
enum	State { Ready, Pass, Fail, Exception }

enum	Types { kAnalyzer, kFilter, kProducer, kOutputModule }

Public Member Functions
void	beginJob ()

void	beginStream (StreamID id, StreamContext &streamContext)

void	clearCounters ()

ModuleDescription const *	descPtr () const

ModuleDescription const &	description () const

template<typename T >
bool	doWork (typename T::MyPrincipal &, EventSetup const &c, StreamID stream, ParentContext const &parentContext, typename T::Context const *context)

void	endJob ()

void	endStream (StreamID id, StreamContext &streamContext)

virtual void	modulesDependentUpon (std::vector< const char * > &oModuleLabels) const =0

virtual Types	moduleType () const =0

Worker &	operator= (Worker const &)=delete

void	pathFinished (EventPrincipal &)

void	postDoEvent (EventPrincipal &)

void	postForkReacquireResources (unsigned int iChildIndex, unsigned int iNumberOfChildren)

void	preForkReleaseResources ()

void	registerThinnedAssociations (ProductRegistry const &registry, ThinnedAssociationsHelper &helper)

void	reset ()

void	respondToCloseInputFile (FileBlock const &fb)

void	respondToOpenInputFile (FileBlock const &fb)

void	setActivityRegistry (std::shared_ptr< ActivityRegistry > areg)

void	setEarlyDeleteHelper (EarlyDeleteHelper *iHelper)

State	state () const

int	timesExcept () const

int	timesFailed () const

int	timesPass () const

int	timesPassed () const

int	timesRun () const

int	timesVisited () const

virtual void	updateLookup (BranchType iBranchType, ProductHolderIndexHelper const &)=0

	Worker (ModuleDescription const &iMD, ExceptionToActionTable const *iActions)

	Worker (Worker const &)=delete

virtual	~Worker ()

Protected Member Functions
ActivityRegistry *	activityRegistry ()

virtual void	implBeginJob ()=0

virtual void	implBeginStream (StreamID)=0

virtual bool	implDo (EventPrincipal &, EventSetup const &c, ModuleCallingContext const *mcc)=0

virtual bool	implDoBegin (RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *mcc)=0

virtual bool	implDoBegin (LuminosityBlockPrincipal &lbp, EventSetup const &c, ModuleCallingContext const *mcc)=0

virtual bool	implDoEnd (RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *mcc)=0

virtual bool	implDoEnd (LuminosityBlockPrincipal &lbp, EventSetup const &c, ModuleCallingContext const *mcc)=0

virtual bool	implDoStreamBegin (StreamID id, RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *mcc)=0

virtual bool	implDoStreamBegin (StreamID id, LuminosityBlockPrincipal &lbp, EventSetup const &c, ModuleCallingContext const *mcc)=0

virtual bool	implDoStreamEnd (StreamID id, RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *mcc)=0

virtual bool	implDoStreamEnd (StreamID id, LuminosityBlockPrincipal &lbp, EventSetup const &c, ModuleCallingContext const *mcc)=0

virtual void	implEndJob ()=0

virtual void	implEndStream (StreamID)=0

void	resetModuleDescription (ModuleDescription const *)

virtual std::string	workerType () const =0

Private Member Functions
virtual void	implPostForkReacquireResources (unsigned int iChildIndex, unsigned int iNumberOfChildren)=0

virtual void	implPreForkReleaseResources ()=0

virtual void	implRegisterThinnedAssociations (ProductRegistry const &, ThinnedAssociationsHelper &)=0

virtual void	implRespondToCloseInputFile (FileBlock const &fb)=0

virtual void	implRespondToOpenInputFile (FileBlock const &fb)=0

virtual void	itemsMayGet (BranchType, std::vector< ProductHolderIndexAndSkipBit > &) const =0

virtual void	itemsToGet (BranchType, std::vector< ProductHolderIndexAndSkipBit > &) const =0

virtual std::vector < ProductHolderIndexAndSkipBit > const &	itemsToGetFromEvent () const =0

Private Attributes
ExceptionToActionTable const *	actions_

std::shared_ptr< ActivityRegistry >	actReg_

std::shared_ptr< cms::Exception >	cached_exception_

EarlyDeleteHelper *	earlyDeleteHelper_

ModuleCallingContext	moduleCallingContext_

State	state_

int	timesExcept_

int	timesFailed_

int	timesPassed_

int	timesRun_

int	timesVisited_

Friends
template<typename O >
class	workerhelper::CallImpl

Detailed Description

Definition at line 64 of file Worker.h.

Member Enumeration Documentation

enum edm::Worker::State

Enumerator
Ready
Pass
Fail
Exception

Definition at line 66 of file Worker.h.

66 { Ready, Pass, Fail, Exception };

edm::Worker::Ready

Definition: Worker.h:66

edm::Worker::Fail

Definition: Worker.h:66

Exception

edm::Worker::Pass

Definition: Worker.h:66

enum edm::Worker::Types

Enumerator
kAnalyzer
kFilter
kProducer
kOutputModule

Definition at line 67 of file Worker.h.

67 { kAnalyzer, kFilter, kProducer, kOutputModule};

edm::Worker::kAnalyzer

Definition: Worker.h:67

edm::Worker::kOutputModule

Definition: Worker.h:67

edm::Worker::kProducer

Definition: Worker.h:67

edm::Worker::kFilter

Definition: Worker.h:67

Constructor & Destructor Documentation

edm::Worker::Worker	(	ModuleDescription const &	iMD,
		ExceptionToActionTable const *	iActions
	)

Definition at line 71 of file Worker.cc.

                                                  :
     timesRun_(),
     timesVisited_(),
     timesPassed_(),
     timesFailed_(),
     timesExcept_(),
     state_(Ready),
     moduleCallingContext_(&iMD),
     actions_(iActions),
     cached_exception_(),
     actReg_(),
     earlyDeleteHelper_(nullptr)
   {
   }

edm::Worker::~Worker ( )

virtual

Definition at line 87 of file Worker.cc.

87 {

88 }

edm::Worker::Worker ( Worker const & )

delete

Member Function Documentation

ActivityRegistry* edm::Worker::activityRegistry ( )

inlineprotected

Definition at line 153 of file Worker.h.

References actReg_.

153 { return actReg_.get(); }

edm::Worker::actReg_

std::shared_ptr< ActivityRegistry > actReg_

Definition: Worker.h:182

void edm::Worker::beginJob ( void )

Definition at line 104 of file Worker.cc.

References actReg_, cms::Exception::addContext(), description(), Exception, implBeginJob(), edm::ModuleDescription::moduleLabel(), edm::ModuleDescription::moduleName(), state_, and edm::convertException::wrap().

Referenced by edm::WorkerManager::beginJob(), and edm::GlobalSchedule::replaceModule().

                         {
     try {
       convertException::wrap([&]() {
         ModuleBeginJobSignalSentry cpp(actReg_.get(), description());
         implBeginJob();
       });
     }
     catch(cms::Exception& ex) {
       state_ = Exception;
       std::ostringstream ost;
       ost << "Calling beginJob for module " << description().moduleName() << "/'" << description().moduleLabel() << "'";
       ex.addContext(ost.str());
       throw;
     }
   }

void edm::Worker::beginStream	(	StreamID	id,
		StreamContext &	streamContext
	)

Definition at line 136 of file Worker.cc.

References actReg_, cms::Exception::addContext(), description(), Exception, implBeginStream(), edm::LuminosityBlockIndex::invalidLuminosityBlockIndex(), edm::RunIndex::invalidRunIndex(), edm::StreamContext::kBeginStream, edm::ModuleCallingContext::kRunning, moduleCallingContext_, edm::ModuleDescription::moduleLabel(), edm::ModuleDescription::moduleName(), edm::StreamContext::setEventID(), edm::StreamContext::setLuminosityBlockIndex(), edm::StreamContext::setRunIndex(), edm::ModuleCallingContext::setState(), edm::StreamContext::setTimestamp(), edm::StreamContext::setTransition(), state_, and edm::convertException::wrap().

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

                                                                     {
     try {
       convertException::wrap([&]() {
         streamContext.setTransition(StreamContext::Transition::kBeginStream);
         streamContext.setEventID(EventID(0, 0, 0));
         streamContext.setRunIndex(RunIndex::invalidRunIndex());
         streamContext.setLuminosityBlockIndex(LuminosityBlockIndex::invalidLuminosityBlockIndex());
         streamContext.setTimestamp(Timestamp());
         ParentContext parentContext(&streamContext);
         ModuleContextSentry moduleContextSentry(&moduleCallingContext_, parentContext);
         moduleCallingContext_.setState(ModuleCallingContext::State::kRunning);
         ModuleBeginStreamSignalSentry beginSentry(actReg_.get(), streamContext, moduleCallingContext_);
         implBeginStream(id);
       });
     }
     catch(cms::Exception& ex) {
       state_ = Exception;
       std::ostringstream ost;
       ost << "Calling beginStream for module " << description().moduleName() << "/'" << description().moduleLabel() << "'";
       ex.addContext(ost.str());
       throw;
     }
   }

void edm::Worker::clearCounters ( )

inline

Definition at line 112 of file Worker.h.

References timesExcept_, timesFailed_, timesPassed_, timesRun_, and timesVisited_.

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

                          {
       timesRun_ = timesVisited_ = timesPassed_ = timesFailed_ = timesExcept_ = 0;
     }

ModuleDescription const* edm::Worker::descPtr ( ) const

inline

Definition at line 97 of file Worker.h.

References moduleCallingContext_, and edm::ModuleCallingContext::moduleDescription().

97 {return moduleCallingContext_.moduleDescription(); }

edm::Worker::moduleCallingContext_

ModuleCallingContext moduleCallingContext_

Definition: Worker.h:177

edm::ModuleCallingContext::moduleDescription

ModuleDescription const * moduleDescription() const

Definition: ModuleCallingContext.h:54

ModuleDescription const& edm::Worker::description ( ) const

inline

Definition at line 96 of file Worker.h.

References moduleCallingContext_, and edm::ModuleCallingContext::moduleDescription().

Referenced by edm::UnscheduledCallProducer::addWorker(), beginJob(), beginStream(), endJob(), endStream(), edm::fillModuleInPathSummary(), edm::StreamSchedule::fillWorkers(), and edm::fillWorkerSummaryAux().

96 {return *(moduleCallingContext_.moduleDescription());}

edm::Worker::moduleCallingContext_

ModuleCallingContext moduleCallingContext_

Definition: Worker.h:177

edm::ModuleCallingContext::moduleDescription

ModuleDescription const * moduleDescription() const

Definition: ModuleCallingContext.h:54

template<typename T >

bool edm::Worker::doWork	(	typename T::MyPrincipal &	ep,
		EventSetup const &	c,
		StreamID	stream,
		ParentContext const &	parentContext,
		typename T::Context const *	context
	)

Definition at line 390 of file Worker.h.

References alignCSCRings::action, actions_, actReg_, cached_exception_, cms::Exception::category(), Exception, Fail, edm::exception_actions::FailPath, edm::ExceptionToActionTable::find(), edm::ModuleCallingContext::getTopModuleCallingContext(), edm::exception_actions::IgnoreCompletely, edm::PathContext::isEndPath(), itemsToGetFromEvent(), edm::ParentContext::kPlaceInPath, edm::ModuleCallingContext::kRunning, moduleCallingContext_, Pass, edm::PlaceInPathContext::pathContext(), edm::ModuleCallingContext::placeInPathContext(), edm::printCmsExceptionWarning(), edm::ProductHolderIndexAmbiguous, Ready, edm::exception_actions::Rethrow, edm::ModuleCallingContext::setState(), edm::exception_actions::SkipEvent, state_, timesExcept_, timesFailed_, timesPassed_, timesRun_, timesVisited_, edm::ModuleCallingContext::type(), and edm::convertException::wrap().

Referenced by edm::WorkerInPath::runWorker().

                                                         {
 
     if (T::isEvent_) {
       ++timesVisited_;
     }
     bool rc = false;
 
     switch(state_) {
       case Ready: break;
       case Pass: return true;
       case Fail: return false;
       case Exception: {
       cached_exception_->raise();
       }
     }
 
     ModuleContextSentry moduleContextSentry(&moduleCallingContext_, parentContext);
 
     try {
       convertException::wrap([&]() {
 
         if (T::isEvent_) {
           ++timesRun_;
 
           // Prefetch products the module declares it consumes (not including the products it maybe consumes)
           std::vector<ProductHolderIndexAndSkipBit> const& items = itemsToGetFromEvent();
           for(auto const& item : items) {
             ProductHolderIndex productHolderIndex = item.productHolderIndex();
             bool skipCurrentProcess = item.skipCurrentProcess();
             if(productHolderIndex != ProductHolderIndexAmbiguous) {
               ep.prefetch(productHolderIndex, skipCurrentProcess, &moduleCallingContext_);
             }
           }
         }
 
         moduleCallingContext_.setState(ModuleCallingContext::State::kRunning);
         rc = workerhelper::CallImpl<T>::call(this,streamID,ep,es, actReg_.get(), &moduleCallingContext_, context);
 
         if (rc) {
           state_ = Pass;
           if (T::isEvent_) ++timesPassed_;
         } else {
           state_ = Fail;
           if (T::isEvent_) ++timesFailed_;
         }
       });
     }
     catch(cms::Exception& ex) {
 
       // 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.
       exception_actions::ActionCodes action = (T::isEvent_ ? actions_->find(ex.category()) : exception_actions::Rethrow);
 
       // If we are processing an endpath and the module was scheduled, treat SkipEvent or FailPath
       // as IgnoreCompletely, so any subsequent OutputModules are still run.
       // For unscheduled modules only treat FailPath as IgnoreCompletely but still allow SkipEvent to throw
       ModuleCallingContext const* top_mcc = moduleCallingContext_.getTopModuleCallingContext();
       if(top_mcc->type() == ParentContext::Type::kPlaceInPath &&
          top_mcc->placeInPathContext()->pathContext()->isEndPath()) {
 
           if ((action == exception_actions::SkipEvent && moduleCallingContext_.type() == ParentContext::Type::kPlaceInPath) ||
                action == exception_actions::FailPath) action = exception_actions::IgnoreCompletely;
       }
       switch(action) {
         case exception_actions::IgnoreCompletely:
           rc = true;
           ++timesPassed_;
       state_ = Pass;
           exceptionContext<T>(ep, ex, &moduleCallingContext_);
           edm::printCmsExceptionWarning("IgnoreCompletely", ex);
       break;
         default:
           if (T::isEvent_) ++timesExcept_;
       state_ = Exception;
           cached_exception_.reset(ex.clone());
       cached_exception_->raise();
       }
     }
     return rc;
   }

void edm::Worker::endJob ( void )

Definition at line 120 of file Worker.cc.

References actReg_, cms::Exception::addContext(), description(), Exception, implEndJob(), edm::ModuleDescription::moduleLabel(), edm::ModuleDescription::moduleName(), state_, and edm::convertException::wrap().

                       {
     try {
       convertException::wrap([&]() {
         ModuleEndJobSignalSentry cpp(actReg_.get(), description());
         implEndJob();
       });
     }
     catch(cms::Exception& ex) {
       state_ = Exception;
       std::ostringstream ost;
       ost << "Calling endJob for module " << description().moduleName() << "/'" << description().moduleLabel() << "'";
       ex.addContext(ost.str());
       throw;
     }
   }

void edm::Worker::endStream	(	StreamID	id,
		StreamContext &	streamContext
	)

Definition at line 160 of file Worker.cc.

References actReg_, cms::Exception::addContext(), description(), Exception, implEndStream(), edm::LuminosityBlockIndex::invalidLuminosityBlockIndex(), edm::RunIndex::invalidRunIndex(), edm::StreamContext::kEndStream, edm::ModuleCallingContext::kRunning, moduleCallingContext_, edm::ModuleDescription::moduleLabel(), edm::ModuleDescription::moduleName(), edm::StreamContext::setEventID(), edm::StreamContext::setLuminosityBlockIndex(), edm::StreamContext::setRunIndex(), edm::ModuleCallingContext::setState(), edm::StreamContext::setTimestamp(), edm::StreamContext::setTransition(), state_, and edm::convertException::wrap().

                                                                   {
     try {
       convertException::wrap([&]() {
         streamContext.setTransition(StreamContext::Transition::kEndStream);
         streamContext.setEventID(EventID(0, 0, 0));
         streamContext.setRunIndex(RunIndex::invalidRunIndex());
         streamContext.setLuminosityBlockIndex(LuminosityBlockIndex::invalidLuminosityBlockIndex());
         streamContext.setTimestamp(Timestamp());
         ParentContext parentContext(&streamContext);
         ModuleContextSentry moduleContextSentry(&moduleCallingContext_, parentContext);
         moduleCallingContext_.setState(ModuleCallingContext::State::kRunning);
         ModuleEndStreamSignalSentry endSentry(actReg_.get(), streamContext, moduleCallingContext_);
         implEndStream(id);
       });
     }
     catch(cms::Exception& ex) {
       state_ = Exception;
       std::ostringstream ost;
       ost << "Calling endStream for module " << description().moduleName() << "/'" << description().moduleLabel() << "'";
       ex.addContext(ost.str());
       throw;
     }
   }

virtual void edm::Worker::implBeginJob ( )

protectedpure virtual

Implemented in edm::WorkerT< T >.

Referenced by beginJob().

virtual void edm::Worker::implBeginStream ( StreamID )

protectedpure virtual

Implemented in edm::WorkerT< T >.

Referenced by beginStream().

virtual bool edm::Worker::implDo	(	EventPrincipal &	,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

protectedpure virtual

Implemented in edm::WorkerT< T >.

Referenced by edm::workerhelper::CallImpl< OccurrenceTraits< EventPrincipal, BranchActionStreamBegin > >::call().

virtual bool edm::Worker::implDoBegin	(	RunPrincipal &	rp,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

protectedpure virtual

Implemented in edm::WorkerT< T >.

Referenced by edm::workerhelper::CallImpl< OccurrenceTraits< RunPrincipal, BranchActionGlobalBegin > >::call(), and edm::workerhelper::CallImpl< OccurrenceTraits< LuminosityBlockPrincipal, BranchActionGlobalBegin > >::call().

virtual bool edm::Worker::implDoBegin	(	LuminosityBlockPrincipal &	lbp,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

protectedpure virtual

Implemented in edm::WorkerT< T >.

virtual bool edm::Worker::implDoEnd	(	RunPrincipal &	rp,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

protectedpure virtual

Implemented in edm::WorkerT< T >.

Referenced by edm::workerhelper::CallImpl< OccurrenceTraits< RunPrincipal, BranchActionGlobalEnd > >::call(), and edm::workerhelper::CallImpl< OccurrenceTraits< LuminosityBlockPrincipal, BranchActionGlobalEnd > >::call().

virtual bool edm::Worker::implDoEnd	(	LuminosityBlockPrincipal &	lbp,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

protectedpure virtual

Implemented in edm::WorkerT< T >.

virtual bool edm::Worker::implDoStreamBegin	(	StreamID	id,
		RunPrincipal &	rp,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

protectedpure virtual

Implemented in edm::WorkerT< T >.

Referenced by edm::workerhelper::CallImpl< OccurrenceTraits< RunPrincipal, BranchActionStreamBegin > >::call(), and edm::workerhelper::CallImpl< OccurrenceTraits< LuminosityBlockPrincipal, BranchActionStreamBegin > >::call().

virtual bool edm::Worker::implDoStreamBegin	(	StreamID	id,
		LuminosityBlockPrincipal &	lbp,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

protectedpure virtual

Implemented in edm::WorkerT< T >.

virtual bool edm::Worker::implDoStreamEnd	(	StreamID	id,
		RunPrincipal &	rp,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

protectedpure virtual

Implemented in edm::WorkerT< T >.

Referenced by edm::workerhelper::CallImpl< OccurrenceTraits< RunPrincipal, BranchActionStreamEnd > >::call(), and edm::workerhelper::CallImpl< OccurrenceTraits< LuminosityBlockPrincipal, BranchActionStreamEnd > >::call().

virtual bool edm::Worker::implDoStreamEnd	(	StreamID	id,
		LuminosityBlockPrincipal &	lbp,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

protectedpure virtual

Implemented in edm::WorkerT< T >.

virtual void edm::Worker::implEndJob ( )

protectedpure virtual

Implemented in edm::WorkerT< T >.

Referenced by endJob().

virtual void edm::Worker::implEndStream ( StreamID )

protectedpure virtual

Implemented in edm::WorkerT< T >.

Referenced by endStream().

virtual void edm::Worker::implPostForkReacquireResources	(	unsigned int	iChildIndex,
		unsigned int	iNumberOfChildren
	)

privatepure virtual

Implemented in edm::WorkerT< T >.

Referenced by postForkReacquireResources().

virtual void edm::Worker::implPreForkReleaseResources ( )

privatepure virtual

Implemented in edm::WorkerT< T >.

Referenced by preForkReleaseResources().

virtual void edm::Worker::implRegisterThinnedAssociations	(	ProductRegistry const &	,
		ThinnedAssociationsHelper &
	)

privatepure virtual

Implemented in edm::WorkerT< T >.

Referenced by registerThinnedAssociations().

virtual void edm::Worker::implRespondToCloseInputFile ( FileBlock const & fb )

privatepure virtual

Implemented in edm::WorkerT< T >.

Referenced by respondToCloseInputFile().

virtual void edm::Worker::implRespondToOpenInputFile ( FileBlock const & fb )

privatepure virtual

Implemented in edm::WorkerT< T >.

Referenced by respondToOpenInputFile().

virtual void edm::Worker::itemsMayGet	(	BranchType	,
		std::vector< ProductHolderIndexAndSkipBit > &
	)		const

privatepure virtual

Implemented in edm::WorkerT< T >.

virtual void edm::Worker::itemsToGet	(	BranchType	,
		std::vector< ProductHolderIndexAndSkipBit > &
	)		const

privatepure virtual

Implemented in edm::WorkerT< T >.

virtual std::vector<ProductHolderIndexAndSkipBit> const& edm::Worker::itemsToGetFromEvent ( ) const

privatepure virtual

Implemented in edm::WorkerT< T >.

Referenced by doWork().

virtual void edm::Worker::modulesDependentUpon ( std::vector< const char * > & oModuleLabels ) const

pure virtual

Implemented in edm::WorkerT< T >.

virtual Types edm::Worker::moduleType ( ) const

pure virtual

Implemented in edm::WorkerT< T >, edm::WorkerT< T >, edm::WorkerT< T >, edm::WorkerT< T >, edm::WorkerT< T >, edm::WorkerT< T >, edm::WorkerT< T >, edm::WorkerT< T >, edm::WorkerT< T >, edm::WorkerT< T >, edm::WorkerT< T >, edm::WorkerT< T >, edm::WorkerT< T >, edm::WorkerT< T >, and edm::WorkerT< T >.

Referenced by edm::WorkerManager::addToUnscheduledWorkers(), and edm::StreamSchedule::fillWorkers().

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

delete

void edm::Worker::pathFinished ( EventPrincipal & iEvent )

Definition at line 184 of file Worker.cc.

References earlyDeleteHelper_, and edm::EarlyDeleteHelper::pathFinished().

                                                   {
     if(earlyDeleteHelper_) {
       earlyDeleteHelper_->pathFinished(iEvent);
     }
   }

void edm::Worker::postDoEvent ( EventPrincipal & iEvent )

Definition at line 189 of file Worker.cc.

References earlyDeleteHelper_, and edm::EarlyDeleteHelper::moduleRan().

Referenced by edm::WorkerT< T >::implDo().

                                                  {
     if(earlyDeleteHelper_) {
       earlyDeleteHelper_->moduleRan(iEvent);
     }
   }

void edm::Worker::postForkReacquireResources	(	unsigned int	iChildIndex,
		unsigned int	iNumberOfChildren
	)

inline

Definition at line 88 of file Worker.h.

References implPostForkReacquireResources().

Referenced by edm::Schedule::postForkReacquireResources().

88 {implPostForkReacquireResources(iChildIndex, iNumberOfChildren);}

edm::Worker::implPostForkReacquireResources

virtual void implPostForkReacquireResources(unsigned int iChildIndex, unsigned int iNumberOfChildren)=0

void edm::Worker::preForkReleaseResources ( )

inline

Definition at line 87 of file Worker.h.

References implPreForkReleaseResources().

Referenced by edm::Schedule::preForkReleaseResources().

87 {implPreForkReleaseResources();}

edm::Worker::implPreForkReleaseResources

virtual void implPreForkReleaseResources()=0

void edm::Worker::registerThinnedAssociations	(	ProductRegistry const &	registry,
		ThinnedAssociationsHelper &	helper
	)

inline

Definition at line 89 of file Worker.h.

References implRegisterThinnedAssociations().

89 { implRegisterThinnedAssociations(registry, helper); }

edm::Worker::implRegisterThinnedAssociations

virtual void implRegisterThinnedAssociations(ProductRegistry const &, ThinnedAssociationsHelper &)=0

PhysicsTools::registry

static Interceptor::Registry registry("Interceptor")

void edm::Worker::reset ( void )

inline

Definition at line 91 of file Worker.h.

References Ready, and state_.

Referenced by edm::WorkerManager::resetAll().

91 { state_ = Ready; }

edm::Worker::Ready

Definition: Worker.h:66

edm::Worker::state_

State state_

Definition: Worker.h:175

void edm::Worker::resetModuleDescription ( ModuleDescription const * iDesc )

protected

Definition at line 98 of file Worker.cc.

References moduleCallingContext_, edm::ModuleCallingContext::parent(), edm::ModuleCallingContext::previousModuleOnThread(), edm::ModuleCallingContext::state(), and groupFilesInBlocks::temp.

Referenced by edm::WorkerT< T >::setModule().

                                                                     {
     ModuleCallingContext temp(iDesc,moduleCallingContext_.state(),moduleCallingContext_.parent(),
                               moduleCallingContext_.previousModuleOnThread());
     moduleCallingContext_ = temp;
   }

void edm::Worker::respondToCloseInputFile ( FileBlock const & fb )

inline

Definition at line 85 of file Worker.h.

References implRespondToCloseInputFile().

Referenced by edm::Schedule::respondToCloseInputFile().

85 {implRespondToCloseInputFile(fb);}

benchmark_cfg.fb

string fb

Definition: benchmark_cfg.py:14

edm::Worker::implRespondToCloseInputFile

virtual void implRespondToCloseInputFile(FileBlock const &fb)=0

void edm::Worker::respondToOpenInputFile ( FileBlock const & fb )

inline

Definition at line 84 of file Worker.h.

References implRespondToOpenInputFile().

Referenced by edm::Schedule::respondToOpenInputFile().

84 {implRespondToOpenInputFile(fb);}

benchmark_cfg.fb

string fb

Definition: benchmark_cfg.py:14

edm::Worker::implRespondToOpenInputFile

virtual void implRespondToOpenInputFile(FileBlock const &fb)=0

void edm::Worker::setActivityRegistry ( std::shared_ptr< ActivityRegistry > areg )

The signals are required to live longer than the last call to 'doWork' this was done to improve performance based on profiling

Definition at line 90 of file Worker.cc.

References actReg_, and edm::areg.

                                                                        {
     actReg_ = areg;
   }

void edm::Worker::setEarlyDeleteHelper ( EarlyDeleteHelper * iHelper )

Definition at line 94 of file Worker.cc.

References earlyDeleteHelper_.

                                                               {
     earlyDeleteHelper_=iHelper;
   }

State edm::Worker::state ( ) const

inline

Definition at line 121 of file Worker.h.

References state_.

121 { return state_; }

edm::Worker::state_

State state_

Definition: Worker.h:175

int edm::Worker::timesExcept ( ) const

inline

Definition at line 120 of file Worker.h.

References timesExcept_.

Referenced by edm::fillWorkerSummaryAux().

120 { return timesExcept_; }

edm::Worker::timesExcept_

int timesExcept_

Definition: Worker.h:174

int edm::Worker::timesFailed ( ) const

inline

Definition at line 119 of file Worker.h.

References timesFailed_.

Referenced by edm::fillWorkerSummaryAux().

119 { return timesFailed_; }

edm::Worker::timesFailed_

int timesFailed_

Definition: Worker.h:173

int edm::Worker::timesPass ( ) const

inline

Definition at line 123 of file Worker.h.

References timesPassed().

123 { return timesPassed(); } // for backward compatibility only - to be removed soon

edm::Worker::timesPassed

int timesPassed() const

Definition: Worker.h:118

int edm::Worker::timesPassed ( ) const

inline

Definition at line 118 of file Worker.h.

References timesPassed_.

Referenced by edm::fillWorkerSummaryAux(), and timesPass().

118 { return timesPassed_; }

edm::Worker::timesPassed_

int timesPassed_

Definition: Worker.h:172

int edm::Worker::timesRun ( ) const

inline

Definition at line 116 of file Worker.h.

References timesRun_.

Referenced by edm::fillWorkerSummaryAux().

116 { return timesRun_; }

edm::Worker::timesRun_

int timesRun_

Definition: Worker.h:170

int edm::Worker::timesVisited ( ) const

inline

Definition at line 117 of file Worker.h.

References timesVisited_.

Referenced by edm::fillWorkerSummaryAux().

117 { return timesVisited_; }

edm::Worker::timesVisited_

int timesVisited_

Definition: Worker.h:171

virtual void edm::Worker::updateLookup	(	BranchType	iBranchType,
		ProductHolderIndexHelper const &
	)

pure virtual

Implemented in edm::WorkerT< T >.

Referenced by edm::Schedule::changeModule().

virtual std::string edm::Worker::workerType ( ) const

protectedpure virtual

Implemented in edm::WorkerT< T >.

Friends And Related Function Documentation

template<typename O >

friend class workerhelper::CallImpl

friend

Definition at line 126 of file Worker.h.

Member Data Documentation

ExceptionToActionTable const* edm::Worker::actions_

private

Definition at line 179 of file Worker.h.

Referenced by doWork().

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

private

Definition at line 182 of file Worker.h.

Referenced by activityRegistry(), beginJob(), beginStream(), doWork(), endJob(), endStream(), and setActivityRegistry().

std::shared_ptr<cms::Exception> edm::Worker::cached_exception_

private

Definition at line 180 of file Worker.h.

Referenced by doWork().

EarlyDeleteHelper* edm::Worker::earlyDeleteHelper_

private

Definition at line 184 of file Worker.h.

Referenced by pathFinished(), postDoEvent(), and setEarlyDeleteHelper().

ModuleCallingContext edm::Worker::moduleCallingContext_

private

Definition at line 177 of file Worker.h.

Referenced by beginStream(), descPtr(), description(), doWork(), endStream(), and resetModuleDescription().

State edm::Worker::state_

private

Definition at line 175 of file Worker.h.

Referenced by beginJob(), beginStream(), doWork(), endJob(), endStream(), reset(), and state().

int edm::Worker::timesExcept_

private

Definition at line 174 of file Worker.h.

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

int edm::Worker::timesFailed_

private

Definition at line 173 of file Worker.h.

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

int edm::Worker::timesPassed_

private

Definition at line 172 of file Worker.h.

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

int edm::Worker::timesRun_

private

Definition at line 170 of file Worker.h.

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

int edm::Worker::timesVisited_

private

Definition at line 171 of file Worker.h.

Referenced by clearCounters(), doWork(), and timesVisited().

Public Types

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Friends

Detailed Description

Member Enumeration Documentation

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation