/* $Id$ // Author: Uli Frankenfeld , Anders Vestbo // -- Copyright © Uli // changes done by Constantin Loizides */ #include #include #include #include #include #include "AliL3MemHandler.h" #include "AliL3Logging.h" #include "AliL3DigitData.h" #include "AliL3TrackSegmentData.h" #include "AliL3SpacePointData.h" #include "AliL3TrackArray.h" /** \class AliL3MemHandler //
//_____________________________________________________________
// AliL3MemHandler
//
// The HLT Binary File handler 
//
//  This class does all the memory I/O handling of HLT binary files.
//  
//  Examples:
//  ---------
//
//  1) Reading a binary file:
//  
//  AliL3MemHandler file;
//  file.SetBinaryInput(filename);
//  
//  UInt_t ndigits;
//  AliL3DigitRowData *data = file.CompBinary2Memory(ndigits);
//  
//  for(int i=0; ifDigitData;
//    for(int j=0; jfNDigit; j++) 
//      {
//      pad = dataPt[j].fPad;
//      time = dataPt[j].fTime;
//      charge = dataPt[j].fCharge;
//     }
//     
//    file.UpdateRowPointer(data);
//  
//    }
//  file.CloseBinaryInput();
//  ________________________
//  
//  2) Writing a binary file:
//  
//  //First of all you need to store the data in memory,
//  //and have a pointer to it of type AliL3DigitRowData.
//  //E.g. if you just want to write the data you read in example 1)
//  //into a new file, you can do the following:
//  
//  AliL3MemHandler newfile;
//  newfile.SetBinaryOutput(newfilename);
//  newfile.Memory2CompBinary((UInt_t)NumberOfRowsInPatch,(AliL3DigitRowData*)data);
//  newfile.CloseBinaryOutput();
//
//
// Compressed file format:
// -----------------------
//
// The data is RLE encoded and currently using _10_ bit range for the ADC-values.
*/ ClassImp(AliL3MemHandler) AliL3MemHandler::AliL3MemHandler() { //Constructor fPt = 0; fSize =0; fInBinary = 0; fOutBinary = 0; fNRandom = 0; Init(0,0); IsRandom = kFALSE; fDigits = 0; fDPt =0; fNGenerate = 0; fNUsed = 0; fNDigits = 0; ResetROI(); } AliL3MemHandler::~AliL3MemHandler() { //Destructor if(fPt) delete[] fPt; if(fDigits) delete [] fDigits; if(fDPt) delete [] fDPt; } void AliL3MemHandler::Init(Int_t s,Int_t p, Int_t *r=0) { fSlice=s;fPatch=p; if(r) { fRowMin=r[0]; fRowMax=r[1]; }else{ fRowMin=AliL3Transform::GetFirstRow(p); fRowMax=AliL3Transform::GetLastRow(p); } ResetROI(); } void AliL3MemHandler::ResetROI() { //Resets the Look-up table for Region of Interest mode. for(Int_t i=fRowMin; i<=fRowMax; i++) { fEtaMinTimeBin[i] = 0; fEtaMaxTimeBin[i] = 445; } } void AliL3MemHandler::SetROI(Float_t *eta,Int_t *slice) { // Init the Look-up table for the Region of Interest mode. // Here you can specify a certain etaregion, - all data // outside this region will be discarded: // eta[0] = mimium eta // eta[1] = maximum eta // slice[0] = mimumum slice // slice[1] = maximum slice if(eta[1]==0) { LOG(AliL3Log::kWarning,"AliL3MemHandler::SetROI","Eta Values") <<"Bad ROI parameters. IDIOT! "<GetOutSize()); } Byte_t *AliL3MemHandler::Allocate(UInt_t size) { //Allocate memory of size in bytes. if(fPt){ LOG(AliL3Log::kWarning,"AliL3MemHandler::Allocate","Memory") <<"Delete Memory"< 1) { i = first; j = last; for (;;) { while (++i < last && CompareDigits(a[i], a[first]) < 0) ; while (--j > first && CompareDigits(a[j], a[first]) > 0) ; if (i >= j) break; tmp = a[i]; a[i] = a[j]; a[j] = tmp; } if (j == first) { ++first; continue; } tmp = a[first]; a[first] = a[j]; a[j] = tmp; if (j - first < last - (j + 1)) { QSort(a, first, j); first = j + 1; // QSort(j + 1, last); } else { QSort(a, j + 1, last); last = j; // QSort(first, j); } } } UInt_t AliL3MemHandler::GetRandomSize() { Int_t nrandom = 0; for(Int_t r=fRowMin;r<=fRowMax;r++){ Int_t npad=AliL3Transform::GetNPads(r); nrandom += Int_t (fNGenerate * ((Double_t) npad/141.)); } return 9 * nrandom * sizeof(AliL3DigitData); } void AliL3MemHandler::Generate(Int_t row) { //Generate random data on row, if you didn't ask for this, nothing happens here. if(!IsRandom) return; ResetRandom(); fNDigits = 0; Int_t npad=AliL3Transform::GetNPads(row); Int_t ntime = fEtaMaxTimeBin[row] - fEtaMinTimeBin[row]; Int_t nrandom = Int_t (fNGenerate * ((Double_t) npad/141.) * (Double_t) ntime/(Double_t) AliL3Transform::GetNTimeBins() ); for(Int_t n=0;nfRow,fDPt[d]->fPad, // fDPt[d]->fTime,fDPt[d]->fCharge); } void AliL3MemHandler::DigitizePoint(Int_t row, Int_t pad, Int_t time,Int_t charge) { //Making one single random cluster. for(Int_t j=-1;j<2;j++){ for(Int_t k=-1;k<2;k++){ Int_t dcharge = charge; if(j) dcharge /=2; if(k) dcharge /=2; if(dcharge<10) continue; Int_t dpad = j + pad; Int_t dtime = k + time; if(dpad<0||dpad>=AliL3Transform::GetNPads(row)) continue; if(dtime<0||dtime>=AliL3Transform::GetNTimeBins()) continue; fDigits[fNDigits].fCharge = dcharge; fDigits[fNDigits].fRow = row; fDigits[fNDigits].fPad = dpad; fDigits[fNDigits].fTime = dtime; fDPt[fNDigits] = &fDigits[fNDigits]; fNDigits++; } } } ///////////////////////////////////////// Digit IO Bool_t AliL3MemHandler::Memory2Binary(UInt_t nrow,AliL3DigitRowData *data) { //Write data to the outputfile as is. No run-length encoding is done. if(!fOutBinary){ LOG(AliL3Log::kWarning,"AliL3MemHandler::Memory2Binary","File") <<"No Output File"<fNDigit + sizeof(AliL3DigitRowData); outsize += size; fwrite(row_pt,size,1,fOutBinary); Byte_t *byte_pt =(Byte_t *) row_pt; byte_pt += size; row_pt = (AliL3DigitRowData *) byte_pt; } LOG(AliL3Log::kDebug,"AliL3MemHandler::Memory2Binary","Memory") <fNDigit; if(fread(byte_pt,size,1,fInBinary)!=1) break; byte_pt += size; outsize += size; row_pt = (AliL3DigitRowData *) byte_pt; rowcount++; } nrow= rowcount; LOG(AliL3Log::kDebug,"AliL3MemHandler::Binary2Memory","Memory") <fPad; data[ndata].fTime = fDPt[fNUsed]->fTime; data[ndata].fCharge = fDPt[fNUsed]->fCharge; ndata++; fNUsed++; } void AliL3MemHandler::MergeDataRandom(AliL3DigitData *data, UInt_t & ndata, UInt_t row, UShort_t pad, UShort_t time, UShort_t charge) { data[ndata].fPad = pad; data[ndata].fTime = time; data[ndata].fCharge = charge; while(ComparePoints(row,pad,time)==0){ Int_t ch = data[ndata].fCharge + fDPt[fNUsed]->fCharge; if(charge>1023) ch = 1023; data[ndata].fCharge = ch; fNUsed++; } ndata++; } void AliL3MemHandler::AddDataRandom(AliL3DigitData *data, UInt_t & ndata, UInt_t row, UShort_t pad, UShort_t time, UShort_t charge) { Int_t action; while((action=ComparePoints(row,pad,time))==1){ AddRandom(data,ndata); } if(action==0){ MergeDataRandom(data,ndata,row,pad,time,charge); } if(action<0){ AddData(data,ndata,row,pad,time,charge); } } void AliL3MemHandler::Write(UInt_t *comp, UInt_t & index, UInt_t & subindex, UShort_t value) { UInt_t shift[3] = {0,10,20}; if(subindex==0) comp[index] =0; //clean up memory comp[index] |= (value&0x03ff)<>shift[subindex])&0x03ff; if(subindex == 2){ subindex = 0; index++; } else subindex++; return value; } UShort_t AliL3MemHandler::Test(UInt_t *comp, UInt_t index, UInt_t subindex) { UInt_t shift[3] = {0,10,20}; return (comp[index]>>shift[subindex])&0x03ff; } Int_t AliL3MemHandler::Memory2CompMemory(UInt_t nrow, AliL3DigitRowData *data,UInt_t *comp) { //Performs run-length encoding on data stored in memory pointed to by data. //The compressed data is written to comp. if(!comp){ LOG(AliL3Log::kWarning,"AliL3MemHandler::Memory2CompMemory","Memory") <<"Pointer to compressed data = 0x0 "<fRow; Write(comp,index,subindex,value); UShort_t maxpad=0; UShort_t npad=0; Int_t ddd[1000]; for(Int_t d=0;d<200;d++) ddd[d]=0; for(UInt_t dig=0;digfNDigit;dig++){ if(row_pt->fDigitData[dig].fPad <200){ ddd[row_pt->fDigitData[dig].fPad]++; } } for(Int_t d=0;d<200;d++){ if(ddd[d]){ npad++; maxpad =d; } } Write(comp,index,subindex,npad); UInt_t digit=0; for(UShort_t pad=0;pad <= maxpad;pad++){ if(digit>=row_pt->fNDigit || row_pt->fDigitData[digit].fPad != pad) continue; Write(comp,index,subindex,pad); // write zero if time != 0 if(digitfNDigit && row_pt->fDigitData[digit].fPad == pad){ if(row_pt->fDigitData[digit].fTime>0){ Write(comp,index,subindex,0); Write(comp,index,subindex,row_pt->fDigitData[digit].fTime); } } while(digitfNDigit && row_pt->fDigitData[digit].fPad == pad){ UShort_t charge = row_pt->fDigitData[digit].fCharge; if(charge>=1024){ charge=1023; } Write(comp,index,subindex,charge); if(digit+1fNDigit&&row_pt->fDigitData[digit+1].fPad == pad){ if(row_pt->fDigitData[digit].fTime +1 != row_pt->fDigitData[digit+1].fTime){ Write(comp,index,subindex,0); UShort_t nzero = row_pt->fDigitData[digit+1].fTime - (row_pt->fDigitData[digit].fTime +1); Write(comp,index,subindex,nzero); } } digit++; } Write(comp,index,subindex,0); Write(comp,index,subindex,0); } Int_t size = sizeof(AliL3DigitData) * row_pt->fNDigit+ sizeof(AliL3DigitRowData); Byte_t *byte_pt =(Byte_t *) row_pt; byte_pt += size; row_pt = (AliL3DigitRowData *) byte_pt; } while(subindex) Write(comp,index,subindex,0); return index * sizeof(UInt_t); } Int_t AliL3MemHandler::CompMemory2Memory(UInt_t nrow, AliL3DigitRowData *data,UInt_t *comp) { //Uncompress the run-length encoded data in memory pointed to by comp, and // store it in data. if(!comp){ LOG(AliL3Log::kWarning,"AliL3MemHandler::CompMemory2Memory","Memory") <<"Pointer to compressed data = 0x0 "<fRow=row; Generate(row); UShort_t npad = Read(comp,index,subindex); for(UShort_t p=0;p=fEtaMinTimeBin[row]&&time<=fEtaMaxTimeBin[row]) // AddData(row_pt->fDigitData,ndigit,row,pad,time,charge); AddDataRandom(row_pt->fDigitData,ndigit,row,pad,time,charge); time++; } UShort_t tshift = Read(comp,index,subindex); if(tshift ==0) break; time += tshift; } } row_pt->fNDigit = ndigit; Int_t size = sizeof(AliL3DigitData) * row_pt->fNDigit+ sizeof(AliL3DigitRowData); Byte_t *byte_pt =(Byte_t *) row_pt; byte_pt += size; outsize += size; row_pt = (AliL3DigitRowData *) byte_pt; } return outsize; } UInt_t AliL3MemHandler::GetCompMemorySize(UInt_t nrow,AliL3DigitRowData *data) { //Return the size of RLE data, after compressing data. if(!data){ LOG(AliL3Log::kWarning,"AliL3MemHandler::GetCompMemorySize","Memory") <<"Pointer to AliL3DigitRowData = 0x0 "<fNDigit;dig++){ if(row_pt->fDigitData[dig].fPad <200){ ddd[row_pt->fDigitData[dig].fPad]++; } } for(Int_t d=0;d<200;d++){ if(ddd[d]){ npad++; maxpad =d; } } index++; UInt_t digit=0; for(UShort_t pad=0;pad <= maxpad;pad++){ if(digit>=row_pt->fNDigit || row_pt->fDigitData[digit].fPad != pad) continue; index++; // write zero if time != 0 if(digitfNDigit && row_pt->fDigitData[digit].fPad == pad){ if(row_pt->fDigitData[digit].fTime>0){ index++; index++; } } while(digitfNDigit && row_pt->fDigitData[digit].fPad == pad){ index++; if(digit+1fNDigit&&row_pt->fDigitData[digit+1].fPad == pad){ if(row_pt->fDigitData[digit].fTime +1 != row_pt->fDigitData[digit+1].fTime){ index++; index++; } } digit++; } index++; index++; } Int_t size = sizeof(AliL3DigitData) * row_pt->fNDigit+ sizeof(AliL3DigitRowData); Byte_t *byte_pt =(Byte_t *) row_pt; byte_pt += size; row_pt = (AliL3DigitRowData *) byte_pt; } while(index%3) index++; return (index/3) * sizeof(UInt_t); } UInt_t AliL3MemHandler::GetMemorySize(UInt_t nrow,UInt_t *comp){ if(!comp){ LOG(AliL3Log::kWarning,"AliL3MemHandler::GetMemorySize","Memory") <<"Pointer to compressed data = 0x0 "<SetBinaryInput(fInBinary); UInt_t *comp =(UInt_t *)handler->Allocate(); handler->CompBinary2CompMemory(nrow,comp); UInt_t size = GetMemorySize(nrow,comp); AliL3DigitRowData *data = (AliL3DigitRowData *)Allocate(size); CompMemory2Memory(nrow,data,comp); handler->Free(); delete handler; return data; } Bool_t AliL3MemHandler::Memory2CompBinary(UInt_t nrow,AliL3DigitRowData *data) { //Perform RLE on the data, and write it to the output file. Bool_t out = kTRUE; AliL3MemHandler * handler = new AliL3MemHandler(); UInt_t size = GetCompMemorySize(nrow,data); UInt_t *comp =(UInt_t *)handler->Allocate(size); Memory2CompMemory(nrow,data,comp); CompMemory2CompBinary(nrow,comp,size); handler->Free(); delete handler; return out; } ///////////////////////////////////////// Point IO Bool_t AliL3MemHandler::Memory2Binary(UInt_t npoint,AliL3SpacePointData *data) { //Writing spacepoints stored in data to the outputfile. if(!fOutBinary){ LOG(AliL3Log::kWarning,"AliL3MemHandler::Memory2Binary","File") <<"No Output File"<fNPoints*sizeof(UInt_t); fwrite(track_pt,size,1,fOutBinary); Byte_t *byte_pt = (Byte_t*) track_pt; byte_pt += size; track_pt = (AliL3TrackSegmentData*) byte_pt; } LOG(AliL3Log::kDebug,"AliL3MemHandler::Memory2Binary","File") <fNPoints*sizeof(UInt_t); if(fread(track_pt->fPointIDs,size,1,fInBinary)!=1) break; Byte_t *byte_pt = (Byte_t*) track_pt; byte_pt += sizeof(AliL3TrackSegmentData)+size; track_pt = (AliL3TrackSegmentData*) byte_pt; ntrack++; } LOG(AliL3Log::kDebug,"AliL3MemHandler::Binary2Memory","File") <WriteTracks(ntrack,data); return kTRUE; } Bool_t AliL3MemHandler::Memory2TrackArray(UInt_t ntrack,AliL3TrackSegmentData *data,AliL3TrackArray *array) { //Fill the tracks in data into trackarray. if(!data){ LOG(AliL3Log::kWarning,"AliL3MemHandler::Memory2TrackArray","Memory") <<"Pointer to AliL3TrackSegmentData = 0x0 "<FillTracks(ntrack,data); return kTRUE; } Bool_t AliL3MemHandler::Memory2TrackArray(UInt_t ntrack,AliL3TrackSegmentData *data,AliL3TrackArray *array,Int_t slice) { //Fill the tracks in data into trackarray, and rotate the tracks to global coordinates. if(!data){ LOG(AliL3Log::kWarning,"AliL3MemHandler::Memory2TrackArray","Memory") <<"Pointer to AliL3TrackSegmentData = 0x0 "<FillTracks(ntrack,data,slice); return kTRUE; } void AliL3MemHandler::UpdateRowPointer(AliL3DigitRowData *&tempPt) { //Update the data pointer to the next padrow in memory. Byte_t *tmp = (Byte_t*)tempPt; Int_t size = sizeof(AliL3DigitRowData) + tempPt->fNDigit*sizeof(AliL3DigitData); tmp += size; tempPt = (AliL3DigitRowData*)tmp; }