[MFT] Add task for async reconstruction

Modules/MFT/CMakeLists.txt

@@ -9,6 +9,7 @@ target_sources(O2QcMFT PRIVATE
                src/QcMFTClusterTask.cxx
                src/QcMFTTrackCheck.cxx
                src/QcMFTTrackTask.cxx
+               src/QcMFTAsyncTask.cxx
                src/QcMFTReadoutCheck.cxx
                src/QcMFTReadoutTask.cxx)
 
@@ -33,6 +34,7 @@ add_root_dictionary(O2QcMFT
                     include/MFT/QcMFTClusterTask.h
                     include/MFT/QcMFTTrackCheck.h
                     include/MFT/QcMFTTrackTask.h 
+                    include/MFT/QcMFTAsyncTask.h
                     include/MFT/QcMFTReadoutCheck.h
                     include/MFT/QcMFTReadoutTask.h
                     include/MFT/QcMFTUtilTables.h
@@ -92,4 +94,6 @@ install(FILES qc-mft-digit.json
               qc-mft-cluster.json
               qc-mft-track.json
               qc-mft-readout.json
+              qc-mft-async.json
+              qc-mft-async_direct.json
         DESTINATION etc)

Modules/MFT/include/MFT/LinkDef.h

@@ -8,6 +8,7 @@
 #pragma link C++ class o2::quality_control_modules::mft::QcMFTClusterTask + ;
 #pragma link C++ class o2::quality_control_modules::mft::QcMFTClusterCheck + ;
 #pragma link C++ class o2::quality_control_modules::mft::QcMFTTrackTask + ;
+#pragma link C++ class o2::quality_control_modules::mft::QcMFTAsyncTask + ;
 #pragma link C++ class o2::quality_control_modules::mft::QcMFTTrackCheck + ;
 #pragma link C++ class o2::quality_control_modules::mft::QcMFTReadoutCheck + ;
 #pragma link C++ class o2::quality_control_modules::mft::QcMFTReadoutTask + ;

Modules/MFT/include/MFT/QcMFTAsyncTask.h

@@ -0,0 +1,96 @@
+// 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.
+
+///
+/// \file   QcMFTAsyncTask.h
+/// \author Tomas Herman
+/// \author Guillermo Contreras
+/// \author Diana Maria Krupova
+/// \author Katarina Krizkova Gajdosova
+
+#ifndef QC_MFT_ASYNC_TASK_H
+#define QC_MFT_ASYNC_TASK_H
+
+// ROOT
+#include <TH1.h>
+#include <TH2.h>
+// Quality Control
+#include "QualityControl/TaskInterface.h"
+// O2
+#include "CommonConstants/LHCConstants.h"
+
+using namespace o2::quality_control::core;
+using namespace std;
+
+namespace o2::quality_control_modules::mft
+{
+
+/// \brief MFT Async QC task
+///
+class QcMFTAsyncTask /*final*/ : public TaskInterface // todo add back the "final" when doxygen is fixed
+{
+ public:
+  /// \brief Constructor
+  QcMFTAsyncTask() = default;
+  /// Destructor
+  ~QcMFTAsyncTask() override;
+
+  // Definition of the methods for the template method pattern
+  void initialize(o2::framework::InitContext& ctx) override;
+  void startOfActivity(Activity& activity) override;
+  void startOfCycle() override;
+  void monitorData(o2::framework::ProcessingContext& ctx) override;
+  void endOfCycle() override;
+  void endOfActivity(Activity& activity) override;
+  void reset() override;
+
+  double orbitToSeconds(uint32_t orbit, uint32_t refOrbit)
+  {
+    return (orbit - refOrbit) * o2::constants::lhc::LHCOrbitNS / 1E9;
+  }
+
+ private:
+  std::unique_ptr<TH1F> mTrackNumberOfClusters = nullptr;
+  std::unique_ptr<TH1F> mCATrackNumberOfClusters = nullptr;
+  std::unique_ptr<TH1F> mLTFTrackNumberOfClusters = nullptr;
+  std::unique_ptr<TH1F> mTrackOnvQPt = nullptr;
+  std::unique_ptr<TH1F> mTrackChi2 = nullptr;
+  std::unique_ptr<TH1F> mTrackCharge = nullptr;
+  std::unique_ptr<TH1F> mTrackPhi = nullptr;
+  std::unique_ptr<TH1F> mPositiveTrackPhi = nullptr;
+  std::unique_ptr<TH1F> mNegativeTrackPhi = nullptr;
+  std::unique_ptr<TH1F> mTrackEta = nullptr;
+  std::array<unique_ptr<TH1F>, 7> mTrackEtaNCls = { nullptr };
+  std::array<unique_ptr<TH1F>, 7> mTrackPhiNCls = { nullptr };
+  std::array<unique_ptr<TH2F>, 7> mTrackXYNCls = { nullptr };
+  std::array<unique_ptr<TH2F>, 7> mTrackEtaPhiNCls = { nullptr };
+  std::unique_ptr<TH1F> mCATrackEta = nullptr;
+  std::unique_ptr<TH1F> mLTFTrackEta = nullptr;
+  std::unique_ptr<TH1F> mTrackTanl = nullptr;
+
+  std::unique_ptr<TH1F> mTrackROFNEntries = nullptr;
+  std::unique_ptr<TH1F> mClusterROFNEntries = nullptr;
+  std::unique_ptr<TH1F> mTracksBC = nullptr;
+
+  std::unique_ptr<TH1F> mNOfTracksTime = nullptr;
+  std::unique_ptr<TH1F> mNOfClustersTime = nullptr;
+
+  std::unique_ptr<TH1F> mClusterSensorIndex = nullptr;
+  std::unique_ptr<TH1F> mClusterPatternIndex = nullptr;
+
+  uint32_t mRefOrbit = 0; // Reference orbit used in relative time calculation
+
+  static constexpr array<short, 7> sMinNClustersList = { 4, 5, 6, 7, 8, 9, 10 };
+};
+
+} // namespace o2::quality_control_modules::mft
+
+#endif // QC_MFT_ASYNC_TASK_H

Modules/MFT/qc-mft-async.json

@@ -0,0 +1,67 @@
+{
+  "qc": {
+    "config": {
+      "database": {
+        "implementation": "CCDB",
+        "host": "ccdb-test.cern.ch:8080",
+        "username": "not_applicable",
+        "password": "not_applicable",
+        "name": "not_applicable"
+      },
+      "Activity": {
+        "number": "42",
+        "type": "2"
+      },
+      "monitoring": {
+        "url": "infologger:///debug?qc"
+      },
+      "consul": {
+        "url": ""
+      },
+      "conditionDB": {
+        "url": "ccdb-test.cern.ch:8080"
+      }
+    },
+    "tasks": {
+      "QcMFTAsync": {
+        "active": "true",
+        "className": "o2::quality_control_modules::mft::QcMFTAsyncTask",
+        "moduleName": "QcMFT",
+        "detectorName": "MFT",
+        "cycleDurationSeconds": "60",
+        "maxNumberCycles": "-1",
+        "dataSource_comment": "The other type of dataSource is \"direct\", see basic-no-sampling.json.",
+        "dataSource": {
+          "type": "dataSamplingPolicy",
+          "name": "mft-async"
+        },
+        "taskParameters": {
+          "ROFLengthInBC": "198",
+          "MaxTrackROFSize": "1000",
+          "MaxClusterROFSize": "5000",
+          "MaxDuration": "60000",
+          "TimeBinSize": "0.1",
+          "RefOrbit": "0"
+        },
+        "location": "remote"
+      }
+    },
+    "checks": {}
+  },
+  "dataSamplingPolicies": [
+    {
+      "id": "mft-async",
+      "active": "true",
+      "machines": [],
+      "query": "tracks:MFT/TRACKS/0;tracksrofs:MFT/MFTTrackROF/0;clusters:MFT/COMPCLUSTERS/0;clustersrofs:MFT/CLUSTERSROF/0",
+      "samplingConditions": [
+        {
+          "condition": "random",
+          "fraction": "0.05",
+          "seed": "1234"
+        }
+      ],
+      "blocking": "false"
+    }
+  ]
+}

Modules/MFT/qc-mft-async_direct.json

@@ -0,0 +1,52 @@
+{
+  "qc": {
+    "config": {
+      "database": {
+        "implementation": "Dummy",
+        "host": "not_applicable",
+        "username": "not_applicable",
+        "password": "not_applicable",
+        "name": "not_applicable"
+      },
+      "Activity": {
+        "number": "42",
+        "type": "2"
+      },
+      "monitoring": {
+        "url": "infologger:///debug?qc"
+      },
+      "consul": {
+        "url": ""
+      },
+      "conditionDB": {
+        "url": "qcdb.cern.ch:8083"
+      }
+    },
+    "tasks": {
+      "QcMFTAsync": {
+        "active": "true",
+        "className": "o2::quality_control_modules::mft::QcMFTAsyncTask",
+        "moduleName": "QcMFT",
+        "detectorName": "MFT",
+        "cycleDurationSeconds": "60",
+        "maxNumberCycles": "-1",
+        "dataSource_comment": "The other type of dataSource is \"direct\", see basic-no-sampling.json.",
+        "dataSource": {
+          "type": "direct",
+          "query": "tracks:MFT/TRACKS/0;tracksrofs:MFT/MFTTrackROF/0;clusters:MFT/COMPCLUSTERS/0;clustersrofs:MFT/CLUSTERSROF/0"
+        },
+        "taskParameters": {
+          "ROFLengthInBC": "198",
+          "MaxTrackROFSize": "1000",
+          "MaxClusterROFSize": "5000",
+          "MaxDuration": "60000",
+          "TimeBinSize": "0.1",
+          "RefOrbit": "0"
+        },
+        "location": "remote"
+      }
+    },
+    "checks": {}
+  },
+  "dataSamplingPolicies": []
+}