GPUWorkflowSpec.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_GPU_WORKFLOW_SPEC_H
#define O2_GPU_WORKFLOW_SPEC_H
 
#include "Framework/DataProcessorSpec.h"
#include "Framework/Task.h"
#include "Framework/ConcreteDataMatcher.h"
#include "Framework/InitContext.h"
#include "Framework/CompletionPolicy.h"
#include "Algorithm/Parser.h"
#include <string>
#include <array>
#include <vector>
#include <mutex>
#include <functional>
#include <queue>
 
class TStopwatch;
namespace fair::mq
{
struct RegionInfo;
enum class State : int32_t;
} // namespace fair::mq
namespace o2
{
namespace base
{
struct GRPGeomRequest;
} // namespace base
namespace tpc
{
class CalibdEdxContainer;
struct ClusterGroupHeader;
class VDriftHelper;
class CorrectionMapsLoader;
class DeadChannelMapCreator;
} // namespace tpc
 
namespace trd
{
class GeometryFlat;
} // namespace trd
 
namespace its
{
template <int>
class TimeFrame;
class ITSTrackingInterface;
} // namespace its
 
namespace itsmft
{
class TopologyDictionary;
} // namespace itsmft
 
namespace dataformats
{
class MeanVertexObject;
} // namespace dataformats
 
namespace gpu
{
struct GPUO2InterfaceConfiguration;
class GPUDisplayFrontendInterface;
class CorrectionMapsHelper;
class TPCFastTransform;
struct GPUSettingsTF;
class GPUO2Interface;
struct TPCPadGainCalib;
struct TPCZSLinkMapping;
struct GPUSettingsO2;
struct GPUSettingsProcessingNNclusterizer;
class GPUTRDRecoParam;
class GPUO2InterfaceQA;
struct GPUTrackingInOutPointers;
struct GPUTrackingInOutZS;
struct GPUInterfaceOutputs;
struct GPUInterfaceInputUpdate;
namespace gpurecoworkflow_internals
{
struct GPURecoWorkflowSpec_TPCZSBuffers;
struct GPURecoWorkflowSpec_PipelineInternals;
struct GPURecoWorkflow_QueueObject;
} // namespace gpurecoworkflow_internals
 
class GPURecoWorkflowSpec : public o2::framework::Task
{
 public:
  using CompletionPolicyData = std::vector<framework::InputSpec>;
 
  struct Config {
    int32_t itsTriggerType = 0;
    int32_t lumiScaleMode = 0;
    bool checkCTPIDCconsistency = true;
    bool enableMShape = false;
    bool enableCTPLumi = false;
    int32_t enableDoublePipeline = 0;
    int32_t tpcDeadMapSources = -1;
    bool tpcUseMCTimeGain = false; // use time gain calibration for MC (true) or from data (false)
    bool decompressTPC = false;
    bool decompressTPCFromROOT = false;
    bool caClusterer = false;
    bool zsDecoder = false;
    bool zsOnTheFly = false;
    bool outputTracks = false;
    bool outputCompClustersRoot = false;
    bool outputCompClustersFlat = false;
    bool outputCAClusters = false;
    bool outputQA = false;
    bool outputSharedClusterMap = false;
    bool processMC = false;
    bool sendClustersPerSector = false;
    bool askDISTSTF = true;
    bool runTPCTracking = false;
    bool runTRDTracking = false;
    bool readTRDtracklets = false;
    int32_t lumiScaleType = 0; // 0=off, 1=CTP, 2=TPC scalers
    bool outputErrorQA = false;
    bool runITSTracking = false;
    bool itsOverrBeamEst = false;
    bool tpcTriggerHandling = false;
    bool isITS3 = false;
    bool useFilteredOutputSpecs = false;
 
    // NN clusterizer
    bool nnLoadFromCCDB = false;
    bool nnDumpToFile = false;
    std::vector<std::string> nnEvalMode;
  };
 
  GPURecoWorkflowSpec(CompletionPolicyData* policyData, Config const& specconfig, std::vector<int32_t> const& tpcsectors, uint64_t tpcSectorMask, std::shared_ptr<o2::base::GRPGeomRequest>& ggr, std::function<bool(o2::framework::DataProcessingHeader::StartTime)>** gPolicyOrder = nullptr);
  ~GPURecoWorkflowSpec() override;
  void init(o2::framework::InitContext& ic) final;
  void run(o2::framework::ProcessingContext& pc) final;
  void endOfStream(o2::framework::EndOfStreamContext& ec) final;
  void stop() final;
  void finaliseCCDB(o2::framework::ConcreteDataMatcher& matcher, void* obj) final;
  o2::framework::Inputs inputs();
  o2::framework::Outputs outputs();
  o2::framework::Options options();
 
  void deinitialize();
 
 private:
  struct calibObjectStruct {
    std::unique_ptr<TPCFastTransform> mFastTransform;
    std::unique_ptr<TPCFastTransform> mFastTransformRef;
    std::unique_ptr<TPCFastTransform> mFastTransformMShape;
    std::unique_ptr<o2::tpc::CorrectionMapsLoader> mFastTransformHelper;
    std::unique_ptr<TPCPadGainCalib> mTPCPadGainCalib;
    std::unique_ptr<o2::tpc::CalibdEdxContainer> mdEdxCalibContainer;
  };
 
