---

edm::WorkerInPath Class Reference

#include <FWCore/Framework/src/WorkerInPath.h>

List of all members.

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 &, CurrentProcessingContext const *cpc)
std::pair< double, double >	timeCpuReal () const
int	timesExcept () const
int	timesFailed () const
int	timesPassed () const
int	timesVisited () const
	WorkerInPath (Worker *, FilterAction theAction)
	WorkerInPath (Worker *)
Private Attributes
FilterAction	filterAction_
RunStopwatch::StopwatchPointer	stopwatch_
int	timesExcept_
int	timesFailed_
int	timesPassed_
int	timesVisited_
Worker *	worker_

---

Detailed Description

Definition at line 21 of file WorkerInPath.h.

---

Member Enumeration Documentation

enum edm::WorkerInPath::FilterAction

Enumerator:

Normal
Ignore
Veto

Definition at line 23 of file WorkerInPath.h.

{ Normal=0, Ignore, Veto };

---

Constructor & Destructor Documentation

edm::WorkerInPath::WorkerInPath

(

Worker *

w

)

[explicit]

Definition at line 17 of file WorkerInPath.cc.

                                     :
    stopwatch_(new RunStopwatch::StopwatchPointer::element_type),
    timesVisited_(),
    timesPassed_(),
    timesFailed_(),
    timesExcept_(),
    filterAction_(Normal),
    worker_(w)
  {
  }

edm::WorkerInPath::WorkerInPath	(	Worker *	w,
		FilterAction	theAction
	)

Definition at line 6 of file WorkerInPath.cc.

                                                                   :
    stopwatch_(new RunStopwatch::StopwatchPointer::element_type),
    timesVisited_(),
    timesPassed_(),
    timesFailed_(),
    timesExcept_(),
    filterAction_(theFilterAction),
    worker_(w)
  {
  }

---

Member Function Documentation

void edm::WorkerInPath::clearCounters

(

)

[inline]

Definition at line 36 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 45 of file WorkerInPath.h.

References filterAction_.

{ return filterAction_; }

Worker* edm::WorkerInPath::getWorker

(

)

const [inline]

Definition at line 46 of file WorkerInPath.h.

References worker_.

{ return worker_; }

template<typename T>

bool edm::WorkerInPath::runWorker	(	typename T::MyPrincipal &	ep,
		EventSetup const &	es,
		CurrentProcessingContext const *	cpc
	)			[inline]

Definition at line 61 of file WorkerInPath.h.

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

                                                                    {

    // A RunStopwatch, but only if we are processing an event.
    std::auto_ptr<RunStopwatch> stopwatch(T::isEvent_ ? new RunStopwatch(stopwatch_) : 0);

    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
        rc = worker_->doWork<T>(ep, es, cpc);

        // 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;
  }

std::pair<double,double> edm::WorkerInPath::timeCpuReal

(

)

const [inline]

Definition at line 32 of file WorkerInPath.h.

References stopwatch_.

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

int edm::WorkerInPath::timesExcept

(

)

const [inline]

Definition at line 43 of file WorkerInPath.h.

References timesExcept_.

{ return timesExcept_; }

int edm::WorkerInPath::timesFailed

(

)

const [inline]

Definition at line 42 of file WorkerInPath.h.

References timesFailed_.

{ return timesFailed_; }

int edm::WorkerInPath::timesPassed

(

)

const [inline]

Definition at line 41 of file WorkerInPath.h.

References timesPassed_.

{ return timesPassed_; }

int edm::WorkerInPath::timesVisited

(

)

const [inline]

Definition at line 40 of file WorkerInPath.h.

References timesVisited_.

{ return timesVisited_; }

---

Member Data Documentation

FilterAction edm::WorkerInPath::filterAction_ [private]

Definition at line 56 of file WorkerInPath.h.

Referenced by filterAction(), and runWorker().

RunStopwatch::StopwatchPointer edm::WorkerInPath::stopwatch_ [private]

Definition at line 49 of file WorkerInPath.h.

Referenced by runWorker(), and timeCpuReal().

int edm::WorkerInPath::timesExcept_ [private]

Definition at line 54 of file WorkerInPath.h.

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

int edm::WorkerInPath::timesFailed_ [private]

Definition at line 53 of file WorkerInPath.h.

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

int edm::WorkerInPath::timesPassed_ [private]

Definition at line 52 of file WorkerInPath.h.

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

int edm::WorkerInPath::timesVisited_ [private]

Definition at line 51 of file WorkerInPath.h.

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

Worker* edm::WorkerInPath::worker_ [private]

Definition at line 57 of file WorkerInPath.h.

Referenced by getWorker(), and runWorker().

---

The documentation for this class was generated from the following files:

• FWCore/Framework/src/WorkerInPath.h
• FWCore/Framework/src/WorkerInPath.cc

---