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
 240   AliRunTag *tag = new AliRunTag();
 241   AliEventTag *evTag = new AliEventTag();
 242   TTree ttag("T","A Tree with event tags");
 243   TBranch * btag = ttag.Branch("AliTAG", &tag);
 244   btag->SetCompressionLevel(9);
 245
 246   AliInfo(Form("Creating the tags......."));
 247
 248   Int_t firstEvent = 0,lastEvent = 0;
 249   TTree *t = (TTree*) file->Get("esdTree");
 250   TBranch * b = t->GetBranch("ESD");
 251   AliESD *esd = 0;
 252   b->SetAddress(&esd);
 253
 254   tag->SetRunId(esd->GetRunNumber());
 255
 256   Int_t iNumberOfEvents = b->GetEntries();
 257   for (Int_t iEventNumber = 0; iEventNumber < iNumberOfEvents; iEventNumber++) {
 258     ntrack = 0;
 259     nPos = 0;
 260     nNeg = 0;
 261     nNeutr =0;
 262     nK0s = 0;
 263     nNeutrons = 0;
 264     nPi0s = 0;
 265     nGamas = 0;
 266     nProtons = 0;
 267     nKaons = 0;
 268     nPions = 0;
 269     nMuons = 0;
 270     nElectrons = 0;
 271     nCh1GeV = 0;
 272     nCh3GeV = 0;
 273     nCh10GeV = 0;
 274     nMu1GeV = 0;
 275     nMu3GeV = 0;
 276     nMu10GeV = 0;
 277     nEl1GeV = 0;
 278     nEl3GeV = 0;
 279     nEl10GeV = 0;
 280     maxPt = .0;
 281     meanPt = .0;
 282     totalP = .0;
 283
 284     b->GetEntry(iEventNumber);
 285     const AliESDVertex * vertexIn = esd->GetVertex();
 286
 287     for (Int_t iTrackNumber = 0; iTrackNumber < esd->GetNumberOfTracks(); iTrackNumber++) {
 288       AliESDtrack * esdTrack = esd->GetTrack(iTrackNumber);
 289       UInt_t status = esdTrack->GetStatus();
 290
 291       //select only tracks with ITS refit
 292       if ((status&AliESDtrack::kITSrefit)==0) continue;
 293       //select only tracks with TPC refit
 294       if ((status&AliESDtrack::kTPCrefit)==0) continue;
 295
 296       //select only tracks with the "combined PID"
 297       if ((status&AliESDtrack::kESDpid)==0) continue;
 298       Double_t p[3];
 299       esdTrack->GetPxPyPz(p);
 300       Double_t momentum = sqrt(pow(p[0],2) + pow(p[1],2) + pow(p[2],2));
 301       Double_t fPt = sqrt(pow(p[0],2) + pow(p[1],2));
 302       totalP += momentum;
 303       meanPt += fPt;
 304       if(fPt > maxPt) maxPt = fPt;
 305
 306       if(esdTrack->GetSign() > 0) {
 307         nPos++;
 308         if(fPt > fLowPtCut) nCh1GeV++;
 309         if(fPt > fHighPtCut) nCh3GeV++;
 310         if(fPt > fVeryHighPtCut) nCh10GeV++;
 311       }
 312       if(esdTrack->GetSign() < 0) {
 313         nNeg++;
 314         if(fPt > fLowPtCut) nCh1GeV++;
 315         if(fPt > fHighPtCut) nCh3GeV++;
 316         if(fPt > fVeryHighPtCut) nCh10GeV++;
 317       }
 318       if(esdTrack->GetSign() == 0) nNeutr++;
 319
 320       //PID
 321       Double_t prob[5];
 322       esdTrack->GetESDpid(prob);
 323
 324       Double_t rcc = 0.0;
 325       for(Int_t i = 0; i < AliPID::kSPECIES; i++) rcc += prob[i]*partFrac[i];
 326       if(rcc == 0.0) continue;
 327       //Bayes' formula
 328       Double_t w[5];
 329       for(Int_t i = 0; i < AliPID::kSPECIES; i++) w[i] = prob[i]*partFrac[i]/rcc;
 330
 331       //protons
 332       if ((w[4]>w[3])&&(w[4]>w[2])&&(w[4]>w[1])&&(w[4]>w[0])) nProtons++;
 333       //kaons
 334       if ((w[3]>w[4])&&(w[3]>w[2])&&(w[3]>w[1])&&(w[3]>w[0])) nKaons++;
 335       //pions
 336       if ((w[2]>w[4])&&(w[2]>w[3])&&(w[2]>w[1])&&(w[2]>w[0])) nPions++;
 337       //electrons
 338       if ((w[0]>w[4])&&(w[0]>w[3])&&(w[0]>w[2])&&(w[0]>w[1])) {
 339         nElectrons++;
 340         if(fPt > fLowPtCut) nEl1GeV++;
 341         if(fPt > fHighPtCut) nEl3GeV++;
 342         if(fPt > fVeryHighPtCut) nEl10GeV++;
 343       }
 344       ntrack++;
 345     }//esd track loop
 346
 347     /////////////
 348     //muon code//
 349     ////////////
 350     Int_t nMuonTracks = esd->GetNumberOfMuonTracks();
 351     // loop over all reconstructed tracks (also first track of combination)
 352     for (Int_t iTrack = 0; iTrack <  nMuonTracks;  iTrack++) {
 353       AliESDMuonTrack* muonTrack = esd->GetMuonTrack(iTrack);
 354       if (muonTrack == 0x0) continue;
 355
 356       // Coordinates at vertex
 357       fZ = muonTrack->GetZ();
 358       fY = muonTrack->GetBendingCoor();
 359       fX = muonTrack->GetNonBendingCoor();
 360
 361       fThetaX = muonTrack->GetThetaX();
 362       fThetaY = muonTrack->GetThetaY();
 363
 364       fPyz = 1./TMath::Abs(muonTrack->GetInverseBendingMomentum());
 365       fPzRec = - fPyz / TMath::Sqrt(1.0 + TMath::Tan(fThetaY)*TMath::Tan(fThetaY));
 366       fPxRec = fPzRec * TMath::Tan(fThetaX);
 367       fPyRec = fPzRec * TMath::Tan(fThetaY);
 368       fCharge = Int_t(TMath::Sign(1.,muonTrack->GetInverseBendingMomentum()));
 369
 370       //ChiSquare of the track if needed
 371       fChisquare = muonTrack->GetChi2()/(2.0 * muonTrack->GetNHit() - 5);
 372       fEnergy = TMath::Sqrt(fMUONMASS * fMUONMASS + fPxRec * fPxRec + fPyRec * fPyRec + fPzRec * fPzRec);
 373       fEPvector.SetPxPyPzE(fPxRec, fPyRec, fPzRec, fEnergy);
 374
 375       // total number of muons inside a vertex cut
 376       if((TMath::Abs(fZ)<fZVertexCut) && (TMath::Sqrt(fY*fY+fX*fX)<fRhoVertexCut)) {
 377         nMuons++;
 378         if(fEPvector.Pt() > fLowPtCut) {
 379           nMu1GeV++;
 380           if(fEPvector.Pt() > fHighPtCut) {
 381             nMu3GeV++;
 382             if (fEPvector.Pt() > fVeryHighPtCut) {
 383               nMu10GeV++;
 384             }
 385           }
 386         }
 387       }
 388     }//muon track loop
 389
 390     // Fill the event tags
 391     if(ntrack != 0)
 392       meanPt = meanPt/ntrack;
 393
 394     evTag->SetEventId(iEventNumber+1);
 395     evTag->SetGUID(guid);
 396     evTag->SetMD5(md5);
 397     evTag->SetTURL(turl);
 398     evTag->SetSize(size);
 399     evTag->SetVertexX(vertexIn->GetXv());
 400     evTag->SetVertexY(vertexIn->GetYv());
 401     evTag->SetVertexZ(vertexIn->GetZv());
 402
 403     evTag->SetT0VertexZ(esd->GetT0zVertex());
 404
 405     evTag->SetTrigger(esd->GetTrigger());
 406
 407     evTag->SetZDCNeutronEnergy(esd->GetZDCNEnergy());
 408     evTag->SetZDCProtonEnergy(esd->GetZDCPEnergy());
 409     evTag->SetZDCEMEnergy(esd->GetZDCEMEnergy());
 410     evTag->SetNumOfParticipants(esd->GetZDCParticipants());
 411
 412
 413     evTag->SetNumOfTracks(esd->GetNumberOfTracks());
 414     evTag->SetNumOfPosTracks(nPos);
 415     evTag->SetNumOfNegTracks(nNeg);
 416     evTag->SetNumOfNeutrTracks(nNeutr);
 417
 418     evTag->SetNumOfV0s(esd->GetNumberOfV0s());
 419     evTag->SetNumOfCascades(esd->GetNumberOfCascades());
 420     evTag->SetNumOfKinks(esd->GetNumberOfKinks());
 421     evTag->SetNumOfPMDTracks(esd->GetNumberOfPmdTracks());
 422
 423     evTag->SetNumOfProtons(nProtons);
 424     evTag->SetNumOfKaons(nKaons);
 425     evTag->SetNumOfPions(nPions);
 426     evTag->SetNumOfMuons(nMuons);
 427     evTag->SetNumOfElectrons(nElectrons);
 428     evTag->SetNumOfPhotons(nGamas);
 429     evTag->SetNumOfPi0s(nPi0s);
 430     evTag->SetNumOfNeutrons(nNeutrons);
 431     evTag->SetNumOfKaon0s(nK0s);
 432
 433     evTag->SetNumOfChargedAbove1GeV(nCh1GeV);
 434     evTag->SetNumOfChargedAbove3GeV(nCh3GeV);
 435     evTag->SetNumOfChargedAbove10GeV(nCh10GeV);
 436     evTag->SetNumOfMuonsAbove1GeV(nMu1GeV);
 437     evTag->SetNumOfMuonsAbove3GeV(nMu3GeV);
 438     evTag->SetNumOfMuonsAbove10GeV(nMu10GeV);
 439     evTag->SetNumOfElectronsAbove1GeV(nEl1GeV);
 440     evTag->SetNumOfElectronsAbove3GeV(nEl3GeV);
 441     evTag->SetNumOfElectronsAbove10GeV(nEl10GeV);
 442
 443     evTag->SetNumOfPHOSClusters(esd->GetNumberOfPHOSClusters());
 444     evTag->SetNumOfEMCALClusters(esd->GetNumberOfEMCALClusters());
 445
 446     evTag->SetTotalMomentum(totalP);
 447     evTag->SetMeanPt(meanPt);
 448     evTag->SetMaxPt(maxPt);
 449
 450     tag->AddEventTag(*evTag);
 451   }//event loop
 452   lastEvent = iNumberOfEvents;
 453
 454   t->Delete("");
 455
 456   ttag.Fill();
 457   tag->Clear();
 458
 459   TString localFileName = "Run"; localFileName += tag->GetRunId();
 460   localFileName += ".Event"; localFileName += firstEvent; localFileName += "_"; localFileName += lastEvent; localFileName += "."; localFileName += Counter;
 461   localFileName += ".ESD.tag.root";
 462
 463   TString alienLocation = "/alien";
 464   alienLocation += gGrid->Pwd();
 465   alienLocation += fgridpath.Data();
 466   alienLocation += "/";
 467   alienLocation +=  localFileName;
 468   alienLocation += "?se=";
 469   alienLocation += fSE.Data();
 470
 471   TString fileName;
 472
 473   if(fStorage == 0)
 474     {
 475       fileName = localFileName.Data();
 476       AliInfo(Form("Writing tags to local file: %s",fileName.Data()));
 477     }
 478   if(fStorage == 1)
 479     {
 480       fileName = alienLocation.Data();
 481       AliInfo(Form("Writing tags to grid file: %s",fileName.Data()));
 482     }
 483
 484   TFile* ftag = TFile::Open(fileName, "recreate");
 485   ftag->cd();
 486   ttag.Write();
 487   ftag->Close();
 488
 489   delete ftag;
 490   delete esd;
 491
 492   delete tag;
 493   delete evTag;
 494 }
 495