]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - MUON/MUONRawStreamTracker.C
PWGJE
[u/mrichter/AliRoot.git] / MUON / MUONRawStreamTracker.C
index 12da17eb7d75b2110c43fa772956d38191b37185..5b708c30c16498d9dee7f66603a91fdd7c339591 100644 (file)
 /**************************************************************************
- * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
- *                                                                        *
- * Author: The ALICE Off-line Project.                                    *
- * Contributors are mentioned in the code where appropriate.              *
- *                                                                        *
- * Permission to use, copy, modify and distribute this software and its   *
- * documentation strictly for non-commercial purposes is hereby granted   *
- * without fee, provided that the above copyright notice appears in all   *
- * copies and that both the copyright notice and this permission notice   *
- * appear in the supporting documentation. The authors make no claims     *
- * about the suitability of this software for any purpose. It is          *
- * provided "as is" without express or implied warranty.                  *
- **************************************************************************/
-
-//
-// Macro for reading tracker raw data
-// Ch. Finck, Subatech Febuary
-//
+* Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
+*                                                                        *
+* Author: The ALICE Off-line Project.                                    *
+* Contributors are mentioned in the code where appropriate.              *
+*                                                                        *
+* Permission to use, copy, modify and distribute this software and its   *
+* documentation strictly for non-commercial purposes is hereby granted   *
+* without fee, provided that the above copyright notice appears in all   *
+* copies and that both the copyright notice and this permission notice   *
+* appear in the supporting documentation. The authors make no claims     *
+* about the suitability of this software for any purpose. It is          *
+* provided "as is" without express or implied warranty.                  *
+**************************************************************************/
+
+// $Id$
+
+/// \ingroup macros
+/// \file MUONRawStreamTracker.C
+/// \brief Macro for reading tracker raw data
+///
+/// \author Ch. Finck, Subatech Febuary
+///
+/// Added example routines to show how to use the interface of the high
+/// performance decoder AliMUONRawStreamTrackerHP.
+/// by  Artur Szostak <artursz@iafrica.com>
+///
+/// This macro is interfaced with AliRawReader for RAW
+///
+/// There are 2 ways of reading the data: 
+/// - one where each intermediate structure (block, dsp, buspatch) is looped over
+/// - and one, using an iterator, where we're directly accessing the pad informations 
+/// (charge).
+///
+
 
 #if !defined(__CINT__) || defined(__MAKECINT__)
 
 // RAW includes
-#include "AliRawReaderDate.h"
-#include "AliRawReaderFile.h"
-#include "AliRawReaderRoot.h"
+#include "AliRawReader.h"
 
 // MUON includes
-#include "AliMUONRawStreamTracker.h"
-#include "AliMUONDspHeader.h"
-#include "AliMUONBlockHeader.h"
-#include "AliMUONBusStruct.h"
-#include "AliMUONDDLTracker.h"
+#include "AliMUONRawStreamTrackerHP.h"
+#include "TStopwatch.h"
+#include "AliRawDataErrorLog.h"
+#include "Riostream.h"
+#include "AliMUONLogger.h"
 
 #endif
 
