LArSoft  v09_90_00
Liquid Argon Software toolkit - https://larsoft.org/
art::WorkerInPath Class Reference

#include "WorkerInPath.h"

Classes

struct  ConfigInfo
 
class  WorkerInPathDoneTask
 

Public Member Functions

 WorkerInPath (cet::exempt_ptr< Worker >, detail::FilterAction, PathContext const &, GlobalTaskGroup &group)
 
WorkergetWorker () const
 
detail::FilterAction filterAction () const
 
bool returnCode () const
 
bool run (Transition, Principal &)
 
void run (hep::concurrency::WaitingTaskPtr workerDoneTask, EventPrincipal &)
 
void clearCounters ()
 
std::size_t timesVisited () const
 
std::size_t timesPassed () const
 
std::size_t timesFailed () const
 
std::size_t timesExcept () const
 

Private Attributes

cet::exempt_ptr< Workerworker_
 
detail::FilterAction filterAction_
 
ModuleContext moduleContext_
 
GlobalTaskGrouptaskGroup_
 
bool returnCode_ {false}
 
std::size_t counts_visited_ {}
 
std::size_t counts_passed_ {}
 
std::size_t counts_failed_ {}
 
std::size_t counts_thrown_ {}
 

Detailed Description

Definition at line 32 of file WorkerInPath.h.

Constructor & Destructor Documentation

art::WorkerInPath::WorkerInPath ( cet::exempt_ptr< Worker w,
detail::FilterAction  fa,
PathContext const &  pc,
GlobalTaskGroup group 
)

Definition at line 17 of file WorkerInPath.cc.

References fa(), filterAction_, moduleContext_, taskGroup_, and w.

21  : worker_{w}
22  , filterAction_{fa}
23  , moduleContext_{pc, w->description()}
24  , taskGroup_{&taskGroup}
25  {}
ModuleContext moduleContext_
Definition: WorkerInPath.h:70
GlobalTaskGroup * taskGroup_
Definition: WorkerInPath.h:71
detail::FilterAction filterAction_
Definition: WorkerInPath.h:69
Float_t w
Definition: plot.C:20
cet::exempt_ptr< Worker > worker_
Definition: WorkerInPath.h:66
TFile fa("Li7.root")

Member Function Documentation

void art::WorkerInPath::clearCounters ( )
detail::FilterAction art::WorkerInPath::filterAction ( ) const

Definition at line 34 of file WorkerInPath.cc.

References filterAction_.

35  {
36  return filterAction_;
37  }
detail::FilterAction filterAction_
Definition: WorkerInPath.h:69
Worker * art::WorkerInPath::getWorker ( ) const

Definition at line 28 of file WorkerInPath.cc.

References worker_.

29  {
30  return worker_.get();
31  }
cet::exempt_ptr< Worker > worker_
Definition: WorkerInPath.h:66
bool art::WorkerInPath::returnCode ( ) const

Definition at line 41 of file WorkerInPath.cc.

References returnCode_.

42  {
43  return returnCode_;
44  }
bool art::WorkerInPath::run ( Transition  trans,
Principal principal 
)

Definition at line 75 of file WorkerInPath.cc.

References moduleContext_, and worker_.

76  {
77  // Note: We ignore the return code because we do not process events here.
78  worker_->doWork(trans, principal, moduleContext_);
79  return true;
80  }
ModuleContext moduleContext_
Definition: WorkerInPath.h:70
cet::exempt_ptr< Worker > worker_
Definition: WorkerInPath.h:66
void art::WorkerInPath::run ( hep::concurrency::WaitingTaskPtr  workerDoneTask,
EventPrincipal  
)
size_t art::WorkerInPath::timesExcept ( ) const

Definition at line 69 of file WorkerInPath.cc.

References counts_thrown_.

70  {
71  return counts_thrown_;
72  }
std::size_t counts_thrown_
Definition: WorkerInPath.h:80
size_t art::WorkerInPath::timesFailed ( ) const

Definition at line 62 of file WorkerInPath.cc.

References counts_failed_.

63  {
64  return counts_failed_;
65  }
std::size_t counts_failed_
Definition: WorkerInPath.h:79
size_t art::WorkerInPath::timesPassed ( ) const

Definition at line 55 of file WorkerInPath.cc.

References counts_passed_.

56  {
57  return counts_passed_;
58  }
std::size_t counts_passed_
Definition: WorkerInPath.h:78
size_t art::WorkerInPath::timesVisited ( ) const

Definition at line 48 of file WorkerInPath.cc.

References counts_visited_.

49  {
50  return counts_visited_;
51  }
std::size_t counts_visited_
Definition: WorkerInPath.h:77

Member Data Documentation

std::size_t art::WorkerInPath::counts_failed_ {}
private

Definition at line 79 of file WorkerInPath.h.

Referenced by timesFailed().

std::size_t art::WorkerInPath::counts_passed_ {}
private

Definition at line 78 of file WorkerInPath.h.

Referenced by timesPassed().

std::size_t art::WorkerInPath::counts_thrown_ {}
private

Definition at line 80 of file WorkerInPath.h.

Referenced by timesExcept().

std::size_t art::WorkerInPath::counts_visited_ {}
private

Definition at line 77 of file WorkerInPath.h.

Referenced by timesVisited().

detail::FilterAction art::WorkerInPath::filterAction_
private

Definition at line 69 of file WorkerInPath.h.

Referenced by filterAction(), and WorkerInPath().

ModuleContext art::WorkerInPath::moduleContext_
private

Definition at line 70 of file WorkerInPath.h.

Referenced by run(), and WorkerInPath().

bool art::WorkerInPath::returnCode_ {false}
private

Definition at line 74 of file WorkerInPath.h.

Referenced by returnCode().

cet::exempt_ptr<Worker> art::WorkerInPath::worker_
private

Definition at line 66 of file WorkerInPath.h.

Referenced by getWorker(), and run().


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