#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>

Classes
struct	fmt::formatter< o2::framework::CompletionPolicy::CompletionOp >

struct	o2::framework::ServiceKindExtractor< ConfigurationInterface >

struct	o2::framework::locked_execution

struct	o2::framework::PollerContext

struct	o2::framework::DecongestionContext

struct	o2::framework::WaitBackpressurePolicy

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

Functions
	O2_DECLARE_DYNAMIC_LOG (device)

	O2_DECLARE_DYNAMIC_LOG (sockets)

	O2_DECLARE_DYNAMIC_LOG (parts)

	O2_DECLARE_DYNAMIC_LOG (calibration)

	O2_DECLARE_DYNAMIC_LOG (async_queue)

	O2_DECLARE_DYNAMIC_LOG (forwarding)

	O2_DECLARE_DYNAMIC_LOG (ccdb)

void	o2::framework::on_idle_timer (uv_timer_t *handle)

bool	o2::framework::hasOnlyTimers (DeviceSpec const &spec)

bool	o2::framework::hasOnlyGenerated (DeviceSpec const &spec)

void	o2::framework::on_transition_requested_expired (uv_timer_t *handle)

auto	o2::framework::switchState (ServiceRegistryRef &ref, StreamingState newState) -> void

void	o2::framework::on_data_processing_expired (uv_timer_t *handle)

void	o2::framework::on_communication_requested (uv_async_t *s)

DeviceSpec const &	o2::framework::getRunningDevice (RunningDeviceRef const &running, ServiceRegistryRef const &services)

void	o2::framework::run_callback (uv_work_t *handle)

void	o2::framework::run_completion (uv_work_t *handle, int status)

void	o2::framework::on_socket_polled (uv_poll_t *poller, int status, int events)

void	o2::framework::on_out_of_band_polled (uv_poll_t *poller, int status, int events)

void	o2::framework::on_signal_callback (uv_signal_t *handle, int signum)

void	o2::framework::handleRegionCallbacks (ServiceRegistryRef registry, std::vector< fair::mq::RegionInfo > &infos)
	Invoke the callbacks for the mPendingRegionInfos.

Variables
constexpr int	DEFAULT_MAX_CHANNEL_AHEAD = 128

auto	o2::framework::decongestionCallbackLate

volatile int	o2::framework::region_read_global_dummy_variable

Typedef Documentation

◆ ConfigurationInterface

using ConfigurationInterface = o2::configuration::ConfigurationInterface

Definition at line 103 of file DataProcessingDevice.cxx.

◆ DataHeader

using DataHeader = o2::header::DataHeader

Definition at line 104 of file DataProcessingDevice.cxx.

Function Documentation

◆ O2_DECLARE_DYNAMIC_LOG() [1/7]

O2_DECLARE_DYNAMIC_LOG ( async_queue )

◆ O2_DECLARE_DYNAMIC_LOG() [2/7]

O2_DECLARE_DYNAMIC_LOG ( calibration )

◆ O2_DECLARE_DYNAMIC_LOG() [3/7]

O2_DECLARE_DYNAMIC_LOG ( ccdb )

◆ O2_DECLARE_DYNAMIC_LOG() [4/7]

O2_DECLARE_DYNAMIC_LOG ( device )

◆ O2_DECLARE_DYNAMIC_LOG() [5/7]

O2_DECLARE_DYNAMIC_LOG ( forwarding )

◆ O2_DECLARE_DYNAMIC_LOG() [6/7]

O2_DECLARE_DYNAMIC_LOG ( parts )

◆ O2_DECLARE_DYNAMIC_LOG() [7/7]

O2_DECLARE_DYNAMIC_LOG ( sockets )

Variable Documentation

◆ DEFAULT_MAX_CHANNEL_AHEAD

constexpr int DEFAULT_MAX_CHANNEL_AHEAD = 128

constexpr

Definition at line 106 of file DataProcessingDevice.cxx.

◆ maxLatency

uint64_t maxLatency = std::numeric_limits<uint64_t>::min()

Definition at line 2162 of file DataProcessingDevice.cxx.

◆ minLatency

uint64_t minLatency = std::numeric_limits<uint64_t>::max()

Definition at line 2161 of file DataProcessingDevice.cxx.

Classes

Namespaces

Typedefs

Functions

Variables