edm::WorkerInPath Class Reference

#include <WorkerInPath.h>

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

Public Member Functions
bool	checkResultsOfRunWorker (bool wasEvent)
void	clearCounters ()
FilterAction	filterAction () const
Worker *	getWorker () const
bool	runConcurrently () const noexcept
template<typename T >
void	runWorkerAsync (WaitingTaskHolder, typename T::TransitionInfoType const &, ServiceToken const &, StreamID, typename T::Context const *)
void	setPathContext (PathContext const *v)
void	skipWorker (EventPrincipal const &iPrincipal)
void	skipWorker (RunPrincipal const &)
void	skipWorker (LuminosityBlockPrincipal const &)
int	timesExcept () const
int	timesFailed () const
int	timesPassed () const
int	timesVisited () const
	WorkerInPath (Worker *, FilterAction theAction, unsigned int placeInPath, bool runConcurrently)

Private Attributes
FilterAction	filterAction_
PlaceInPathContext	placeInPathContext_
bool	runConcurrently_
int	timesExcept_
int	timesFailed_
int	timesPassed_
int	timesVisited_
Worker *	worker_

Detailed Description

Definition at line 25 of file WorkerInPath.h.

Member Enumeration Documentation

enum edm::WorkerInPath::FilterAction

Enumerator
Normal
Ignore
Veto

Definition at line 27 of file WorkerInPath.h.

{ Normal = 0, Ignore, Veto };

Constructor & Destructor Documentation

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

Definition at line 6 of file WorkerInPath.cc.

References edm::Worker::addedToPath().

      : timesVisited_(),
        timesPassed_(),
        timesFailed_(),
        timesExcept_(),
        filterAction_(theFilterAction),
        worker_(w),
        placeInPathContext_(placeInPath),
        runConcurrently_(runConcurrently) {
    w->addedToPath();
  }

Member Function Documentation

bool edm::WorkerInPath::checkResultsOfRunWorker ( bool  wasEvent )

inline

Definition at line 70 of file WorkerInPath.h.

References cms::cuda::assert(), edm::Worker::Exception, edm::Worker::Fail, filterAction(), Ignore, edm::Worker::Pass, edm::Worker::state(), timesExcept_, timesFailed_, timesPassed_, Veto, and worker_.

                                                                 {
    if (not wasEvent) {
      return true;
    }
    auto state = worker_->state();
    bool rc = true;
    switch (state) {
      case Worker::Fail: {
        rc = false;
        break;
      }
      case Worker::Pass:
        break;
      case Worker::Exception: {
        ++timesExcept_;
        return true;
      }

      default:
        assert(false);
    }

    if (Ignore == filterAction()) {
      rc = true;
    } else if (Veto == filterAction()) {
      rc = !rc;
    }

    if (rc) {
      ++timesPassed_;
    } else {
      ++timesFailed_;
    }
    return rc;
  }

void edm::WorkerInPath::clearCounters ( )

inline

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

References filterAction_.

Referenced by checkResultsOfRunWorker().

{ return filterAction_; }

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

inline

Definition at line 52 of file WorkerInPath.h.

References worker_.

{ return worker_; }

bool edm::WorkerInPath::runConcurrently ( ) const

inlinenoexcept

Definition at line 53 of file WorkerInPath.h.

References runConcurrently_.

{ return runConcurrently_; }

template<typename T >

void edm::WorkerInPath::runWorkerAsync	(	WaitingTaskHolder	iTask,
		typename T::TransitionInfoType const &	info,
		ServiceToken const &	token,
		StreamID	streamID,
		typename T::Context const *	context
	)

Definition at line 107 of file WorkerInPath.h.

References visDQMUpload::context, edm::Worker::doWorkAsync(), edm::Worker::doWorkNoPrefetchingAsync(), info(), placeInPathContext_, timesVisited_, unpackBuffers-CaloStage2::token, and worker_.

                                                                      {
    if constexpr (T::isEvent_) {
      ++timesVisited_;
    }

    if constexpr (T::isEvent_) {
      ParentContext parentContext(&placeInPathContext_);
      worker_->doWorkAsync<T>(iTask, info, token, streamID, parentContext, context);
    } else {
      ParentContext parentContext(context);

      // We do not need to run prefetching here because this only handles
      // stream transitions for runs and lumis. There are no products put
      // into the runs or lumis in stream transitions, so there can be
      // no data dependencies which require prefetching. Prefetching is
      // needed for global transitions, but they are run elsewhere.
      worker_->doWorkNoPrefetchingAsync<T>(iTask, info, token, streamID, parentContext, context);
    }
  }

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

void edm::WorkerInPath::skipWorker ( EventPrincipal const &  iPrincipal )

inline

Definition at line 40 of file WorkerInPath.h.

References edm::Worker::skipOnPath(), and worker_.

{ worker_->skipOnPath(iPrincipal); }

void edm::WorkerInPath::skipWorker ( RunPrincipal const &  )

inline

Definition at line 41 of file WorkerInPath.h.

{}

void edm::WorkerInPath::skipWorker ( LuminosityBlockPrincipal const &  )

inline

Definition at line 42 of file WorkerInPath.h.

{}

int edm::WorkerInPath::timesExcept ( ) const

inline

Definition at line 49 of file WorkerInPath.h.

References timesExcept_.

{ return timesExcept_; }

int edm::WorkerInPath::timesFailed ( ) const

inline

Definition at line 48 of file WorkerInPath.h.

References timesFailed_.

{ return timesFailed_; }

int edm::WorkerInPath::timesPassed ( ) const

inline

Definition at line 47 of file WorkerInPath.h.

References timesPassed_.

{ return timesPassed_; }

int edm::WorkerInPath::timesVisited ( ) const

inline

Definition at line 46 of file WorkerInPath.h.

References timesVisited_.

{ return timesVisited_; }

Member Data Documentation

FilterAction edm::WorkerInPath::filterAction_

private

Definition at line 63 of file WorkerInPath.h.

Referenced by filterAction().

PlaceInPathContext edm::WorkerInPath::placeInPathContext_

private

Definition at line 66 of file WorkerInPath.h.

Referenced by runWorkerAsync(), and setPathContext().

bool edm::WorkerInPath::runConcurrently_

private

Definition at line 67 of file WorkerInPath.h.

Referenced by runConcurrently().

int edm::WorkerInPath::timesExcept_

private

Definition at line 61 of file WorkerInPath.h.

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

int edm::WorkerInPath::timesFailed_

private

Definition at line 60 of file WorkerInPath.h.

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

int edm::WorkerInPath::timesPassed_

private

Definition at line 59 of file WorkerInPath.h.

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

int edm::WorkerInPath::timesVisited_

private

Definition at line 58 of file WorkerInPath.h.

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

Worker* edm::WorkerInPath::worker_

private

Definition at line 64 of file WorkerInPath.h.

Referenced by checkResultsOfRunWorker(), getWorker(), runWorkerAsync(), and skipWorker().