Catch corrupted data exception and exit with reporting corruptions

Author: shahor02

Detectors/Raw/include/DetectorsRaw/RawFileReader.h

@@ -120,7 +120,7 @@ class RawFileReader
     true,  // ErrWrongNumberOfTF
     true,  // ErrHBFJump
     false, // ErrNoSuperPageForTF
-    true,  // ErrNoSOX
+    false, // ErrNoSOX
     true,  // ErrMismatchTF
   };
   //================================================================================
@@ -250,6 +250,7 @@ class RawFileReader
   void setCheckErrors(uint32_t m = 0xffffffff) { mCheckErrors = m & ((0x1 << NErrorsDefined) - 1); }
   int getVerbosity() const { return mVerbosity; }
   uint32_t getCheckErrors() const { return mCheckErrors; }
+  bool isProcessingStopped() const { return mStopProcessing; }
 
   void setNominalSPageSize(int n = 0x1 << 20) { mNominalSPageSize = n > (0x1 << 15) ? n : (0x1 << 15); }
   int getNominalSPageSize() const { return mNominalSPageSize; }
@@ -315,6 +316,7 @@ class RawFileReader
   long int mPosInFile = 0;                                          //! current position in the file
   bool mMultiLinkFile = false;                                      //! was > than 1 link seen in the file?
   bool mCacheData = false;                                          //! cache data to block after 1st scan (may require excessive memory, use with care)
+  bool mStopProcessing = false;                                     //! stop processing after error
   uint32_t mCheckErrors = 0;                                        //! mask for errors to check
   FirstTFDetection mFirstTFAutodetect = FirstTFDetection::Disabled; //!
   bool mPreferCalculatedTFStart = false;                            //! prefer TFstart calculated via HBFUtils

Detectors/Raw/src/RawFileReader.cxx

@@ -590,7 +590,14 @@ bool RawFileReader::preprocessFile(int ifl)
         lID = getLinkLocalID(rdh, mCurrentFileID);
       }
       bool newSPage = lID != lIDPrev;
-      mLinksData[lID].preprocessCRUPage(rdh, newSPage);
+      try {
+        mLinksData[lID].preprocessCRUPage(rdh, newSPage);
+      } catch (...) {
+        LOG(error) << "Corrupted data, abandoning processing";
+        mStopProcessing = true;
+        break;
+      }
+
       if (mLinksData[lID].nTimeFrames && (mLinksData[lID].nTimeFrames - 1 > mMaxTFToRead)) { // limit reached, discard the last read
         mLinksData[lID].nTimeFrames--;
         mLinksData[lID].blocks.pop_back();
@@ -706,6 +713,10 @@ bool RawFileReader::init()
       mEmpty = false;
     }
   }
+  if (mStopProcessing) {
+    LOG(error) << "Abandoning processing due to corrupted data";
+    return false;
+  }
   mOrderedIDs.resize(mLinksData.size());
   for (int i = mLinksData.size(); i--;) {
     mOrderedIDs[i] = i;

Detectors/Raw/src/RawFileReaderWorkflow.cxx

@@ -206,8 +206,8 @@ void RawReaderSpecs::run(o2f::ProcessingContext& ctx)
   auto tfID = mReader->getNextTFToRead();
   int nlinks = mReader->getNLinks();
 
-  if (tfID > mMaxTFID) {
-    if (!mReader->isEmpty() && --mLoop) {
+  if (tfID > mMaxTFID || mReader->isProcessingStopped()) {
+    if (!mReader->isProcessingStopped() && !mReader->isEmpty() && --mLoop) {
       mLoopsDone++;
       tfID = 0;
       LOG(info) << "Starting new loop " << mLoopsDone << " from the beginning of data";