Initialisation.

[u/mrichter/AliRoot.git] / MUON / AliMUONPayloadTracker.cxx

diff --git a/MUON/AliMUONPayloadTracker.cxx b/MUON/AliMUONPayloadTracker.cxx
index c0b17a541041db72d17608744e9ef4c9abc191be..60923ddeed14201a10b4ee83b889ae3e6a232371 100644 (file)
--- a/MUON/AliMUONPayloadTracker.cxx
+++ b/MUON/AliMUONPayloadTracker.cxx
@@ -13,12 +13,17 @@
  * provided "as is" without express or implied warranty.                  *
  **************************************************************************/
 
-///
+// $Id$
+
+//-----------------------------------------------------------------------------
 /// \class AliMUONPayloadTracker
 /// Decodes rawdata from buffer and stores in TClonesArray.
 /// First version implement for Tracker
 ///
 /// \author Christian Finck
+//-----------------------------------------------------------------------------
+
+#include <TObjString.h>
 
 #include "AliMUONPayloadTracker.h"
 
@@ -27,6 +32,7 @@
 #include "AliMUONBusStruct.h"
 #include "AliMUONDDLTracker.h"
 
+#include "AliMUONLogger.h"
 #include "AliLog.h"
 
 /// \cond CLASSIMP
@@ -46,8 +52,11 @@ AliMUONPayloadTracker::AliMUONPayloadTracker()
     fBusStruct(new AliMUONBusStruct()),
     fBlockHeader(new AliMUONBlockHeader()),
     fDspHeader(new AliMUONDspHeader()),
-    fParityErrBus(),
-    fGlitchErrors(0)
+    fLog(new AliMUONLogger(1000)),
+    fParityErrors(0),
+    fGlitchErrors(0),
+    fPaddingErrors(0),
+    fWarnings(kTRUE)
 {
   ///
   /// create an object to decode MUON payload
@@ -65,6 +74,7 @@ AliMUONPayloadTracker::~AliMUONPayloadTracker()
   delete fBusStruct;
   delete fBlockHeader;
   delete fDspHeader;
+  delete fLog;
 }
 
 //______________________________________________________
@@ -124,14 +134,17 @@ Bool_t AliMUONPayloadTracker::Decode(UInt_t* buffer, Int_t totalDDLSize)
       totalDspSize = fDspHeader->GetTotalLength();
 
       if (fDspHeader->GetErrorWord()) {
-       fDspHeader->Print("");
-       if (fDspHeader->GetErrorWord() == (0x000000B1 |  fBlockHeader->GetDspId())){
+//     fDspHeader->Print("");
+       if ( fDspHeader->GetErrorWord() == (0x000000B1 |  fBlockHeader->GetDspId())
+            ||  fDspHeader->GetErrorWord() == (0x00000091 |  fBlockHeader->GetDspId()) ){
          // an event with a glitch in the readout  has been detected
          // it means that somewhere a 1 byte word has been randomly inserted
          // all the readout sequence is shifted  untill the next event 
-
-         AliWarning(Form("Glitch in data detected, skipping event ")); 
-
+   
+          Char_t* msg = Form("Glitch error detected in DSP %d, skipping event ", fBlockHeader->GetDspId());
+          
+          if (fWarnings) AliWarning(msg); 
+          AddErrorMessage(msg);
          fGlitchErrors++;
          return kFALSE ; 
        }       
@@ -172,8 +185,11 @@ Bool_t AliMUONPayloadTracker::Decode(UInt_t* buffer, Int_t totalDDLSize)
            fBusStruct->SetDspId(iDsp);
 
            // check parity
-           if(!CheckDataParity())
-               AddParityErrBus(fBusStruct->GetBusPatchId());
+            if(!CheckDataParity()) {
+                fParityErrors++;
+                return kFALSE;
+             }
+
 
            // copy in TClonesArray
            fDDLTracker->AddBusPatch(*fBusStruct, iBlock, iDsp);
@@ -192,11 +208,15 @@ Bool_t AliMUONPayloadTracker::Decode(UInt_t* buffer, Int_t totalDDLSize)
 
       // skipping additionnal word if padding
       if (fDspHeader->GetPaddingWord() == 1) {
-       if (buffer[index++] != fDspHeader->GetDefaultPaddingWord())
-
-           AliError(Form("Error in padding word for iBlock %d, iDsp %d, iBus %d\n", 
-                         iBlock, iDsp, iBusPatch));
-
+       if (buffer[index++] != fDspHeader->GetDefaultPaddingWord()) {
+
+          Char_t *msg = Form("Padding word error for iBlock %d, iDsp %d, iBus %d\n", 
+                      iBlock, iDsp, iBusPatch);
+        
+          if (fWarnings) AliWarning(msg);
+          AddErrorMessage(msg);
+          fPaddingErrors++;
+       }
       }
 
       index = indexDsp + totalDspSize;
@@ -225,8 +245,9 @@ void AliMUONPayloadTracker::ResetDDL()
   /// after each DDL
   ///
   fDDLTracker->GetBlkHeaderArray()->Delete();
-  fGlitchErrors = 0;
-  fParityErrBus.Reset();
+  fGlitchErrors  = 0;
+  fPaddingErrors = 0;
+  fParityErrors  = 0;
 
 }
 
@@ -261,9 +282,14 @@ Bool_t AliMUONPayloadTracker::CheckDataParity()
     // Check
     if (parity != fBusStruct->GetParity(idata)) {
 
-      AliWarning(Form("Parity error in word %d for manuId %d and channel %d\n", 
-                     idata, fBusStruct->GetManuId(idata), fBusStruct->GetChannelId(idata)));
-
+      Char_t* msg = Form("Parity error in word %d for manuId %d and channel %d in buspatch %d\n", 
+                          idata, fBusStruct->GetManuId(idata), fBusStruct->GetChannelId(idata),
+                          fBusStruct->GetBusPatchId());
+      
+      if (fWarnings) AliWarning(msg);
+      AddErrorMessage(msg);
+      fParityErrors++;
+      
       return kFALSE;
                     
     }
@@ -272,9 +298,16 @@ Bool_t AliMUONPayloadTracker::CheckDataParity()
 }
 
 //______________________________________________________
-void AliMUONPayloadTracker::AddParityErrBus(Int_t buspatch)
+void AliMUONPayloadTracker::AddErrorMessage(const Char_t* msg)
 {
-/// adding bus with at least on parity error
-    fParityErrBus.Set(fParityErrBus.GetSize() + 1);
-    fParityErrBus.AddAt(buspatch, fParityErrBus.GetSize() - 1);
+/// adding message to logger
+ 
+    TString tmp(msg);
+  
+    Int_t pos = tmp.First("\n");
+    tmp[pos] = 0;
+    
+    fLog->Log(tmp.Data());
 }
+
+