]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - ITS/AliITSRawStreamSDD.cxx
Update for Ds
[u/mrichter/AliRoot.git] / ITS / AliITSRawStreamSDD.cxx
index 31b1726e7ecca80efb78bda00d245ba1564a21c1..1cf27439a1cfd07fddab35f3860c67073309b644 100644 (file)
@@ -22,6 +22,7 @@
 ///////////////////////////////////////////////////////////////////////////////
 
 #include "AliITSRawStreamSDD.h"
+#include "AliITSRawStreamSDDCompressed.h"
 #include "AliRawReader.h"
 #include "AliLog.h"
 
@@ -34,25 +35,21 @@ AliITSRawStreamSDD::AliITSRawStreamSDD(AliRawReader* rawReader) :
   AliITSRawStream(rawReader),
 fDDLModuleMap(0),
 fData(0),
+fResetSkip(kTRUE),
 fEventId(0),
 fCarlosId(-1),
 fChannel(0),
 fJitter(0),
-fNCarlos(kModulesPerDDL),
-fDDL(0),
-fEndWords(0),
-fResetSkip(0)
+fEightBitSignal(0),
+fDecompressAmbra(kTRUE)
 {
 // create an object to read ITS SDD raw digits
-  fDDLModuleMap=new AliITSDDLModuleMapSDD();
-  fDDLModuleMap->SetDefaultMap();
   Reset();
   for(Int_t im=0;im<kSDDModules;im++){
     fLowThresholdArray[im][0]=0;
     fLowThresholdArray[im][1]=0;
   }
   for(Int_t i=0;i<kFifoWords;i++) fNfifo[i]=0;
-  for(Int_t i=0;i<kDDLsNumber;i++) fSkip[i]=0;
   fRawReader->Reset();
   fRawReader->Select("ITSSDD");
 
@@ -65,14 +62,13 @@ AliITSRawStreamSDD::AliITSRawStreamSDD(const AliITSRawStreamSDD& rs) :
 AliITSRawStream(rs.fRawReader),
 fDDLModuleMap(rs.fDDLModuleMap),
 fData(0),
+fResetSkip(kTRUE),
 fEventId(0),
 fCarlosId(-1),
 fChannel(0),
 fJitter(0),
-fNCarlos(kModulesPerDDL),
-fDDL(0),
-fEndWords(0),
-fResetSkip(0)
+fEightBitSignal(0),
+fDecompressAmbra(kTRUE)
 {
   // copy constructor
   AliError("Copy constructor should not be used.");
@@ -90,6 +86,39 @@ AliITSRawStreamSDD::~AliITSRawStreamSDD(){
   if(fDDLModuleMap) delete fDDLModuleMap;
 }
 //______________________________________________________________________
+UChar_t AliITSRawStreamSDD::ReadBlockAttributes(AliRawReader* rawReader){
+  // reads block attribuited from CDH
+  UChar_t *data;
+  rawReader->Reset();
+  rawReader->Select("ITSSDD");
+  do{
+    if(!rawReader->ReadNextData(data)) return 0x0;
+  }while(rawReader->GetDataSize()==0);
+  UChar_t attr=rawReader->GetBlockAttributes();
+  return attr;
+}
+//______________________________________________________________________
+AliITSRawStream* AliITSRawStreamSDD::CreateRawStreamSDD(AliRawReader* rawReader, UChar_t attributes){
+  // instantiates the proper raw stream from block attributes value
+
+  Int_t rawFormat=(attributes&0xE0)>>5;  
+  rawReader->Reset();
+  AliITSRawStream* inputSDD;
+  if(rawFormat==0){
+    inputSDD=new AliITSRawStreamSDDCompressed(rawReader);
+    inputSDD->SetADCEncoded(kTRUE);
+  }else{
+    inputSDD=new AliITSRawStreamSDD(rawReader);
+  }
+  return inputSDD;
+}
+//______________________________________________________________________
+AliITSRawStream* AliITSRawStreamSDD::CreateRawStreamSDD(AliRawReader* rawReader){
+  // reads the data format from CDH and instantiates the proper raw stream
+  UChar_t attr=ReadBlockAttributes(rawReader);
+  return CreateRawStreamSDD(rawReader,attr);
+}
+//______________________________________________________________________
 UInt_t AliITSRawStreamSDD::ReadBits()
 {
 // read bits from the given channel
@@ -107,10 +136,13 @@ Int_t AliITSRawStreamSDD::DecompAmbra(Int_t value) const
   if ((value & 0x80) == 0) {
     return value & 0x7f;
   } else if ((value & 0x40) == 0) {
+    if(value&1) return 0x080 + ((value & 0x3f) << 1);
     return 0x081 + ((value & 0x3f) << 1);
   } else if ((value & 0x20) == 0) {
+    if(value&1) return 0x103 + ((value & 0x1f) << 3);
     return 0x104 + ((value & 0x1f) << 3);
   } else {
+    if(value&1) return 0x207 + ((value & 0x1f) << 4);
     return 0x208 + ((value & 0x1f) << 4);
   }
   
@@ -121,37 +153,31 @@ Bool_t AliITSRawStreamSDD::Next()
 {
 // read the next raw digit
 // returns kFALSE if there is no digit left
-// returns kTRUE and fCompletedModule=kFALSE when a digit is found
-// returns kTRUE and fCompletedModule=kTRUE  when a module is completed (=3x3FFFFFFF footer words)
+// returns kTRUE and fCompletedModule=kFALSE and fCompletedDDL=kFALSE when a digit is found
+// returns kTRUE and fCompletedModule=kTRUE  and fCompletedDDL=kFALSE when a module is completed (=3x3FFFFFFF footer words)
+// returns kTRUE and fCompletedModule=kFALSE and fCompletedDDL=kTRUE  when a DDL is completed (=jitter word)
 
   fPrevModuleID = fModuleID;
-  fDDL=fRawReader->GetDDLID();
-  Int_t ddln = fRawReader->GetDDLID();
-  if(ddln <0) ddln=0;
   fCompletedModule=kFALSE;
 
   while (kTRUE) {
-    if(fResetSkip==0){
+    if(fResetSkip){
+      Reset();
       Bool_t kSkip = SkipHeaderWord();
-      fResetSkip=1;
-      if(!kSkip) return kSkip;
+      if(!kSkip) return kSkip; 
+      fResetSkip=kFALSE;
     }
-  
     if ((fChannel < 0) || (fCarlosId < 0) || (fChannel >= 2) || (fCarlosId >= kModulesPerDDL) || (fLastBit[fCarlosId][fChannel] < fReadBits[fCarlosId][fChannel]) ) {
       if (!fRawReader->ReadNextInt(fData)) return kFALSE;  // read next word
-      ddln = fRawReader->GetDDLID();
-      if(ddln!=fDDL) { 
-       Reset();
-       fDDL=fRawReader->GetDDLID();
-      }
-      if(ddln < 0 || ddln > (kDDLsNumber-1)) ddln  = 0;
 
-      fChannel = -1;
+
       if((fData >> 16) == 0x7F00){ // jitter word
-       fResetSkip=0;
-       fEndWords=0;
-       continue;
-      }
+       fJitter = fData&0x000000ff;
+       fResetSkip=kTRUE;
+       fCompletedModule=kFALSE;
+       fCompletedDDL=kTRUE;
+       return kTRUE;
+       }
 
       UInt_t nData28= fData >> 28;
       UInt_t nData30= fData >> 30;
@@ -159,51 +185,47 @@ Bool_t AliITSRawStreamSDD::Next()
 
       if (nData28== 0x02) {           // header
        fEventId = (fData >> 3) & 0x07FF; 
-      } else if (nData28== 0x04) {
-       // JTAG word -- do nothing
       } else if (nData28== 0x03) {    // Carlos and FIFO words or Footers
        if(fData>=fICarlosWord[0]&&fData<=fICarlosWord[11]) { // Carlos Word
-         if(fEndWords==12) continue; // out of event
          fCarlosId = fData-fICarlosWord[0];
          Int_t iFifoIdx = fCarlosId/3;
-         if(fNCarlos == 8) iFifoIdx=fCarlosId/2;
          fNfifo[iFifoIdx] = fCarlosId;
        } else if (fData>=fIFifoWord[0]&&fData<=fIFifoWord[3]){ // FIFO word
-         if(fEndWords==12) continue; // out of event
          fCarlosId = fNfifo[fData-fIFifoWord[0]];          
-       } else if(fData==0x3FFFFFFF){ // Carlos footer
-         if(fCarlosId>=0 && fCarlosId<kModulesPerDDL){
-           fICountFoot[fCarlosId]++; // stop before the last word (last word=jitter)
-           if(fICountFoot[fCarlosId]==3){
-             fCompletedModule=kTRUE;
-             //              printf("Completed module %d DDL %d\n",fCarlosId,ddln);
-             return kTRUE;
-           }
+       } else if(fData==0x3FFFFFFF && fCarlosId>=0 && fCarlosId<kModulesPerDDL){ // Carlos footer
+         fICountFoot[fCarlosId]++; // stop before the last word (last word=jitter)
+         if(fICountFoot[fCarlosId]==3){
+           fCompletedModule=kTRUE;
+           fCompletedDDL=kFALSE;
+           return kTRUE;
          }
        } else if(fData==0x3F1F1F1F){ // CarlosRX footer
-         fEndWords++;
-         if(fEndWords<=12) continue;
+         // CARLOSRX footer -- do nothing
        }else{
-         fRawReader->AddMajorErrorLog(kDataError,"Too many footers");
-         AliWarning(Form("invalid data: too many footers\n", fData));
+         fRawReader->AddMajorErrorLog(kDataError,"Bad footer");
+         AliWarning(Form("Invalid data: bad footer %08X\n", fData));
          return kFALSE;            
        }
       } else if (nData30 == 0x02 || nData30 == 0x03) {
        fChannel = nData30-2;
-       if(fCarlosId>=0 && fChannel>=0 && fCarlosId <kModulesPerDDL && fChannel<2){
+       if(fCarlosId>=0 && fCarlosId<kModulesPerDDL){
          fChannelData[fCarlosId][fChannel] += 
            (ULong64_t(fData & 0x3FFFFFFF) << fLastBit[fCarlosId][fChannel]);
          fLastBit[fCarlosId][fChannel] += 30;
        }
+      } else if (nData28== 0x04) {
+       // JTAG word -- do nothing
       } else {                               // unknown data format
        fRawReader->AddMajorErrorLog(kDataFormatErr,Form("Invalid data %8.8x",fData));
-       AliWarning(Form("invalid data: %8.8x\n", fData));
+       AliWarning(Form("Invalid data: %08X\n", fData));
        return kFALSE;
       }
       
-      if (fNCarlos == 8 && fCarlosId >= 8) continue;  // old data, fNCarlos = 8;
       if(fCarlosId>=0 && fCarlosId <kModulesPerDDL){
-        fModuleID = GetModuleNumber(ddln,fCarlosId);
+       Int_t nDDL=fRawReader->GetDDLID();
+       if(nDDL>=0){
+         fModuleID = GetModuleNumber(nDDL,fCarlosId);
+       }
       }
     } else {  // decode data
       if (fReadCode[fCarlosId][fChannel]) {// read the next code word
@@ -220,11 +242,13 @@ Bool_t AliITSRawStreamSDD::Next()
          fTimeBin[fCarlosId][fChannel] = 0;
          fAnode[fCarlosId][fChannel]++;
        } else {                                   // ADC signal data
-         fSignal = DecompAmbra(data + (1 << fChannelCode[fCarlosId][fChannel]) + fLowThresholdArray[fModuleID-kSPDModules][fChannel]);
+         fEightBitSignal=data + (1 << fChannelCode[fCarlosId][fChannel]);
+         if(fDecompressAmbra) fSignal = DecompAmbra(fEightBitSignal + fLowThresholdArray[fModuleID-kSPDModules][fChannel]);
          fCoord1 = fAnode[fCarlosId][fChannel];
          fCoord2 = fTimeBin[fCarlosId][fChannel];
          fTimeBin[fCarlosId][fChannel]++;
-         //printf("Data read, Module=%d , Anode=%d , Time=%d , Charge=%d\n",fModuleID,fCoord1,fCoord2,fSignal);
+         fCompletedModule=kFALSE;
+         fCompletedDDL=kFALSE;
          return kTRUE;
        }
       }
@@ -246,10 +270,9 @@ void AliITSRawStreamSDD::Reset(){
       fReadBits[ic][i]=3;
       fTimeBin[ic][i]=0;
       fAnode[ic][i]=0;     
+      fICountFoot[ic]=0;
     }
-    fLowThreshold[i]=0;
   }
-  for(Int_t i=0;i<kModulesPerDDL;i++) fICountFoot[i]=0;
 }
 
 //______________________________________________________________________