![]() |
Project
|
#include "Framework/AsyncQueue.h"
#include "Framework/DataProcessingDevice.h"
#include "Framework/ControlService.h"
#include "Framework/ComputingQuotaEvaluator.h"
#include "Framework/DataProcessingHeader.h"
#include "Framework/DataProcessingStates.h"
#include "Framework/DataProcessor.h"
#include "Framework/DataSpecUtils.h"
#include "Framework/DeviceState.h"
#include "Framework/DispatchPolicy.h"
#include "Framework/DispatchControl.h"
#include "Framework/DanglingContext.h"
#include "Framework/DomainInfoHeader.h"
#include "Framework/DriverClient.h"
#include "Framework/EndOfStreamContext.h"
#include "Framework/FairOptionsRetriever.h"
#include "ConfigurationOptionsRetriever.h"
#include "Framework/FairMQDeviceProxy.h"
#include "Framework/CallbackService.h"
#include "Framework/InputRecord.h"
#include "Framework/InputSpan.h"
#include "Framework/Signpost.h"
#include "Framework/TimingHelpers.h"
#include "Framework/SourceInfoHeader.h"
#include "Framework/TimesliceIndex.h"
#include "Framework/VariableContextHelpers.h"
#include "Framework/DataProcessingContext.h"
#include "Framework/DeviceContext.h"
#include "Framework/RawDeviceService.h"
#include "Framework/StreamContext.h"
#include "Framework/DefaultsHelpers.h"
#include "Framework/ServiceRegistryRef.h"
#include "DecongestionService.h"
#include "Framework/DataProcessingHelpers.h"
#include "DataRelayerHelpers.h"
#include "Headers/DataHeader.h"
#include "Headers/DataHeaderHelpers.h"
#include <Framework/Tracing.h>
#include <fairmq/Parts.h>
#include <fairmq/Socket.h>
#include <fairmq/ProgOptions.h>
#include <Configuration/ConfigurationInterface.h>
#include <Configuration/ConfigurationFactory.h>
#include <Monitoring/Monitoring.h>
#include <TMessage.h>
#include <TClonesArray.h>
#include <fmt/ostream.h>
#include <algorithm>
#include <vector>
#include <numeric>
#include <memory>
#include <uv.h>
#include <execinfo.h>
#include <sstream>
#include <boost/property_tree/json_parser.hpp>
Go to the source code of this file.
Namespaces | |
namespace | fmt |
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 | ConfigurationInterface = o2::configuration::ConfigurationInterface |
using | DataHeader = o2::header::DataHeader |
Variables | |
constexpr int | DEFAULT_MAX_CHANNEL_AHEAD = 128 |
auto | o2::framework::decongestionCallbackLate |
volatile int | o2::framework::region_read_global_dummy_variable |
using ConfigurationInterface = o2::configuration::ConfigurationInterface |
Definition at line 99 of file DataProcessingDevice.cxx.
using DataHeader = o2::header::DataHeader |
Definition at line 100 of file DataProcessingDevice.cxx.
O2_DECLARE_DYNAMIC_LOG | ( | async_queue | ) |
O2_DECLARE_DYNAMIC_LOG | ( | calibration | ) |
O2_DECLARE_DYNAMIC_LOG | ( | device | ) |
O2_DECLARE_DYNAMIC_LOG | ( | forwarding | ) |
O2_DECLARE_DYNAMIC_LOG | ( | parts | ) |
|
constexpr |
Definition at line 102 of file DataProcessingDevice.cxx.
uint64_t maxLatency = std::numeric_limits<uint64_t>::min() |
Definition at line 2153 of file DataProcessingDevice.cxx.
uint64_t minLatency = std::numeric_limits<uint64_t>::max() |
Definition at line 2152 of file DataProcessingDevice.cxx.