edm::WaitingTaskHolder Class Reference

#include <WaitingTaskHolder.h>

Public Member Functions
void	doneWaiting (std::exception_ptr iExcept)
WaitingTaskHolder &	operator= (const WaitingTaskHolder &iRHS)
WaitingTaskHolder &	operator= (WaitingTaskHolder &&iRHS)
void	presetTaskAsFailed (std::exception_ptr iExcept)
bool	taskHasFailed () const
	WaitingTaskHolder ()
	WaitingTaskHolder (const WaitingTaskHolder &iHolder)
	WaitingTaskHolder (edm::WaitingTask *iTask)
	WaitingTaskHolder (WaitingTaskHolder &&iOther)
	~WaitingTaskHolder ()

Private Attributes
WaitingTask *	m_task

Detailed Description

Definition at line 30 of file WaitingTaskHolder.h.

Constructor & Destructor Documentation

WaitingTaskHolder() [1/4]

edm::WaitingTaskHolder::WaitingTaskHolder ( )

inline

Definition at line 32 of file WaitingTaskHolder.h.

: m_task(nullptr) {}

WaitingTaskHolder() [2/4]

edm::WaitingTaskHolder::WaitingTaskHolder ( edm::WaitingTask *  iTask )

inlineexplicit

Definition at line 34 of file WaitingTaskHolder.h.

: m_task(iTask) { m_task->increment_ref_count(); }

References m_task.

~WaitingTaskHolder()

edm::WaitingTaskHolder::~WaitingTaskHolder ( )

inline

Definition at line 35 of file WaitingTaskHolder.h.

                         {
      if (m_task) {
        doneWaiting(std::exception_ptr{});
      }
    }

References doneWaiting(), and m_task.

WaitingTaskHolder() [3/4]

edm::WaitingTaskHolder::WaitingTaskHolder ( const WaitingTaskHolder &  iHolder )

inline

Definition at line 41 of file WaitingTaskHolder.h.

: m_task(iHolder.m_task) { m_task->increment_ref_count(); }

References m_task.

WaitingTaskHolder() [4/4]

edm::WaitingTaskHolder::WaitingTaskHolder ( WaitingTaskHolder &&  iOther )

inline

Definition at line 43 of file WaitingTaskHolder.h.

: m_task(iOther.m_task) { iOther.m_task = nullptr; }

Member Function Documentation

doneWaiting()

void edm::WaitingTaskHolder::doneWaiting ( std::exception_ptr  iExcept )

inline

Definition at line 75 of file WaitingTaskHolder.h.

                                               {
      if (iExcept) {
        m_task->dependentTaskFailed(iExcept);
      }
      //spawn can run the task before we finish
      // doneWaiting and some other thread might
      // try to reuse this object. Resetting
      // before spawn avoids problems
      auto task = m_task;
      m_task = nullptr;
      if (0 == task->decrement_ref_count()) {
        tbb::task::spawn(*task);
      }
    }

References edm::WaitingTask::dependentTaskFailed(), m_task, and TrackValidation_cff::task.

Referenced by edm::beginGlobalTransitionAsync(), edm::EventProcessor::beginLumiAsync(), edm::beginStreamTransitionAsync(), edm::endGlobalTransitionAsync(), edm::endStreamTransitionAsync(), edm::Worker::HandleExternalWorkExceptionTask::execute(), edm::StreamSchedule::finishedPaths(), edm::EventProcessor::handleNextEventForStreamAsync(), edm::SubProcess::processAsync(), edm::EventProcessor::processEventAsyncImpl(), edm::StreamSchedule::processOneEventAsync(), edm::GlobalSchedule::processOneGlobalAsync(), edm::StreamSchedule::processOneStreamAsync(), edm::OutputModuleCommunicatorT< T >::writeLumiAsync(), edm::OutputModuleCommunicatorT< T >::writeProcessBlockAsync(), edm::OutputModuleCommunicatorT< T >::writeRunAsync(), and ~WaitingTaskHolder().

operator=() [1/2]

WaitingTaskHolder& edm::WaitingTaskHolder::operator= ( const WaitingTaskHolder &  iRHS )

inline

Definition at line 45 of file WaitingTaskHolder.h.

                                                                {
      WaitingTaskHolder tmp(iRHS);
      std::swap(m_task, tmp.m_task);
      return *this;
    }

References m_task, std::swap(), and createJobs::tmp.

operator=() [2/2]

WaitingTaskHolder& edm::WaitingTaskHolder::operator= ( WaitingTaskHolder &&  iRHS )

inline

Definition at line 51 of file WaitingTaskHolder.h.

                                                           {
      WaitingTaskHolder tmp(std::move(iRHS));
      std::swap(m_task, tmp.m_task);
      return *this;
    }

References m_task, eostools::move(), std::swap(), and createJobs::tmp.

presetTaskAsFailed()

void edm::WaitingTaskHolder::presetTaskAsFailed ( std::exception_ptr  iExcept )

inline

Use in the case where you need to inform the parent task of a failure before some other child task which may be run later reports a different, but related failure. You must later call doneWaiting in the same thread passing the same exceptoin.

Definition at line 69 of file WaitingTaskHolder.h.

                                                      {
      if (iExcept) {
        m_task->dependentTaskFailed(iExcept);
      }
    }

References edm::WaitingTask::dependentTaskFailed(), and m_task.

taskHasFailed()

bool edm::WaitingTaskHolder::taskHasFailed ( ) const

inline

Definition at line 58 of file WaitingTaskHolder.h.

{ return m_task->exceptionPtr() != nullptr; }

References edm::WaitingTask::exceptionPtr(), and m_task.

Referenced by edm::EventProcessor::beginLumiAsync().

Member Data Documentation

m_task

WaitingTask* edm::WaitingTaskHolder::m_task

private

Definition at line 92 of file WaitingTaskHolder.h.

Referenced by doneWaiting(), operator=(), presetTaskAsFailed(), taskHasFailed(), WaitingTaskHolder(), and ~WaitingTaskHolder().