edm::WaitingTask Class Reference

#include <WaitingTask.h>

Inheritance diagram for edm::WaitingTask:

Public Member Functions
std::exception_ptr const *	exceptionPtr () const
	Returns exception thrown by dependent task. More...
	WaitingTask ()
	Constructor. More...
	~WaitingTask () override
Public Member Functions inherited from edm::TaskBase
unsigned int	decrement_ref_count ()
virtual void	execute ()=0
void	increment_ref_count ()
	TaskBase ()
	Constructor. More...
virtual	~TaskBase ()=default

Private Member Functions
void	dependentTaskFailed (std::exception_ptr iPtr)
	Called if waited for task failed. More...

Private Attributes
std::atomic< std::exception_ptr * >	m_ptr

Friends
class	WaitingTaskHolder
class	WaitingTaskList
class	WaitingTaskWithArenaHolder

Detailed Description

Definition at line 36 of file WaitingTask.h.

Constructor & Destructor Documentation

WaitingTask()

edm::WaitingTask::WaitingTask ( )

inline

Constructor.

Definition at line 43 of file WaitingTask.h.

: m_ptr{nullptr} {}

~WaitingTask()

edm::WaitingTask::~WaitingTask ( )

inlineoverride

Definition at line 44 of file WaitingTask.h.

References m_ptr.

{ delete m_ptr.load(); };

Member Function Documentation

dependentTaskFailed()

void edm::WaitingTask::dependentTaskFailed ( std::exception_ptr  iPtr )

inlineprivate

Called if waited for task failed.

Allows transfer of the exception caused by the dependent task to be moved to another thread. This method should only be called by WaitingTaskList

Definition at line 59 of file WaitingTask.h.

References m_ptr, and groupFilesInBlocks::temp.

Referenced by edm::WaitingTaskList::add(), edm::WaitingTaskWithArenaHolder::doneWaiting(), edm::WaitingTaskHolder::doneWaiting(), edm::WaitingTaskHolder::presetTaskAsFailed(), and edm::WaitingTaskList::presetTaskAsFailed().

                                                    {
      if (iPtr and not m_ptr) {
        auto temp = std::make_unique<std::exception_ptr>(iPtr);
        std::exception_ptr* expected = nullptr;
        if (m_ptr.compare_exchange_strong(expected, temp.get())) {
          temp.release();
        }
      }
    }

exceptionPtr()

std::exception_ptr const* edm::WaitingTask::exceptionPtr ( ) const

inline

Returns exception thrown by dependent task.

If the value is non-null then the dependent task failed.

Definition at line 51 of file WaitingTask.h.

References m_ptr.

Referenced by edm::test::TestProcessor::beginLuminosityBlock(), edm::EventProcessor::beginProcessBlock(), edm::test::TestProcessor::beginProcessBlock(), edm::EventProcessor::beginRun(), edm::test::TestProcessor::beginRun(), edm::test::TestProcessor::endLuminosityBlock(), edm::EventProcessor::endProcessBlock(), edm::test::TestProcessor::endProcessBlock(), edm::EventProcessor::endRun(), edm::test::TestProcessor::endRun(), edm::EventProcessor::endUnfinishedLumi(), edm::test::TestProcessor::event(), edm::Worker::RunModuleTask< T >::execute(), edm::Worker::AcquireTask< OccurrenceTraits< EventPrincipal, BranchActionStreamBegin >, DUMMY >::execute(), edm::EventProcessor::inputProcessBlocks(), edm::EventProcessor::processLumis(), edm::eventsetup::synchronousEventSetupForInstance(), edm::WaitingTaskHolder::taskHasFailed(), and edm::WaitingTaskWithArenaHolder::taskHasFailed().

{ return m_ptr.load(); }

Friends And Related Function Documentation

WaitingTaskHolder

friend class WaitingTaskHolder

friend

Definition at line 39 of file WaitingTask.h.

WaitingTaskList

friend class WaitingTaskList

friend

Definition at line 38 of file WaitingTask.h.

WaitingTaskWithArenaHolder

friend class WaitingTaskWithArenaHolder

friend

Definition at line 40 of file WaitingTask.h.

Member Data Documentation

m_ptr

std::atomic<std::exception_ptr*> edm::WaitingTask::m_ptr

private

Definition at line 69 of file WaitingTask.h.

Referenced by dependentTaskFailed(), exceptionPtr(), and ~WaitingTask().