art::Path::WorkerDoneTask Class Reference

Public Member Functions
	WorkerDoneTask (Path *path, size_t const idx, size_t const max_idx, EventPrincipal &ep, WaitingTaskPtr pathsDone, GlobalTaskGroup &group)
void	operator() (exception_ptr ex)

Private Attributes
Path *	path_
size_t const	idx_
size_t const	max_idx_
EventPrincipal &	ep_
WaitingTaskPtr	pathsDone_
GlobalTaskGroup &	group_

Detailed Description

Definition at line 245 of file Path.cc.

Constructor & Destructor Documentation

art::Path::WorkerDoneTask::WorkerDoneTask ( Path *  path, size_t const  idx, size_t const  max_idx, EventPrincipal &  ep, WaitingTaskPtr  pathsDone, GlobalTaskGroup &  group  )

inline

Definition at line 247 of file Path.cc.

      : path_{path}
      , idx_{idx}
      , max_idx_{max_idx}
      , ep_{ep}
      , pathsDone_{pathsDone}
      , group_{group}
    {}

Member Function Documentation

void art::Path::WorkerDoneTask::operator() ( exception_ptr  ex )

inline

Definition at line 261 of file Path.cc.

References e, art::actions::FailModule, art::actions::FailPath, art::errors::ScheduleExecutionFailure, TDEBUG_BEGIN_TASK_SI, TDEBUG_END_TASK_SI, and TDEBUG_TASK_SI.

    {
      auto const sid = path_->pc_.scheduleID();
      TDEBUG_BEGIN_TASK_SI(4, sid);
      auto& workerInPath = path_->workers_[idx_];
      // Note: This will only be set false by a filter which has rejected.
      bool new_should_continue = workerInPath.returnCode();
      TDEBUG_TASK_SI(4, sid) << "new_should_continue: " << new_should_continue;
      if (ex) {
        try {
          rethrow_exception(ex);
        }
        catch (cet::exception& e) {
          auto action = path_->actionTable_.find(e.root_cause());
          assert(action != actions::FailModule);
          if (action != actions::FailPath) {
            // Possible actions: IgnoreCompletely, Rethrow, SkipEvent
            ++path_->timesExcept_;
            path_->state_ = hlt::Exception;
            if (path_->trptr_) {
              // Not the end path.
              path_->trptr_->at(path_->pathPosition_) =
                HLTPathStatus(path_->state_, idx_);
            }
            auto art_ex =
              Exception{
                errors::ScheduleExecutionFailure, "Path: ProcessingStopped.", e}
              << "Exception going through path " << path_->name() << '\n';
            auto ex_ptr = make_exception_ptr(art_ex);
            group_.may_run(pathsDone_, ex_ptr);
            TDEBUG_END_TASK_SI(4, sid) << "terminate path because of EXCEPTION";
            return;
          }
          new_should_continue = false;
          mf::LogWarning(e.category()) << "Failing path " << path_->name()
                                       << ", due to exception, message:\n"
                                       << e.what();
          // WARNING: We continue processing below!!!
        }
        catch (...) {
          mf::LogError("PassingThrough")
            << "Exception passing through path " << path_->name();
          ++path_->timesExcept_;
          path_->state_ = hlt::Exception;
          if (path_->trptr_) {
            // Not the end path.
            path_->trptr_->at(path_->pathPosition_) =
              HLTPathStatus(path_->state_, idx_);
          }
          group_.may_run(pathsDone_, current_exception());
          TDEBUG_END_TASK_SI(4, sid) << "terminate path because of EXCEPTION";
          return;
        }
      }

      path_->process_event_workerFinished(
        idx_, max_idx_, ep_, new_should_continue, pathsDone_);
      TDEBUG_END_TASK_SI(4, sid);
    }

Member Data Documentation

EventPrincipal& art::Path::WorkerDoneTask::ep_

private

Definition at line 325 of file Path.cc.

GlobalTaskGroup& art::Path::WorkerDoneTask::group_

private

Definition at line 327 of file Path.cc.

size_t const art::Path::WorkerDoneTask::idx_

private

Definition at line 323 of file Path.cc.

size_t const art::Path::WorkerDoneTask::max_idx_

private

Definition at line 324 of file Path.cc.

Path* art::Path::WorkerDoneTask::path_

private

Definition at line 322 of file Path.cc.

WaitingTaskPtr art::Path::WorkerDoneTask::pathsDone_

private

Definition at line 326 of file Path.cc.

---

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

• art/Framework/Core/Path.cc