#include "AliRawReader.h"
#include "AliLog.h"
#include "AliFstream.h"
+#include "AliLoader.h"
+#include "AliTreeLoader.h"
#include "AliTRDrawData.h"
#include "AliTRDdigitsManager.h"
#include "AliTRDgeometry.h"
#include "AliTRDarrayDictionary.h"
#include "AliTRDarrayADC.h"
-#include "AliTRDrawStreamBase.h"
+#include "AliTRDrawStream.h"
#include "AliTRDcalibDB.h"
#include "AliTRDSignalIndex.h"
#include "AliTRDfeeParam.h"
#include "AliTRDmcmSim.h"
+#include "AliTRDtrackletWord.h"
+#include "AliTRDtrackGTU.h"
+#include "AliESDTrdTrack.h"
+#include "AliTRDdigitsParam.h"
ClassImp(AliTRDrawData)
-Int_t AliTRDrawData::fgRawFormatVersion = AliTRDrawData::kRawNewFormat;
Int_t AliTRDrawData::fgDataSuppressionLevel = 0;
//_____________________________________________________________________________
,fFee(NULL)
,fNumberOfDDLs(0)
,fTrackletTree(NULL)
- ,fTrackletContainer(NULL)
+ ,fTracklets(new TClonesArray("AliTRDtrackletWord", 1000))
+ ,fTracks(new TClonesArray("AliESDTrdTrack", 500))
,fSMindexPos(0)
,fStackindexPos(0)
,fEventCounter(0)
+ ,fTrgFlags()
+ ,fMcmSim(new AliTRDmcmSim)
+ ,fDigitsParam(NULL)
{
//
// Default constructor
,fFee(NULL)
,fNumberOfDDLs(0)
,fTrackletTree(NULL)
- ,fTrackletContainer(NULL)
+ ,fTracklets(new TClonesArray("AliTRDtrackletWord", 1000))
+ ,fTracks(new TClonesArray("AliESDTrdTrack", 500))
,fSMindexPos(0)
,fStackindexPos(0)
,fEventCounter(0)
+ ,fTrgFlags()
+ ,fMcmSim(new AliTRDmcmSim)
+ ,fDigitsParam(NULL)
{
//
// Copy constructor
// Destructor
//
- if (fTrackletContainer){
- delete fTrackletContainer;
- fTrackletContainer = NULL;
- }
+ delete fTracklets;
+ delete fTracks;
+ delete fMcmSim;
}
// Buffer to temporary store half chamber data
UInt_t *hcBuffer = new UInt_t[kMaxHcWords];
-
+
Bool_t newEvent = kFALSE; // only for correct readout tree
Bool_t newSM = kFALSE; // new SM flag, for writing SM index words
- Bool_t newStack = kFALSE; // new stack flag, for writing stack index words
+ // Coverity
+ //Bool_t newStack = kFALSE; // new stack flag, for writing stack index words
+
+ // Get digits parameter
+ fDigitsParam = digitsManager->GetDigitsParam();
// sect is same as iDDL, so I use only sect here.
for (Int_t sect = 0; sect < fGeo->Nsector(); sect++) {
char name[1024];
- sprintf(name,"TRD_%d.ddl",sect + AliTRDrawStreamBase::kDDLOffset);
+ snprintf(name,1024,"TRD_%d.ddl",sect + AliTRDrawStream::kDDLOffset);
AliFstream* of = new AliFstream(name);
- // Write a dummy data header
+ // Write a dummy data header
AliRawDataHeaderSim header; // the event header
UInt_t hpos = of->Tellp();
of->WriteBuffer((char *) (& header), sizeof(header));
-
+
// Reset payload byte size (payload does not include header).
Int_t npayloadbyte = 0;
-
- if ( fgRawFormatVersion == 0 ){
- // GTU common data header (5x4 bytes per super module, shows link mask)
- for( Int_t stack = 0; stack < fGeo->Nstack(); stack++ ) {
- UInt_t gtuCdh = (UInt_t)(0xe << 28);
- for( Int_t layer = 0; layer < fGeo->Nlayer(); layer++) {
- Int_t iDet = fGeo->GetDetector(layer, stack, sect);
-
- // If chamber status is ok, we assume that the optical link is also OK.
- // This is shown in the GTU link mask.
- if ( AliTRDcalibDB::Instance()->GetChamberStatus(iDet) )
- gtuCdh = gtuCdh | (3 << (2*layer));
- }
- of->WriteBuffer((char *) (& gtuCdh), sizeof(gtuCdh));
- npayloadbyte += 4;
- }
- }
-
-
// check the existance of the data
// SM index word and Stack index word
- if ( fgRawFormatVersion == 1 ){
UInt_t *iwbuffer = new UInt_t[109]; // index word buffer; max 109 = 2 SM headers + 67 dummy headers + 5*8 stack headers
Int_t nheader = 0;
UInt_t bStackMask = 0x0;
Bool_t bStackHasData = kFALSE;
Bool_t bSMHasData = kFALSE;
-
+
//iwbuffer[nheader++] = 0x0001a020; // SM index words
- iwbuffer[nheader++] = 0x0044a020; // SM index words | additional SM header:48 = 1 SM header + 47 dummy words(for future use)
+ iwbuffer[nheader++] = 0x0044b020; // SM index words | additional SM header:48 = 1 SM header + 47 dummy words(for future use)
iwbuffer[nheader++] = 0x10404071; // SM header
for ( Int_t i=0; i<66; i++ ) iwbuffer[nheader++] = 0x00000000; // dummy words
iwbuffer[nheader++] = 0x10000000; // end of dummy words
-
+
for ( Int_t stack= 0; stack < fGeo->Nstack(); stack++) {
- UInt_t linkMask = 0x0;
- for( Int_t layer = 0; layer < fGeo->Nlayer(); layer++) {
- Int_t iDet = fGeo->GetDetector(layer,stack,sect);
- AliTRDarrayADC *digits = (AliTRDarrayADC *) digitsManager->GetDigits(iDet);
- if ( digits->HasData() ) {
- bStackMask = bStackMask | ( 1 << stack ); // active stack mask for new stack
- linkMask = linkMask | ( 3 << (2*layer) ); // 3 = 0011
- bStackHasData = kTRUE;
- bSMHasData = kTRUE;
- } // has data
- } // loop over layer
-
- if ( fgDataSuppressionLevel==0 || bStackHasData ){
- iwbuffer[nheader++] = 0x0007a000 | linkMask; // stack index word + link masks
- if (fgDataSuppressionLevel==0) iwbuffer[nheader-1] = 0x0007afff; // no suppression
- iwbuffer[nheader++] = 0x04045b01; // stack header
- for (Int_t i=0;i<6;i++) iwbuffer[nheader++] = 0x00000000; // 6 dummy words
- bStackHasData = kFALSE;
- }
+ UInt_t linkMask = 0x0;
+ for( Int_t layer = 0; layer < fGeo->Nlayer(); layer++) {
+ Int_t iDet = fGeo->GetDetector(layer,stack,sect);
+ AliTRDarrayADC *digits = (AliTRDarrayADC *) digitsManager->GetDigits(iDet);
+ if ( fgDataSuppressionLevel==0 || digits->HasData() ) {
+ bStackMask = bStackMask | ( 1 << stack ); // active stack mask for new stack
+ linkMask = linkMask | ( 3 << (2*layer) ); // 3 = 0011
+ bStackHasData = kTRUE;
+ bSMHasData = kTRUE;
+ } // has data
+ } // loop over layer
+
+ if ( fgDataSuppressionLevel==0 || bStackHasData ){
+ iwbuffer[nheader++] = 0x0007a000 | linkMask; // stack index word + link masks
+ if (fgDataSuppressionLevel==0) iwbuffer[nheader-1] = 0x0007afff; // no suppression
+ iwbuffer[nheader++] = 0x04045b01; // stack header
+ for (Int_t i=0;i<6;i++) iwbuffer[nheader++] = 0x00000000; // 6 dummy words
+ bStackHasData = kFALSE;
+ }
} // loop over stack
-
+
if ( fgDataSuppressionLevel==0 || bSMHasData ){
- iwbuffer[0] = iwbuffer[0] | bStackMask; // add stack masks to SM index word
- if (fgDataSuppressionLevel==0) iwbuffer[0] = 0x0044a03f; // no suppression : all stacks are active
- of->WriteBuffer((char *) iwbuffer, nheader*4);
- AliDebug(11, Form("SM %d index word: %08x", iwbuffer[0]));
- AliDebug(11, Form("SM %d header: %08x", iwbuffer[1]));
+ iwbuffer[0] = iwbuffer[0] | bStackMask; // add stack masks to SM index word
+ if (fgDataSuppressionLevel==0) iwbuffer[0] = 0x0044b03f; // no suppression : all stacks are active
+ of->WriteBuffer((char *) iwbuffer, nheader*4);
+ AliDebug(11, Form("SM %d index word: %08x", sect, iwbuffer[0]));
+ AliDebug(11, Form("SM %d header: %08x", sect, iwbuffer[1]));
}
- }
// end of SM & stack header ------------------------------------------------------------------------
// -------------------------------------------------------------------------------------------------
-
+
// Prepare chamber data
for( Int_t stack = 0; stack < fGeo->Nstack(); stack++) {
for( Int_t layer = 0; layer < fGeo->Nlayer(); layer++) {
-
- Int_t iDet = fGeo->GetDetector(layer,stack,sect);
- if (iDet == 0){
- newEvent = kTRUE; // it is expected that each event has at least one tracklet;
- // this is only needed for correct readout tree
- fEventCounter++;
- AliDebug(11, Form("New event!! Event counter: %d",fEventCounter));
- }
-
- if ( stack==0 && layer==0 ) newSM = kTRUE; // new SM flag
- if ( layer==0 ) newStack = kTRUE; // new stack flag
- AliDebug(15, Form("stack : %d, layer : %d, iDec : %d\n",stack,layer,iDet));
- // Get the digits array
- AliTRDarrayADC *digits = (AliTRDarrayADC *) digitsManager->GetDigits(iDet);
- if (fgDataSuppressionLevel==0 || digits->HasData() ) { // second part is new!! and is for indicating a new event
-
- if (digits->HasData()) digits->Expand();
-
- Int_t hcwords = 0;
- Int_t rv = fFee->GetRAWversion();
-
-
- if ( fgRawFormatVersion == 0 ){
- // Process A side of the chamber
- if ( rv >= 1 && rv <= 2 ) {
- hcwords = ProduceHcDataV1andV2(digits,0,iDet,hcBuffer,kMaxHcWords);
- }
- if ( rv == 3 ) {
-
- hcwords = ProduceHcDataV3 (digits,0,iDet,hcBuffer,kMaxHcWords,newEvent);
- //hcwords = ProduceHcDataV3 (digits,0,iDet,hcBuffer,kMaxHcWords);
- if(newEvent == kTRUE) newEvent = kFALSE;
- }
-
- of->WriteBuffer((char *) hcBuffer, hcwords*4);
- npayloadbyte += hcwords*4;
-
- // Process B side of the chamber
- if ( rv >= 1 && rv <= 2 ) {
- hcwords = ProduceHcDataV1andV2(digits,1,iDet,hcBuffer,kMaxHcWords);
- }
- if ( rv >= 3 ) {
-
- hcwords = ProduceHcDataV3 (digits,1,iDet,hcBuffer,kMaxHcWords,newEvent);
- //hcwords = ProduceHcDataV3 (digits,1,iDet,hcBuffer,kMaxHcWords);
- }
-
- of->WriteBuffer((char *) hcBuffer, hcwords*4);
- npayloadbyte += hcwords*4;
-
- } else { // real data format
-
- if (digits->HasData()){
- // Process A side of the chamber
- hcwords = ProduceHcData(digits,0,iDet,hcBuffer,kMaxHcWords,newEvent,newSM);
- //if ( newStack ){
- // AssignStackMask(hcBuffer, stack); // active stack mask for this stack
- // hcwords += AddStackIndexWords(hcBuffer, stack, hcwords);
- // newStack = kFALSE;
- //}
- //if ( newSM ) newSM = kFALSE;
- if ( newEvent ) newEvent = kFALSE;
- //AssignLinkMask(hcBuffer, layer); // active link mask for this layer(2*HC)
- of->WriteBuffer((char *) hcBuffer, hcwords*4);
- npayloadbyte += hcwords*4;
- //for ( Int_t i=0; i<hcwords; i++ ) AliInfo(Form("Buf : %X",hcBuffer[i]));
-
- // Process B side of the chamber
- hcwords = ProduceHcData(digits,1,iDet,hcBuffer,kMaxHcWords,newEvent,newSM);
- of->WriteBuffer((char *) hcBuffer, hcwords*4);
- npayloadbyte += hcwords*4;
- } else { // in case of no-suppression or NZS
-/*
- hcBuffer[hcwords++] = fgkEndOfTrackletMarker;
- hcBuffer[hcwords++] = fgkEndOfTrackletMarker;
- hcBuffer[hcwords++] = (1<<31) | (0<<24) | (0<<17) | (1<<14) | (sect<<9) | (layer<<6) | (stack<<3) | (0<<2) | 1;
- hcBuffer[hcwords++] = (24<<26) | (99<<10) | (15<<6) | (11<<2) | 1;
- hcBuffer[hcwords++] = kEndofrawdatamarker;
- hcBuffer[hcwords++] = kEndofrawdatamarker;
- hcBuffer[hcwords++] = kEndofrawdatamarker;
- hcBuffer[hcwords++] = kEndofrawdatamarker;
- npayloadbyte += hcwords*4;
-
- hcBuffer[hcwords++] = fgkEndOfTrackletMarker;
- hcBuffer[hcwords++] = fgkEndOfTrackletMarker;
- hcBuffer[hcwords++] = (1<<31) | (0<<24) | (0<<17) | (1<<14) | (sect<<9) | (layer<<6) | (stack<<3) | (1<<2) | 1;
- hcBuffer[hcwords++] = (24<<26) | (99<<10) | (15<<6) | (11<<2) | 1;
- hcBuffer[hcwords++] = kEndofrawdatamarker;
- hcBuffer[hcwords++] = kEndofrawdatamarker;
- hcBuffer[hcwords++] = kEndofrawdatamarker;
- hcBuffer[hcwords++] = kEndofrawdatamarker;
-*/
- hcwords = ProduceHcDataNoSuppression(0,iDet,hcBuffer,kMaxHcWords); // side 0
- of->WriteBuffer((char *) hcBuffer, hcwords*4);
- npayloadbyte += hcwords*4;
-
- hcwords = ProduceHcDataNoSuppression(1,iDet,hcBuffer,kMaxHcWords); // side 1
- of->WriteBuffer((char *) hcBuffer, hcwords*4);
- npayloadbyte += hcwords*4;
- }
- }
-
- } // has data
-
+
+ Int_t iDet = fGeo->GetDetector(layer,stack,sect);
+ if (iDet == 0){
+ newEvent = kTRUE; // it is expected that each event has at least one tracklet;
+ // this is only needed for correct readout tree
+ fEventCounter++;
+ AliDebug(11, Form("New event!! Event counter: %d",fEventCounter));
+ }
+
+ if ( stack==0 && layer==0 ) newSM = kTRUE; // new SM flag
+ // Coverity
+ //if ( layer==0 ) newStack = kTRUE; // new stack flag
+ AliDebug(15, Form("stack : %d, layer : %d, iDec : %d\n",stack,layer,iDet));
+ // Get the digits array
+ AliTRDarrayADC *digits = (AliTRDarrayADC *) digitsManager->GetDigits(iDet);
+ if (fgDataSuppressionLevel==0 || digits->HasData() ) { // second part is new!! and is for indicating a new event
+
+ if (digits->HasData()) digits->Expand();
+
+ Int_t hcwords = 0;
+
+ // Process A side of the chamber
+ hcwords = ProduceHcData(digits,0,iDet,hcBuffer,kMaxHcWords,newEvent,newSM);
+ if ( newEvent ) newEvent = kFALSE;
+ //AssignLinkMask(hcBuffer, layer); // active link mask for this layer(2*HC)
+ of->WriteBuffer((char *) hcBuffer, hcwords*4);
+ npayloadbyte += hcwords*4;
+
+ // Process B side of the chamber
+ hcwords = ProduceHcData(digits,1,iDet,hcBuffer,kMaxHcWords,newEvent,newSM);
+ of->WriteBuffer((char *) hcBuffer, hcwords*4);
+ npayloadbyte += hcwords*4;
+ } // has data
+
} // loop over layer
} // loop over stack
-
+
// Complete header
header.fSize = UInt_t(of->Tellp()) - hpos;
header.SetAttribute(0); // Valid data
of->Seekp(hpos); // Rewind to header position
of->WriteBuffer((char *) (& header), sizeof(header));
delete of;
- } // loop over sector(SM)
- delete [] hcBuffer;
+ delete [] iwbuffer;
+ } // loop over sector(SM)
+
+ delete [] hcBuffer;
+
return kTRUE;
-
}
//_____________________________________________________________________________
//buf[nw++] = 0x0001a03f; // SM index words
fSMindexPos = nw; // memorize position of the SM index word for re-allocating stack mask
- buf[nw++] = 0x0001a020; // SM index words
+ buf[nw++] = 0x0001b020; // SM index words
buf[nw++] = 0x10404071; // SM header
fStackindexPos = nw; // memorize position of the stack index word for future adding
//_____________________________________________________________________________
Int_t AliTRDrawData::ProduceHcData(AliTRDarrayADC *digits, Int_t side, Int_t det, UInt_t *buf, Int_t maxSize, Bool_t /*newEvent = kFALSE*/, Bool_t /*newSM = kFALSE*/){
//
+ // This function produces the raw data for one HC, i.e. tracklets, tracklet endmarkers,
+ // raw data, raw data endmarkers.
// This function can be used for both ZS and NZS data
//
Int_t nw = 0; // Number of written words
Int_t of = 0; // Number of overflowed words
- Int_t *tempnw = 0x0; // Number of written words for temp. buffer
- Int_t *tempof = 0x0; // Number of overflowed words for temp. buffer
+ Int_t *tempnw = &nw; // Number of written words for temp. buffer
+ Int_t *tempof = &of; // Number of overflowed words for temp. buffer
Int_t layer = fGeo->GetLayer( det ); // Layer
Int_t stack = fGeo->GetStack( det ); // Stack
Int_t sect = fGeo->GetSector( det ); // Sector (=iDDL)
AliDebug(1,Form("Producing raw data for sect=%d layer=%d stack=%d side=%d",sect,layer,stack,side));
- AliTRDmcmSim* mcm = new AliTRDmcmSim();
-
UInt_t *tempBuffer = buf; // tempBuffer used to write ADC data
// different in case of tracklet writing
if (trackletOn) {
tempBuffer = new UInt_t[maxSize];
- tempnw = new Int_t(0);
- tempof = new Int_t(0);
- }
- else {
- tempnw = &nw;
- tempof = &of;
- }
-
- WriteIntermediateWordsV2(tempBuffer,*tempnw,*tempof,maxSize,det,side); //??? no tracklet or NZS
-
- // scanning direction such, that tracklet-words are sorted in ascending z and then in ascending y order
- // ROB numbering on chamber and MCM numbering on ROB increase with decreasing z and increasing y
- for (Int_t iRobRow = 0; iRobRow <= (kCtype + 3)-1; iRobRow++ ) { // ROB number should be increasing
- Int_t iRob = iRobRow * 2 + side;
- // MCM on one ROB
- for (Int_t iMcmRB = 0; iMcmRB < fGeo->MCMmax(); iMcmRB++ ) {
- Int_t iMcm = 16 - 4*(iMcmRB/4 + 1) + (iMcmRB%4);
-
- mcm->Init(det, iRob, iMcm);
- mcm->SetData(digits); // no filtering done here (already done in digitizer)
- if (trackletOn) {
- mcm->Tracklet();
- Int_t tempNw = mcm->ProduceTrackletStream(&buf[nw], maxSize - nw);
- if( tempNw < 0 ) {
- of += tempNw;
- nw += maxSize - nw;
+ tempnw = new Int_t(0);
+ tempof = new Int_t(0);
+ }
+
+ WriteIntermediateWords(tempBuffer,*tempnw,*tempof,maxSize,det,side);
+
+ if (digits->HasData()) {
+ // scanning direction such, that tracklet-words are sorted in ascending z and then in ascending y order
+ // ROB numbering on chamber and MCM numbering on ROB increase with decreasing z and increasing y
+ for (Int_t iRobRow = 0; iRobRow <= (kCtype + 3)-1; iRobRow++ ) {
+ // ROB number should be increasing
+ Int_t iRob = iRobRow * 2 + side;
+ // MCM on one ROB
+ for (Int_t iMcmRB = 0; iMcmRB < fGeo->MCMmax(); iMcmRB++ ) {
+ Int_t iMcm = 16 - 4*(iMcmRB/4 + 1) + (iMcmRB%4);
+
+ fMcmSim->Init(det, iRob, iMcm);
+ fMcmSim->SetData(digits); // no filtering done here (already done in digitizer)
+ if (trackletOn) {
+ fMcmSim->Tracklet();
+ Int_t tempNw = fMcmSim->ProduceTrackletStream(&buf[nw], maxSize - nw);
+ if( tempNw < 0 ) {
+ of += tempNw;
+ nw += maxSize - nw;
+ AliError(Form("Buffer overflow detected. Please increase the buffer size and recompile."));
+ } else {
+ nw += tempNw;
+ }
+ }
+ fMcmSim->ZSMapping(); // Calculate zero suppression mapping
+ // at the moment it has to be rerun here
+ // Write MCM data to temp. buffer
+ Int_t tempNw = fMcmSim->ProduceRawStream( &tempBuffer[*tempnw], maxSize - *tempnw, fEventCounter );
+ if ( tempNw < 0 ) {
+ *tempof += tempNw;
+ *tempnw += maxSize - nw;
AliError(Form("Buffer overflow detected. Please increase the buffer size and recompile."));
} else {
- nw += tempNw;
+ *tempnw += tempNw;
}
}
- mcm->ZSMapping(); // Calculate zero suppression mapping
- // at the moment it has to be rerun here
- // Write MCM data to temp. buffer
- Int_t tempNw = mcm->ProduceRawStream( &tempBuffer[*tempnw], maxSize - *tempnw, fEventCounter );
- if ( tempNw < 0 ) {
- *tempof += tempNw;
- *tempnw += maxSize - nw;
- AliError(Form("Buffer overflow detected. Please increase the buffer size and recompile."));
- } else {
- *tempnw += tempNw;
- }
- }
+ }
}
-
- delete mcm;
-
-
+
// in case of tracklet writing copy temp data to final buffer
if (trackletOn) {
if (nw + *tempnw < maxSize) {
else {
AliError("Buffer overflow detected");
}
- }
+ delete [] tempBuffer;
+ delete tempof;
+ delete tempnw;
+ }
+
// Write end of raw data marker
if (nw+3 < maxSize) {
- buf[nw++] = fgkEndOfDataMarker; // fFee->GetRawDataEndmarker();
- buf[nw++] = fgkEndOfDataMarker; // fFee->GetRawDataEndmarker();
- //buf[nw++] = fgkEndOfDataMarker; // fFee->GetRawDataEndmarker();
- //buf[nw++] = fgkEndOfDataMarker; // fFee->GetRawDataEndmarker();
+ buf[nw++] = fgkEndOfDataMarker;
+ buf[nw++] = fgkEndOfDataMarker;
+ buf[nw++] = fgkEndOfDataMarker;
+ buf[nw++] = fgkEndOfDataMarker;
} else {
- of++;
+ of += 4;
}
- if (trackletOn) {
- delete [] tempBuffer;
- delete tempof;
- delete tempnw;
- }
-
if (of != 0) {
AliError("Buffer overflow. Data is truncated. Please increase buffer size and recompile.");
}
return nw;
}
-//_____________________________________________________________________________
-Int_t AliTRDrawData::ProduceHcDataNoSuppression(Int_t side, Int_t det, UInt_t *buf, Int_t maxSize){
-
- // This function generates below words for no-suppression option(same as real data format)
- // 1. end of tracklet marker
- // 2. HC index word, HC header
- // 3. MCM header, ADC mask
- // 4. end of data marker
- //
-
- Int_t nw = 0; // number of written words
- Int_t of = 0; // number of overflowed words
- UInt_t x = 0; // word buffer
- //UInt_t *tempBuffer = buf; // temp buffer
- Int_t *tempnw = &nw; // temp number of written words
- Int_t *tempof = &of; // temp number of overflowed words
-
- const Int_t kCtype = fGeo->GetStack(det) == 2 ? 0 : 1; // Chamber type (0:C0, 1:C1)
-
- WriteIntermediateWordsV2(buf, *tempnw, *tempof, maxSize, det, side); // end of tracklet marker and HC headers
-
- for (Int_t iRobRow = 0; iRobRow <= (kCtype + 3)-1; iRobRow++ ) { // ROB number should be increasing
- Int_t iRob = iRobRow * 2 + side; // ROB position
-
- for (Int_t iMcmRB = 0; iMcmRB < fGeo->MCMmax(); iMcmRB++ ) { // MCM on ROB
- Int_t iMcm = 16 - 4*(iMcmRB/4 + 1) + (iMcmRB%4); // MCM position
-
- if ( nw+2 < maxSize ){
- x = 0;
- x = (1<<31) | (iRob << 28) | (iMcm << 24) | ((fEventCounter % 0x100000) << 4) | 0xC; // MCM header
- buf[nw++] = x;
-
- x = 0;
- // Produce ADC mask : nncc cccm mmmm mmmm mmmm mmmm mmmm 1100
- // n : unused , c : ADC count, m : selected ADCs , where ccccc are inverted
- x = x | (1 << 30) | (31 << 25) | 0xC; // 11111 = 31
- buf[nw++] = x;
- } else {
- of++;
- }
-
- } // loop over MCM
- } // loop over ROB
-
- // Write end of raw data marker
- if (nw+1 < maxSize) {
- buf[nw++] = fgkEndOfDataMarker; // fFee->GetRawDataEndmarker();
- buf[nw++] = fgkEndOfDataMarker; // fFee->GetRawDataEndmarker();
- //buf[nw++] = fgkEndOfDataMarker; // fFee->GetRawDataEndmarker();
- //buf[nw++] = fgkEndOfDataMarker; // fFee->GetRawDataEndmarker();
- } else {
- of++;
- }
-
- if ( of != 0 ){ // if there is overflow
- AliError("Buffer overflow. Data is truncated. Please increase buffer size and recompile.");
- }
-
- AliDebug(1, Form("Number of written words in this HC is %d",nw));
-
- return nw;
-}
-
-//_____________________________________________________________________________
-Int_t AliTRDrawData::ProduceHcDataV1andV2(AliTRDarrayADC *digits, Int_t side
- , Int_t det, UInt_t *buf, Int_t maxSize)
-{
- //
- // This function simulates: 1) SM-I commissiong data Oct. 06 (Raw Version == 1).
- // 2) Full Raw Production Version (Raw Version == 2)
- //
- // Produce half chamber data (= an ORI data) for the given chamber (det) and side (side)
- // where
- //
- // side=0 means A side with ROB positions 0, 2, 4, 6.
- // side=1 means B side with ROB positions 1, 3, 5, 7.
- //
- // Chamber type (C0 orC1) is determined by "det" automatically.
- // Appropriate size of buffer (*buf) must be prepared prior to calling this function.
- // Pointer to the buffer and its size must be given to "buf" and "maxSize".
- // Return value is the number of valid data filled in the buffer in unit of 32 bits
- // UInt_t words.
- // If buffer size if too small, the data is truncated with the buffer size however
- // the function will finish without crash (this behaviour is similar to the MCM).
- //
-
- Int_t nw = 0; // Number of written words
- Int_t of = 0; // Number of overflowed words
- Int_t layer = fGeo->GetLayer( det ); // Layer
- Int_t stack = fGeo->GetStack( det ); // Stack
- Int_t sect = fGeo->GetSector( det ); // Sector (=iDDL)
- Int_t nRow = fGeo->GetRowMax( layer, stack, sect );
- Int_t nCol = fGeo->GetColMax( layer );
- const Int_t kNTBin = AliTRDcalibDB::Instance()->GetNumberOfTimeBins();
- Int_t kCtype = 0; // Chamber type (0:C0, 1:C1)
- Int_t iEv = 0xA; // Event ID. Now fixed to 10, how do I get event id?
- UInt_t x = 0; // General used number
- Int_t rv = fFee->GetRAWversion();
-
- // Check the nCol and nRow.
- if ((nCol == 144) &&
- (nRow == 16 || nRow == 12)) {
- kCtype = (nRow-12) / 4;
- }
- else {
- AliError(Form("This type of chamber is not supported (nRow=%d, nCol=%d)."
- ,nRow,nCol));
- return 0;
- }
-
- AliDebug(1,Form("Producing raw data for sect=%d layer=%d stack=%d side=%d"
- ,sect,layer,stack,side));
-
- // Tracklet should be processed here but not implemented yet
-
- // Write end of tracklet marker
- if (nw < maxSize) {
- buf[nw++] = kEndoftrackletmarker;
- }
- else {
- of++;
- }
-
- // Half Chamber header
- if ( rv == 1 ) {
- // Now it is the same version as used in SM-I commissioning.
- Int_t dcs = det+100; // DCS Serial (in simulation, it is meaningless
- x = (dcs<<20) | (sect<<15) | (layer<<12) | (stack<<9) | (side<<8) | 1;
- if (nw < maxSize) {
- buf[nw++] = x;
- }
- else {
- of++;
- }
- }
- else if ( rv == 2 ) {
- // h[0] (there are 3 HC header)
- Int_t minorv = 0; // The minor version number
- Int_t add = 2; // The number of additional header words to follow
- x = (1<<31) | (rv<<24) | (minorv<<17) | (add<<14) | (sect<<9) | (layer<<6) | (stack<<3) | (side<<2) | 1;
- if (nw < maxSize) {
- buf[nw++] = x;
- }
- else {
- of++;
- }
- // h[1]
- Int_t bcCtr = 99; // bunch crossing counter. Here it is set to 99 always for no reason
- Int_t ptCtr = 15; // pretrigger counter. Here it is set to 15 always for no reason
- Int_t ptPhase = 11; // pretrigger phase. Here it is set to 11 always for no reason
- x = (bcCtr<<16) | (ptCtr<<12) | (ptPhase<<8) | ((kNTBin-1)<<2) | 1;
- if (nw < maxSize) {
- buf[nw++] = x;
- }
- else {
- of++;
- }
- // h[2]
- Int_t pedSetup = 1; // Pedestal filter setup (0:1). Here it is always 1 for no reason
- Int_t gainSetup = 1; // Gain filter setup (0:1). Here it is always 1 for no reason
- Int_t tailSetup = 1; // Tail filter setup (0:1). Here it is always 1 for no reason
- Int_t xtSetup = 0; // Cross talk filter setup (0:1). Here it is always 0 for no reason
- Int_t nonlinSetup = 0; // Nonlinearity filter setup (0:1). Here it is always 0 for no reason
- Int_t bypassSetup = 0; // Filter bypass (for raw data) setup (0:1). Here it is always 0 for no reason
- Int_t commonAdditive = 10; // Digital filter common additive (0:63). Here it is always 10 for no reason
- x = (pedSetup<<31) | (gainSetup<<30) | (tailSetup<<29) | (xtSetup<<28) | (nonlinSetup<<27)
- | (bypassSetup<<26) | (commonAdditive<<20) | 1;
- if (nw < maxSize) {
- buf[nw++] = x;
- }
- else {
- of++;
- }
- }
-
- // Scan for ROB and MCM
- for (Int_t iRobRow = 0; iRobRow < (kCtype + 3); iRobRow++ ) {
- Int_t iRob = iRobRow * 2 + side;
- for (Int_t iMcm = 0; iMcm < fGeo->MCMmax(); iMcm++ ) {
- Int_t padrow = iRobRow * 4 + iMcm / 4;
-
- // MCM header
- x = ((iRob * fGeo->MCMmax() + iMcm) << 24) | ((iEv % 0x100000) << 4) | 0xC;
- if (nw < maxSize) {
- buf[nw++] = x;
- }
- else {
- of++;
- }
-
- // ADC data
- for (Int_t iAdc = 0; iAdc < 21; iAdc++ ) {
- Int_t padcol = fFee->GetPadColFromADC(iRob, iMcm, iAdc);
- UInt_t aa = !(iAdc & 1) + 2; // 3 for the even ADC channel , 2 for the odd ADC channel
- UInt_t *a = new UInt_t[kNTBin+2];
- // 3 timebins are packed into one 32 bits word
- for (Int_t iT = 0; iT < kNTBin; iT+=3) {
- if ((padcol >= 0) && (padcol < nCol)) {
- a[iT ] = ((iT ) < kNTBin ) ? digits->GetData(padrow,padcol,iT ) : 0;
- a[iT+1] = ((iT + 1) < kNTBin ) ? digits->GetData(padrow,padcol,iT + 1) : 0;
- a[iT+2] = ((iT + 2) < kNTBin ) ? digits->GetData(padrow,padcol,iT + 2) : 0;
- }
- else {
- a[iT] = a[iT+1] = a[iT+2] = 0; // This happenes at the edge of chamber (should be pedestal! How?)
- }
- x = (a[iT+2] << 22) | (a[iT+1] << 12) | (a[iT] << 2) | aa;
- if (nw < maxSize) {
- buf[nw++] = x;
- }
- else {
- of++;
- }
- }
- // Diagnostics
- Float_t avg = 0;
- Float_t rms = 0;
- for (Int_t iT = 0; iT < kNTBin; iT++) {
- avg += (Float_t) (a[iT]);
- }
- avg /= (Float_t) kNTBin;
- for (Int_t iT = 0; iT < kNTBin; iT++) {
- rms += ((Float_t) (a[iT]) - avg) * ((Float_t) (a[iT]) - avg);
- }
- rms = TMath::Sqrt(rms / (Float_t) kNTBin);
- if (rms > 1.7) {
- AliDebug(2,Form("Large RMS (>1.7) (ROB,MCM,ADC)=(%02d,%02d,%02d), avg=%03.1f, rms=%03.1f"
- ,iRob,iMcm,iAdc,avg,rms));
- }
- delete [] a;
- }
- }
- }
-
- // Write end of raw data marker
- if (nw < maxSize) {
- buf[nw++] = kEndofrawdatamarker;
- }
- else {
- of++;
- }
- if (of != 0) {
- AliWarning("Buffer overflow. Data is truncated. Please increase buffer size and recompile.");
- }
-
- return nw;
-
-}
-
-//_____________________________________________________________________________
-
-//Int_t AliTRDrawData::ProduceHcDataV3(AliTRDarrayADC *digits, Int_t side , Int_t det, UInt_t *buf, Int_t maxSize)
-Int_t AliTRDrawData::ProduceHcDataV3(AliTRDarrayADC *digits, Int_t side , Int_t det, UInt_t *buf, Int_t maxSize, Bool_t newEvent = kFALSE)
-{
- //
- // This function simulates: Raw Version == 3 (Zero Suppression Prototype)
- //
-
- Int_t nw = 0; // Number of written words
- Int_t of = 0; // Number of overflowed words
- Int_t layer = fGeo->GetLayer( det ); // Layer
- Int_t stack = fGeo->GetStack( det ); // Stack
- Int_t sect = fGeo->GetSector( det ); // Sector (=iDDL)
- Int_t nRow = fGeo->GetRowMax( layer, stack, sect );
- Int_t nCol = fGeo->GetColMax( layer );
- const Int_t kNTBin = AliTRDcalibDB::Instance()->GetNumberOfTimeBins();
- Int_t kCtype = 0; // Chamber type (0:C0, 1:C1)
- //Int_t iEv = 0xA; // Event ID. Now fixed to 10, how do I get event id?
-
-
-
- Bool_t trackletOn = fFee->GetTracklet(); // **new**
-
- // Check the nCol and nRow.
- if ((nCol == 144) &&
- (nRow == 16 || nRow == 12)) {
- kCtype = (nRow-12) / 4;
- }
- else {
- AliError(Form("This type of chamber is not supported (nRow=%d, nCol=%d)."
- ,nRow,nCol));
- return 0;
- }
-
- AliDebug(1,Form("Producing raw data for sect=%d layer=%d stack=%d side=%d"
- ,sect,layer,stack,side));
-
- AliTRDmcmSim** mcm = new AliTRDmcmSim*[(kCtype + 3)*(fGeo->MCMmax())];
-
- // in case no tracklet-words are processed: write the tracklet-endmarker as well as all additional words immediately and write
- // raw-data in one go; if tracklet-processing is enabled, first all tracklet-words of a half-chamber have to be processed before the
- // additional words (tracklet-endmarker,headers,...)are written. Raw-data is written in a second loop;
-
- if (!trackletOn) {
- WriteIntermediateWords(buf,nw,of,maxSize,det,side);
- }
-
- // Scan for ROB and MCM
- // scanning direction such, that tracklet-words are sorted in ascending z and then in ascending y order
- // ROB numbering on chamber and MCM numbering on ROB increase with decreasing z and increasing y
- for (Int_t iRobRow = (kCtype + 3)-1; iRobRow >= 0; iRobRow-- ) {
- Int_t iRob = iRobRow * 2 + side;
- // MCM on one ROB
- for (Int_t iMcmRB = 0; iMcmRB < fGeo->MCMmax(); iMcmRB++ ) {
- Int_t iMcm = 16 - 4*(iMcmRB/4 + 1) + (iMcmRB%4);
- Int_t entry = iRobRow*(fGeo->MCMmax()) + iMcm;
-
- mcm[entry] = new AliTRDmcmSim();
- mcm[entry]->Init( det, iRob, iMcm , newEvent);
- //mcm[entry]->Init( det, iRob, iMcm);
- if (newEvent == kTRUE) newEvent = kFALSE; // only one mcm is concerned with new event
- Int_t padrow = mcm[entry]->GetRow();
-
- // Copy ADC data to MCM simulator
- for (Int_t iAdc = 0; iAdc < 21; iAdc++ ) {
- Int_t padcol = mcm[entry]->GetCol( iAdc );
- if ((padcol >= 0) && (padcol < nCol)) {
- for (Int_t iT = 0; iT < kNTBin; iT++) {
- mcm[entry]->SetData( iAdc, iT, digits->GetData( padrow, padcol, iT) );
- }
- }
- else { // this means it is out of chamber, and masked ADC
- mcm[entry]->SetDataPedestal( iAdc );
- }
- }
-
- // Simulate process in MCM
- mcm[entry]->Filter(); // Apply filter
- mcm[entry]->ZSMapping(); // Calculate zero suppression mapping
-//jkl mcm[entry]->CopyArrays();
-//jkl mcm[entry]->GeneratefZSM1Dim();
-//jkl mcm[entry]->RestoreZeros();
-
- if (trackletOn) {
- mcm[entry]->Tracklet();
- Int_t tempNw = mcm[entry]->ProduceTrackletStream( &buf[nw], maxSize - nw );
- //Int_t tempNw = 0;
- if( tempNw < 0 ) {
- of += tempNw;
- nw += maxSize - nw;
- AliError(Form("Buffer overflow detected. Please increase the buffer size and recompile."));
- } else {
- nw += tempNw;
- }
- }
- // no tracklets: write raw-data already in this loop
- else {
- // Write MCM data to buffer
- Int_t tempNw = mcm[entry]->ProduceRawStream( &buf[nw], maxSize - nw );
- if( tempNw < 0 ) {
- of += tempNw;
- nw += maxSize - nw;
- AliError(Form("Buffer overflow detected. Please increase the buffer size and recompile."));
- } else {
- nw += tempNw;
- }
-
- delete mcm[entry];
- }
-
-
-
-
- //mcm->DumpData( "trdmcmdata.txt", "RFZS" ); // debugging purpose
- }
- }
-
- // if tracklets are switched on, raw-data can be written only after all tracklets
- if (trackletOn) {
- WriteIntermediateWords(buf,nw,of,maxSize,det,side);
-
-
- // Scan for ROB and MCM
- for (Int_t iRobRow = (kCtype + 3)-1; iRobRow >= 0; iRobRow-- ) {
- //Int_t iRob = iRobRow * 2 + side;
- // MCM on one ROB
- for (Int_t iMcmRB = 0; iMcmRB < fGeo->MCMmax(); iMcmRB++ ) {
- Int_t iMcm = 16 - 4*(iMcmRB/4 + 1) + (iMcmRB%4);
-
- Int_t entry = iRobRow*(fGeo->MCMmax()) + iMcm;
-
- // Write MCM data to buffer
- Int_t tempNw = mcm[entry]->ProduceRawStream( &buf[nw], maxSize - nw );
- if( tempNw < 0 ) {
- of += tempNw;
- nw += maxSize - nw;
- AliError(Form("Buffer overflow detected. Please increase the buffer size and recompile."));
- } else {
- nw += tempNw;
- }
-
- delete mcm[entry];
-
- }
- }
- }
-
- delete [] mcm;
-
- // Write end of raw data marker
- if (nw < maxSize) {
- buf[nw++] = kEndofrawdatamarker;
- }
- else {
- of++;
- }
- if (of != 0) {
- AliError("Buffer overflow. Data is truncated. Please increase buffer size and recompile.");
- }
-
-
- return nw;
-
-}
-
//_____________________________________________________________________________
AliTRDdigitsManager *AliTRDrawData::Raw2Digits(AliRawReader *rawReader)
{
AliTRDdigitsManager* digitsManager = new AliTRDdigitsManager();
digitsManager->CreateArrays();
- if (!fTrackletContainer) {
- //if (!fTrackletContainer && ( fReconstructor->IsWritingTracklets() || fReconstructor->IsProcessingTracklets() )) {
- // maximum tracklets for one HC
- const Int_t kTrackletChmb=256;
- fTrackletContainer = new UInt_t *[2];
- fTrackletContainer[0] = new UInt_t[kTrackletChmb];
- fTrackletContainer[1] = new UInt_t[kTrackletChmb];
+ AliTRDrawStream input(rawReader);
+
+ AliRunLoader *runLoader = AliRunLoader::Instance();
+
+ // ----- preparing tracklet output -----
+ AliDataLoader *trklLoader = runLoader->GetLoader("TRDLoader")->GetDataLoader("tracklets");
+ if (!trklLoader) {
+ trklLoader = new AliDataLoader("TRD.Tracklets.root","tracklets", "tracklets");
+ runLoader->GetLoader("TRDLoader")->AddDataLoader(trklLoader);
+ }
+ if (!trklLoader) {
+ AliError("Could not get the tracklet data loader!");
+ return 0x0;
+ }
+ // trklLoader->SetEvent();
+ trklLoader->Load("update");
+ AliTreeLoader *trklTreeLoader = dynamic_cast<AliTreeLoader*> (trklLoader->GetBaseLoader("tracklets-raw"));
+ if (!trklTreeLoader) {
+ trklTreeLoader = new AliTreeLoader("tracklets-raw", trklLoader);
+ trklLoader->AddBaseLoader(trklTreeLoader);
}
- AliTRDrawStreamBase *pinput = AliTRDrawStreamBase::GetRawStream(rawReader);
- AliTRDrawStreamBase &input = *pinput;
- input.SetRawVersion( fFee->GetRAWversion() ); //<= ADDED by MinJung
+ TClonesArray *fTrackletArray = new TClonesArray("AliTRDtrackletWord", 256);
+ Int_t lastHC = -1;
+ if (trklLoader->Tree())
+ trklLoader->MakeTree();
+ TTree *trackletTree = trklTreeLoader->Tree();
+ if (!trackletTree) {
+ trklTreeLoader->MakeTree();
+ trackletTree = trklTreeLoader->Tree();
+ }
+ if (!trackletTree->GetBranch("hc"))
+ trackletTree->Branch("hc", &lastHC, "hc/I");
+ else
+ trackletTree->SetBranchAddress("hc", &lastHC);
+
+ if (!trackletTree->GetBranch("trkl"))
+ trackletTree->Branch("trkl", &fTrackletArray);
+ else
+ trackletTree->SetBranchAddress("trkl", &fTrackletArray);
+
+ // ----- preparing track output -----
+ AliDataLoader *trkLoader = 0x0;
+ trkLoader = runLoader->GetLoader("TRDLoader")->GetDataLoader("gtutracks");
+ if (!trkLoader) {
+ trkLoader = new AliDataLoader("TRD.GtuTracks.root","gtutracks", "gtutracks");
+ runLoader->GetLoader("TRDLoader")->AddDataLoader(trkLoader);
+ }
+ if (!trkLoader) {
+ AliError("Could not get the GTU-track data loader!");
+ return 0x0;
+ }
+ trkLoader->Load("UPDATE");
+
+ TTree *trackTree = trkLoader->Tree();
+ if (!trackTree) {
+ trkLoader->MakeTree();
+ trackTree = trkLoader->Tree();
+ }
+
+ AliTRDtrackGTU trk;
+ if (!trackTree->GetBranch("TRDtrackGTU"))
+ trackTree->Branch("TRDtrackGTU", "AliTRDtrackGTU", &trk, 32000);
- AliInfo(Form("Stream version: %s", input.IsA()->GetName()));
+ // ----- read the raw data -----
+ // write the tracklets to arrays while reading raw data
+ input.SetTrackletArray(fTracklets);
+ input.SetTrackArray(fTracks);
// Loop through the digits
Int_t det = 0;
while (det >= 0)
{
- //det = input.NextChamber(digitsManager);
- det = input.NextChamber(digitsManager,fTrackletContainer);
-
- //if (!fReconstructor->IsWritingTracklets()) continue;
- if (*(fTrackletContainer[0]) > 0 || *(fTrackletContainer[1]) > 0) WriteTracklets(det);
+ det = input.NextChamber(digitsManager);
if (det >= 0)
{
}
}
- if (fTrackletContainer){
- delete [] fTrackletContainer[0];
- delete [] fTrackletContainer[1];
- delete [] fTrackletContainer;
- fTrackletContainer = NULL;
+ for (Int_t iSector = 0; iSector < fGeo->Nsector(); iSector++) {
+ fTrgFlags[iSector] = input.GetTriggerFlags(iSector);
}
- delete pinput;
- pinput = NULL;
+ // ----- tracklet output -----
+ fTrackletArray->Clear();
+ Int_t nTracklets = fTracklets ? fTracklets->GetEntries() : 0;
+ AliDebug(1, Form("Writing %i tracklets to loader", nTracklets));
+ for (Int_t iTracklet = 0; iTracklet < nTracklets; ++iTracklet) {
+ AliTRDtrackletWord *trkl = (AliTRDtrackletWord*) fTracklets->At(iTracklet);
+ if (trkl->GetHCId() != lastHC) {
+ if (fTrackletArray->GetEntriesFast() > 0) {
+ trackletTree->Fill();
+ fTrackletArray->Clear();
+ }
+ lastHC = trkl->GetHCId();
+ }
+ new ((*fTrackletArray)[fTrackletArray->GetEntriesFast()]) AliTRDtrackletWord(*trkl);
+ }
+ if (fTrackletArray->GetEntriesFast() > 0) {
+ trackletTree->Fill();
+ fTrackletArray->Clear();
+ }
+ trklTreeLoader->WriteData("OVERWRITE");
+ trklLoader->WriteData("OVERWRITE");
+ trklLoader->UnloadAll();
+ trklLoader->CloseFile();
+
+ // ----- track output -----
+ Int_t nTracks = fTracks ? fTracks->GetEntriesFast() : 0;
+ AliDebug(1, Form("Writing %i tracks to loader", nTracks));
+ for (Int_t iTrack = 0; iTrack < nTracks; ++iTrack) {
+ AliESDTrdTrack *trkEsd = (AliESDTrdTrack*) fTracks->At(iTrack);
+ trk = *trkEsd;
+ trackTree->Fill();
+ }
+ trkLoader->WriteData("OVERWRITE");
+ trkLoader->UnloadAll();
+ trkLoader->CloseFile();
return digitsManager;
}
//_____________________________________________________________________________
void AliTRDrawData::WriteIntermediateWords(UInt_t* buf, Int_t& nw, Int_t& of, const Int_t& maxSize, const Int_t& det, const Int_t& side) {
- //
- // write half-chamber headers
- //
-
- Int_t layer = fGeo->GetLayer( det ); // Layer
- Int_t stack = fGeo->GetStack( det ); // Stack
- Int_t sect = fGeo->GetSector( det ); // Sector (=iDDL)
- Int_t rv = fFee->GetRAWversion();
- const Int_t kNTBin = AliTRDcalibDB::Instance()->GetNumberOfTimeBins();
- UInt_t x = 0;
-
- // Write end of tracklet marker
- if (nw < maxSize) {
- buf[nw++] = kEndoftrackletmarker;
- }
- else {
- of++;
- }
-
- // Half Chamber header
- // h[0] (there are 3 HC header)
- Int_t minorv = 0; // The minor version number
- Int_t add = 2; // The number of additional header words to follow
- x = (1<<31) | (rv<<24) | (minorv<<17) | (add<<14) | (sect<<9) | (layer<<6) | (stack<<3) | (side<<2) | 1;
- if (nw < maxSize) {
- buf[nw++] = x;
- }
- else {
- of++;
- }
- // h[1]
- Int_t bcCtr = 99; // bunch crossing counter. Here it is set to 99 always for no reason
- Int_t ptCtr = 15; // pretrigger counter. Here it is set to 15 always for no reason
- Int_t ptPhase = 11; // pretrigger phase. Here it is set to 11 always for no reason
- x = (bcCtr<<16) | (ptCtr<<12) | (ptPhase<<8) | ((kNTBin-1)<<2) | 1;
- if (nw < maxSize) {
- buf[nw++] = x;
- }
- else {
- of++;
- }
- // h[2]
- Int_t pedSetup = 1; // Pedestal filter setup (0:1). Here it is always 1 for no reason
- Int_t gainSetup = 1; // Gain filter setup (0:1). Here it is always 1 for no reason
- Int_t tailSetup = 1; // Tail filter setup (0:1). Here it is always 1 for no reason
- Int_t xtSetup = 0; // Cross talk filter setup (0:1). Here it is always 0 for no reason
- Int_t nonlinSetup = 0; // Nonlinearity filter setup (0:1). Here it is always 0 for no reason
- Int_t bypassSetup = 0; // Filter bypass (for raw data) setup (0:1). Here it is always 0 for no reason
- Int_t commonAdditive = 10; // Digital filter common additive (0:63). Here it is always 10 for no reason
- x = (pedSetup<<31) | (gainSetup<<30) | (tailSetup<<29) | (xtSetup<<28) | (nonlinSetup<<27)
- | (bypassSetup<<26) | (commonAdditive<<20) | 1;
- if (nw < maxSize) {
- buf[nw++] = x;
- }
- else {
- of++;
- }
-}
-
-//_____________________________________________________________________________
-void AliTRDrawData::WriteIntermediateWordsV2(UInt_t* buf, Int_t& nw, Int_t& of, const Int_t& maxSize, const Int_t& det, const Int_t& side) {
//
// write tracklet end marker(0x10001000)
// and half chamber headers(H[0] and H[1])
Int_t stack = fGeo->GetStack( det ); // Stack
Int_t sect = fGeo->GetSector( det ); // Sector (=iDDL)
Int_t rv = fFee->GetRAWversion();
- const Int_t kNTBin = AliTRDcalibDB::Instance()->GetNumberOfTimeBins();
- Bool_t trackletOn = fFee->GetTracklet();
+ const Int_t kNTBin = fDigitsParam->GetNTimeBins(det);
+ Bool_t trackletOn = fFee->GetTracklet();
UInt_t x = 0;
// Write end of tracklet marker
- if (nw < maxSize){
- buf[nw++] = fgkEndOfTrackletMarker;
- buf[nw++] = fgkEndOfTrackletMarker; // the number of tracklet end marker should be more than 2
+ if (nw < maxSize){
+ buf[nw++] = fgkEndOfTrackletMarker;
+ buf[nw++] = fgkEndOfTrackletMarker; // the number of tracklet end marker should be more than 2
}
else {
- of++;
+ of++;
}
-
- // Half Chamber header
- // h[0] (there are 2 HC headers) xmmm mmmm nnnn nnnq qqss sssp ppcc ci01
- // , where x : Raw version speacial number (=1)
- // m : Raw version major number (test pattern, ZS, disable tracklet, 0, options)
- // n : Raw version minor number
- // q : number of addtional header words (default = 1)
- // s : SM sector number (ALICE numbering)
- // p : plane(layer) number
- // c : chamber(stack) number
- // i : side number (0:A, 1:B)
- Int_t majorv = 0; // The major version number
+ // Half Chamber header
+ // h[0] (there are 2 HC headers) xmmm mmmm nnnn nnnq qqss sssp ppcc ci01
+ // , where x : Raw version speacial number (=1)
+ // m : Raw version major number (test pattern, ZS, disable tracklet, 0, options)
+ // n : Raw version minor number
+ // q : number of addtional header words (default = 1)
+ // s : SM sector number (ALICE numbering)
+ // p : plane(layer) number
+ // c : chamber(stack) number
+ // i : side number (0:A, 1:B)
+ Int_t majorv = 0; // The major version number
Int_t minorv = 0; // The minor version number
Int_t add = 1; // The number of additional header words to follow : now 1, previous 2
- Int_t tp = 0; // test pattern (default=0)
- Int_t zs = (rv==3) ? 1 : 0; // zero suppression
- Int_t dt = (trackletOn) ? 0 : 1; // disable tracklet
-
- majorv = (tp<<6) | (zs<<5) | (dt<<4) | 1; // major version
-
+ Int_t tp = 0; // test pattern (default=0)
+ Int_t zs = (rv==3) ? 1 : 0; // zero suppression
+ Int_t dt = (trackletOn) ? 0 : 1; // disable tracklet
+
+ majorv = (tp<<6) | (zs<<5) | (dt<<4) | 1; // major version
+
x = (1<<31) | (majorv<<24) | (minorv<<17) | (add<<14) | (sect<<9) | (layer<<6) | (stack<<3) | (side<<2) | 1;
if (nw < maxSize) buf[nw++] = x; else of++;
-
+
// h[1] tttt ttbb bbbb bbbb bbbb bbpp pphh hh01
- // , where t : number of time bins
- // b : bunch crossing number
- // p : pretrigger counter
- // h : pretrigger phase
+ // , where t : number of time bins
+ // b : bunch crossing number
+ // p : pretrigger counter
+ // h : pretrigger phase
Int_t bcCtr = 99; // bunch crossing counter. Here it is set to 99 always for no reason
Int_t ptCtr = 15; // pretrigger counter. Here it is set to 15 always for no reason
Int_t ptPhase = 11; // pretrigger phase. Here it is set to 11 always for no reason
//x = (bcCtr<<16) | (ptCtr<<12) | (ptPhase<<8) | ((kNTBin-1)<<2) | 1; // old format
x = ((kNTBin)<<26) | (bcCtr<<10) | (ptCtr<<6) | (ptPhase<<2) | 1;
if (nw < maxSize) buf[nw++] = x; else of++;
-
}
-
-//_____________________________________________________________________________
-Bool_t AliTRDrawData::WriteTracklets(Int_t det)
-{
- //
- // Write the raw data tracklets into seperate file
- //
-
- UInt_t **leaves = new UInt_t *[2];
- for (Int_t i=0; i<2 ;i++){
- leaves[i] = new UInt_t[258];
- leaves[i][0] = det; // det
- leaves[i][1] = i; // side
- memcpy(leaves[i]+2, fTrackletContainer[i], sizeof(UInt_t) * 256);
- }
-
- if (!fTrackletTree){
- AliDataLoader *dl = fRunLoader->GetLoader("TRDLoader")->GetDataLoader("tracklets");
- dl->MakeTree();
- fTrackletTree = dl->Tree();
- }
-
- TBranch *trkbranch = fTrackletTree->GetBranch("trkbranch");
- if (!trkbranch) {
- trkbranch = fTrackletTree->Branch("trkbranch",leaves[0],"det/i:side/i:tracklets[256]/i");
- }
-
- for (Int_t i=0; i<2; i++){
- if (leaves[i][2]>0) {
- trkbranch->SetAddress(leaves[i]);
- fTrackletTree->Fill();
- }
- }
-
- AliDataLoader *dl = fRunLoader->GetLoader("TRDLoader")->GetDataLoader("tracklets");
- dl->WriteData("OVERWRITE");
- //dl->Unload();
- delete [] leaves;
-
- return kTRUE;
-
-}
-
-//_____________________________________________________________________________
-Bool_t AliTRDrawData::OpenOutput()
-{
- //
- // Connect the output tree
- //
-
- // tracklet writing
- if (1){
- //if (fReconstructor->IsWritingTracklets()){
- TString evfoldname = AliConfig::GetDefaultEventFolderName();
- fRunLoader = AliRunLoader::GetRunLoader(evfoldname);
-
- if (!fRunLoader) {
- fRunLoader = AliRunLoader::Open("galice.root");
- }
- if (!fRunLoader) {
- AliError(Form("Can not open session for file galice.root."));
- return kFALSE;
- }
-
- UInt_t **leaves = new UInt_t *[2];
- AliDataLoader *dl = fRunLoader->GetLoader("TRDLoader")->GetDataLoader("tracklets");
- if (!dl) {
- AliError("Could not get the tracklets data loader!");
- dl = new AliDataLoader("TRD.Tracklets.root","tracklets", "tracklets");
- fRunLoader->GetLoader("TRDLoader")->AddDataLoader(dl);
- }
- fTrackletTree = dl->Tree();
- if (!fTrackletTree)
- {
- dl->MakeTree();
- fTrackletTree = dl->Tree();
- }
- TBranch *trkbranch = fTrackletTree->GetBranch("trkbranch");
- if (!trkbranch)
- fTrackletTree->Branch("trkbranch",leaves[0],"det/i:side/i:tracklets[256]/i");
- }
- return kTRUE;
-
-}
-
-
-
-
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff