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
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
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) {
}
}
- bool bHavePartitionRawData=false;
- bool bHavePartitionCompressedData=false;
vector<bool> bHavePartitionData(216, false);
// read data