Project
Loading...
Searching...
No Matches
Classes | Public Attributes | List of all members
o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals Struct Reference

#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 endOfStreamAsyncReceived = false
 
volatile bool endOfStreamDplReceived = false
 
volatile bool runStarted = false
 
volatile bool shouldTerminate = false
 
std::mutex stateMutex
 
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 60 of file GPUWorkflowInternal.h.

Member Data Documentation

◆ completionPolicyMutex

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

Definition at line 89 of file GPUWorkflowInternal.h.

◆ completionPolicyNotify

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

Definition at line 90 of file GPUWorkflowInternal.h.

◆ completionPolicyQueue

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

Definition at line 87 of file GPUWorkflowInternal.h.

◆ endOfStreamAsyncReceived

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

Definition at line 66 of file GPUWorkflowInternal.h.

◆ endOfStreamDplReceived

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

Definition at line 67 of file GPUWorkflowInternal.h.

◆ fmqDevice

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

Definition at line 63 of file GPUWorkflowInternal.h.

◆ fmqPreviousState

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

Definition at line 65 of file GPUWorkflowInternal.h.

◆ fmqState

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

Definition at line 65 of file GPUWorkflowInternal.h.

◆ mayInject

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

Definition at line 94 of file GPUWorkflowInternal.h.

◆ mayInjectCondition

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

Definition at line 97 of file GPUWorkflowInternal.h.

◆ mayInjectMutex

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

Definition at line 96 of file GPUWorkflowInternal.h.

◆ mayInjectTFId

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

Definition at line 95 of file GPUWorkflowInternal.h.

◆ mNTFReceived

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

Definition at line 92 of file GPUWorkflowInternal.h.

◆ mutexDecodeInput

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

Definition at line 61 of file GPUWorkflowInternal.h.

◆ pipelineQueue

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

Definition at line 83 of file GPUWorkflowInternal.h.

◆ pipelineSenderTerminating

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

Definition at line 88 of file GPUWorkflowInternal.h.

◆ queueMutex

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

Definition at line 84 of file GPUWorkflowInternal.h.

◆ queueNotify

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

Definition at line 85 of file GPUWorkflowInternal.h.

◆ receiveThread

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

Definition at line 73 of file GPUWorkflowInternal.h.

◆ runStarted

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

Definition at line 68 of file GPUWorkflowInternal.h.

◆ shouldTerminate

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

Definition at line 69 of file GPUWorkflowInternal.h.

◆ stateMutex

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

Definition at line 70 of file GPUWorkflowInternal.h.

◆ stateNotify

std::condition_variable o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::stateNotify

Definition at line 71 of file GPUWorkflowInternal.h.

◆ workers

std::array<pipelineWorkerStruct, 2> o2::gpu::gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals::workers

Definition at line 81 of file GPUWorkflowInternal.h.

The documentation for this struct was generated from the following file: