edm::WaitingTaskHolder Class Reference

#include <WaitingTaskHolder.h>

Public Member Functions
void	doneWaiting (std::exception_ptr iExcept)
WaitingTaskHolder &	operator= (const WaitingTaskHolder &iRHS)
	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 67 of file WaitingTaskHolder.h.

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

Referenced by edm::StreamSchedule::finishedPaths(), edm::EventProcessor::handleNextEventForStreamAsync(), edm::SubProcess::processAsync(), edm::EventProcessor::processEventAsync(), 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;
    }

Member Data Documentation

WaitingTask* edm::WaitingTaskHolder::m_task

private

Definition at line 80 of file WaitingTaskHolder.h.

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