Inheritance diagram for edm::Worker::AcquireTask< OccurrenceTraits< EventPrincipal, BranchActionStreamBegin >, DUMMY >:

Public Member Functions
	AcquireTask (Worker *worker, EventPrincipal const &ep, EventSetupImpl const &es, ServiceToken const &token, ParentContext const &parentContext, WaitingTaskWithArenaHolder holder)

tbb::task *	execute () override

Public Member Functions inherited from edm::WaitingTask
std::exception_ptr const *	exceptionPtr () const
	Returns exception thrown by dependent task. More...

	WaitingTask ()
	Constructor. More...

	~WaitingTask () override

Private Attributes
EventSetupImpl const &	m_es

WaitingTaskWithArenaHolder	m_holder

ParentContext const	m_parentContext

EventPrincipal const &	m_principal

ServiceToken	m_serviceToken

Worker *	m_worker

Detailed Description

template<typename DUMMY>
class edm::Worker::AcquireTask< OccurrenceTraits< EventPrincipal, BranchActionStreamBegin >, DUMMY >

Definition at line 519 of file Worker.h.

Constructor & Destructor Documentation

template<typename DUMMY >

edm::Worker::AcquireTask< OccurrenceTraits< EventPrincipal, BranchActionStreamBegin >, DUMMY >::AcquireTask	(	Worker *	worker,
		EventPrincipal const &	ep,
		EventSetupImpl const &	es,
		ServiceToken const &	token,
		ParentContext const &	parentContext,
		WaitingTaskWithArenaHolder	holder
	)

inline

Definition at line 521 of file Worker.h.

           : m_worker(worker),
             m_principal(ep),
             m_es(es),
             m_parentContext(parentContext),
             m_holder(std::move(holder)),
             m_serviceToken(token) {}

Member Function Documentation

template<typename DUMMY >

tbb::task* edm::Worker::AcquireTask< OccurrenceTraits< EventPrincipal, BranchActionStreamBegin >, DUMMY >::execute ( void )

inlineoverride

Definition at line 534 of file Worker.h.

References eostools::move(), cmsRelvalreport::principal(), and createBeamHaloJobs::queue.

                                   {
         //Need to make the services available early so other services can see them
         ServiceRegistry::Operate guard(m_serviceToken);
 
         //incase the emit causes an exception, we need a memory location
         // to hold the exception_ptr
         std::exception_ptr temp_excptr;
         auto excptr = exceptionPtr();
         try {
           //pre was called in prefetchAsync
           m_worker->emitPostModuleEventPrefetchingSignal();
         } catch (...) {
           temp_excptr = std::current_exception();
           if (not excptr) {
             excptr = &temp_excptr;
           }
         }
 
         if (not excptr) {
           if (auto queue = m_worker->serializeRunModule()) {
             auto const& principal = m_principal;
             auto& es = m_es;
             queue.push([worker = m_worker,
                         &principal,
                         &es,
                         parentContext = m_parentContext,
                         serviceToken = m_serviceToken,
                         holder = m_holder]() {
               //Need to make the services available
               ServiceRegistry::Operate guard(serviceToken);
 
               std::exception_ptr* ptr = nullptr;
               worker->runAcquireAfterAsyncPrefetch(ptr, principal, es, parentContext, holder);
             });
             return nullptr;
           }
         }
 
         m_worker->runAcquireAfterAsyncPrefetch(excptr, m_principal, m_es, m_parentContext, std::move(m_holder));
         return nullptr;
       }