Check for missing GBT links in MID raw data

Author: dstocco

Detectors/MUON/MID/QC/include/MIDQC/GBTRawDataChecker.h

@@ -33,7 +33,7 @@ namespace mid
 class GBTRawDataChecker
 {
  public:
-  void init(uint16_t feeId, uint8_t mask);
+  void init(uint16_t gbtUniqueId, uint8_t mask);
   bool process(gsl::span<const ROBoard> localBoards, gsl::span<const ROFRecord> rofRecords, gsl::span<const ROFRecord> pageRecords);
   /// Gets the number of processed events
   unsigned int getNEventsProcessed() const { return mStatistics[0]; }
@@ -43,6 +43,8 @@ class GBTRawDataChecker
   unsigned int getNBusyRaised() const { return mStatistics[2]; }
   /// Gets the
   std::string getDebugMessage() const { return mDebugMsg; }
+  /// Returns the GBTUniqueId
+  uint16_t getGBTUniqueId() const { return mGBTUniqueId; }
   void clear(bool all = false);
 
   /// Sets the delay in the electronics
@@ -96,7 +98,7 @@ class GBTRawDataChecker
   std::array<unsigned long int, 3> mStatistics{}; /// Processed events statistics
   std::unordered_map<uint8_t, Mask> mMasks;       /// Masks
   uint8_t mCrateMask{0xFF};                       /// Crate mask
-  uint16_t mFeeId{0};                             /// FeeId
+  uint16_t mGBTUniqueId{0};                       /// GBTUniqueId
   uint16_t mResetVal{0};                          /// Reset value
   ElectronicsDelay mElectronicsDelay{};           /// Delays in the electronics
   uint32_t mSyncTrigger{raw::sORB};               /// Trigger for synchronization

Detectors/MUON/MID/QC/include/MIDQC/RawDataChecker.h

@@ -34,6 +34,7 @@ class RawDataChecker
  public:
   void init(const CrateMasks& masks);
   bool process(gsl::span<const ROBoard> localBoards, gsl::span<const ROFRecord> rofRecords, gsl::span<const ROFRecord> pageRecords);
+  bool checkMissingLinks(bool clear = true);
   /// Gets the number of processed events
   unsigned int getNEventsProcessed() const;
   /// Gets the number of faulty events

Detectors/MUON/MID/QC/src/GBTRawDataChecker.cxx

@@ -25,10 +25,10 @@ namespace o2
 namespace mid
 {
 
-void GBTRawDataChecker::init(uint16_t feeId, uint8_t mask)
+void GBTRawDataChecker::init(uint16_t gbtUniqueId, uint8_t mask)
 {
   /// Initializer
-  mFeeId = feeId;
+  mGBTUniqueId = gbtUniqueId;
   mCrateMask = mask;
 }
 
@@ -421,11 +421,8 @@ bool GBTRawDataChecker::checkEvents(bool isTriggered)
   for (auto& evtIdxItem : orderedIndexes) {
     // All of these boards have the same timestamp
     GBT gbtEvent;
-    // bool busyRaised = false;
     for (auto& evtPair : evtIdxItem.second) {
       auto& boardInfo = boards[evtPair.first][evtPair.second];
-      uint8_t triggerId = boardInfo.board.triggerWord;
-      auto elinkId = getElinkId(boardInfo.board);
 
       if (raw::isLoc(boardInfo.board.statusWord)) {
         gbtEvent.locs.push_back(boardInfo.board);

Detectors/MUON/MID/QC/src/RawDataChecker.cxx

@@ -17,6 +17,7 @@
 #include "MIDQC/RawDataChecker.h"
 
 #include <unordered_map>
+#include "fmt/format.h"
 #include "MIDRaw/CrateParameters.h"
 
 namespace o2
@@ -56,6 +57,22 @@ bool RawDataChecker::process(gsl::span<const ROBoard> localBoards, gsl::span<con
   return isOk;
 }
 
+bool RawDataChecker::checkMissingLinks(bool clear)
+{
+  /// Checks for missing links
+  if (clear) {
+    mDebugMsg.clear();
+  }
+  bool isOk = true;
+  for (auto& checker : mCheckers) {
+    if (checker.getNEventsProcessed() == 0) {
+      isOk = false;
+      mDebugMsg += fmt::format("Missing info from GBT 0x{:02x}\n", checker.getGBTUniqueId());
+    }
+  }
+  return isOk;
+}
+
 void RawDataChecker::setSyncTrigger(uint32_t syncTrigger)
 {
   /// Sets the trigger use to verify if all data of an event where received

Detectors/MUON/MID/Workflow/src/RawCheckerSpec.cxx

@@ -77,6 +77,11 @@ class RawCheckerDeviceDPL
     mOutFile.open(outFilename.c_str());
 
     auto stop = [this]() {
+      if constexpr (std::is_same_v<RAWCHECKER, RawDataChecker>) {
+        if (!mChecker.checkMissingLinks()) {
+          mOutFile << mChecker.getDebugMessage() << "\n";
+        }
+      }
       bool hasProcessed = (mChecker.getNEventsProcessed() > 0);
       double scaleFactor = (mChecker.getNEventsProcessed() > 0) ? 1.e6 / static_cast<double>(mChecker.getNEventsProcessed()) : 0.;
       LOG(info) << "Processing time / " << mChecker.getNEventsProcessed() << " BCs: full: " << mTimer.count() * scaleFactor << " us  checker: " << mTimerAlgo.count() * scaleFactor << " us";