9 #include "hep_concurrency/WaitingTask.h" 86 WaitingTaskPtr workerDoneTask,
90 , workerDoneTask_{std::move(workerDoneTask)}
99 ++wip_->counts_thrown_;
105 wip_->returnCode_ = wip_->worker_->returnCode();
106 TDEBUG_TASK_SI(5, sid_) <<
"raw returnCode_: " << wip_->returnCode_;
107 if (wip_->filterAction_ == FilterAction::Veto) {
108 wip_->returnCode_ = !wip_->returnCode_;
109 }
else if (wip_->filterAction_ == FilterAction::Ignore) {
110 wip_->returnCode_ =
true;
112 TDEBUG_TASK_SI(5, sid_) <<
"final returnCode_: " << wip_->returnCode_;
113 if (wip_->returnCode_) {
114 ++wip_->counts_passed_;
116 ++wip_->counts_failed_;
136 auto workerInPathDoneTask = make_waiting_task<WorkerInPathDoneTask>(
137 this, scheduleID, workerDoneTask,
taskGroup_);
#define TDEBUG_BEGIN_TASK_SI(LEVEL, SI)
WorkerInPath(cet::exempt_ptr< Worker >, detail::FilterAction, PathContext const &, GlobalTaskGroup &group)
detail::FilterAction filterAction() const
std::size_t timesPassed() const
Worker * getWorker() const
std::size_t timesFailed() const
#define TDEBUG_END_TASK_SI(LEVEL, SI)
ModuleContext moduleContext_
#define TDEBUG_TASK_SI(LEVEL, SI)
GlobalTaskGroup * taskGroup_
GlobalTaskGroup * taskGroup_
void operator()(exception_ptr const ex) const
std::size_t counts_thrown_
std::size_t timesVisited() const
#define TDEBUG_END_FUNC_SI(LEVEL, SI)
detail::FilterAction filterAction_
bool run(Transition, Principal &)
WaitingTaskPtr workerDoneTask_
WorkerInPathDoneTask(WorkerInPath *wip, ScheduleID const scheduleID, WaitingTaskPtr workerDoneTask, GlobalTaskGroup *taskGroup)
std::size_t timesExcept() const
void may_run(hep::concurrency::WaitingTaskPtr task, std::exception_ptr ex_ptr={})
std::size_t counts_visited_
#define TDEBUG_BEGIN_FUNC_SI(LEVEL, SI)
std::size_t counts_failed_
cet::exempt_ptr< Worker > worker_
std::size_t counts_passed_