![]() |
Project
|
#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 |
using DataHeader = o2::header::DataHeader |
Definition at line 53 of file DataRelayer.cxx.
Definition at line 54 of file DataRelayer.cxx.
using Verbosity = o2::monitoring::Verbosity |
Definition at line 55 of file DataRelayer.cxx.
O2_DECLARE_DYNAMIC_LOG | ( | data_relayer | ) |