Project
Loading...
Searching...
No Matches
Static Public Member Functions | List of all members
o2::framework::CommonDataProcessors Struct Reference

Helpers to create a few general data processors. More...

#include <CommonDataProcessors.h>

Static Public Member Functions

static DataProcessorSpec getGlobalFileSink (std::vector< InputSpec > const &danglingInputs, std::vector< InputSpec > &unmatched)
 
static DataProcessorSpec getGlobalFairMQSink (std::vector< InputSpec > const &danglingInputs)
 
static DataProcessorSpec getDummySink (std::vector< InputSpec > const &danglingInputs, std::string rateLimitingChannelConfig)
 
static DataProcessorSpec getScheduledDummySink (std::vector< InputSpec > const &danglingInputs)
 
static AlgorithmSpec wrapWithRateLimiting (AlgorithmSpec spec)
 
static AlgorithmSpec wrapWithTimesliceConsumption (AlgorithmSpec spec)
 

Detailed Description

Helpers to create a few general data processors.

Definition at line 23 of file CommonDataProcessors.h.

Member Function Documentation

◆ getDummySink()

DataProcessorSpec o2::framework::CommonDataProcessors::getDummySink ( std::vector< InputSpec > const &  danglingInputs,
std::string  rateLimitingChannelConfig 
)
static
Returns
a dummy DataProcessorSpec which requires all the passed InputSpec and simply discards them. rateLimitingChannelConfig is the configuration for the rate limiting channel, if any required.

Definition at line 199 of file CommonDataProcessors.cxx.

◆ getGlobalFairMQSink()

DataProcessorSpec o2::framework::CommonDataProcessors::getGlobalFairMQSink ( std::vector< InputSpec > const &  danglingInputs)
static

Given the list of danglingInputs

Returns
a DataProcessor which exposes them through a FairMQ channel. @fixme: for now we only support shmem and ipc @fixme: for now only the dangling inputs are forwarded.

Definition at line 129 of file CommonDataProcessors.cxx.

◆ getGlobalFileSink()

DataProcessorSpec o2::framework::CommonDataProcessors::getGlobalFileSink ( std::vector< InputSpec > const &  danglingInputs,
std::vector< InputSpec > &  unmatched 
)
static

Given the list of danglingInputs

Returns
a DataProcessor which does a binary dump for all the dangling inputs matching the Timeframe lifetime. unmatched will be filled with all the InputSpecs which are not going to be used by the returned DataProcessorSpec.

Definition at line 54 of file CommonDataProcessors.cxx.

◆ getScheduledDummySink()

DataProcessorSpec o2::framework::CommonDataProcessors::getScheduledDummySink ( std::vector< InputSpec > const &  danglingInputs)
static
Returns
a dummy DataProcessorSpec which requires all the passed InputSpec and simply discards them. Rate limiting goes through the DPL driver

Definition at line 234 of file CommonDataProcessors.cxx.

◆ wrapWithRateLimiting()

AlgorithmSpec o2::framework::CommonDataProcessors::wrapWithRateLimiting ( AlgorithmSpec  spec)
static

Definition at line 268 of file CommonDataProcessors.cxx.

◆ wrapWithTimesliceConsumption()

AlgorithmSpec o2::framework::CommonDataProcessors::wrapWithTimesliceConsumption ( AlgorithmSpec  spec)
static

Definition at line 287 of file CommonDataProcessors.cxx.

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