edm::WorkerInPath Class Reference

#include <WorkerInPath.h>

Public Types
enum	FilterAction { Normal =0, Ignore, Veto }

Public Member Functions
void	clearCounters ()
FilterAction	filterAction () const
Worker *	getWorker () const
template<typename T >
bool	runWorker (typename T::MyPrincipal &, EventSetup const &, StreamID streamID, typename T::Context const *context)
void	setPathContext (PathContext const *v)
std::pair< double, double >	timeCpuReal () const
int	timesExcept () const
int	timesFailed () const
int	timesPassed () const
int	timesVisited () const
void	useStopwatch ()
	WorkerInPath (Worker *, FilterAction theAction, unsigned int placeInPath)

Private Attributes
FilterAction	filterAction_
PlaceInPathContext	placeInPathContext_
RunStopwatch::StopwatchPointer	stopwatch_
int	timesExcept_
int	timesFailed_
int	timesPassed_
int	timesVisited_
Worker *	worker_

Detailed Description

Definition at line 24 of file WorkerInPath.h.

Member Enumeration Documentation

enum edm::WorkerInPath::FilterAction

Enumerator
Normal
Ignore
Veto

Definition at line 26 of file WorkerInPath.h.

{ Normal=0, Ignore, Veto };

Constructor & Destructor Documentation

edm::WorkerInPath::WorkerInPath	(	Worker *	w,
		FilterAction	theAction,
		unsigned int	placeInPath
	)

Definition at line 6 of file WorkerInPath.cc.

                                                                                             :
    stopwatch_(),
    timesVisited_(),
    timesPassed_(),
    timesFailed_(),
    timesExcept_(),
    filterAction_(theFilterAction),
    worker_(w),
    placeInPathContext_(placeInPath)
  {
  }

Member Function Documentation

void edm::WorkerInPath::clearCounters ( )

inline

Definition at line 42 of file WorkerInPath.h.

References timesExcept_, timesFailed_, timesPassed_, and timesVisited_.

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

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

FilterAction edm::WorkerInPath::filterAction ( ) const

inline

Definition at line 52 of file WorkerInPath.h.

References filterAction_.

{ return filterAction_; }

Worker* edm::WorkerInPath::getWorker ( ) const

inline

Definition at line 53 of file WorkerInPath.h.

References worker_.

{ return worker_; }

template<typename T >

bool edm::WorkerInPath::runWorker	(	typename T::MyPrincipal &	ep,
		EventSetup const &	es,
		StreamID	streamID,
		typename T::Context const *	context
	)

Definition at line 72 of file WorkerInPath.h.

References edm::Worker::doWork(), filterAction_, Ignore, placeInPathContext_, stopwatch_, timesExcept_, timesFailed_, timesPassed_, timesVisited_, Veto, and worker_.

                                                                 {

    if (T::isEvent_) {
      ++timesVisited_;
    }
    bool rc = true;

    try {
    // may want to change the return value from the worker to be 
    // the Worker::FilterAction so conditions in the path will be easier to 
    // identify
        if(T::isEvent_) {
          ParentContext parentContext(&placeInPathContext_);          
          rc = worker_->doWork<T>(ep, es, stopwatch_.get(),streamID, parentContext, context);
        } else {
          ParentContext parentContext(context);
          rc = worker_->doWork<T>(ep, es, stopwatch_.get(),streamID, parentContext, context);
        }
        // Ignore return code for non-event (e.g. run, lumi) calls
    if (!T::isEvent_) rc = true;
    else if (filterAction_ == Veto) rc = !rc;
        else if (filterAction_ == Ignore) rc = true;

    if (T::isEvent_) {
      if(rc) ++timesPassed_; else ++timesFailed_;
    }
    }
    catch(...) {
    if (T::isEvent_) ++timesExcept_;
    throw;
    }

    return rc;
  }

void edm::WorkerInPath::setPathContext ( PathContext const *  v )

inline

Definition at line 55 of file WorkerInPath.h.

References placeInPathContext_, and edm::PlaceInPathContext::setPathContext().

{ placeInPathContext_.setPathContext(v); }

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

inline

Definition at line 35 of file WorkerInPath.h.

References stopwatch_.

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

int edm::WorkerInPath::timesExcept ( ) const

inline

Definition at line 50 of file WorkerInPath.h.

References timesExcept_.

{ return timesExcept_; }

int edm::WorkerInPath::timesFailed ( ) const

inline

Definition at line 49 of file WorkerInPath.h.

References timesFailed_.

{ return timesFailed_; }

int edm::WorkerInPath::timesPassed ( ) const

inline

Definition at line 48 of file WorkerInPath.h.

References timesPassed_.

{ return timesPassed_; }

int edm::WorkerInPath::timesVisited ( ) const

inline

Definition at line 47 of file WorkerInPath.h.

References timesVisited_.

{ return timesVisited_; }

void edm::WorkerInPath::useStopwatch

(

)

Definition at line 19 of file WorkerInPath.cc.

References stopwatch_.

                              {
      stopwatch_.reset(new RunStopwatch::StopwatchPointer::element_type);
   }

Member Data Documentation

FilterAction edm::WorkerInPath::filterAction_

private

Definition at line 65 of file WorkerInPath.h.

Referenced by filterAction(), and runWorker().

PlaceInPathContext edm::WorkerInPath::placeInPathContext_

private

Definition at line 68 of file WorkerInPath.h.

Referenced by runWorker(), and setPathContext().

RunStopwatch::StopwatchPointer edm::WorkerInPath::stopwatch_

private

Definition at line 58 of file WorkerInPath.h.

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

int edm::WorkerInPath::timesExcept_

private

Definition at line 63 of file WorkerInPath.h.

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

int edm::WorkerInPath::timesFailed_

private

Definition at line 62 of file WorkerInPath.h.

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

int edm::WorkerInPath::timesPassed_

private

Definition at line 61 of file WorkerInPath.h.

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

int edm::WorkerInPath::timesVisited_

private

Definition at line 60 of file WorkerInPath.h.

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

Worker* edm::WorkerInPath::worker_

private

Definition at line 66 of file WorkerInPath.h.

Referenced by getWorker(), and runWorker().