Running state information of a given device. More...

#include <DeviceState.h>

Public Types
enum	LoopReason : int { NO_REASON = 0 , METRICS_MUST_FLUSH = 1 , SIGNAL_ARRIVED = 1 << 1 , DATA_SOCKET_POLLED = 1 << 2 , DATA_INCOMING = 1 << 3 , DATA_OUTGOING = 1 << 4 , WS_COMMUNICATION = 1 << 5 , TIMER_EXPIRED = 1 << 6 , WS_CONNECTED = 1 << 7 , WS_CLOSING = 1 << 8 , WS_READING = 1 << 9 , WS_WRITING = 1 << 10 , ASYNC_NOTIFICATION = 1 << 11 , OOB_ACTIVITY = 1 << 12 , UNKNOWN = 1 << 13 , FIRST_LOOP = 1 << 14 , NEW_STATE_PENDING = 1 << 15 , PREVIOUSLY_ACTIVE = 1 << 16 , TRACE_CALLBACKS = 1 << 17 , TRACE_USERCODE = 1 << 18 , DATA_CONNECTED = 1 << 19 }
	Motivation for the loop being triggered. More...

enum	LogStreams : int { NO_LOG = 0 , DEVICE_LOG = 1 << 0 , COMPLETION_LOG = 1 << 1 , MONITORING_SERVICE_LOG = 1 << 2 , DATA_PROCESSOR_CONTEXT_LOG = 1 << 3 , STREAM_CONTEXT_LOG = 1 << 4 }

enum	ProcessingType : int { Any , CalibrationOnly }

Public Attributes
std::vector< InputChannelInfo >	inputChannelInfos

StreamingState	streaming = StreamingState::Streaming

ProcessingType	allowedProcessing = ProcessingType::Any

bool	quitRequested = false

std::atomic< int64_t >	cleanupCount = -1

std::vector< ComputingQuotaOffer >	pendingOffers

std::vector< ComputingQuotaConsumer >	offerConsumers

uv_loop_t *	loop = nullptr

std::vector< uv_timer_t * >	activeTimers

std::vector< uv_timer_t * >	firedTimers

std::vector< uv_poll_t * >	activeInputPollers

std::vector< uv_poll_t * >	activeOutputPollers

std::vector< uv_signal_t * >	activeSignals
	The list of active signal handlers.

std::vector< uv_poll_t * >	activeOutOfBandPollers
	The list for active out-of-bound pollers.

uv_async_t *	awakeMainThread = nullptr

std::vector< std::string >	nextFairMQState

int	loopReason = 0
	Bitmask of LoopReason which caused this iterations.

int	tracingFlags = 0
	Bitmask of LoopReason to trace.

int	logStreams = 0
	Bitmask of log streams which are available.

std::vector< int >	severityStack

TransitionHandlingState	transitionHandling = TransitionHandlingState::NoTransition

std::atomic< DataProcessorContext * >	lastActiveDataProcessor = nullptr

Detailed Description

Running state information of a given device.

Definition at line 34 of file DeviceState.h.

Member Enumeration Documentation

◆ LogStreams

enum o2::framework::DeviceState::LogStreams : int

Enumerator
NO_LOG
DEVICE_LOG
COMPLETION_LOG
MONITORING_SERVICE_LOG
DATA_PROCESSOR_CONTEXT_LOG
STREAM_CONTEXT_LOG

Definition at line 60 of file DeviceState.h.

◆ LoopReason

enum o2::framework::DeviceState::LoopReason : int

Motivation for the loop being triggered.

Enumerator
NO_REASON
METRICS_MUST_FLUSH
SIGNAL_ARRIVED
DATA_SOCKET_POLLED
DATA_INCOMING
DATA_OUTGOING
WS_COMMUNICATION
TIMER_EXPIRED
WS_CONNECTED
WS_CLOSING
WS_READING
WS_WRITING
ASYNC_NOTIFICATION
OOB_ACTIVITY
UNKNOWN
FIRST_LOOP
NEW_STATE_PENDING
PREVIOUSLY_ACTIVE
TRACE_CALLBACKS
TRACE_USERCODE
DATA_CONNECTED

