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 evTag;
 201   delete newTag;
 202
 203   return kTRUE;
 204 }
 205
 206 //_____________________________________________________________________________
 207 void AliTagCreator::CreateTag(TFile* file, const char *guid, const char *md5, const char *turl, Long64_t size, Int_t Counter)
 208 {
 209   /////////////
 210   //muon code//
 211   ////////////
 212   Double_t fMUONMASS = 0.105658369;
 213   //Variables
 214   Double_t fX,fY,fZ ;
 215   Double_t fThetaX, fThetaY, fPyz, fChisquare;
 216   Double_t fPxRec, fPyRec, fPzRec, fEnergy;
 217   Int_t fCharge;
 218   TLorentzVector fEPvector;
 219
 220   Float_t fZVertexCut = 10.0;
 221   Float_t fRhoVertexCut = 2.0;
 222
 223   Float_t fLowPtCut = 1.0;
 224   Float_t fHighPtCut = 3.0;
 225   Float_t fVeryHighPtCut = 10.0;
 226   ////////////
 227
 228   Double_t partFrac[5] = {0.01, 0.01, 0.85, 0.10, 0.05};
 229
 230   // Creates the tags for all the events in a given ESD file
 231   Int_t ntrack;
 232   Int_t nProtons, nKaons, nPions, nMuons, nElectrons;
 233   Int_t nPos, nNeg, nNeutr;
 234   Int_t nK0s, nNeutrons, nPi0s, nGamas;
 235   Int_t nCh1GeV, nCh3GeV, nCh10GeV;
 236   Int_t nMu1GeV, nMu3GeV, nMu10GeV;
 237   Int_t nEl1GeV, nEl3GeV, nEl10GeV;
 238   Float_t maxPt = .0, meanPt = .0, totalP = .0;
 239   Int_t fVertexflag;
 240   TString fVertexName;
 241
 242   AliRunTag *tag = new AliRunTag();
 243   AliEventTag *evTag = new AliEventTag();
 244   TTree ttag("T","A Tree with event tags");
 245   TBranch * btag = ttag.Branch("AliTAG", &tag);
 246   btag->SetCompressionLevel(9);
 247
 248   AliInfo(Form("Creating the tags......."));
 249
 250   Int_t firstEvent = 0,lastEvent = 0;
 251   TTree *t = (TTree*) file->Get("esdTree");
 252   TBranch * b = t->GetBranch("ESD");
 253   AliESD *esd = 0;
 254   b->SetAddress(&esd);
 255
 256   tag->SetRunId(esd->GetRunNumber());
 257
 258   Int_t iNumberOfEvents = b->GetEntries();
 259   for (Int_t iEventNumber = 0; iEventNumber < iNumberOfEvents; iEventNumber++) {
 260     ntrack = 0;
 261     nPos = 0;
 262     nNeg = 0;
 263     nNeutr =0;
 264     nK0s = 0;
 265     nNeutrons = 0;
 266     nPi0s = 0;
 267     nGamas = 0;
 268     nProtons = 0;
 269     nKaons = 0;
 270     nPions = 0;
 271     nMuons = 0;
 272     nElectrons = 0;
 273     nCh1GeV = 0;
 274     nCh3GeV = 0;
 275     nCh10GeV = 0;
 276     nMu1GeV = 0;
 277     nMu3GeV = 0;
 278     nMu10GeV = 0;
 279     nEl1GeV = 0;
 280     nEl3GeV = 0;
 281     nEl10GeV = 0;
 282     maxPt = .0;
 283     meanPt = .0;
 284     totalP = .0;
 285     fVertexflag = 1;
 286
 287     b->GetEntry(iEventNumber);
 288     const AliESDVertex * vertexIn = esd->GetVertex();
 289     fVertexName = vertexIn->GetName();
 290     if(fVertexName == "default") fVertexflag = 0;
 291
 292     for (Int_t iTrackNumber = 0; iTrackNumber < esd->GetNumberOfTracks(); iTrackNumber++) {
 293       AliESDtrack * esdTrack = esd->GetTrack(iTrackNumber);
 294       UInt_t status = esdTrack->GetStatus();
 295
 296       //select only tracks with ITS refit
 297       if ((status&AliESDtrack::kITSrefit)==0) continue;
 298       //select only tracks with TPC refit
 299       if ((status&AliESDtrack::kTPCrefit)==0) continue;
 300
 301       //select only tracks with the "combined PID"
 302       if ((status&AliESDtrack::kESDpid)==0) continue;
 303       Double_t p[3];
 304       esdTrack->GetPxPyPz(p);
 305       Double_t momentum = sqrt(pow(p[0],2) + pow(p[1],2) + pow(p[2],2));
 306       Double_t fPt = sqrt(pow(p[0],2) + pow(p[1],2));
 307       totalP += momentum;
 308       meanPt += fPt;
 309       if(fPt > maxPt) maxPt = fPt;
 310
 311       if(esdTrack->GetSign() > 0) {
 312         nPos++;
 313         if(fPt > fLowPtCut) nCh1GeV++;
 314         if(fPt > fHighPtCut) nCh3GeV++;
 315         if(fPt > fVeryHighPtCut) nCh10GeV++;
 316       }
 317       if(esdTrack->GetSign() < 0) {
 318         nNeg++;
 319         if(fPt > fLowPtCut) nCh1GeV++;
 320         if(fPt > fHighPtCut) nCh3GeV++;
 321         if(fPt > fVeryHighPtCut) nCh10GeV++;
 322       }
 323       if(esdTrack->GetSign() == 0) nNeutr++;
 324
 325       //PID
 326       Double_t prob[5];
 327       esdTrack->GetESDpid(prob);
 328
 329       Double_t rcc = 0.0;
 330       for(Int_t i = 0; i < AliPID::kSPECIES; i++) rcc += prob[i]*partFrac[i];
 331       if(rcc == 0.0) continue;
 332       //Bayes' formula
 333       Double_t w[5];
 334       for(Int_t i = 0; i < AliPID::kSPECIES; i++) w[i] = prob[i]*partFrac[i]/rcc;
 335
 336       //protons
 337       if ((w[4]>w[3])&&(w[4]>w[2])&&(w[4]>w[1])&&(w[4]>w[0])) nProtons++;
 338       //kaons
 339       if ((w[3]>w[4])&&(w[3]>w[2])&&(w[3]>w[1])&&(w[3]>w[0])) nKaons++;
 340       //pions
 341       if ((w[2]>w[4])&&(w[2]>w[3])&&(w[2]>w[1])&&(w[2]>w[0])) nPions++;
 342       //electrons
 343       if ((w[0]>w[4])&&(w[0]>w[3])&&(w[0]>w[2])&&(w[0]>w[1])) {
 344         nElectrons++;
 345         if(fPt > fLowPtCut) nEl1GeV++;
 346         if(fPt > fHighPtCut) nEl3GeV++;
 347         if(fPt > fVeryHighPtCut) nEl10GeV++;
 348       }
 349       ntrack++;
 350     }//esd track loop
 351
 352     /////////////
 353     //muon code//
 354     ////////////
 355     Int_t nMuonTracks = esd->GetNumberOfMuonTracks();
 356     // loop over all reconstructed tracks (also first track of combination)
 357     for (Int_t iTrack = 0; iTrack <  nMuonTracks;  iTrack++) {
 358       AliESDMuonTrack* muonTrack = esd->GetMuonTrack(iTrack);
 359       if (muonTrack == 0x0) continue;
 360
 361       // Coordinates at vertex
 362       fZ = muonTrack->GetZ();
 363       fY = muonTrack->GetBendingCoor();
 364       fX = muonTrack->GetNonBendingCoor();
 365
 366       fThetaX = muonTrack->GetThetaX();
 367       fThetaY = muonTrack->GetThetaY();
 368
 369       fPyz = 1./TMath::Abs(muonTrack->GetInverseBendingMomentum());
 370       fPzRec = - fPyz / TMath::Sqrt(1.0 + TMath::Tan(fThetaY)*TMath::Tan(fThetaY));
 371       fPxRec = fPzRec * TMath::Tan(fThetaX);
 372       fPyRec = fPzRec * TMath::Tan(fThetaY);
 373       fCharge = Int_t(TMath::Sign(1.,muonTrack->GetInverseBendingMomentum()));
 374
 375       //ChiSquare of the track if needed
 376       fChisquare = muonTrack->GetChi2()/(2.0 * muonTrack->GetNHit() - 5);
 377       fEnergy = TMath::Sqrt(fMUONMASS * fMUONMASS + fPxRec * fPxRec + fPyRec * fPyRec + fPzRec * fPzRec);
 378       fEPvector.SetPxPyPzE(fPxRec, fPyRec, fPzRec, fEnergy);
 379
 380       // total number of muons inside a vertex cut
 381       if((TMath::Abs(fZ)<fZVertexCut) && (TMath::Sqrt(fY*fY+fX*fX)<fRhoVertexCut)) {
 382         nMuons++;
 383         if(fEPvector.Pt() > fLowPtCut) {
 384           nMu1GeV++;
 385           if(fEPvector.Pt() > fHighPtCut) {
 386             nMu3GeV++;
 387             if (fEPvector.Pt() > fVeryHighPtCut) {
 388               nMu10GeV++;
 389             }
 390           }
 391         }
 392       }
 393     }//muon track loop
 394
 395     // Fill the event tags
 396     if(ntrack != 0)
 397       meanPt = meanPt/ntrack;
 398
 399     evTag->SetEventId(iEventNumber+1);
 400     evTag->SetGUID(guid);
 401     evTag->SetMD5(md5);
 402     evTag->SetTURL(turl);
 403     evTag->SetSize(size);
 404     evTag->SetVertexX(vertexIn->GetXv());
 405     evTag->SetVertexY(vertexIn->GetYv());
 406     evTag->SetVertexZ(vertexIn->GetZv());
 407     evTag->SetVertexZError(vertexIn->GetZRes());
 408     evTag->SetVertexFlag(fVertexflag);
 409
 410     evTag->SetT0VertexZ(esd->GetT0zVertex());
 411
 412     evTag->SetTrigger(esd->GetTrigger());
 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   delete evTag;
 503 }
 504