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
std::atomic< bool > *	m_finishedProcessingEvents
EventProcessor *	m_proc
unsigned int	m_streamID
tbb::task *	m_waitTask

Detailed Description

Definition at line 1852 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 1854 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 1863 of file EventProcessor.cc.

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

Member Data Documentation

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

private

Definition at line 1871 of file EventProcessor.cc.

EventProcessor* edm::StreamProcessingTask::m_proc

private

Definition at line 1869 of file EventProcessor.cc.

unsigned int edm::StreamProcessingTask::m_streamID

private

Definition at line 1870 of file EventProcessor.cc.

tbb::task* edm::StreamProcessingTask::m_waitTask

private

Definition at line 1872 of file EventProcessor.cc.