-
-// Macro to read rawdata for tracker
-// Ch. Finck, Subatech, April. 2006
-//
-// This macro is interface with AliRawReader for RAW
-// The different stucture of the patload are readout and stored in TClonesArray
-// with AliMUONRawStreamTracker classe.
-// The macro just simpy read again the TClonesArray contents.
-// The parameter of each structure could be seen in the container classes
-// AliMUONBlockHeader, AliMUONBlockHeader, AliMUONBusStruct.
-// The class AliMUONDDLTracker manages the structure containers.
-// The number of structures in the rawdata file could be set.
-
-void MUONRawStreamTracker(Int_t maxEvent = 1000, Int_t minDDL = 0, Int_t maxDDL = 19, TString fileName = "./")
+void MUONRawStreamTrackerExpert(TString fileName = "./", Int_t maxEvent = 1000,  
+                                Int_t minDDL = 0, Int_t maxDDL = 19)
 {
-   AliRawReader* rawReader = 0x0;
-
-   // check extention to choose the rawdata file format
-   if (fileName.EndsWith("/")) {
-     rawReader = new AliRawReaderFile(fileName); // DDL files
-   } else if (fileName.EndsWith(".root")) {
-     rawReader = new AliRawReaderRoot(fileName);
-   } else if (!fileName.IsNull()) {
-     rawReader = new AliRawReaderDate(fileName); // DATE file
-   }
-
-   // raw stream
-   AliMUONRawStreamTracker* rawStream  = new AliMUONRawStreamTracker(rawReader);    
-
-   // set the number of DDL block Dsp & buspatch structures that are PRESENT in the rawdata file
-   // it's NOT the number to be read.
-   // default wise set to 20, 2, 5 ans 5 respectively.
-   //    rawStream->SetMaxDDL(xx);
-   //    rawStream->SetMaxBlock(xx);
-   //    rawStream->SetMaxDsp(xx);
-   //    rawStream->SetMaxBus(xx);
-
-   // containers
-   AliMUONDDLTracker*       ddlTracker = 0x0;
-   AliMUONBlockHeader*      blkHeader  = 0x0;
-   AliMUONDspHeader*        dspHeader  = 0x0;
-   AliMUONBusStruct*        busStruct  = 0x0;
-
-   //   Loop over events  
-   Int_t iEvent = 0;
-   Int_t dataSize;
+  /// This routine shows how to use the decoder's expert interface.
+  
+  TStopwatch timer;
+  timer.Start(kTRUE);
+  
+  AliRawReader* rawReader = AliRawReader::Create(fileName.Data());
+  
+  // raw stream
+  AliMUONRawStreamTrackerHP rawStream(rawReader);
+  
+  // light weight interfaces to headers
+  const AliMUONRawStreamTrackerHP::AliBlockHeader*      blkHeader  = 0x0;
+  const AliMUONRawStreamTrackerHP::AliDspHeader*        dspHeader  = 0x0;
+  const AliMUONRawStreamTrackerHP::AliBusPatch*         busStruct  = 0x0;
+  
+  //   Loop over events  
+  Int_t iEvent = 0;
+  Int_t dataSize;
+  
+  while (rawReader->NextEvent()) {
+    
+    if (iEvent == maxEvent)
+      break;
+    
+    printf("Event %d\n",iEvent++);
+    
+    // read DDL while < 20 DDL
+    while(rawStream.NextDDL()) {
+      
+      if (rawStream.GetDDL() < minDDL || rawStream.GetDDL() > maxDDL)
+        continue;
+      
+      printf("\niDDL %d\n", rawStream.GetDDL());
+      
+      // loop over block structure
+      Int_t nBlock = rawStream.GetBlockCount();
+      for(Int_t iBlock = 0; iBlock < nBlock ;iBlock++){
+        
+        blkHeader = rawStream.GetBlockHeader(iBlock);
+        printf("Block %d Total length %d\n",iBlock,blkHeader->GetTotalLength());
+       
+        // loop over DSP structure
+        Int_t nDsp = rawStream.GetDspCount(iBlock);
+        for(Int_t iDsp = 0; iDsp < nDsp ;iDsp++){   //DSP loop
+          
+          dspHeader =  blkHeader->GetDspHeader(iDsp);
+          printf("Dsp %d length %d error word %d\n",iDsp,dspHeader->GetTotalLength(), dspHeader->GetErrorWord());
+          
+          // loop over BusPatch structure
+          Int_t nBusPatch = rawStream.GetBusPatchCount(iBlock, iDsp);
+          for(Int_t iBusPatch = 0; iBusPatch < nBusPatch; iBusPatch++) {  
+            
+            busStruct = dspHeader->GetBusPatch(iBusPatch);
+            
+            // loop over data
+            dataSize = busStruct->GetLength();
+            for (Int_t iData = 0; iData < dataSize; iData++) {
+              
+              Int_t  manuId    = busStruct->GetManuId(iData);
+              Int_t  channelId = busStruct->GetChannelId(iData);
+              Int_t  charge    = busStruct->GetCharge(iData);
+              printf("buspatch %5d manuI %4d channel %3d charge %4d\n", 
+                     busStruct->GetBusPatchId(),
+                     manuId, 
+                     channelId, charge);
+            } // iData
+          } // iBusPatch
+        } // iDsp
+      } // iBlock
+    } // NextDDL
+  }// NextEvent
+  
+  delete rawReader;
+  timer.Print();
+}
 
