CommonServices.h

Go to the documentation of this file.

// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
// All rights not expressly granted are reserved.
//
// This software is distributed under the terms of the GNU General Public
// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
//
// In applying this license CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.
#ifndef O2_FRAMEWORK_COMMONSERVICES_H_
#define O2_FRAMEWORK_COMMONSERVICES_H_
 
#include "Framework/ServiceSpec.h"
#include "Framework/ServiceRegistryRef.h"
#include "Framework/TypeIdHelpers.h"
 
namespace o2::framework
{
 
struct ThreadPool {
  int poolSize;
};
 
struct CommonServices {
  template <typename T>
  static ServiceId simpleServiceId()
  {
    return []() -> uint32_t {
      return TypeIdHelpers::uniqueId<T>();
    };
  }
  template <typename I, typename T, enum ServiceKind KIND = ServiceKind::Serial>
  static ServiceInit simpleServiceInit()
  {
    return [](ServiceRegistryRef, DeviceState&, fair::mq::ProgOptions&) -> ServiceHandle {
      return ServiceHandle{TypeIdHelpers::uniqueId<I>(), new T, KIND, typeid(T).name()};
    };
  }
 
  template <typename I, typename T>
  static ServiceInit singletonServiceInit()
  {
    return [](ServiceRegistryRef, DeviceState&, fair::mq::ProgOptions&) -> ServiceHandle {
      return ServiceHandle{TypeIdHelpers::uniqueId<I>(), T::instance(), ServiceKind::Serial, typeid(T).name()};
    };
  }
 
  static ServiceConfigureCallback noConfiguration()
  {
    return [](InitContext&, void* service) -> void* { return service; };
  }
 
  static ServiceSpec deviceContextSpec();
  static ServiceSpec dataProcessorContextSpec();
  static ServiceSpec driverClientSpec();
  static ServiceSpec monitoringSpec();
  static ServiceSpec datatakingContextSpec();
  static ServiceSpec configurationSpec();
  static ServiceSpec controlSpec();
  static ServiceSpec rootFileSpec();
  static ServiceSpec parallelSpec();
  static ServiceSpec rawDeviceSpec();
  static ServiceSpec callbacksSpec();
  static ServiceSpec timesliceIndex();
  static ServiceSpec dataRelayer();
  static ServiceSpec dataSender();
  static ServiceSpec tracingSpec();
  static ServiceSpec summaryServiceSpec();
  static ServiceSpec threadPool(int numWorkers);
  static ServiceSpec dataProcessingStats();
  static ServiceSpec dataProcessingStates();
  static ServiceSpec objectCache();
  static ServiceSpec timingInfoSpec();
  static ServiceSpec ccdbSupportSpec();
  static ServiceSpec decongestionSpec();
  static ServiceSpec asyncQueue();
  static ServiceSpec guiMetricsSpec();
  static ServiceSpec dataAllocatorSpec();
  static ServiceSpec streamContextSpec();
 
  static std::vector<ServiceSpec> defaultServices(std::string extraPlugins = "", int numWorkers = 0);
  static std::vector<ServiceSpec> arrowServices();
  static std::vector<ServiceSpec> requiredServices();
};
 
} // namespace o2::framework
 
#endif // O2_FRAMEWORK_COMMONSERVICES_H_