#include <GPUWorkflowInternal.h>

Classes
struct	pipelineWorkerStruct

Public Attributes
std::mutex	mutexDecodeInput

fair::mq::Device *	fmqDevice = nullptr

volatile fair::mq::State	fmqState = fair::mq::State::Undefined

volatile fair::mq::State	fmqPreviousState = fair::mq::State::Undefined

volatile bool	endOfStreamAsyncWaiting = true

volatile bool	endOfStreamDplReceived = false

volatile bool	runStarted = false

volatile bool	shouldTerminate = false

volatile bool	pipelineAbort = false

std::mutex	stateMutex

std::mutex	receiveMutex

std::condition_variable	stateNotify

std::thread	receiveThread

std::array< pipelineWorkerStruct, 2 >	workers

std::queue< std::unique_ptr< GPURecoWorkflow_QueueObject > >	pipelineQueue

std::mutex	queueMutex

std::condition_variable	queueNotify

std::queue< o2::framework::DataProcessingHeader::StartTime >	completionPolicyQueue

volatile bool	pipelineSenderTerminating = false

std::mutex	completionPolicyMutex

std::condition_variable	completionPolicyNotify

uint64_t	mNTFReceived = 0

volatile bool	mayInject = true

volatile uint64_t	mayInjectTFId = 0

std::mutex	mayInjectMutex

std::condition_variable	mayInjectCondition

Detailed Description

Definition at line 61 of file GPUWorkflowInternal.h.

Member Data Documentation

◆ completionPolicyMutex

std::mutex o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::completionPolicyMutex

Definition at line 91 of file GPUWorkflowInternal.h.

◆ completionPolicyNotify

std::condition_variable o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::completionPolicyNotify

Definition at line 92 of file GPUWorkflowInternal.h.

◆ completionPolicyQueue

std::queue<o2::framework::DataProcessingHeader::StartTime> o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::completionPolicyQueue

Definition at line 89 of file GPUWorkflowInternal.h.

◆ endOfStreamAsyncWaiting

volatile bool o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::endOfStreamAsyncWaiting = true

Definition at line 67 of file GPUWorkflowInternal.h.

◆ endOfStreamDplReceived

volatile bool o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::endOfStreamDplReceived = false

Definition at line 68 of file GPUWorkflowInternal.h.

◆ fmqDevice

fair::mq::Device* o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::fmqDevice = nullptr

Definition at line 64 of file GPUWorkflowInternal.h.

◆ fmqPreviousState

volatile fair::mq::State o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::fmqPreviousState = fair::mq::State::Undefined

Definition at line 66 of file GPUWorkflowInternal.h.

◆ fmqState

volatile fair::mq::State o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::fmqState = fair::mq::State::Undefined

Definition at line 66 of file GPUWorkflowInternal.h.

◆ mayInject

volatile bool o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::mayInject = true

Definition at line 96 of file GPUWorkflowInternal.h.

◆ mayInjectCondition

std::condition_variable o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::mayInjectCondition

Definition at line 99 of file GPUWorkflowInternal.h.

◆ mayInjectMutex

std::mutex o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::mayInjectMutex

Definition at line 98 of file GPUWorkflowInternal.h.

◆ mayInjectTFId

volatile uint64_t o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::mayInjectTFId = 0

Definition at line 97 of file GPUWorkflowInternal.h.

◆ mNTFReceived

uint64_t o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::mNTFReceived = 0

Definition at line 94 of file GPUWorkflowInternal.h.

◆ mutexDecodeInput

std::mutex o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::mutexDecodeInput

Definition at line 62 of file GPUWorkflowInternal.h.

◆ pipelineAbort

volatile bool o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::pipelineAbort = false

Definition at line 71 of file GPUWorkflowInternal.h.

◆ pipelineQueue

std::queue<std::unique_ptr<GPURecoWorkflow_QueueObject> > o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::pipelineQueue

Definition at line 85 of file GPUWorkflowInternal.h.

◆ pipelineSenderTerminating

volatile bool o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::pipelineSenderTerminating = false

Definition at line 90 of file GPUWorkflowInternal.h.

◆ queueMutex

std::mutex o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::queueMutex

Definition at line 86 of file GPUWorkflowInternal.h.

◆ queueNotify

std::condition_variable o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::queueNotify

Definition at line 87 of file GPUWorkflowInternal.h.

◆ receiveMutex

std::mutex o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::receiveMutex

Definition at line 72 of file GPUWorkflowInternal.h.

◆ receiveThread

std::thread o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::receiveThread

Definition at line 75 of file GPUWorkflowInternal.h.

◆ runStarted

volatile bool o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::runStarted = false

Definition at line 69 of file GPUWorkflowInternal.h.

◆ shouldTerminate

volatile bool o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::shouldTerminate = false

Definition at line 70 of file GPUWorkflowInternal.h.

◆ stateMutex

std::mutex o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::stateMutex