art::EventProcessor::EndPathTask Class Reference

Public Member Functions
	EndPathTask (EventProcessor *evp, ScheduleID const sid)
void	operator() (exception_ptr const ex)

Private Attributes
EventProcessor *	evp_
ScheduleID const	sid_

Detailed Description

Definition at line 1307 of file EventProcessor.cc.

Constructor & Destructor Documentation

art::EventProcessor::EndPathTask::EndPathTask ( EventProcessor *  evp, ScheduleID const  sid  )

inline

Definition at line 1309 of file EventProcessor.cc.

      : evp_{evp}, sid_{sid}
    {}

Member Function Documentation

void art::EventProcessor::EndPathTask::operator() ( exception_ptr const  ex )

inline

Definition at line 1314 of file EventProcessor.cc.

    {
      // Note: When we start our parent is the eventLoopTask.
      TDEBUG_BEGIN_TASK_SI(4, sid_);
      if (ex) {
        try {
          rethrow_exception(ex);
        }
        catch (cet::exception& e) {
          if (evp_->error_action(e) != actions::IgnoreCompletely) {
            evp_->sharedException_.store<Exception>(
              errors::EventProcessorFailure,
              "EventProcessor: an exception occurred during current "
              "event processing",
              e);
            TDEBUG_END_TASK_SI(4, sid_)
              << "terminate event loop because of EXCEPTION";
            return;
          }
          mf::LogWarning(e.category())
            << "exception being ignored for current event:\n"
            << cet::trim_right_copy(e.what(), " \n");
          // WARNING: We continue processing after the catch blocks!!!
        }
        catch (...) {
          mf::LogError("PassingThrough")
            << "an exception occurred during current event processing\n";
          evp_->sharedException_.store_current();
          TDEBUG_END_TASK_SI(4, sid_)
            << "terminate event loop because of EXCEPTION";
          return;
        }
      }

      auto finalize_event_task =
        make_waiting_task<EndPathRunnerTask>(evp_, sid_);
      try {
        evp_->schedule(sid_).process_event_observers(finalize_event_task);
      }
      catch (cet::exception& e) {
        if (evp_->error_action(e) != actions::IgnoreCompletely) {
          evp_->sharedException_.store<Exception>(
            errors::EventProcessorFailure,
            "EventProcessor: an exception occurred during current event "
            "processing",
            e);
          TDEBUG_END_TASK_SI(4, sid_)
            << "terminate event loop because of EXCEPTION";
          return;
        }
        mf::LogWarning(e.category())
          << "exception being ignored for current event:\n"
          << cet::trim_right_copy(e.what(), " \n");
        // WARNING: We continue processing after the catch blocks!!!
      }
      catch (...) {
        mf::LogError("PassingThrough")
          << "an exception occurred during current event processing\n";
        evp_->sharedException_.store_current();
        TDEBUG_END_TASK_SI(4, sid_)
          << "terminate event loop because of EXCEPTION";
        return;
      }

      // Once the end path processing is done, exit this task, which
      // does not end event-processing because of the continuation
      // task.
      TDEBUG_END_TASK_SI(4, sid_);
    }

Member Data Documentation

EventProcessor* art::EventProcessor::EndPathTask::evp_

private

Definition at line 1385 of file EventProcessor.cc.

ScheduleID const art::EventProcessor::EndPathTask::sid_

private

Definition at line 1386 of file EventProcessor.cc.

---

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

• art/art/Framework/EventProcessor/EventProcessor.cc