art::WorkerInPath::WorkerInPathDoneTask Class Reference

Public Member Functions
	WorkerInPathDoneTask (WorkerInPath *wip, ScheduleID const scheduleID, WaitingTaskPtr workerDoneTask, GlobalTaskGroup *taskGroup)
void	operator() (exception_ptr const ex) const

Private Attributes
WorkerInPath *	wip_
ScheduleID const	sid_
WaitingTaskPtr	workerDoneTask_
GlobalTaskGroup *	taskGroup_

Detailed Description

Definition at line 82 of file WorkerInPath.cc.

Constructor & Destructor Documentation

art::WorkerInPath::WorkerInPathDoneTask::WorkerInPathDoneTask ( WorkerInPath *  wip, ScheduleID const  scheduleID, WaitingTaskPtr  workerDoneTask, GlobalTaskGroup *  taskGroup  )

inline

Definition at line 84 of file WorkerInPath.cc.

References art::WorkerInPath::taskGroup_.

      : wip_{wip}
      , sid_{scheduleID}
      , workerDoneTask_{std::move(workerDoneTask)}
      , taskGroup_{taskGroup}
    {}

Member Function Documentation

void art::WorkerInPath::WorkerInPathDoneTask::operator() ( exception_ptr const  ex ) const

inline

Definition at line 95 of file WorkerInPath.cc.

References art::GlobalTaskGroup::may_run(), art::WorkerInPath::taskGroup_, TDEBUG_BEGIN_TASK_SI, TDEBUG_END_TASK_SI, and TDEBUG_TASK_SI.

    {
      TDEBUG_BEGIN_TASK_SI(4, sid_);
      if (ex) {
        ++wip_->counts_thrown_;
        taskGroup_->may_run(workerDoneTask_, ex);
        TDEBUG_END_TASK_SI(4, sid_) << "because of EXCEPTION";
        return;
      }

      wip_->returnCode_ = wip_->worker_->returnCode();
      TDEBUG_TASK_SI(5, sid_) << "raw returnCode_: " << wip_->returnCode_;
      if (wip_->filterAction_ == FilterAction::Veto) {
        wip_->returnCode_ = !wip_->returnCode_;
      } else if (wip_->filterAction_ == FilterAction::Ignore) {
        wip_->returnCode_ = true;
      }
      TDEBUG_TASK_SI(5, sid_) << "final returnCode_: " << wip_->returnCode_;
      if (wip_->returnCode_) {
        ++wip_->counts_passed_;
      } else {
        ++wip_->counts_failed_;
      }
      TDEBUG_END_TASK_SI(4, sid_) << "returnCode_: " << wip_->returnCode_;
      taskGroup_->may_run(workerDoneTask_);
    }

Member Data Documentation

ScheduleID const art::WorkerInPath::WorkerInPathDoneTask::sid_

private

Definition at line 124 of file WorkerInPath.cc.

GlobalTaskGroup* art::WorkerInPath::WorkerInPathDoneTask::taskGroup_

private

Definition at line 126 of file WorkerInPath.cc.

WorkerInPath* art::WorkerInPath::WorkerInPathDoneTask::wip_

private

Definition at line 123 of file WorkerInPath.cc.

WaitingTaskPtr art::WorkerInPath::WorkerInPathDoneTask::workerDoneTask_

private

Definition at line 125 of file WorkerInPath.cc.

---

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

• art/Framework/Core/WorkerInPath.cc