edm::WaitingTaskHolder Class Reference

#include <WaitingTaskHolder.h>

Public Member Functions
void	doneWaiting (std::exception_ptr iExcept)
tbb::task_group *	group () const noexcept
bool	hasTask () const noexcept
WaitingTaskHolder &	operator= (const WaitingTaskHolder &iRHS)
WaitingTaskHolder &	operator= (WaitingTaskHolder &&iRHS)
void	presetTaskAsFailed (std::exception_ptr iExcept)
bool	taskHasFailed () const noexcept
	WaitingTaskHolder ()
	WaitingTaskHolder (const WaitingTaskHolder &iHolder)
	WaitingTaskHolder (tbb::task_group &iGroup, edm::WaitingTask *iTask)
	WaitingTaskHolder (WaitingTaskHolder &&iOther)
	~WaitingTaskHolder ()

Private Member Functions
WaitingTask *	release_no_decrement () noexcept

Private Attributes
tbb::task_group *	m_group
WaitingTask *	m_task

Friends
class	WaitingTaskList
class	WaitingTaskWithArenaHolder

Detailed Description

Definition at line 32 of file WaitingTaskHolder.h.

Constructor & Destructor Documentation

WaitingTaskHolder() [1/4]

edm::WaitingTaskHolder::WaitingTaskHolder ( )

inline

Definition at line 37 of file WaitingTaskHolder.h.

: m_task(nullptr), m_group(nullptr) {}

WaitingTaskHolder() [2/4]

edm::WaitingTaskHolder::WaitingTaskHolder ( tbb::task_group &  iGroup, edm::WaitingTask *  iTask  )

inlineexplicit

Definition at line 39 of file WaitingTaskHolder.h.

                                                                             : m_task(iTask), m_group(&iGroup) {
      m_task->increment_ref_count();
    }

References edm::TaskBase::increment_ref_count(), and m_task.

~WaitingTaskHolder()

edm::WaitingTaskHolder::~WaitingTaskHolder ( )

inline

Definition at line 42 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 48 of file WaitingTaskHolder.h.

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

References edm::TaskBase::increment_ref_count(), and m_task.

WaitingTaskHolder() [4/4]

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

inline

Definition at line 52 of file WaitingTaskHolder.h.

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

Member Function Documentation

doneWaiting()

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

inline

Definition at line 93 of file WaitingTaskHolder.h.

                                               {
      if (iExcept) {
        m_task->dependentTaskFailed(iExcept);
      }
      //task_group::run 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()) {
        m_group->run([task]() {
          TaskSentry s{task};
          task->execute();
        });
      }
    }

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

Referenced by edm::WaitingTaskList::add(), 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::eventsetup::synchronousEventSetupForInstance(), edm::OutputModuleCommunicatorT< T >::writeLumiAsync(), edm::OutputModuleCommunicatorT< T >::writeProcessBlockAsync(), edm::OutputModuleCommunicatorT< T >::writeRunAsync(), and ~WaitingTaskHolder().

group()

tbb::task_group* edm::WaitingTaskHolder::group ( ) const

inlinenoexcept

since tbb::task_group is thread safe, we can return it non-const from here since the object is not really part of the state of the holder

Definition at line 77 of file WaitingTaskHolder.h.

{ return m_group; }

References m_group.

Referenced by edm::WaitingTaskList::add(), edm::beginGlobalTransitionAsync(), edm::EventProcessor::beginLumiAsync(), edm::beginStreamTransitionAsync(), edm::EventProcessor::continueLumiAsync(), edm::endGlobalTransitionAsync(), edm::endStreamTransitionAsync(), edm::Worker::esPrefetchAsync(), edm::EventProcessor::globalEndLumiAsync(), edm::EventProcessor::handleNextEventForStreamAsync(), edm::eventsetup::Callback< T, TReturn, TRecord, TDecorator >::prefetchAsync(), edm::DelayedReaderInputProductResolver::prefetchAsync_(), edm::PuttableProductResolver::prefetchAsync_(), edm::UnscheduledProductResolver::prefetchAsync_(), edm::SwitchProducerProductResolver::prefetchAsync_(), edm::SwitchAliasProductResolver::prefetchAsync_(), edm::NoProcessProductResolver::prefetchAsync_(), edm::eventsetup::ESSourceDataProxyBase::prefetchAsyncImpl(), edm::eventsetup::DataProxyTemplate< RecordT, DataT >::prefetchAsyncImpl(), edm::SubProcess::processAsync(), edm::EventProcessor::processEventAsync(), edm::EventProcessor::processEventAsyncImpl(), edm::StreamSchedule::processOneEventAsync(), edm::GlobalSchedule::processOneGlobalAsync(), edm::Path::processOneOccurrenceAsync(), edm::StreamSchedule::processOneStreamAsync(), edm::eventsetup::EventSetupRecordIOVQueue::startNewIOVAsync(), edm::EventProcessor::streamEndLumiAsync(), edm::OutputModuleCommunicatorT< T >::writeLumiAsync(), edm::OutputModuleCommunicatorT< T >::writeProcessBlockAsync(), and edm::OutputModuleCommunicatorT< T >::writeRunAsync().

hasTask()

bool edm::WaitingTaskHolder::hasTask ( ) const

inlinenoexcept

Definition at line 73 of file WaitingTaskHolder.h.

{ return m_task != nullptr; }

References m_task.

Referenced by edm::eventsetup::EventSetupRecordIOVQueue::endIOVAsync().

operator=() [1/2]

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

inline

Definition at line 56 of file WaitingTaskHolder.h.

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

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

operator=() [2/2]

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

inline

Definition at line 63 of file WaitingTaskHolder.h.

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

References m_group, 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 87 of file WaitingTaskHolder.h.

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

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

release_no_decrement()

WaitingTask* edm::WaitingTaskHolder::release_no_decrement ( )

inlineprivatenoexcept

Definition at line 112 of file WaitingTaskHolder.h.

                                                 {
      auto t = m_task;
      m_task = nullptr;
      return t;
    }

References m_task, and submitPVValidationJobs::t.

Referenced by edm::WaitingTaskList::add().

taskHasFailed()

bool edm::WaitingTaskHolder::taskHasFailed ( ) const

inlinenoexcept

Definition at line 71 of file WaitingTaskHolder.h.

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

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

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

Friends And Related Function Documentation

WaitingTaskList

friend class WaitingTaskList

friend

Definition at line 34 of file WaitingTaskHolder.h.

WaitingTaskWithArenaHolder

friend class WaitingTaskWithArenaHolder

friend

Definition at line 35 of file WaitingTaskHolder.h.

Member Data Documentation

m_group

tbb::task_group* edm::WaitingTaskHolder::m_group

private

Definition at line 119 of file WaitingTaskHolder.h.

Referenced by doneWaiting(), group(), and operator=().

m_task

WaitingTask* edm::WaitingTaskHolder::m_task

private

Definition at line 118 of file WaitingTaskHolder.h.

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