ArrowSupport.cxx File Reference

#include "ArrowSupport.h"
#include "Framework/AODReaderHelpers.h"
#include "Framework/ArrowContext.h"
#include "Framework/ArrowTableSlicingCache.h"
#include "Framework/DataProcessor.h"
#include "Framework/DataProcessingStats.h"
#include "Framework/ServiceRegistry.h"
#include "Framework/ConfigContext.h"
#include "Framework/DataSpecUtils.h"
#include "Framework/DataSpecViews.h"
#include "Framework/DeviceSpec.h"
#include "Framework/DeviceMetricsInfo.h"
#include "Framework/DeviceMetricsHelper.h"
#include "Framework/DeviceInfo.h"
#include "Framework/DevicesManager.h"
#include "Framework/DeviceConfig.h"
#include "Framework/PluginManager.h"
#include "Framework/ServiceMetricsInfo.h"
#include "WorkflowHelpers.h"
#include "Framework/WorkflowSpecNode.h"
#include "Framework/AnalysisSupportHelpers.h"
#include "Framework/ServiceRegistryRef.h"
#include "Framework/ServiceRegistryHelpers.h"
#include "Framework/Signpost.h"
#include "CommonMessageBackendsHelpers.h"
#include <Monitoring/Monitoring.h>
#include "Headers/DataHeader.h"
#include <RtypesCore.h>
#include <fairmq/ProgOptions.h>
#include <uv.h>
#include <boost/program_options/variables_map.hpp>
#include <csignal>

Go to the source code of this file.

Classes
struct	o2::framework::RateLimitConfig
struct	o2::framework::MetricIndices
struct	o2::framework::ResourceState
struct	o2::framework::ResourceStats
struct	o2::framework::ResourceSpec

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.

Enumerations
enum struct	o2::framework::RateLimitingState {   o2::framework::UNKNOWN = 0 , o2::framework::STARTED = 1 , o2::framework::CHANGED = 2 , o2::framework::BELOW_LIMIT = 3 ,   o2::framework::NEXT_ITERATION_FROM_BELOW = 4 , o2::framework::ABOVE_LIMIT = 5 , o2::framework::EMPTY = 6 }

Functions
	O2_DECLARE_DYNAMIC_LOG (rate_limiting)
std::vector< MetricIndices >	o2::framework::createDefaultIndices (std::vector< DeviceMetricsInfo > &allDevicesMetrics)
uint64_t	o2::framework::calculateAvailableSharedMemory (ServiceRegistryRef registry)
auto	o2::framework::offerResources (ResourceState &resourceState, ResourceSpec const &resourceSpec, ResourceStats &resourceStats, std::vector< DeviceSpec > const &specs, std::vector< DeviceInfo > const &infos, DevicesManager &manager, int64_t offerConsumedCurrentValue, int64_t offerExpiredCurrentValue, int64_t acquiredResourceCurrentValue, int64_t disposedResourceCurrentValue, size_t timestamp, DeviceMetricsInfo &driverMetrics, std::function< void(DeviceMetricsInfo &, int value, size_t timestamp)> &availableResourceMetric, std::function< void(DeviceMetricsInfo &, int value, size_t timestamp)> &unusedOfferedResourceMetric, std::function< void(DeviceMetricsInfo &, int value, size_t timestamp)> &offeredResourceMetric, void *signpostId) -> void

Function Documentation

O2_DECLARE_DYNAMIC_LOG()

O2_DECLARE_DYNAMIC_LOG

(

rate_limiting

)