Project
Loading...
Searching...
No Matches
Static Public Member Functions | List of all members
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.
 

Detailed Description

Generic helpers for DataProcessing releated functions.

Definition at line 26 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 82 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
devicethe fair::mq::Device which needs to send the EndOfStream message
channelthe OutputChannelSpec of the channel which needs to be signaled for EndOfStream

Definition at line 29 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 62 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 72 of file DataProcessingHelpers.cxx.

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