#include "Framework/DataProcessorSpec.h"
#include "Framework/OutputSpec.h"
#include <fairmq/FwdDecls.h>
#include <vector>
#include <functional>

Go to the source code of this file.

Classes
struct	o2::framework::DPLModelAdapterConfig

Namespaces
namespace	o2
	a couple of static helper functions to create timestamp values for CCDB queries or override obsolete objects

namespace	o2::framework
	Defining PrimaryVertex explicitly as messageable.

Typedefs
using	o2::framework::ChannelRetriever = std::function< std::string const &(OutputSpec const &, DataProcessingHeader::StartTime)>

using	o2::framework::InjectorFunction = std::function< bool(TimingInfo &, ServiceRegistryRef const &services, fair::mq::Parts &inputs, ChannelRetriever, size_t newTimesliceId, bool &stop)>

using	o2::framework::ChannelSelector = std::function< std::string(InputSpec const &input, const std::unordered_map< std::string, std::vector< fair::mq::Channel > > &channels)>

Functions
std::string	o2::framework::formatExternalChannelConfiguration (InputChannelSpec const &)
	helper method to format a configuration string for an external channel

std::string	o2::framework::formatExternalChannelConfiguration (OutputChannelSpec const &)
	helper method to format a configuration string for an external channel

void	o2::framework::sendOnChannel (fair::mq::Device &device, o2::header::Stack &&headerStack, fair::mq::MessagePtr &&payloadMessage, OutputSpec const &spec, ChannelRetriever &channelRetriever)

void	o2::framework::sendOnChannel (fair::mq::Device &device, fair::mq::Parts &messages, std::string const &channel, size_t timeSlice)

void	o2::framework::appendForSending (fair::mq::Device &device, o2::header::Stack &&headerStack, size_t timeSliceID, fair::mq::MessagePtr &&payloadMessage, OutputSpec const &spec, fair::mq::Parts &messageCache, ChannelRetriever &channelRetriever)

InjectorFunction	o2::framework::incrementalConverter (OutputSpec const &spec, o2::header::SerializationMethod method, uint64_t startTime, uint64_t step)

InjectorFunction	o2::framework::o2DataModelAdaptor (OutputSpec const &spec, uint64_t startTime, uint64_t step)

InjectorFunction	o2::framework::dplModelAdaptor (std::vector< OutputSpec > const &specs={{header::gDataOriginAny, header::gDataDescriptionAny}}, DPLModelAdapterConfig config=DPLModelAdapterConfig{})

InjectorFunction	o2::framework::dplModelAdaptor (std::vector< OutputSpec > const &specs, bool throwOnUnmatchedInputs)
	legacy function

std::string	o2::framework::defaultOutputProxyChannelSelector (InputSpec const &input, const std::unordered_map< std::string, std::vector< fair::mq::Channel > > &channels)
	Default way to select an output channel for multi-output proxy.

DataProcessorSpec	o2::framework::specifyExternalFairMQDeviceProxy (char const label, std::vector< OutputSpec > const &outputs, const char defaultChannelConfig, InjectorFunction converter, uint64_t minSHM=0, bool sendTFcounter=false, bool doInjectMissingData=false, unsigned int doPrintSizes=0)

DataProcessorSpec	o2::framework::specifyFairMQDeviceOutputProxy (char const label, Inputs const &inputSpecs, const char defaultChannelConfig)

DataProcessorSpec	o2::framework::specifyFairMQDeviceMultiOutputProxy (char const label, Inputs const &inputSpecs, const char defaultChannelConfig, ChannelSelector channelSelector=defaultOutputProxyChannelSelector)

Classes

Namespaces

Typedefs

Functions