Project
Loading...
Searching...
No Matches
DataRelayer.cxx File Reference
#include "Framework/RootSerializationSupport.h"
#include "Framework/DataRelayer.h"
#include "Framework/DataProcessingStats.h"
#include "Framework/DriverConfig.h"
#include "Framework/CompilerBuiltins.h"
#include "Framework/DataDescriptorMatcher.h"
#include "Framework/DataSpecUtils.h"
#include "Framework/DataProcessingHeader.h"
#include "Framework/DataRef.h"
#include "Framework/InputRecord.h"
#include "Framework/InputSpan.h"
#include "Framework/CompletionPolicy.h"
#include "Framework/Logger.h"
#include "Framework/PartRef.h"
#include "Framework/TimesliceIndex.h"
#include "Framework/RoutingIndices.h"
#include "Framework/VariableContextHelpers.h"
#include "Framework/FairMQDeviceProxy.h"
#include "DataProcessingStatus.h"
#include "DataRelayerHelpers.h"
#include "InputRouteHelpers.h"
#include "Framework/LifetimeHelpers.h"
#include "Framework/CommonServices.h"
#include "Framework/DataProcessingStates.h"
#include "Framework/DataTakingContext.h"
#include "Framework/DefaultsHelpers.h"
#include "Headers/DataHeaderHelpers.h"
#include "Framework/Formatters.h"
#include <Monitoring/Metric.h>
#include <Monitoring/Monitoring.h>
#include <fairmq/Channel.h>
#include <fmt/format.h>
#include <fmt/ostream.h>
#include <gsl/span>
#include <numeric>
#include <string>

Go to the source code of this file.

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 DataHeader = o2::header::DataHeader
 
using DataProcessingHeader = o2::framework::DataProcessingHeader
 
using Verbosity = o2::monitoring::Verbosity
 

Functions

 O2_DECLARE_DYNAMIC_LOG (data_relayer)
 
size_t o2::framework::matchToContext (void const *data, std::vector< DataDescriptorMatcher > const &matchers, std::vector< size_t > const &index, VariableContext &context)
 
void o2::framework::sendVariableContextMetrics (VariableContext &context, TimesliceSlot slot, DataProcessingStates &states)
 
bool o2::framework::isCalibrationData (std::unique_ptr< fair::mq::Message > &first)
 

Variables

constexpr int o2::framework::INVALID_INPUT = -1
 

Typedef Documentation

◆ DataHeader

Definition at line 53 of file DataRelayer.cxx.

◆ DataProcessingHeader

◆ Verbosity

using Verbosity = o2::monitoring::Verbosity

Definition at line 55 of file DataRelayer.cxx.

Function Documentation

◆ O2_DECLARE_DYNAMIC_LOG()

O2_DECLARE_DYNAMIC_LOG ( data_relayer  )