STEER/AliTagCreator.cxx

   1 /**************************************************************************
   2  * Author: Panos Christakoglou.                                           *
   3  * Contributors are mentioned in the code where appropriate.              *
   4  *                                                                        *
   5  * Permission to use, copy, modify and distribute this software and its   *
   6  * documentation strictly for non-commercial purposes is hereby granted   *
   7  * without fee, provided that the above copyright notice appears in all   *
   8  * copies and that both the copyright notice and this permission notice   *
   9  * appear in the supporting documentation. The authors make no claims     *
  10  * about the suitability of this software for any purpose. It is          *
  11  * provided "as is" without express or implied warranty.                  *
  12  **************************************************************************/
  13
  14 /* $Id$ */
  15
  16 //-----------------------------------------------------------------
  17 //           AliTagCreator class
  18 //   This is the class to deal with the tag creation (post process)
  19 //   Origin: Panos Christakoglou, UOA-CERN, Panos.Christakoglou@cern.ch
  20 //-----------------------------------------------------------------
  21
  22 //ROOT
  23 #include <TFile.h>
  24 #include <TString.h>
  25 #include <TTree.h>
  26 #include <TSystem.h>
  27 #include <TChain.h>
  28 #include <TLorentzVector.h>
  29
  30 //ROOT-AliEn
  31 #include <TGrid.h>
  32 #include <TGridResult.h>
  33
  34 //AliRoot
  35 #include "AliRunTag.h"
  36 #include "AliEventTag.h"
  37 #include "AliESD.h"
  38 #include "AliESDVertex.h"
  39 #include "AliLog.h"
  40
  41
  42 #include "AliTagCreator.h"
  43
  44
  45 ClassImp(AliTagCreator)
  46
  47
  48 //______________________________________________________________________________
  49 AliTagCreator::AliTagCreator() //local mode
  50 {
  51   //==============Default constructor for a AliTagCreator==================
  52   fgridpath = "";
  53   fSE = "";
  54   fStorage = 0;
  55 }
  56
  57 //______________________________________________________________________________
  58 AliTagCreator::~AliTagCreator()
  59 {
  60 //================Default destructor for a AliTagCreator=======================
  61 }
  62
  63 //______________________________________________________________________________
  64 void AliTagCreator::SetStorage(Int_t storage)
  65 {
  66   // Sets correctly the storage: 0 for local, 1 for GRID
  67   fStorage = storage;
  68   if(fStorage == 0)
  69     AliInfo(Form("Tags will be stored locally...."));
  70   if(fStorage == 1)
  71     AliInfo(Form("Tags will be stored in the grid...."));
  72   if((fStorage != 0)&&(fStorage != 1))
  73     {
  74       AliInfo(Form("Storage was not properly set!!!"));
  75       abort();
  76     }
  77 }
  78
  79
  80 //______________________________________________________________________________
  81 Bool_t AliTagCreator::ReadESDCollection(TGridResult *fresult)
  82 {
  83   // Reads the entry of the TGridResult and creates the tags
  84   Int_t nEntries = fresult->GetEntries();
  85
  86   TString alienUrl;
  87   const char *guid;
  88   const char *md5;
  89   const char *turl;
  90   Long64_t size = -1;
  91
  92   Int_t counter = 0;
  93   for(Int_t i = 0; i < nEntries; i++)
  94     {
  95       alienUrl = fresult->GetKey(i,"turl");
  96       guid = fresult->GetKey(i,"guid");
  97       if(fresult->GetKey(i,"size"))
  98         size = atol (fresult->GetKey(i,"size"));
  99       md5 = fresult->GetKey(i,"md5");
 100       turl = fresult->GetKey(i,"turl");
 101       if(md5 && !strlen(guid))
 102         md5 = 0;
 103       if(guid && !strlen(guid))
 104         guid = 0;
 105
 106       TFile *f = TFile::Open(alienUrl,"READ");
 107       CreateTag(f,guid,md5,turl,size,counter);
 108       f->Close();
 109       delete f;
 110       counter += 1;
 111     }//grid result loop
 112
 113   return kTRUE;
 114 }
 115
 116 //__________________________________________________________________________
 117 Bool_t AliTagCreator::MergeTags()
 118 {
 119   //Merges the tags and stores the merged tag file
 120   //locally if fStorage=0 or in the grid if fStorage=1
 121   AliInfo(Form("Merging tags....."));
 122   TChain *fgChain = new TChain("T");
 123
 124   if(fStorage == 0) {
 125     const char * tagPattern = "tag";
 126     // Open the working directory
 127     void * dirp = gSystem->OpenDirectory(gSystem->pwd());
 128     const char * name = 0x0;
 129     // Add all files matching *pattern* to the chain
 130     while((name = gSystem->GetDirEntry(dirp))) {
 131       if (strstr(name,tagPattern))
 132         fgChain->Add(name);
 133     }//directory loop
 134     AliInfo(Form("Chained tag files: %d",fgChain->GetEntries()));
 135   }//local mode
 136
 137   else if(fStorage == 1) {
 138     TString alienLocation = gGrid->Pwd();
 139     alienLocation += fgridpath.Data();
 140     alienLocation += "/";
 141
 142     TGridResult *tagresult = gGrid->Query(alienLocation,"*tag.root","","");
 143     Int_t nEntries = tagresult->GetEntries();
 144     for(Int_t i = 0; i < nEntries; i++) {
 145       TString alienUrl = tagresult->GetKey(i,"turl");
 146       fgChain->Add(alienUrl);
 147     }//grid result loop
 148     AliInfo(Form("Chained tag files: %d",fgChain->GetEntries()));
 149   }//grid mode
 150
 151   AliRunTag *tag = new AliRunTag;
 152   AliEventTag *evTag = new AliEventTag;
 153   fgChain->SetBranchAddress("AliTAG",&tag);
 154
 155   //Defining new tag objects
 156   AliRunTag *newTag = new AliRunTag();
 157   TTree ttag("T","A Tree with event tags");
 158   TBranch * btag = ttag.Branch("AliTAG", &newTag);
 159   btag->SetCompressionLevel(9);
 160   for(Int_t iTagFiles = 0; iTagFiles < fgChain->GetEntries(); iTagFiles++) {
 161     fgChain->GetEntry(iTagFiles);
 162     newTag->SetRunId(tag->GetRunId());
 163     const TClonesArray *tagList = tag->GetEventTags();
 164     for(Int_t j = 0; j < tagList->GetEntries(); j++) {
 165       evTag = (AliEventTag *) tagList->At(j);
 166       newTag->AddEventTag(*evTag);
 167     }
 168     ttag.Fill();
 169     newTag->Clear();
 170   }//tag file loop
 171
 172   TString localFileName = "Run"; localFileName += tag->GetRunId();
 173   localFileName += ".Merged"; localFileName += ".ESD.tag.root";
 174
 175   TString alienFileName = "/alien";
 176   alienFileName += gGrid->Pwd();
 177   alienFileName += fgridpath.Data();
 178   alienFileName += "/";
 179   alienFileName +=  localFileName;
 180   alienFileName += "?se=";
 181   alienFileName += fSE.Data();
 182
 183   TString filename = 0x0;
 184
 185   if(fStorage == 0) {
 186     filename = localFileName.Data();
 187     AliInfo(Form("Writing merged tags to local file: %s",filename.Data()));
 188   }
 189   if(fStorage == 1) {
 190     filename = alienFileName.Data();
 191     AliInfo(Form("Writing merged tags to grid file: %s",filename.Data()));
 192   }
 193
 194   TFile* ftag = TFile::Open(filename, "recreate");
 195   ftag->cd();
 196   ttag.Write();
 197   ftag->Close();
 198
 199   delete tag;
 200   delete newTag;
 201
 202   return kTRUE;
 203 }
 204
 205 //_____________________________________________________________________________
 206 void AliTagCreator::CreateTag(TFile* file, const char *guid, const char *md5, const char *turl, Long64_t size, Int_t Counter)
 207 {
 208   /////////////
 209   //muon code//
 210   ////////////
 211   Double_t fMUONMASS = 0.105658369;
 212   //Variables
 213   Double_t fX,fY,fZ ;
 214   Double_t fThetaX, fThetaY, fPyz, fChisquare;
 215   Double_t fPxRec, fPyRec, fPzRec, fEnergy;
 216   Int_t fCharge;
 217   TLorentzVector fEPvector;
 218
 219   Float_t fZVertexCut = 10.0;
 220   Float_t fRhoVertexCut = 2.0;
 221
 222   Float_t fLowPtCut = 1.0;
 223   Float_t fHighPtCut = 3.0;
 224   Float_t fVeryHighPtCut = 10.0;
 225   ////////////
 226
 227   Double_t partFrac[5] = {0.01, 0.01, 0.85, 0.10, 0.05};
 228
 229   // Creates the tags for all the events in a given ESD file
 230   Int_t ntrack;
 231   Int_t nProtons, nKaons, nPions, nMuons, nElectrons;
 232   Int_t nPos, nNeg, nNeutr;
 233   Int_t nK0s, nNeutrons, nPi0s, nGamas;
 234   Int_t nCh1GeV, nCh3GeV, nCh10GeV;
 235   Int_t nMu1GeV, nMu3GeV, nMu10GeV;
 236   Int_t nEl1GeV, nEl3GeV, nEl10GeV;
 237   Float_t maxPt = .0, meanPt = .0, totalP = .0;
 238   Int_t fVertexflag;
 239   TString fVertexName;
 240
 241   AliRunTag *tag = new AliRunTag();
 242   AliEventTag *evTag = new AliEventTag();
 243   TTree ttag("T","A Tree with event tags");
 244   TBranch * btag = ttag.Branch("AliTAG", &tag);
 245   btag->SetCompressionLevel(9);
 246
 247   AliInfo(Form("Creating the tags......."));
 248
 249   Int_t firstEvent = 0,lastEvent = 0;
 250   TTree *t = (TTree*) file->Get("esdTree");
 251   TBranch * b = t->GetBranch("ESD");
 252   AliESD *esd = 0;
 253   b->SetAddress(&esd);
 254
 255   tag->SetRunId(esd->GetRunNumber());
 256
 257   Int_t iNumberOfEvents = b->GetEntries();
 258   for (Int_t iEventNumber = 0; iEventNumber < iNumberOfEvents; iEventNumber++) {
 259     ntrack = 0;
 260     nPos = 0;
 261     nNeg = 0;
 262     nNeutr =0;
 263     nK0s = 0;
 264     nNeutrons = 0;
 265     nPi0s = 0;
 266     nGamas = 0;
 267     nProtons = 0;
 268     nKaons = 0;
 269     nPions = 0;
 270     nMuons = 0;
 271     nElectrons = 0;
 272     nCh1GeV = 0;
 273     nCh3GeV = 0;
 274     nCh10GeV = 0;
 275     nMu1GeV = 0;
 276     nMu3GeV = 0;
 277     nMu10GeV = 0;
 278     nEl1GeV = 0;
 279     nEl3GeV = 0;
 280     nEl10GeV = 0;
 281     maxPt = .0;
 282     meanPt = .0;
 283     totalP = .0;
 284     fVertexflag = 1;
 285
 286     b->GetEntry(iEventNumber);
 287     const AliESDVertex * vertexIn = esd->GetVertex();
 288     fVertexName = vertexIn->GetName();
 289     if(fVertexName == "default") fVertexflag = 0;
 290
 291     for (Int_t iTrackNumber = 0; iTrackNumber < esd->GetNumberOfTracks(); iTrackNumber++) {
 292       AliESDtrack * esdTrack = esd->GetTrack(iTrackNumber);
 293       UInt_t status = esdTrack->GetStatus();
 294
 295       //select only tracks with ITS refit
 296       if ((status&AliESDtrack::kITSrefit)==0) continue;
 297       //select only tracks with TPC refit
 298       if ((status&AliESDtrack::kTPCrefit)==0) continue;
 299
 300       //select only tracks with the "combined PID"
 301       if ((status&AliESDtrack::kESDpid)==0) continue;
 302       Double_t p[3];
 303       esdTrack->GetPxPyPz(p);
 304       Double_t momentum = sqrt(pow(p[0],2) + pow(p[1],2) + pow(p[2],2));
 305       Double_t fPt = sqrt(pow(p[0],2) + pow(p[1],2));
 306       totalP += momentum;
 307       meanPt += fPt;
 308       if(fPt > maxPt) maxPt = fPt;
 309
 310       if(esdTrack->GetSign() > 0) {
 311         nPos++;
 312         if(fPt > fLowPtCut) nCh1GeV++;
 313         if(fPt > fHighPtCut) nCh3GeV++;
 314         if(fPt > fVeryHighPtCut) nCh10GeV++;
 315       }
 316       if(esdTrack->GetSign() < 0) {
 317         nNeg++;
 318         if(fPt > fLowPtCut) nCh1GeV++;
 319         if(fPt > fHighPtCut) nCh3GeV++;
 320         if(fPt > fVeryHighPtCut) nCh10GeV++;
 321       }
 322       if(esdTrack->GetSign() == 0) nNeutr++;
 323
 324       //PID
 325       Double_t prob[5];
 326       esdTrack->GetESDpid(prob);
 327
 328       Double_t rcc = 0.0;
 329       for(Int_t i = 0; i < AliPID::kSPECIES; i++) rcc += prob[i]*partFrac[i];
 330       if(rcc == 0.0) continue;
 331       //Bayes' formula
 332       Double_t w[5];
 333       for(Int_t i = 0; i < AliPID::kSPECIES; i++) w[i] = prob[i]*partFrac[i]/rcc;
 334
 335       //protons
 336       if ((w[4]>w[3])&&(w[4]>w[2])&&(w[4]>w[1])&&(w[4]>w[0])) nProtons++;
 337       //kaons
 338       if ((w[3]>w[4])&&(w[3]>w[2])&&(w[3]>w[1])&&(w[3]>w[0])) nKaons++;
 339       //pions
 340       if ((w[2]>w[4])&&(w[2]>w[3])&&(w[2]>w[1])&&(w[2]>w[0])) nPions++;
 341       //electrons
 342       if ((w[0]>w[4])&&(w[0]>w[3])&&(w[0]>w[2])&&(w[0]>w[1])) {
 343         nElectrons++;
 344         if(fPt > fLowPtCut) nEl1GeV++;
 345         if(fPt > fHighPtCut) nEl3GeV++;
 346         if(fPt > fVeryHighPtCut) nEl10GeV++;
 347       }
 348       ntrack++;
 349     }//esd track loop
 350
 351     /////////////
 352     //muon code//
 353     ////////////
 354     Int_t nMuonTracks = esd->GetNumberOfMuonTracks();
 355     // loop over all reconstructed tracks (also first track of combination)
 356     for (Int_t iTrack = 0; iTrack <  nMuonTracks;  iTrack++) {
 357       AliESDMuonTrack* muonTrack = esd->GetMuonTrack(iTrack);
 358       if (muonTrack == 0x0) continue;
 359
 360       // Coordinates at vertex
 361       fZ = muonTrack->GetZ();
 362       fY = muonTrack->GetBendingCoor();
 363       fX = muonTrack->GetNonBendingCoor();
 364
 365       fThetaX = muonTrack->GetThetaX();
 366       fThetaY = muonTrack->GetThetaY();
 367
 368       fPyz = 1./TMath::Abs(muonTrack->GetInverseBendingMomentum());
 369       fPzRec = - fPyz / TMath::Sqrt(1.0 + TMath::Tan(fThetaY)*TMath::Tan(fThetaY));
 370       fPxRec = fPzRec * TMath::Tan(fThetaX);
 371       fPyRec = fPzRec * TMath::Tan(fThetaY);
 372       fCharge = Int_t(TMath::Sign(1.,muonTrack->GetInverseBendingMomentum()));
 373
 374       //ChiSquare of the track if needed
 375       fChisquare = muonTrack->GetChi2()/(2.0 * muonTrack->GetNHit() - 5);
 376       fEnergy = TMath::Sqrt(fMUONMASS * fMUONMASS + fPxRec * fPxRec + fPyRec * fPyRec + fPzRec * fPzRec);
 377       fEPvector.SetPxPyPzE(fPxRec, fPyRec, fPzRec, fEnergy);
 378
 379       // total number of muons inside a vertex cut
 380       if((TMath::Abs(fZ)<fZVertexCut) && (TMath::Sqrt(fY*fY+fX*fX)<fRhoVertexCut)) {
 381         nMuons++;
 382         if(fEPvector.Pt() > fLowPtCut) {
 383           nMu1GeV++;
 384           if(fEPvector.Pt() > fHighPtCut) {
 385             nMu3GeV++;
 386             if (fEPvector.Pt() > fVeryHighPtCut) {
 387               nMu10GeV++;
 388             }
 389           }
 390         }
 391       }
 392     }//muon track loop
 393
 394     // Fill the event tags
 395     if(ntrack != 0)
 396       meanPt = meanPt/ntrack;
 397
 398     evTag->SetEventId(iEventNumber+1);
 399     evTag->SetGUID(guid);
 400     evTag->SetMD5(md5);
 401     evTag->SetTURL(turl);
 402     evTag->SetSize(size);
 403     evTag->SetVertexX(vertexIn->GetXv());
 404     evTag->SetVertexY(vertexIn->GetYv());
 405     evTag->SetVertexZ(vertexIn->GetZv());
 406     evTag->SetVertexZError(vertexIn->GetZRes());
 407     evTag->SetVertexFlag(fVertexflag);
 408
 409     evTag->SetT0VertexZ(esd->GetT0zVertex());
 410
 411     evTag->SetTriggerMask(esd->GetTriggerMask());
 412     evTag->SetTriggerCluster(esd->GetTriggerCluster());
 413
 414     evTag->SetZDCNeutron1Energy(esd->GetZDCN1Energy());
 415     evTag->SetZDCProton1Energy(esd->GetZDCP1Energy());
 416     evTag->SetZDCEMEnergy(esd->GetZDCEMEnergy());
 417     evTag->SetZDCNeutron1Energy(esd->GetZDCN2Energy());
 418     evTag->SetZDCProton1Energy(esd->GetZDCP2Energy());
 419     evTag->SetNumOfParticipants(esd->GetZDCParticipants());
 420
 421
 422     evTag->SetNumOfTracks(esd->GetNumberOfTracks());
 423     evTag->SetNumOfPosTracks(nPos);
 424     evTag->SetNumOfNegTracks(nNeg);
 425     evTag->SetNumOfNeutrTracks(nNeutr);
 426
 427     evTag->SetNumOfV0s(esd->GetNumberOfV0s());
 428     evTag->SetNumOfCascades(esd->GetNumberOfCascades());
 429     evTag->SetNumOfKinks(esd->GetNumberOfKinks());
 430     evTag->SetNumOfPMDTracks(esd->GetNumberOfPmdTracks());
 431
 432     evTag->SetNumOfProtons(nProtons);
 433     evTag->SetNumOfKaons(nKaons);
 434     evTag->SetNumOfPions(nPions);
 435     evTag->SetNumOfMuons(nMuons);
 436     evTag->SetNumOfElectrons(nElectrons);
 437     evTag->SetNumOfPhotons(nGamas);
 438     evTag->SetNumOfPi0s(nPi0s);
 439     evTag->SetNumOfNeutrons(nNeutrons);
 440     evTag->SetNumOfKaon0s(nK0s);
 441
 442     evTag->SetNumOfChargedAbove1GeV(nCh1GeV);
 443     evTag->SetNumOfChargedAbove3GeV(nCh3GeV);
 444     evTag->SetNumOfChargedAbove10GeV(nCh10GeV);
 445     evTag->SetNumOfMuonsAbove1GeV(nMu1GeV);
 446     evTag->SetNumOfMuonsAbove3GeV(nMu3GeV);
 447     evTag->SetNumOfMuonsAbove10GeV(nMu10GeV);
 448     evTag->SetNumOfElectronsAbove1GeV(nEl1GeV);
 449     evTag->SetNumOfElectronsAbove3GeV(nEl3GeV);
 450     evTag->SetNumOfElectronsAbove10GeV(nEl10GeV);
 451
 452     evTag->SetNumOfPHOSClusters(esd->GetNumberOfPHOSClusters());
 453     evTag->SetNumOfEMCALClusters(esd->GetNumberOfEMCALClusters());
 454
 455     evTag->SetTotalMomentum(totalP);
 456     evTag->SetMeanPt(meanPt);
 457     evTag->SetMaxPt(maxPt);
 458
 459     tag->AddEventTag(*evTag);
 460   }//event loop
 461   lastEvent = iNumberOfEvents;
 462
 463   t->Delete("");
 464
 465   ttag.Fill();
 466   tag->Clear();
 467
 468   TString localFileName = "Run"; localFileName += tag->GetRunId();
 469   localFileName += ".Event"; localFileName += firstEvent; localFileName += "_"; localFileName += lastEvent; localFileName += "."; localFileName += Counter;
 470   localFileName += ".ESD.tag.root";
 471
 472   TString alienLocation = "/alien";
 473   alienLocation += gGrid->Pwd();
 474   alienLocation += fgridpath.Data();
 475   alienLocation += "/";
 476   alienLocation +=  localFileName;
 477   alienLocation += "?se=";
 478   alienLocation += fSE.Data();
 479
 480   TString fileName;
 481
 482   if(fStorage == 0)
 483     {
 484       fileName = localFileName.Data();
 485       AliInfo(Form("Writing tags to local file: %s",fileName.Data()));
 486     }
 487   if(fStorage == 1)
 488     {
 489       fileName = alienLocation.Data();
 490       AliInfo(Form("Writing tags to grid file: %s",fileName.Data()));
 491     }
 492
 493   TFile* ftag = TFile::Open(fileName, "recreate");
 494   ftag->cd();
 495   ttag.Write();
 496   ftag->Close();
 497
 498   delete ftag;
 499   delete esd;
 500
 501   delete tag;
 502 }
 503