]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - HLT/TPCLib/AliHLTTPCDataPublisherComponent.cxx
Minor fix to dynamic cast introduced in e4edd69
[u/mrichter/AliRoot.git] / HLT / TPCLib / AliHLTTPCDataPublisherComponent.cxx
index cd1095800884a80f7a9c3b44f6798547859ba10c..38bbe35a5d71db4b1274440274361b0f6b379b47 100644 (file)
@@ -134,7 +134,7 @@ int AliHLTTPCDataPublisherComponent::GetEvent(const AliHLTComponentEventData& ev
       fMaxSize+=offset;
     } else if (iResult>=0) {
       if (outputBlocks.size()>firstBlock && CheckMode(kPublishRawFiltered)) {
-       AliInfo(Form("publishing %d DDL(s) for emulation of compressed TPC clusters", outputBlocks.size()-firstBlock));
+       AliInfo(Form("publishing %lu DDL(s) for emulation of compressed TPC clusters", outputBlocks.size()-firstBlock));
       }
       // correct for the shifted buffer which was provided to the
       // GetEvent method
@@ -190,8 +190,10 @@ int AliHLTTPCDataPublisherComponent::ReadClusterFromHLTOUT(AliHLTTPCDataPublishe
 
   AliHLTTPCDataCompressionDecoder& decoder=*fpDecoder;
   decoder.Clear();
-  decoder.SetVerbosity(GetVerbosity());
-  decoder.EnableClusterMerger();
+  decoder.SetVerbosity(GetVerbosity());  
+
+  bool bHavePartitionRawData=false;
+  bool bHavePartitionCompressedData=false;
 
   bool bNextBlock=false;
   // add cluster id and mc information data blocks
@@ -201,6 +203,20 @@ int AliHLTTPCDataPublisherComponent::ReadClusterFromHLTOUT(AliHLTTPCDataPublishe
     if ((iResult=pHLTOUT->GetDataBuffer(desc))<0) {
       continue;
     }
+    if (desc.fDataType==AliHLTTPCDefinitions::DataCompressionDescriptorDataType()) {
+      // compression header      
+      if ((iResult=decoder.AddCompressionDescriptor(&desc))<0) {
+       return iResult;
+      }
+      bHavePartitionCompressedData = true;
+    }
+    if (desc.fDataType==AliHLTTPCDefinitions::RawClustersDescriptorDataType()) {
+      // raw clusters header      
+      if ((iResult=decoder.AddRawClustersDescriptor(&desc))<0) {
+       return iResult;
+      }
+      bHavePartitionRawData = true;
+    }
     if (desc.fDataType==AliHLTTPCDefinitions::AliHLTDataTypeClusterMCInfo()) {
       // add mc information
       if ((iResult=decoder.AddClusterMCData(&desc))<0) {
@@ -216,8 +232,6 @@ int AliHLTTPCDataPublisherComponent::ReadClusterFromHLTOUT(AliHLTTPCDataPublishe
     }
   }
 
-  bool bHavePartitionRawData=false;
-  bool bHavePartitionCompressedData=false;
   vector<bool> bHavePartitionData(216, false);
 
   // read data