edm::WaitingTaskHolder Class Reference

#include <WaitingTaskHolder.h>

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

Private Attributes
WaitingTask *	m_task

Detailed Description

Definition at line 30 of file WaitingTaskHolder.h.

Constructor & Destructor Documentation

edm::WaitingTaskHolder::WaitingTaskHolder ( )

inline

Definition at line 34 of file WaitingTaskHolder.h.

                       :
    m_task(nullptr) {}

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

inlineexplicit

Definition at line 37 of file WaitingTaskHolder.h.

References m_task.

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

edm::WaitingTaskHolder::~WaitingTaskHolder ( )

inline

Definition at line 40 of file WaitingTaskHolder.h.

References doneWaiting(), and m_task.

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

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

inline

Definition at line 46 of file WaitingTaskHolder.h.

References m_task.

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

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

inline

Definition at line 51 of file WaitingTaskHolder.h.

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

Member Function Documentation

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

inline

Definition at line 80 of file WaitingTaskHolder.h.

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

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

                                               {
      if(iExcept) {
        m_task->dependentTaskFailed(iExcept);
      }
      if(0==m_task->decrement_ref_count()){
        tbb::task::spawn(*m_task);
      }
      m_task = nullptr;
    }

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

inline

Definition at line 56 of file WaitingTaskHolder.h.

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

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

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 74 of file WaitingTaskHolder.h.

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

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

bool edm::WaitingTaskHolder::taskHasFailed ( ) const

inline

Definition at line 63 of file WaitingTaskHolder.h.

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

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

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

Member Data Documentation

WaitingTask* edm::WaitingTaskHolder::m_task

private

Definition at line 93 of file WaitingTaskHolder.h.

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