  void initFunctionTPCCalib(o2::framework::InitContext& ic);
  void initFunctionITS(o2::framework::InitContext& ic);
  void finaliseCCDBTPC(o2::framework::ConcreteDataMatcher& matcher, void* obj);
  void finaliseCCDBITS(o2::framework::ConcreteDataMatcher& matcher, void* obj);
  template <class T>
  bool fetchCalibsCCDBTPC(o2::framework::ProcessingContext& pc, T& newCalibObjects, calibObjectStruct& oldCalibObjects);
  bool fetchCalibsCCDBITS(o2::framework::ProcessingContext& pc);
  void cleanOldCalibsTPCPtrs(calibObjectStruct& oldCalibObjects);
 
  void doCalibUpdates(o2::framework::ProcessingContext& pc, calibObjectStruct& oldCalibObjects);
 
  void doTrackTuneTPC(GPUTrackingInOutPointers& ptrs, char* buffout);
 
  template <class D, class E, class F, class G, class H, class I, class J, class K>
  void processInputs(o2::framework::ProcessingContext&, D&, E&, F&, G&, bool&, H&, I&, J&, K&);
 
  int32_t runMain(o2::framework::ProcessingContext* pc, GPUTrackingInOutPointers* ptrs, GPUInterfaceOutputs* outputRegions, int32_t threadIndex = 0, GPUInterfaceInputUpdate* inputUpdateCallback = nullptr);
  int32_t runITSTracking(o2::framework::ProcessingContext& pc);
 
  int32_t handlePipeline(o2::framework::ProcessingContext& pc, GPUTrackingInOutPointers& ptrs, gpurecoworkflow_internals::GPURecoWorkflowSpec_TPCZSBuffers& tpcZSmeta, o2::gpu::GPUTrackingInOutZS& tpcZS, std::unique_ptr<gpurecoworkflow_internals::GPURecoWorkflow_QueueObject>& context);
  void RunReceiveThread();
  void RunWorkerThread(int32_t id);
  void ExitPipeline();
  void handlePipelineEndOfStream(o2::framework::EndOfStreamContext& ec);
  void handlePipelineStop();
  void initPipeline(o2::framework::InitContext& ic);
  void enqueuePipelinedJob(GPUTrackingInOutPointers* ptrs, GPUInterfaceOutputs* outputRegions, gpurecoworkflow_internals::GPURecoWorkflow_QueueObject* context, bool inputFinal);
  void finalizeInputPipelinedJob(GPUTrackingInOutPointers* ptrs, GPUInterfaceOutputs* outputRegions, gpurecoworkflow_internals::GPURecoWorkflow_QueueObject* context);
  void receiveFMQStateCallback(fair::mq::State);
 
  CompletionPolicyData* mPolicyData;
  std::function<bool(o2::framework::DataProcessingHeader::StartTime)> mPolicyOrder;
  std::unique_ptr<GPUO2Interface> mGPUReco;
  std::unique_ptr<GPUDisplayFrontendInterface> mDisplayFrontend;
 
  calibObjectStruct mCalibObjects;
  std::unique_ptr<o2::tpc::DeadChannelMapCreator> mTPCDeadChannelMapCreator;
  std::unique_ptr<o2::tpc::CalibdEdxContainer> mdEdxCalibContainerBufferNew;
  std::unique_ptr<TPCPadGainCalib> mTPCPadGainCalibBufferNew;
  std::queue<calibObjectStruct> mOldCalibObjects;
  std::unique_ptr<TPCZSLinkMapping> mTPCZSLinkMapping;
  std::unique_ptr<o2::tpc::VDriftHelper> mTPCVDriftHelper;
  std::unique_ptr<o2::trd::GeometryFlat> mTRDGeometry;
  std::unique_ptr<GPUTRDRecoParam> mTRDRecoParam;
  std::unique_ptr<GPUO2InterfaceConfiguration> mConfig;
  std::unique_ptr<GPUSettingsO2> mConfParam;
  std::unique_ptr<TStopwatch> mTimer;
  std::vector<std::array<uint32_t, 4>> mErrorQA;
  int32_t mQATaskMask = 0;
  std::unique_ptr<GPUO2InterfaceQA> mQA;
  std::vector<int32_t> mClusterOutputIds;
  std::vector<int32_t> mTPCSectors;
  std::unique_ptr<o2::its::ITSTrackingInterface> mITSTrackingInterface;
  std::unique_ptr<gpurecoworkflow_internals::GPURecoWorkflowSpec_PipelineInternals> mPipeline;
  o2::its::TimeFrame<7>* mITSTimeFrame = nullptr;
  std::vector<fair::mq::RegionInfo> mRegionInfos;
  const o2::itsmft::TopologyDictionary* mITSDict = nullptr;
  const o2::dataformats::MeanVertexObject* mMeanVertex;
  uint64_t mTPCSectorMask = 0;
  int64_t mCreationForCalib = -1; 
  int32_t mVerbosity = 0;
  uint32_t mNTFs = 0;
  uint32_t mNTFDumps = 0;
  uint32_t mNDebugDumps = 0;
  uint32_t mNextThreadIndex = 0;
  bool mUpdateGainMapCCDB = true;
  std::unique_ptr<o2::gpu::GPUSettingsTF> mTFSettings;
  std::map<std::string, std::string> nnCCDBSettings;
 
  Config mSpecConfig;
  std::shared_ptr<o2::base::GRPGeomRequest> mGGR;
  bool mGRPGeomUpdated = false;
  bool mAutoContinuousMaxTimeBin = false;
  bool mAutoSolenoidBz = false;
  bool mMatLUTCreated = false;
  bool mITSGeometryCreated = false;
  bool mTRDGeometryCreated = false;
  bool mTRDRecoParamCreated = false;
  bool mPropagatorInstanceCreated = false;
  int32_t mTPCCutAtTimeBin = -1;
};
 
} // end namespace gpu
} // end namespace o2
 
#endif // O2_GPU_WORKFLOW_SPEC_H