- fixing compilation errors/warnings

[u/mrichter/AliRoot.git] / HLT / PHOS / AliHLTPHOSRawAnalyzerComponentv3.cxx

diff --git a/HLT/PHOS/AliHLTPHOSRawAnalyzerComponentv3.cxx b/HLT/PHOS/AliHLTPHOSRawAnalyzerComponentv3.cxx
index 344b446b457e2637222c798f99ce0dbaaa4e56fe..8f982deab50c06792d4eaa92c2b9e206cc4e357b 100644 (file)
--- a/HLT/PHOS/AliHLTPHOSRawAnalyzerComponentv3.cxx
+++ b/HLT/PHOS/AliHLTPHOSRawAnalyzerComponentv3.cxx
@@ -40,8 +40,8 @@ AliHLTPHOSRawAnalyzerComponentv3::AliHLTPHOSRawAnalyzerComponentv3():
   fBunchSizeCut(0),
   fMinPeakPosition(0),
   fMaxPeakPosition(100),
-  fkDoPushRawData(true),
-
+  fDoPushRawData(false),
+  fInspectSanity(false),
   fRawDataWriter(0)
 {
   //comment
@@ -50,10 +50,10 @@ AliHLTPHOSRawAnalyzerComponentv3::AliHLTPHOSRawAnalyzerComponentv3():
   fRawReaderMemoryPtr = new AliRawReaderMemory();
 
   fAltroRawStreamPtr = new AliAltroRawStreamV3(fRawReaderMemoryPtr);
-
+  //  fAltroRawStreamPtr = new AliCaloRawStreamV3(fRawReaderMemoryPtr, TString("PHOS"));
   fSanityInspectorPtr = new AliHLTPHOSSanityInspector();
 
-  if( fkDoPushRawData == true  )
+  if( fDoPushRawData == true  )
     {
       
       fRawDataWriter  = new AliHLTPHOSRawAnalyzerComponentv3::RawDataWriter();
@@ -175,8 +175,6 @@ AliHLTPHOSRawAnalyzerComponentv3::DoEvent( const AliHLTComponentEventData& evtDa
   return 0;
 }//end DoEvent
 
-
-
 Int_t
 AliHLTPHOSRawAnalyzerComponentv3::DoIt(const AliHLTComponentBlockData* iter, AliHLTUInt8_t* outputPtr, const AliHLTUInt32_t size, UInt_t& totSize)
 {
@@ -194,97 +192,98 @@ AliHLTPHOSRawAnalyzerComponentv3::DoIt(const AliHLTComponentBlockData* iter, Ali
   //Adding to the total size of data written
   totSize += sizeof( AliHLTPHOSChannelDataHeaderStruct );
 
-  fRawReaderMemoryPtr->SetMemory(         reinterpret_cast<UChar_t*>( iter->fPtr ),  static_cast<ULong_t>( iter->fSize )  );
-  fRawReaderMemoryPtr->SetEquipmentID(    fMapperPtr->GetDDLFromSpec(  iter->fSpecification) + 1792  );
+  fRawReaderMemoryPtr->SetMemory(reinterpret_cast<UChar_t*>(iter->fPtr), static_cast<ULong_t>(iter->fSize));
+  fRawReaderMemoryPtr->SetEquipmentID(fMapperPtr->GetDDLFromSpec(iter->fSpecification) + 1792);
   fRawReaderMemoryPtr->Reset();
   fRawReaderMemoryPtr->NextEvent();
   
-  if( fkDoPushRawData == true)
-    {
-      fRawDataWriter->NewEvent( );
-    }
+ //  if( fDoPushRawData == true)
+//     {
+//       fRawDataWriter->NewEvent( );
+//     }
   if(fAltroRawStreamPtr != NULL)
     {
       delete fAltroRawStreamPtr;
       fAltroRawStreamPtr=NULL;
     }
   
-  fAltroRawStreamPtr = new AliCaloRawStreamV3(fRawReaderMemoryPtr, TString("PHOS"));
-  //  fAltroRawStreamPtr = new AliCaloRawStreamV3(fRawReaderMemoryPtr, TString("EMCAL"));
-  //  while( fAltroRawStreamPtr->NextDDL() )
-  fAltroRawStreamPtr->NextDDL();
-  {
-    int cnt = 0;
-    while( fAltroRawStreamPtr->NextChannel()  )
-      { 
-       if(  fAltroRawStreamPtr->GetHWAddress() < 128 || ( fAltroRawStreamPtr->GetHWAddress() ^ 0x800) < 128 ) 
-         {
-           continue; 
-         }
-       else
-         {
-           cnt ++;
-           UShort_t* firstBunchPtr;
-           UShort_t chId = fMapperPtr->GetChannelID(iter->fSpecification, fAltroRawStreamPtr->GetHWAddress()); 
+  //  fAltroRawStreamPtr = new AliCaloRawStreamV3(fRawReaderMemoryPtr, TString("PHOS"));
+  fAltroRawStreamPtr = new AliAltroRawStreamV3(fRawReaderMemoryPtr);
+
+  if(fAltroRawStreamPtr->NextDDL())
+    {
+      int cnt = 0;
+      while( fAltroRawStreamPtr->NextChannel()  )
+       { 
+         // Removing TRUs
+         if(  fAltroRawStreamPtr->GetHWAddress() < 128 || ( fAltroRawStreamPtr->GetHWAddress() ^ 0x800) < 128 ) 
+           {
+             continue; 
+           }
+         else
+           {
+             cnt ++;
+             UShort_t* firstBunchPtr = 0;
+             UShort_t chId = fMapperPtr->GetChannelID(iter->fSpecification, fAltroRawStreamPtr->GetHWAddress()); 
            
-           if( fkDoPushRawData == true)
-             {
-               fRawDataWriter->SetChannelId( chId );
-             }
-           while( fAltroRawStreamPtr->NextBunch() == true )
-             {
-               nSamples = fAltroRawStreamPtr->GetBunchLength();
+//           if( fDoPushRawData == true)
+//             {
+//               fRawDataWriter->SetChannelId( chId );
+//             }
+             while( fAltroRawStreamPtr->NextBunch() == true )
+               {
+                 nSamples = fAltroRawStreamPtr->GetBunchLength();
                  
-               if( fkDoPushRawData == true)
-                 {
-                   //                fRawDataWriter->WriteBunchData( fAltroRawStreamPtr->GetSignals(), nSamples,  fAltroRawStreamPtr->GetStartTimeBin()  );
-                   fRawDataWriter->WriteBunchData( fAltroRawStreamPtr->GetSignals(), nSamples,  fAltroRawStreamPtr->GetEndTimeBin()  );
-                 }
-               firstBunchPtr = const_cast< UShort_t* >(  fAltroRawStreamPtr->GetSignals()  );
-             }
-             
-           totSize += sizeof( AliHLTPHOSChannelDataStruct );
-           if(totSize > size)
-             {
-               HLTError("Buffer overflow: Trying to write data of size: %d bytes. Output buffer available: %d bytes.", totSize, size);
-               return -1;
-             }
-
-           fAnalyzerPtr->SetData( firstBunchPtr, nSamples);
-           fAnalyzerPtr->Evaluate(0, nSamples);  
+//               if( fDoPushRawData == true)
+//                 {
+//                   fRawDataWriter->WriteBunchData( fAltroRawStreamPtr->GetSignals(), nSamples,  fAltroRawStreamPtr->GetEndTimeBin()  );
+//                 }
+                 firstBunchPtr = const_cast< UShort_t* >(  fAltroRawStreamPtr->GetSignals()  );
+               }
+             if(firstBunchPtr)
+               {             
+                 totSize += sizeof( AliHLTPHOSChannelDataStruct );
+                 if(totSize > size)
+                   {
+                     HLTError("Buffer overflow: Trying to write data of size: %d bytes. Output buffer available: %d bytes.", totSize, size);
+                     return -1;
+                   }
+//               if(fInspectSanity)
+//                 {
+//                   crazyness = fSanityInspectorPtr->CheckAndHealInsanity(firstBunchPtr, nSamples);
+//                 }
+
+                 fAnalyzerPtr->SetData( firstBunchPtr, nSamples);
+                 fAnalyzerPtr->Evaluate(0, nSamples);  
           
-           //        if(fAnalyzerPtr->GetTiming() > fMinPeakPosition && fAnalyzerPtr->GetTiming() < fMaxPeakPosition)
-           {
-             channelDataPtr->fChannelID =  chId;
-             channelDataPtr->fEnergy = static_cast<Float_t>(fAnalyzerPtr->GetEnergy()) - fOffset;
+                 channelDataPtr->fChannelID =  chId;
+                 channelDataPtr->fEnergy = static_cast<Float_t>(fAnalyzerPtr->GetEnergy()) - fOffset;
                
-             if( channelDataPtr->fEnergy > 70 )
-               {
-                 cout << __FILE__ << __LINE__ << "The energy is of  channel  "<< chId << "  is "  <<  channelDataPtr->fEnergy << endl;
+                 channelDataPtr->fTime = static_cast<Float_t>(fAnalyzerPtr->GetTiming());
+                 channelDataPtr->fCrazyness = static_cast<Short_t>(crazyness);
+                 channelCount++;
+                 channelDataPtr++; // Updating position of the free output.
                }
-               
-             channelDataPtr->fTime = static_cast<Float_t>(fAnalyzerPtr->GetTiming());
-             channelDataPtr->fCrazyness = static_cast<Short_t>(crazyness);
-             channelCount++;
-             channelDataPtr++; // Updating position of the free output.
-           }   
-         }
-       fRawDataWriter->NewChannel();
-      }
-  }
-
+           }
+//       if(fDoPushRawData)
+//         {
+//           fRawDataWriter->NewChannel();
+//         }
+       }
+    }
+  
   //Writing the header
   channelDataHeaderPtr->fNChannels   =  channelCount;
   channelDataHeaderPtr->fAlgorithm   = fAlgorithm;
   channelDataHeaderPtr->fInfo        = 0;
 
-  if( fkDoPushRawData == true)
-    {
-      tmpsize += fRawDataWriter->CopyBufferToSharedMemory( (UShort_t *)channelDataPtr, size, totSize);
-    }
+//   if( fDoPushRawData == true)
+//     {
+//       tmpsize += fRawDataWriter->CopyBufferToSharedMemory( (UShort_t *)channelDataPtr, size, totSize);
+//     }
 
   // channelDataHeaderPtr->fHasRawData  = false;
-  channelDataHeaderPtr->fHasRawData = fkDoPushRawData;
+  channelDataHeaderPtr->fHasRawData = fDoPushRawData;
 
   HLTDebug("Number of channels: %d", channelCount);
   //returning the size used
@@ -298,13 +297,11 @@ AliHLTPHOSRawAnalyzerComponentv3::DoIt(const AliHLTComponentBlockData* iter, Ali
  
 
 int 
-AliHLTPHOSRawAnalyzerComponentv3::WriteRawData(AliHLTPHOSChannelDataStruct *dtaPtr)
+AliHLTPHOSRawAnalyzerComponentv3::WriteRawData(AliHLTPHOSChannelDataStruct*) //dtaPtr)
 {
-  cout << dtaPtr << endl;
   return 0;
 }
 
-
 int
 AliHLTPHOSRawAnalyzerComponentv3::DoInit( int argc, const char** argv )
 { 
@@ -316,10 +313,6 @@ AliHLTPHOSRawAnalyzerComponentv3::DoInit( int argc, const char** argv )
 
   for(int i = 0; i < argc; i++)
     {
-      if(!strcmp("-offset", argv[i]))
-       {
-         fOffset = atoi(argv[i+1]);
-       }
       if(!strcmp("-bunchsizecut", argv[i]))
        {
          fBunchSizeCut = atoi(argv[i+1]);
@@ -332,6 +325,14 @@ AliHLTPHOSRawAnalyzerComponentv3::DoInit( int argc, const char** argv )
        {
          fMaxPeakPosition = atoi(argv[i+1]);
        }  
+      if(!strcmp("-pushrawdata", argv[i]))
+       {
+         fDoPushRawData = true;
+       }
+      if(!strcmp("-inspectsanity", argv[i]))
+       {
+         fInspectSanity = true;
+       }
     }
  
   if(fMapperPtr->GetIsInitializedMapping() == false)