Definition at line 36 of file DeviceState.h.

◆ ProcessingType

enum o2::framework::DeviceState::ProcessingType : int

Enumerator
Any
CalibrationOnly

Definition at line 69 of file DeviceState.h.

Member Data Documentation

◆ activeInputPollers

std::vector<uv_poll_t*> o2::framework::DeviceState::activeInputPollers

Definition at line 98 of file DeviceState.h.

◆ activeOutOfBandPollers

std::vector<uv_poll_t*> o2::framework::DeviceState::activeOutOfBandPollers

The list for active out-of-bound pollers.

Definition at line 104 of file DeviceState.h.

◆ activeOutputPollers

std::vector<uv_poll_t*> o2::framework::DeviceState::activeOutputPollers

Definition at line 100 of file DeviceState.h.

◆ activeSignals

std::vector<uv_signal_t*> o2::framework::DeviceState::activeSignals

The list of active signal handlers.

Definition at line 102 of file DeviceState.h.

◆ activeTimers

std::vector<uv_timer_t*> o2::framework::DeviceState::activeTimers

Definition at line 94 of file DeviceState.h.

◆ allowedProcessing

ProcessingType o2::framework::DeviceState::allowedProcessing = ProcessingType::Any

Definition at line 79 of file DeviceState.h.

◆ awakeMainThread

uv_async_t* o2::framework::DeviceState::awakeMainThread = nullptr

Definition at line 106 of file DeviceState.h.

◆ cleanupCount

std::atomic<int64_t> o2::framework::DeviceState::cleanupCount = -1

Definition at line 82 of file DeviceState.h.

◆ firedTimers

std::vector<uv_timer_t*> o2::framework::DeviceState::firedTimers

Definition at line 96 of file DeviceState.h.

◆ inputChannelInfos

std::vector<InputChannelInfo> o2::framework::DeviceState::inputChannelInfos

Definition at line 74 of file DeviceState.h.

◆ lastActiveDataProcessor

std::atomic<DataProcessorContext*> o2::framework::DeviceState::lastActiveDataProcessor = nullptr

Definition at line 125 of file DeviceState.h.

◆ logStreams

int o2::framework::DeviceState::logStreams = 0

Bitmask of log streams which are available.

Definition at line 116 of file DeviceState.h.

◆ loop

uv_loop_t* o2::framework::DeviceState::loop = nullptr

Definition at line 92 of file DeviceState.h.

◆ loopReason

int o2::framework::DeviceState::loopReason = 0

Bitmask of LoopReason which caused this iterations.

Definition at line 112 of file DeviceState.h.

◆ nextFairMQState

std::vector<std::string> o2::framework::DeviceState::nextFairMQState

Definition at line 109 of file DeviceState.h.

◆ offerConsumers

std::vector<ComputingQuotaConsumer> o2::framework::DeviceState::offerConsumers

ComputingQuotaOffers which should be removed from the queue.

Definition at line 89 of file DeviceState.h.

◆ pendingOffers

std::vector<ComputingQuotaOffer> o2::framework::DeviceState::pendingOffers

ComputingQuotaOffers which have not yet been evaluated by the ComputingQuotaEvaluator

Definition at line 86 of file DeviceState.h.

◆ quitRequested

bool o2::framework::DeviceState::quitRequested = false

Definition at line 81 of file DeviceState.h.

◆ severityStack

std::vector<int> o2::framework::DeviceState::severityStack

Stack of the severity, so that we can display only the bits we are interested in.

Definition at line 119 of file DeviceState.h.

◆ streaming

StreamingState o2::framework::DeviceState::streaming = StreamingState::Streaming

Definition at line 75 of file DeviceState.h.

◆ tracingFlags

int o2::framework::DeviceState::tracingFlags = 0

Bitmask of LoopReason to trace.

Definition at line 114 of file DeviceState.h.

◆ transitionHandling

TransitionHandlingState o2::framework::DeviceState::transitionHandling = TransitionHandlingState::NoTransition

Definition at line 120 of file DeviceState.h.

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

/home/runner/work/AliceO2/AliceO2/Framework/Core/include/Framework/DeviceState.h

Public Types

Public Attributes