#include <stdlib.h>
#include <TClonesArray.h>
#include <TTree.h>
#include "AliITSdigit.h"
#include "AliITSDDLRawData.h"
#include "AliRawDataHeaderSim.h"
#include "AliITSRawStreamSPD.h"
#include "AliITSRawStreamSDD.h"
#include "AliITSDDLModuleMapSDD.h"
#include "AliITSRawStreamSSD.h"
#include "AliITSIntMap.h"
#include "AliBitPacking.h"
#include "AliDAQ.h"
#include "AliFstream.h"
#include "AliITSFOSignalsSPD.h"
using std::ofstream;
using std::ios;
using std::endl;
ClassImp(AliITSDDLRawData)
AliITSDDLRawData::AliITSDDLRawData():
fVerbose(0),
fIndex(-1),
fHalfStaveModule(-1),
fSDDRawFormat(7){
}
AliITSDDLRawData::AliITSDDLRawData(const AliITSDDLRawData &source) :
TObject(source),
fVerbose(source.fVerbose),
fIndex(source.fIndex),
fHalfStaveModule(source.fHalfStaveModule),
fSDDRawFormat(source.fSDDRawFormat){
}
AliITSDDLRawData& AliITSDDLRawData::operator=(const AliITSDDLRawData &source){
if(this==&source) return *this;
fIndex=source.fIndex;
fHalfStaveModule=source.fHalfStaveModule;
fVerbose=source.fVerbose;
fSDDRawFormat=source.fSDDRawFormat;
return *this;
}
void AliITSDDLRawData::GetDigitsSSD(TClonesArray *ITSdigits,Int_t mod,Int_t modR,Int_t ddl,UInt_t *buf){
Int_t ix;
Int_t iz;
Int_t is;
UInt_t word;
UInt_t baseWord;
Int_t ndigits = ITSdigits->GetEntries();
AliITSdigit *digs;
ofstream ftxt;
if(ndigits){
if (fVerbose==2){
ftxt.open("SSDdigits.txt",ios::app);
}
for (Int_t digit=0;digit<ndigits;digit++) {
digs = (AliITSdigit*)ITSdigits->UncheckedAt(digit);
iz=digs->GetCoord1();
ix=digs->GetCoord2();
is=digs->GetCompressedSignal();
if(is<0) is = 0;
if(is>4095) is = 4095;
if (fVerbose==2)
ftxt<<"DDL:"<<ddl<<" Mod: "<<modR<<" N/P: "<<iz<<" Strip: "<<ix<<" Value: "<<is-1<<endl;
baseWord=0;
word=is;
AliBitPacking::PackWord(word,baseWord,0,11);
word = (iz==0) ? ix : 1535-ix ;
AliBitPacking::PackWord(word,baseWord,12,22);
word = mod%12;
word += ( word<6 ) ? 0 : 2;
AliBitPacking::PackWord(word,baseWord,24,27);
word = mod/12+1;
AliBitPacking::PackWord(word,baseWord,28,31);
fIndex++;
buf[fIndex]=baseWord;
}
}
if (fVerbose==2)
ftxt.close();
return;
}
void AliITSDDLRawData::GetDigitsSDDCompressed(TClonesArray *ITSdigits, Int_t mod, UInt_t *buf){
UInt_t dataWord=0;
Int_t ndigits = ITSdigits->GetEntries();
AliITSdigit *digs;
if(ndigits){
for (Int_t digit=0;digit<ndigits;digit++) {
digs = (AliITSdigit*)ITSdigits->UncheckedAt(digit);
Int_t iz=digs->GetCoord1();
Int_t ix=digs->GetCoord2();
Int_t is=digs->GetCompressedSignal();
dataWord=mod<<27;
Int_t sid=0;
if(iz>=256){
sid=1;
iz-=256;
}
dataWord+=sid<<26;
dataWord+=iz<<18;
dataWord+=ix<<10;
UInt_t adcEncoded=0;
Int_t shift=0;
if(is < 8) shift=2;
else if(is<16) shift=3;
else if(is<32) shift=4;
else if(is<64) shift=5;
else if(is<128) shift=6;
else shift=7;
adcEncoded=shift+((is-(1<<shift))<<3);
dataWord+=adcEncoded;
fIndex++;
buf[fIndex]=dataWord;
}
}
UInt_t finalWord=UInt_t(15)<<28;
finalWord+=mod;
fIndex++;
buf[fIndex]=finalWord;
}
void AliITSDDLRawData::GetDigitsSDD(TClonesArray *ITSdigits,Int_t mod,Int_t modR,Int_t ddl,UInt_t *buf){
Int_t ix;
Int_t iz;
Int_t is;
UInt_t word=0;
UInt_t baseWord=0;
Int_t ndigits = ITSdigits->GetEntries();
AliITSdigit *digs;
ofstream ftxt;
Int_t digarr[512][256];
for(Int_t i=0;i<512;i++){
for(Int_t j=0;j<256;j++){
digarr[i][j]=0;
}
}
UInt_t carlosid=0x30000000+mod;
fIndex++;
buf[fIndex]=carlosid;
Int_t first=0;
Int_t last=0;
Int_t diff=0;
Int_t nbit=0;
UInt_t word2=0;
Bool_t flag = kFALSE;
baseWord=0;
Int_t bitinfo1[4] = {3,8,3,7};
Int_t wordinfo1[4]= {0,0,0,0};
Int_t bitinfo2[2] = {3,18};
Int_t wordinfo2[3]= {1,65593};
if(ndigits){
if (fVerbose==2)
ftxt.open("SDDdigits.txt",ios::app);
for (Int_t digit=0;digit<ndigits;digit++) {
digs = (AliITSdigit*)ITSdigits->UncheckedAt(digit);
iz=digs->GetCoord1();
ix=digs->GetCoord2();
is=digs->GetCompressedSignal();
digarr[iz][ix]=is;
if (fVerbose==2)
ftxt<<"DDL:"<<ddl<<" MID:"<<modR<<" An:"<<iz<<" T:"<<ix<<" A:"<<is<<endl;
if (is>255){Error("GetDigitsSDD", "bits words is needed)!!!");}
}
for(Int_t anode=0;anode<512;anode++){
if(flag){
last = first+diff-1;
AliBitPacking::PackWord(word2,baseWord,first,last);
flag = kFALSE;
first = last+1;
diff=0;
}
if(anode == 256){
last = 0;
first = 0;
flag = kFALSE;
diff = 0;
word2=0;
}
for(Int_t tb=0;tb<256;tb++){
if(digarr[anode][tb]!=0){
if(flag){
last = first+diff-1;
AliBitPacking::PackWord(word2,baseWord,first,last);
flag = kFALSE;
first = last+1;
diff=0;
}
wordinfo1[1] = tb;
if(digarr[anode][tb]<8){
bitinfo1[3] = 2;
wordinfo1[2] = 2;
wordinfo1[3] = digarr[anode][tb]-(1 << bitinfo1[3]);
}
if(digarr[anode][tb]>=8 && digarr[anode][tb]<16){
bitinfo1[3] = 3;
wordinfo1[2] = 3;
wordinfo1[3] = digarr[anode][tb]-(1 << bitinfo1[3]);
}
if(digarr[anode][tb]>=16 && digarr[anode][tb]<32){
bitinfo1[3] = 4;
wordinfo1[2] = 4;
wordinfo1[3] = digarr[anode][tb]-(1 << bitinfo1[3]);
}
if(digarr[anode][tb]>=32 && digarr[anode][tb]<64){
bitinfo1[3] = 5;
wordinfo1[2] = 5;
wordinfo1[3] = digarr[anode][tb]-(1 << bitinfo1[3]);
}
if(digarr[anode][tb]>=64 && digarr[anode][tb]<128){
bitinfo1[3] = 6;
wordinfo1[2] = 6;
wordinfo1[3] = digarr[anode][tb]-(1 << bitinfo1[3]);
}
if(digarr[anode][tb]>=128){
bitinfo1[3] = 7;
wordinfo1[2] = 7;
wordinfo1[3] = digarr[anode][tb]-(1 << bitinfo1[3]);
}
for(Int_t ie=0;ie<4;ie++){
if(flag){
last = first+diff-1;
AliBitPacking::PackWord(word2,baseWord,first,last);
flag = kFALSE;
first = last+1;
diff=0;
}
last = first+bitinfo1[ie]-1;
if(first < 30 && last < 30){
AliBitPacking::PackWord(wordinfo1[ie],baseWord,first,last);
first = last+1;
}
else{
if(first<=29){
UInt_t w = AliBitPacking::UnpackWord(wordinfo1[ie],0,29-first);
AliBitPacking::PackWord(w,baseWord,first,29);
Int_t lb = 29-first+1;
diff = bitinfo1[ie]-lb;
word2 = AliBitPacking::UnpackWord(wordinfo1[ie],lb,lb+diff-1);
flag = kTRUE;
if(anode<256) word = 2;
else word = 3;
AliBitPacking::PackWord(word,baseWord,30,31);
fIndex++;
buf[fIndex]=baseWord;
first=0;
last = 0;
baseWord=0;
word = 0;
}
else{
word2 = wordinfo1[ie];
diff = bitinfo1[ie];
flag = kTRUE;
if(anode<256) word = 2;
else word = 3;
AliBitPacking::PackWord(word,baseWord,30,31);
fIndex++;
buf[fIndex]=baseWord;
first=0;
last=0;
baseWord=0;
word = 0;
}
}
}
}
}
for(Int_t i=0;i<2;i++){
if(flag){
last = first+diff-1;
AliBitPacking::PackWord(word2,baseWord,first,last);
flag = kFALSE;
first = last+1;
diff=0;
}
word = wordinfo2[i];
nbit = bitinfo2[i];
last = first+nbit-1;
if(first < 30 && last < 30){
AliBitPacking::PackWord(word,baseWord,first,last);
first = last+1;
}
else{
if(first<=29){
UInt_t w = AliBitPacking::UnpackWord(word,0,29-first);
AliBitPacking::PackWord(w,baseWord,first,29);
Int_t lb = 29-first+1;
diff = nbit-lb;
word2 = AliBitPacking::UnpackWord(word,lb,lb+diff-1);
flag = kTRUE;
if(anode<256) word = 2;
else word = 3;
AliBitPacking::PackWord(word,baseWord,30,31);
fIndex++;
buf[fIndex]=baseWord;
first=0;
last = 0;
baseWord=0;
if(anode==255){
flag=kFALSE;
word2=0;
}
}
else{
word2 = word;
diff = nbit;
flag = kTRUE;
if(anode<256) word = 2;
else word = 3;
AliBitPacking::PackWord(word,baseWord,30,31);
fIndex++;
buf[fIndex]=baseWord;
first=0;
last=0;
baseWord=0;
if(anode==255){
flag=kFALSE;
word2=0;
}
}
}
}
}
}
if(fVerbose==2)
ftxt.close();
return;
}
void AliITSDDLRawData::GetDigitsSPD(TClonesArray *ITSdigits,Int_t mod,Int_t ddl, UInt_t *buf, AliITSFOSignalsSPD* foSignals){
Int_t chipLow = AliITSRawStreamSPD::GetOnlineChipFromOffline(mod,0);
Int_t chipHigh = AliITSRawStreamSPD::GetOnlineChipFromOffline(mod,159);
if (chipLow>chipHigh) {chipLow -= 4; chipHigh += 4;}
UInt_t eq = AliITSRawStreamSPD::GetOnlineEqIdFromOffline(mod);
UInt_t hs = AliITSRawStreamSPD::GetOnlineHSFromOffline(mod);
AliITSIntMap* digMap = new AliITSIntMap();
UInt_t baseWord=0;
Int_t ndigits = ITSdigits->GetEntries();
AliITSdigit *digs;
ofstream ftxt;
if (ndigits) {
if (fVerbose==2) ftxt.open("SPDdigits.txt",ios::app);
for (Int_t digit=0; digit<ndigits; digit++) {
digs = (AliITSdigit*) ITSdigits->UncheckedAt(digit);
Int_t iz=digs->GetCoord1();
Int_t ix=digs->GetCoord2();
if(fVerbose==2) ftxt<<"DDL:"<<ddl<<" Mod:"<<mod<<" Row:"<<ix<<" Col:"<<iz<<endl;
UInt_t dummyDDL, dummyHS, chip, col, row;
AliITSRawStreamSPD::OfflineToOnline(mod,iz,ix,dummyDDL,dummyHS,chip,col,row);
digMap->Insert(chip*256*32+(31-col)*256+(255-row),row);
}
}
Int_t previousChip = chipLow-1;
Int_t chip = chipLow-1;
UInt_t chipHitCount = 0;
UInt_t nrHits = digMap->GetNrEntries();
for (UInt_t nHit=0; nHit<nrHits; nHit++) {
Int_t key = digMap->GetKeyIndex(nHit);
chip = key/(256*32);
Int_t col = 31 - (key%(256*32))/256;
Int_t row = digMap->GetValIndex(nHit);
if (chip>previousChip && previousChip>chipLow-1) {
WriteChipTrailer(buf, chipHitCount, foSignals->GetSignal(eq,hs,previousChip), baseWord);
}
for (Int_t ch=previousChip+1; ch<chip; ch++) {
WriteChipHeader(ch, hs, baseWord);
WriteChipTrailer(buf, 0, foSignals->GetSignal(eq,hs,ch), baseWord);
}
if (chip>previousChip) {
WriteChipHeader(chip, hs, baseWord);
chipHitCount = 0;
previousChip = chip;
}
chipHitCount++;
WriteHit(buf,row,col,baseWord);
}
if (chip>chipLow-1) {
WriteChipTrailer(buf, chipHitCount, foSignals->GetSignal(eq,hs,chip), baseWord);
}
for (Int_t ch=chip+1; ch<=chipHigh; ch++) {
WriteChipHeader(ch, hs, baseWord);
WriteChipTrailer(buf, 0, foSignals->GetSignal(eq,hs,ch), baseWord);
}
delete digMap;
if(fVerbose==2)
ftxt.close();
return;
}
Int_t AliITSDDLRawData::RawDataSPD(TBranch* branch, AliITSFOSignalsSPD* foSignals){
const Int_t kSize=21000;
UInt_t buf[kSize];
fIndex=-1;
TClonesArray*& digits = * (TClonesArray**) branch->GetAddress();
TString fileName;
AliFstream* outfile;
AliRawDataHeaderSim header;
for(Int_t ddl=0;ddl<AliDAQ::NumberOfDdls("ITSSPD");ddl++){
fileName.Form("%s",AliDAQ::DdlFileName("ITSSPD",ddl));
outfile = new AliFstream(fileName.Data());
UInt_t dataHeaderPosition=outfile->Tellp();
outfile->WriteBuffer((char*)(&header),sizeof(header));
for (Int_t mod=0; mod<AliITSRawStreamSPD::kModulesPerDDL; mod++){
Int_t moduleNumber = AliITSRawStreamSPD::GetModuleNumber(ddl, mod);
digits->Clear();
branch->GetEvent(moduleNumber);
GetDigitsSPD(digits, moduleNumber, ddl, buf, foSignals);
outfile->WriteBuffer((char *)buf,((fIndex+1)*sizeof(UInt_t)));
for(Int_t i=0;i<(fIndex+1);i++){
buf[i]=0;
}
fIndex=-1;
}
UInt_t currentFilePosition=outfile->Tellp();
outfile->Seekp(dataHeaderPosition);
header.fSize=currentFilePosition-dataHeaderPosition;
outfile->WriteBuffer((char*)(&header),sizeof(header));
delete outfile;
}
return 0;
}
Int_t AliITSDDLRawData::RawDataSSD(TBranch* branch){
const Int_t kSize=1536;
UInt_t buf[kSize];
fIndex=-1;
TClonesArray*& digits = * (TClonesArray**) branch->GetAddress();
TString fileName;
AliFstream* outfile;
AliRawDataHeaderSim header;
for(Int_t i=0;i<AliDAQ::NumberOfDdls("ITSSSD");i++){
fileName.Form("%s",AliDAQ::DdlFileName("ITSSSD",i));
outfile = new AliFstream(fileName.Data());
UInt_t dataHeaderPosition=outfile->Tellp();
outfile->WriteBuffer((char*)(&header),sizeof(header));
for (Int_t mod=0; mod<AliITSRawStreamSSD::kModulesPerDDL; mod++){
Int_t moduleNumber = AliITSRawStreamSSD::GetModuleNumber(i, mod);
if(moduleNumber!=-1){
digits->Clear();
branch->GetEvent(moduleNumber);
GetDigitsSSD(digits,mod,moduleNumber,i,buf);
outfile->WriteBuffer((char *)buf,((fIndex+1)*sizeof(UInt_t)));
fIndex=-1;
}
}
UInt_t currentFilePosition=outfile->Tellp();
outfile->Seekp(dataHeaderPosition);
header.fSize=currentFilePosition-dataHeaderPosition;
header.SetAttribute(0);
outfile->WriteBuffer((char*)(&header),sizeof(header));
delete outfile;
}
return 0;
}
Int_t AliITSDDLRawData::RawDataSDD(TBranch* branch, const AliITSDDLModuleMapSDD* ddlsdd){
const Int_t kSize=131072;
UInt_t buf[kSize];
fIndex=-1;
TClonesArray*& digits = * (TClonesArray**) branch->GetAddress();
TString fileName;
AliFstream* outfile;
AliRawDataHeaderSim header;
if(fSDDRawFormat!=0){
for(Int_t ibit=0; ibit<8; ibit++) header.SetAttribute(ibit);
}else{
for(Int_t ibit=0; ibit<5; ibit++) header.SetAttribute(ibit);
for(Int_t ibit=5; ibit<8; ibit++) header.ResetAttribute(ibit);
}
UInt_t skippedword=0;
UInt_t carlosFooterWord=0;
UInt_t fifoFooterWord=0;
UInt_t jitterWord=0;
Bool_t retcode;
retcode = AliBitPacking::PackWord(0x3FFFFFFF,carlosFooterWord,0,31);
if(!retcode)AliError("AliBitPacking error\n");
retcode = AliBitPacking::PackWord(0x3F1F1F1F,fifoFooterWord,0,31);
if(fSDDRawFormat!=0) retcode = AliBitPacking::PackWord(0x7F000000,jitterWord,0,31);
else retcode = AliBitPacking::PackWord(0x80000000,jitterWord,0,31);
for(Int_t i=0;i<AliDAQ::NumberOfDdls("ITSSDD");i++){
fileName.Form("%s",AliDAQ::DdlFileName("ITSSDD",i));
outfile = new AliFstream(fileName.Data());
UInt_t dataHeaderPosition=outfile->Tellp();
outfile->WriteBuffer((char*)(&header),sizeof(header));
if(fSDDRawFormat!=0){
retcode = AliBitPacking::PackWord(0xFFFFFFFF,skippedword,0,31);
outfile->WriteBuffer((char*)(&skippedword),sizeof(skippedword));
}
for (Int_t mod=0; mod<AliITSRawStreamSDD::kModulesPerDDL; mod++){
Int_t moduleNumber = ddlsdd->GetModuleNumber(i, mod);
if(moduleNumber!=-1){
digits->Clear();
branch->GetEvent(moduleNumber);
if(fSDDRawFormat==0){
GetDigitsSDDCompressed(digits,mod,buf);
outfile->WriteBuffer((char *)buf,((fIndex+1)*sizeof(UInt_t)));
}else{
GetDigitsSDD(digits,mod,moduleNumber,i,buf);
outfile->WriteBuffer((char *)buf,((fIndex+1)*sizeof(UInt_t)));
for(Int_t iw=0;iw<3;iw++) outfile->WriteBuffer((char*)(&carlosFooterWord),sizeof(carlosFooterWord));
}
fIndex=-1;
}
}
if(fSDDRawFormat!=0){
for(Int_t iw=0;iw<12;iw++) outfile->WriteBuffer((char*)(&fifoFooterWord),sizeof(fifoFooterWord));
}
outfile->WriteBuffer((char*)(&jitterWord),sizeof(jitterWord));
UInt_t currentFilePosition=outfile->Tellp();
outfile->Seekp(dataHeaderPosition);
header.fSize=currentFilePosition-dataHeaderPosition;
header.SetAttribute(0);
outfile->WriteBuffer((char*)(&header),sizeof(header));
delete outfile;
}
return 0;
}
void AliITSDDLRawData::WriteChipHeader(Int_t ChipAddr,Int_t halfStave,UInt_t &BaseWord){
BaseWord=0;
AliBitPacking::PackWord(ChipAddr,BaseWord,16,19);
AliBitPacking::PackWord(0,BaseWord,20,26);
AliBitPacking::PackWord(halfStave,BaseWord,27,29);
AliBitPacking::PackWord(0x1,BaseWord,30,31);
return;
}
void AliITSDDLRawData::WriteChipTrailer(UInt_t *buf, Int_t ChipHitCount, Bool_t foBit, UInt_t &BaseWord){
if((ChipHitCount%2)!=0){
AliBitPacking::PackWord(0xC000,BaseWord,16,31);
}
AliBitPacking::PackWord(ChipHitCount,BaseWord,0,11);
AliBitPacking::PackWord(0x0,BaseWord,12,12);
AliBitPacking::PackWord(foBit,BaseWord,13,13);
AliBitPacking::PackWord(0x0,BaseWord,14,15);
fIndex++;
buf[fIndex]=BaseWord;
BaseWord=0;
return;
}
void AliITSDDLRawData::WriteHit(UInt_t *buf,Int_t RowAddr,Int_t HitAddr,UInt_t &BaseWord){
if(!BaseWord){
AliBitPacking::PackWord(HitAddr,BaseWord,16,20);
AliBitPacking::PackWord(RowAddr,BaseWord,21,28);
AliBitPacking::PackWord(2,BaseWord,30,31);
}
else{
AliBitPacking::PackWord(HitAddr,BaseWord,0,4);
AliBitPacking::PackWord(RowAddr,BaseWord,5,12);
AliBitPacking::PackWord(2,BaseWord,14,15);
fIndex++;
buf[fIndex]=BaseWord;
BaseWord=0;
}
return;
}