art::EndPathExecutor::PathsDoneTask Class Reference

Public Member Functions
	PathsDoneTask (EndPathExecutor *const endPathExec, WaitingTaskPtr const finalizeEventTask, GlobalTaskGroup &taskGroup)
void	operator() (exception_ptr const ex)

Private Attributes
EndPathExecutor *const	endPathExec_
WaitingTaskPtr const	finalizeEventTask_
GlobalTaskGroup &	taskGroup_

Detailed Description

Definition at line 237 of file EndPathExecutor.cc.

Constructor & Destructor Documentation

art::EndPathExecutor::PathsDoneTask::PathsDoneTask ( EndPathExecutor *const  endPathExec, WaitingTaskPtr const  finalizeEventTask, GlobalTaskGroup &  taskGroup  )

inline

Definition at line 239 of file EndPathExecutor.cc.

References art::EndPathExecutor::taskGroup_.

      : endPathExec_{endPathExec}
      , finalizeEventTask_{finalizeEventTask}
      , taskGroup_{taskGroup}
    {}

Member Function Documentation

void art::EndPathExecutor::PathsDoneTask::operator() ( exception_ptr const  ex )

inline

Definition at line 248 of file EndPathExecutor.cc.

References e, art::errors::EventProcessorFailure, art::GlobalTaskGroup::may_run(), art::EndPathExecutor::taskGroup_, TDEBUG_BEGIN_TASK_SI, TDEBUG_END_TASK_SI, and tmp.

    {
      auto const scheduleID = endPathExec_->sc_.id();

      // Note: When we start our parent task is the eventLoop task.
      TDEBUG_BEGIN_TASK_SI(4, scheduleID);

      if (ex) {
        try {
          rethrow_exception(ex);
        }
        catch (cet::exception& e) {
          Exception tmp(errors::EventProcessorFailure, "EndPathExecutor:");
          tmp << "an exception occurred during current event processing\n" << e;
          taskGroup_.may_run(finalizeEventTask_, make_exception_ptr(tmp));
          TDEBUG_END_TASK_SI(4, scheduleID)
            << "end path processing terminate because of EXCEPTION";
          return;
        }
        catch (...) {
          taskGroup_.may_run(finalizeEventTask_, current_exception());
          TDEBUG_END_TASK_SI(4, scheduleID)
            << "end path processing terminate because of EXCEPTION";
          return;
        }
      }

      endPathExec_->endPathInfo_.incrementPassedEventCount();

      taskGroup_.may_run(finalizeEventTask_);
      TDEBUG_END_TASK_SI(4, scheduleID);
    }

Member Data Documentation

EndPathExecutor* const art::EndPathExecutor::PathsDoneTask::endPathExec_

private

Definition at line 282 of file EndPathExecutor.cc.

WaitingTaskPtr const art::EndPathExecutor::PathsDoneTask::finalizeEventTask_

private

Definition at line 283 of file EndPathExecutor.cc.

GlobalTaskGroup& art::EndPathExecutor::PathsDoneTask::taskGroup_

private

Definition at line 284 of file EndPathExecutor.cc.

---

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

• art/Framework/Core/EndPathExecutor.cc