o2::framework::DataProcessingHelpers Struct Reference

Generic helpers for DataProcessing releated functions. More...

#include <DataProcessingHelpers.h>

Static Public Member Functions
static void	sendEndOfStream (ServiceRegistryRef const &ref, OutputChannelSpec const &channel)
static bool	sendOldestPossibleTimeframe (ServiceRegistryRef const &ref, ForwardChannelInfo const &info, ForwardChannelState &state, size_t timeslice)
static bool	sendOldestPossibleTimeframe (ServiceRegistryRef const &ref, OutputChannelInfo const &info, OutputChannelState &state, size_t timeslice)
static void	broadcastOldestPossibleTimeslice (ServiceRegistryRef const &ref, size_t timeslice)
	Broadcast the oldest possible timeslice to all channels in output.
static void	switchState (ServiceRegistryRef const &ref, StreamingState newState)
	change the device StreamingState to newState
static bool	hasOnlyGenerated (DeviceSpec const &spec)
	check if spec is a source devide
static TransitionHandlingState	updateStateTransition (ServiceRegistryRef const &ref, ProcessingPolicies const &policies)
	starts the EoS timers and returns the new TransitionHandlingState in case as new state is requested

Detailed Description

Generic helpers for DataProcessing releated functions.

Definition at line 30 of file DataProcessingHelpers.h.

Member Function Documentation

broadcastOldestPossibleTimeslice()

void o2::framework::DataProcessingHelpers::broadcastOldestPossibleTimeslice ( ServiceRegistryRef const &  ref, size_t  timeslice  )

static

Broadcast the oldest possible timeslice to all channels in output.

Definition at line 100 of file DataProcessingHelpers.cxx.

hasOnlyGenerated()

bool o2::framework::DataProcessingHelpers::hasOnlyGenerated ( DeviceSpec const &  spec )

static

check if spec is a source devide

Definition at line 126 of file DataProcessingHelpers.cxx.

sendEndOfStream()

void o2::framework::DataProcessingHelpers::sendEndOfStream ( ServiceRegistryRef const &  ref, OutputChannelSpec const &  channel  )

static

Send EndOfStream message to a given channel

Parameters

device	the fair::mq::Device which needs to send the EndOfStream message
channel	the OutputChannelSpec of the channel which needs to be signaled for EndOfStream

Definition at line 47 of file DataProcessingHelpers.cxx.

sendOldestPossibleTimeframe() [1/2]

bool o2::framework::DataProcessingHelpers::sendOldestPossibleTimeframe ( ServiceRegistryRef const &  ref, ForwardChannelInfo const &  info, ForwardChannelState &  state, size_t  timeslice  )

static

Returns

true if we did send the oldest possible timeslice message, false otherwise.

Definition at line 80 of file DataProcessingHelpers.cxx.

sendOldestPossibleTimeframe() [2/2]

bool o2::framework::DataProcessingHelpers::sendOldestPossibleTimeframe ( ServiceRegistryRef const &  ref, OutputChannelInfo const &  info, OutputChannelState &  state, size_t  timeslice  )

static

Returns

true if we did send the oldest possible timeslice message, false otherwise.

Definition at line 90 of file DataProcessingHelpers.cxx.

switchState()

void o2::framework::DataProcessingHelpers::switchState ( ServiceRegistryRef const &  ref, StreamingState  newState  )

static

change the device StreamingState to newState

Definition at line 110 of file DataProcessingHelpers.cxx.

updateStateTransition()

TransitionHandlingState o2::framework::DataProcessingHelpers::updateStateTransition ( ServiceRegistryRef const &  ref, ProcessingPolicies const &  policies  )

static

starts the EoS timers and returns the new TransitionHandlingState in case as new state is requested

Definition at line 167 of file DataProcessingHelpers.cxx.

---

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

• /home/runner/work/AliceO2/AliceO2/Framework/Core/include/Framework/DataProcessingHelpers.h
• /home/runner/work/AliceO2/AliceO2/Framework/Core/src/DataProcessingHelpers.cxx