-   while (rawReader->NextEvent()) {
 
-     if (iEvent == maxEvent)
-       break;
+void MUONRawStreamTrackerExpert2(TString fileName = "./", Int_t maxEvent = 1000,  
+                                Int_t minDDL = 0, Int_t maxDDL = 19)
+{
+  /// This routine shows an alternate way to iterate over the DDL structures
+  /// compared to MUONRawStreamTrackerExpert().
+  
+  TStopwatch timer;
+  timer.Start(kTRUE);
+  
+  AliRawReader* rawReader = AliRawReader::Create(fileName.Data());
+  
+  // raw stream
+  AliMUONRawStreamTrackerHP rawStream(rawReader);
+  
+  // light weight interfaces to headers
+  const AliMUONRawStreamTrackerHP::AliBlockHeader*      blkHeader  = 0x0;
+  const AliMUONRawStreamTrackerHP::AliDspHeader*        dspHeader  = 0x0;
+  const AliMUONRawStreamTrackerHP::AliBusPatch*         busStruct  = 0x0;
+  
+  //   Loop over events  
+  Int_t iEvent = 0;
+  Int_t dataSize;
+  
+  while (rawReader->NextEvent()) {
+    
+    if (iEvent == maxEvent)
+      break;
+    
+    printf("Event %d\n",iEvent++);
+    
+    // read DDL while < 20 DDL
+    while(rawStream.NextDDL()) {
+      
+      if (rawStream.GetDDL() < minDDL || rawStream.GetDDL() > maxDDL)
+        continue;
+      
+      printf("\niDDL %d\n", rawStream.GetDDL());
+      
+      // loop over block structure
+      Int_t nBlock = rawStream.GetBlockCount();
+      for(Int_t iBlock = 0; iBlock < nBlock ;iBlock++){
+        
+        blkHeader = rawStream.GetBlockHeader(iBlock);
+        printf("Block %d Total length %d\n",iBlock,blkHeader->GetTotalLength());
+       
+        // loop over DSP structure
+        Int_t nDsp = rawStream.GetDspCount(iBlock);
+        for(Int_t iDsp = 0; iDsp < nDsp ;iDsp++){   //DSP loop
+          
+          dspHeader =  rawStream.GetDspHeader(iBlock, iDsp);
+          printf("Dsp %d length %d error word %d\n",iDsp,dspHeader->GetTotalLength(), dspHeader->GetErrorWord());
+          
+          // loop over BusPatch structure
+          Int_t nBusPatch = rawStream.GetBusPatchCount(iBlock, iDsp);
+          for(Int_t iBusPatch = 0; iBusPatch < nBusPatch; iBusPatch++) {  
+            
+            busStruct = rawStream.GetBusPatch(iBlock, iDsp, iBusPatch);
+            
+            // loop over data
+            dataSize = busStruct->GetLength();
+            for (Int_t iData = 0; iData < dataSize; iData++) {
+              
+              Int_t  manuId    = busStruct->GetManuId(iData);
+              Int_t  channelId = busStruct->GetChannelId(iData);
+              Int_t  charge    = busStruct->GetCharge(iData);
+              printf("buspatch %5d manuI %4d channel %3d charge %4d\n", 
+                     busStruct->GetBusPatchId(),
+                     manuId, 
+                     channelId, charge);
+            } // iData
+          } // iBusPatch
+        } // iDsp
+      } // iBlock
+    } // NextDDL
+  }// NextEvent
+  
+  delete rawReader;
+  timer.Print();
+}
 
-     printf("Event %d\n",iEvent++);
 
-     // read DDL while < 20 DDL
-     while(rawStream->NextDDL()) {
+void MUONRawStreamTrackerExpert3(TString fileName = "./", Int_t maxEvent = 1000,  
+                                Int_t minDDL = 0, Int_t maxDDL = 19)
+{
+  /// This routine shows yet another alternate way to iterate over the DDL
+  /// structures compared to MUONRawStreamTrackerExpert().
+  
+  TStopwatch timer;
+  timer.Start(kTRUE);
+  
+  AliRawReader* rawReader = AliRawReader::Create(fileName.Data());
+  
+  // raw stream
+  AliMUONRawStreamTrackerHP rawStream(rawReader);
+  
+  // light weight interfaces to headers
+  const AliMUONRawStreamTrackerHP::AliBlockHeader*      blkHeader  = 0x0;
+  const AliMUONRawStreamTrackerHP::AliDspHeader*        dspHeader  = 0x0;
+  const AliMUONRawStreamTrackerHP::AliBusPatch*         busStruct  = 0x0;
+  
+  //   Loop over events  
+  Int_t iEvent = 0;
+  Int_t dataSize;
+  
+  while (rawReader->NextEvent()) {
+    
+    if (iEvent == maxEvent)
+      break;
+    
+    printf("Event %d\n",iEvent++);
+    
+    // read DDL while < 20 DDL
+    while(rawStream.NextDDL()) {
+      
+      if (rawStream.GetDDL() < minDDL || rawStream.GetDDL() > maxDDL)
+        continue;
+      
+      printf("\niDDL %d\n", rawStream.GetDDL());
+      
+      // loop over block structure
+      Int_t iBlock = 0;
+      blkHeader = rawStream.GetFirstBlockHeader();
+      while (blkHeader != NULL)
+      {
+        printf("Block %d Total length %d\n",iBlock,blkHeader->GetTotalLength());
+       
+        // loop over DSP structure
+        Int_t iDsp = 0;
+        dspHeader = blkHeader->GetFirstDspHeader();
+        while (dspHeader != NULL)
+        {
+          printf("Dsp %d length %d error word %d\n",iDsp,dspHeader->GetTotalLength(), dspHeader->GetErrorWord());
+          
+          // loop over BusPatch structure
+          Int_t iBusPatch = 0;
+          busStruct = dspHeader->GetFirstBusPatch();
+          while (busStruct != NULL)
+          {
+            // loop over data
+            dataSize = busStruct->GetLength();
+            for (Int_t iData = 0; iData < dataSize; iData++) {
+              
+              Int_t  manuId    = busStruct->GetManuId(iData);
+              Int_t  channelId = busStruct->GetChannelId(iData);
+              Int_t  charge    = busStruct->GetCharge(iData);
+              printf("buspatch %5d manuI %4d channel %3d charge %4d\n", 
+                     busStruct->GetBusPatchId(),
+                     manuId, 
+                     channelId, charge);
+            } // iData
+            busStruct = busStruct->Next();
+            iBusPatch++;
+          } // iBusPatch
+          dspHeader = dspHeader->Next();
+          iDsp++;
+        } // iDsp
+        blkHeader = blkHeader->Next();
+        iBlock++;
+      } // iBlock
+    } // NextDDL
+  }// NextEvent
+  
+  delete rawReader;
+  timer.Print();
+}
 
-       if (rawStream->GetDDL() < minDDL || rawStream->GetDDL() > maxDDL)
-        continue;
 
-       printf("\niDDL %d\n", rawStream->GetDDL());
+void MUONRawStreamTrackerSimple(TString fileName = "./", Int_t maxEvent = 1000)
+{
+  /// This routine shows how to use the high performance decoder's simple interface.
 
-       ddlTracker =  rawStream->GetDDLTracker();
+  TStopwatch timer;
+  timer.Start(kTRUE);
+  
+  AliRawReader* rawReader = AliRawReader::Create(fileName.Data());
+  
+  // raw stream
+  AliMUONRawStreamTrackerHP rawStream(rawReader);    
+  
+  //   Loop over events  
+  Int_t iEvent = 0;
+  
+  while (rawReader->NextEvent()) {
+    
+    if (iEvent == maxEvent)
+      break;
+    
+    printf("Event %d\n",iEvent++);
+    
+    Int_t busPatch;
+    UShort_t manuId, adc;
+    UChar_t manuChannel;
+    
+    rawStream.First();
+    
+    while ( rawStream.Next(busPatch,manuId,manuChannel,adc) )
+    {      
+      printf("buspatch %5d manuI %4d channel %3d charge %4d\n", 
+             busPatch,manuId,manuChannel, adc);
+    }
+  }
+  
+  delete rawReader;
+  timer.Print();
+}
 
-       // loop over block structure
-       Int_t nBlock = ddlTracker->GetBlkHeaderEntries();
-       for(Int_t iBlock = 0; iBlock < nBlock ;iBlock++){
 
-        blkHeader = ddlTracker->GetBlkHeaderEntry(iBlock);
-        printf("Block Total length %d\n",blkHeader->GetTotalLength());
+void ShowErrors(const AliRawReader& rawReader)
+{
+  for ( Int_t i = 0; i < rawReader.GetNumberOfErrorLogs(); ++i )
+  {
+    AliRawDataErrorLog* error = rawReader.GetErrorLog(i);
+    error->Print();
+  }
 
-        // loop over DSP structure
-        Int_t nDsp = blkHeader->GetDspHeaderEntries();
-        for(Int_t iDsp = 0; iDsp < nDsp ;iDsp++){   //DSP loop
+  cout << Form("Number of error logs : %d (%d events)",
+               rawReader.GetNumberOfErrorLogs(),
+               rawReader.GetNumberOfEvents()) << endl;
+}
 
-          dspHeader =  blkHeader->GetDspHeaderEntry(iDsp);
-          //   printf("Dsp length %d even word %d\n",dspHeader->GetTotalLength(), dspHeader->GetEventWord());
 
-          // loop over BusPatch structure
-          Int_t nBusPatch = dspHeader->GetBusPatchEntries();
-          for(Int_t iBusPatch = 0; iBusPatch < nBusPatch; iBusPatch++) {  
+void MUONRawStreamTrackerSimple2(TString fileName = "./", Int_t maxEvent = 1000)
+{
+  /// This routine is an alternative to MUONRawStreamTrackerSimple() which is even faster.
 
-            busStruct = dspHeader->GetBusPatchEntry(iBusPatch);
+  TStopwatch timer;
+  timer.Start(kTRUE);
+  
+  AliRawReader* rawReader = AliRawReader::Create(fileName.Data());
+  
+  // raw stream
+  AliMUONRawStreamTrackerHP rawStream(rawReader);
+  rawStream.EnableRawReaderErrorLogger();
+  
+  //   Loop over events  
+  Int_t iEvent = 0;
+  
+  while (rawReader->NextEvent()) {
+    
+    if (iEvent == maxEvent)
+      break;
+    
+    printf("Event %d\n",iEvent++);
+    
+    UShort_t manuId, adc;
+    UChar_t manuChannel;
+    
+    rawStream.First();
+    const AliMUONRawStreamTrackerHP::AliBusPatch* buspatch = NULL;
+    while ((buspatch = rawStream.Next()) != NULL)
+    {
+      for (UInt_t i = 0; i < buspatch->GetDataCount(); i++)
+      {
+        buspatch->GetData(i, manuId, manuChannel, adc);
+        printf("buspatch %5d manuI %4d channel %3d charge %4d\n", 
+               buspatch->GetBusPatchId(), manuId, manuChannel, adc);
+      }
+    }
+  }
 
-            printf("busPatchId %d", busStruct->GetBusPatchId());
-            printf(" BlockId %d", busStruct->GetBlockId());
-            printf(" DspId %d\n", busStruct->GetDspId());
+  ShowErrors(*rawReader);
+  
+  delete rawReader;
+  timer.Print();
+}
 
-          // loop over data
-            dataSize = busStruct->GetLength();
-            for (Int_t iData = 0; iData < dataSize; iData++) {
+void MUONRawStreamTrackerErrorCount(TString fileName = "collection://filelist", Int_t maxEvent = -1)
+{
+  /// This routine is just a loop to get the error log at the end
+  
+  TStopwatch timer;
+  timer.Start(kTRUE);
+  
+  AliRawReader* rawReader = AliRawReader::Create(fileName.Data());
+  
+  // raw stream
+  AliMUONRawStreamTrackerHP rawStream(rawReader);
+  rawStream.DisableWarnings();    
 
-              Int_t  manuId    = busStruct->GetManuId(iData);
-              Int_t  channelId = busStruct->GetChannelId(iData);
-              Int_t  charge    = busStruct->GetCharge(iData);
-              printf("manuId: %d, channelId: %d charge: %d\n", manuId, 
-                     channelId, charge);
+  AliMUONLogger logger;
+  
+  rawStream.EnableMUONErrorLogger();  
+  rawStream.SetMUONErrorLogger(&logger);    
+  rawStream.SetLoggingDetailLevel(AliMUONRawStreamTrackerHP::kMediumErrorDetail);
+  
+  //   Loop over events  
+  Int_t iEvent = 0;
+  
+  while (rawReader->NextEvent()) 
+  {    
+    if (iEvent == maxEvent) break;
+    
+    rawStream.First();
 
-            } // iData
-          } // iBusPatch
-        } // iDsp
-       } // iBlock
-     } // NextDDL
-   }// NextEvent
+    const AliMUONRawStreamTrackerHP::AliBusPatch* buspatch = NULL;
+    
+    while ((buspatch = rawStream.Next()) != NULL)
+    {
+    }
+    
+    ++iEvent;
+  }
+  
+  logger.Print();
+  
+//  ShowErrors(*rawReader);
 
-   delete rawReader;
-   delete rawStream;
+  delete rawReader;
+  timer.Print();
 }
+