edm::StreamProcessingTask Class Reference

Inheritance diagram for edm::StreamProcessingTask:

Public Member Functions
tbb::task *	execute ()
	StreamProcessingTask (EventProcessor *iProc, unsigned int iStreamIndex, std::atomic< bool > *iFinishedProcessingEvents, tbb::task *iWaitTask)

Private Attributes
edm::propagate_const < std::atomic< bool > * >	m_finishedProcessingEvents
edm::propagate_const < EventProcessor * >	m_proc
unsigned int	m_streamID
edm::propagate_const< tbb::task * >	m_waitTask

Detailed Description

Definition at line 1861 of file EventProcessor.cc.

Constructor & Destructor Documentation

edm::StreamProcessingTask::StreamProcessingTask ( EventProcessor *  iProc, unsigned int  iStreamIndex, std::atomic< bool > *  iFinishedProcessingEvents, tbb::task *  iWaitTask  )

inline

Definition at line 1863 of file EventProcessor.cc.

                                            :
      m_proc(iProc),
      m_streamID(iStreamIndex),
      m_finishedProcessingEvents(iFinishedProcessingEvents),
      m_waitTask(iWaitTask){}

Member Function Documentation

tbb::task* edm::StreamProcessingTask::execute ( void  )

inline

Definition at line 1872 of file EventProcessor.cc.

                       {
      m_proc->processEventsForStreamAsync(m_streamID,m_finishedProcessingEvents);
      m_waitTask->decrement_ref_count();
      return nullptr;
    }

Member Data Documentation

edm::propagate_const<std::atomic<bool>*> edm::StreamProcessingTask::m_finishedProcessingEvents

private

Definition at line 1880 of file EventProcessor.cc.

edm::propagate_const<EventProcessor*> edm::StreamProcessingTask::m_proc

private

Definition at line 1878 of file EventProcessor.cc.

unsigned int edm::StreamProcessingTask::m_streamID

private

Definition at line 1879 of file EventProcessor.cc.

edm::propagate_const<tbb::task*> edm::StreamProcessingTask::m_waitTask

private

Definition at line 1881 of file EventProcessor.cc.