// The reconstruction requires digits or raw data as input. For the creation //
// of digits and raw data have a look at the class AliSimulation. //
// //
+// The input data of a detector can be replaced by the corresponding HLT //
+// data by calling (usual detector string) //
+// SetUseHLTData("..."); //
+// //
// For debug purposes the method SetCheckPointLevel can be used. If the //
// argument is greater than 0, files with ESD events will be written after //
// selected steps of the reconstruction for each event: //
#include <TLorentzVector.h>
#include <TArrayS.h>
#include <TArrayD.h>
+#include <TObjArray.h>
#include "AliReconstruction.h"
#include "AliCodeTimer.h"
#include "AliESDkink.h"
#include "AliESDtrack.h"
#include "AliESDCaloCluster.h"
+#include "AliESDCaloCells.h"
#include "AliMultiplicity.h"
#include "AliTracker.h"
#include "AliVertexer.h"
#include "AliGeomManager.h"
#include "AliTrackPointArray.h"
#include "AliCDBManager.h"
+#include "AliCDBStorage.h"
#include "AliCDBEntry.h"
#include "AliAlignObj.h"
#include "AliCentralTrigger.h"
+#include "AliTriggerConfiguration.h"
+#include "AliTriggerClass.h"
#include "AliCTPRawStream.h"
#include "AliAODEvent.h"
#include "AliAODFmdCluster.h"
#include "AliAODTracklets.h"
-//#include "AliQADataMaker.h"
+#include "AliQADataMakerRec.h"
+#include "AliGlobalQADataMaker.h"
#include "AliQA.h"
#include "AliQADataMakerSteer.h"
+#include "AliPlaneEff.h"
+
#include "AliSysInfo.h" // memory snapshots
+#include "AliRawHLTManager.h"
ClassImp(AliReconstruction)
const char* AliReconstruction::fgkDetectorName[AliReconstruction::fgkNDetectors] = {"ITS", "TPC", "TRD", "TOF", "PHOS", "HMPID", "EMCAL", "MUON", "FMD", "ZDC", "PMD", "T0", "VZERO", "ACORDE", "HLT"};
//_____________________________________________________________________________
-AliReconstruction::AliReconstruction(const char* gAliceFilename, const char* cdbUri,
+AliReconstruction::AliReconstruction(const char* gAliceFilename,
const char* name, const char* title) :
TNamed(name, title),
fUniformField(kTRUE),
fRunVertexFinder(kTRUE),
+ fRunVertexFinderTracks(kTRUE),
fRunHLTTracking(kFALSE),
fRunMuonTracking(kFALSE),
fRunV0Finder(kTRUE),
fFillTriggerESD(kTRUE),
fCleanESD(kTRUE),
+ fV0DCAmax(3.),
+ fV0CsPmin(0.),
fDmax(50.),
fZmax(50.),
fLoadAlignFromCDB(kTRUE),
fLoadAlignData("ALL"),
fESDPar(""),
+ fUseHLTData(),
fRunLoader(NULL),
fRawReader(NULL),
+ fParentRawReader(NULL),
fVertexer(NULL),
fDiamondProfile(NULL),
+ fDiamondProfileTPC(NULL),
+ fMeanVertexConstraint(kTRUE),
fGRPList(NULL),
fAlignObjArray(NULL),
- fCDBUri(cdbUri),
- fRemoteCDBUri(""),
+ fCDBUri(),
fSpecCDBUri(),
- fRunQA(kTRUE)
+ fInitCDBCalled(kFALSE),
+ fSetRunNumberFromDataCalled(kFALSE),
+ fRunQA(kTRUE),
+ fRunGlobalQA(kTRUE),
+ fInLoopQA(kFALSE),
+ fRunPlaneEff(kFALSE)
{
// create reconstruction object with default parameters
fReconstructor[iDet] = NULL;
fLoader[iDet] = NULL;
fTracker[iDet] = NULL;
-// fQADataMaker[iDet] = NULL;
-// fQACycles[iDet] = 999999;
+ fQADataMaker[iDet] = NULL;
+ fQACycles[iDet] = 999999;
}
+ fQADataMaker[fgkNDetectors]=NULL; //Global QA
AliPID pid;
}
fUniformField(rec.fUniformField),
fRunVertexFinder(rec.fRunVertexFinder),
+ fRunVertexFinderTracks(rec.fRunVertexFinderTracks),
fRunHLTTracking(rec.fRunHLTTracking),
fRunMuonTracking(rec.fRunMuonTracking),
fRunV0Finder(rec.fRunV0Finder),
fFillTriggerESD(rec.fFillTriggerESD),
fCleanESD(rec.fCleanESD),
+ fV0DCAmax(rec.fV0DCAmax),
+ fV0CsPmin(rec.fV0CsPmin),
fDmax(rec.fDmax),
fZmax(rec.fZmax),
fLoadAlignFromCDB(rec.fLoadAlignFromCDB),
fLoadAlignData(rec.fLoadAlignData),
fESDPar(rec.fESDPar),
+ fUseHLTData(rec.fUseHLTData),
fRunLoader(NULL),
fRawReader(NULL),
+ fParentRawReader(NULL),
fVertexer(NULL),
fDiamondProfile(NULL),
+ fDiamondProfileTPC(NULL),
+ fMeanVertexConstraint(rec.fMeanVertexConstraint),
fGRPList(NULL),
fAlignObjArray(rec.fAlignObjArray),
fCDBUri(rec.fCDBUri),
- fRemoteCDBUri(rec.fRemoteCDBUri),
fSpecCDBUri(),
- fRunQA(kTRUE)
+ fInitCDBCalled(rec.fInitCDBCalled),
+ fSetRunNumberFromDataCalled(rec.fSetRunNumberFromDataCalled),
+ fRunQA(rec.fRunQA),
+ fRunGlobalQA(rec.fRunGlobalQA),
+ fInLoopQA(rec.fInLoopQA),
+ fRunPlaneEff(rec.fRunPlaneEff)
{
// copy constructor
fReconstructor[iDet] = NULL;
fLoader[iDet] = NULL;
fTracker[iDet] = NULL;
-// fQADataMaker[iDet] = NULL;
-// fQACycles[iDet] = rec.fQACycles[iDet];
+ fQADataMaker[iDet] = NULL;
+ fQACycles[iDet] = rec.fQACycles[iDet];
}
+ fQADataMaker[fgkNDetectors]=NULL; //Global QA
for (Int_t i = 0; i < rec.fSpecCDBUri.GetEntriesFast(); i++) {
if (rec.fSpecCDBUri[i]) fSpecCDBUri.Add(rec.fSpecCDBUri[i]->Clone());
}
}
//_____________________________________________________________________________
-void AliReconstruction::InitCDBStorage()
+void AliReconstruction::InitCDB()
{
// activate a default CDB storage
// First check if we have any CDB storage set, because it is used
// to retrieve the calibration and alignment constants
+ if (fInitCDBCalled) return;
+ fInitCDBCalled = kTRUE;
+
AliCDBManager* man = AliCDBManager::Instance();
if (man->IsDefaultStorageSet())
{
AliWarning("Default CDB storage has been already set !");
AliWarning(Form("Ignoring the default storage declared in AliReconstruction: %s",fCDBUri.Data()));
AliWarning("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
- fCDBUri = "";
+ fCDBUri = man->GetDefaultStorage()->GetURI();
}
else {
- AliDebug(2, "!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
- AliDebug(2, Form("Default CDB storage is set to: %s",fCDBUri.Data()));
- AliDebug(2, "!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
+ if (fCDBUri.Length() > 0)
+ {
+ AliDebug(2,"!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
+ AliDebug(2, Form("Default CDB storage is set to: %s", fCDBUri.Data()));
+ AliDebug(2, "!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
+ } else {
+ fCDBUri="local://$ALICE_ROOT";
+ AliWarning("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
+ AliWarning("Default CDB storage not yet set !!!!");
+ AliWarning(Form("Setting it now to: %s", fCDBUri.Data()));
+ AliWarning("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
+
+ }
man->SetDefaultStorage(fCDBUri);
}
- // Remote storage (the Grid storage) is used if it is activated
- // and if the object is not found in the default storage
- // OBSOLETE: Removed
- // if (man->IsRemoteStorageSet())
- // {
- // AliWarning("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
- // AliWarning("Remote CDB storage has been already set !");
- // AliWarning(Form("Ignoring the remote storage declared in AliReconstruction: %s",fRemoteCDBUri.Data()));
- // AliWarning("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
- // fRemoteCDBUri = "";
- // }
- // else {
- // AliDebug(2,"!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
- // AliDebug(2, Form("Remote CDB storage is set to: %s",fRemoteCDBUri.Data()));
- // AliDebug(2, "!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
- // man->SetRemoteStorage(fRemoteCDBUri);
- // }
-
// Now activate the detector specific CDB storage locations
for (Int_t i = 0; i < fSpecCDBUri.GetEntriesFast(); i++) {
TObject* obj = fSpecCDBUri[i];
AliDebug(2, "!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
man->SetSpecificStorage(obj->GetName(), obj->GetTitle());
}
- man->Print();
+
}
//_____________________________________________________________________________
}
-//_____________________________________________________________________________
-void AliReconstruction::SetRemoteStorage(const char* uri) {
-// Store the desired remote CDB storage location
-// Activate it later within the Run() method
-// Remote storage (the Grid storage) is used if it is activated
-// and if the object is not found in the default storage
-
- fRemoteCDBUri = uri;
-
-}
-
//_____________________________________________________________________________
void AliReconstruction::SetSpecificStorage(const char* calibType, const char* uri) {
// Store a detector-specific CDB storage location
}
-
-
-
//_____________________________________________________________________________
-Bool_t AliReconstruction::SetRunNumber()
+Bool_t AliReconstruction::SetRunNumberFromData()
{
// The method is called in Run() in order
// to set a correct run number.
// In case of raw data reconstruction the
// run number is taken from the raw data header
- if(AliCDBManager::Instance()->GetRun() < 0) {
- if (!fRunLoader) {
+ if (fSetRunNumberFromDataCalled) return kTRUE;
+ fSetRunNumberFromDataCalled = kTRUE;
+
+ AliCDBManager* man = AliCDBManager::Instance();
+
+ if(man->GetRun() > 0) {
+ AliWarning("Run number is taken from event header! Ignoring settings in AliCDBManager!");
+ }
+
+ if (!fRunLoader) {
AliError("No run loader is found !");
return kFALSE;
}
AliError("Neither gAlice nor RawReader objects are found !");
return kFALSE;
}
- }
- AliInfo(Form("CDB Run number: %d",AliCDBManager::Instance()->GetRun()));
}
+
+ man->Print();
+
return kTRUE;
}
+//_____________________________________________________________________________
+void AliReconstruction::SetCDBLock() {
+ // Set CDB lock: from now on it is forbidden to reset the run number
+ // or the default storage or to activate any further storage!
+
+ AliCDBManager::Instance()->SetLock(1);
+}
+
//_____________________________________________________________________________
Bool_t AliReconstruction::MisalignGeometry(const TString& detectors)
{
//_____________________________________________________________________________
-Bool_t AliReconstruction::Run(const char* input)
+Bool_t AliReconstruction::Run(const char* input, Bool_t IsOnline)
{
// run the reconstruction
AliCodeTimerAuto("")
// set the input
- if (!input) input = fInput.Data();
- TString fileName(input);
- if (fileName.EndsWith("/")) {
- fRawReader = new AliRawReaderFile(fileName);
- } else if (fileName.EndsWith(".root")) {
- fRawReader = new AliRawReaderRoot(fileName);
- } else if (!fileName.IsNull()) {
- fRawReader = new AliRawReaderDate(fileName);
- fRawReader->SelectEvents(7);
+ if (!IsOnline) {
+ if (!input) input = fInput.Data();
+ TString fileName(input);
+ if (fileName.EndsWith("/")) {
+ fRawReader = new AliRawReaderFile(fileName);
+ } else if (fileName.EndsWith(".root")) {
+ fRawReader = new AliRawReaderRoot(fileName);
+ } else if (!fileName.IsNull()) {
+ fRawReader = new AliRawReaderDate(fileName);
+ }
}
+ else {
+ if (!input) {
+ AliError("Null pointer to the event structure!");
+ return kFALSE;
+ }
+ fRawReader = new AliRawReaderDate((void *)input);
+ }
+
if (!fEquipIdMap.IsNull() && fRawReader)
fRawReader->LoadEquipmentIdsMap(fEquipIdMap);
+ if (!fUseHLTData.IsNull()) {
+ // create the RawReaderHLT which performs redirection of HLT input data for
+ // the specified detectors
+ AliRawReader* pRawReader=AliRawHLTManager::CreateRawReaderHLT(fRawReader, fUseHLTData.Data());
+ if (pRawReader) {
+ fParentRawReader=fRawReader;
+ fRawReader=pRawReader;
+ } else {
+ AliError(Form("can not create Raw Reader for HLT input %s", fUseHLTData.Data()));
+ }
+ }
+
AliSysInfo::AddStamp("Start");
// get the run loader
if (!InitRunLoader()) return kFALSE;
AliSysInfo::AddStamp("LoadLoader");
// Initialize the CDB storage
- InitCDBStorage();
- AliSysInfo::AddStamp("LoadCDB");
+ InitCDB();
+
+ AliSysInfo::AddStamp("LoadCDB");
// Set run number in CDBManager (if it is not already set by the user)
- if (!SetRunNumber()) if (fStopOnError) return kFALSE;
-
+ if (!SetRunNumberFromData()) if (fStopOnError) return kFALSE;
+
+ // Set CDB lock: from now on it is forbidden to reset the run number
+ // or the default storage or to activate any further storage!
+ SetCDBLock();
+
// Import ideal TGeo geometry and apply misalignment
if (!gGeoManager) {
TString geom(gSystem->DirName(fGAliceFileName));
if (!MisalignGeometry(fLoadAlignData)) if (fStopOnError) return kFALSE;
AliSysInfo::AddStamp("LoadGeom");
+ //QA
+ Int_t sameQACycle = kFALSE ;
+ AliQADataMakerSteer qas ;
+ if (fRunQA && fRawReader) {
+ qas.Run(fRunLocalReconstruction, fRawReader) ;
+ sameQACycle = kTRUE;
+ }
+ // checking the QA of previous steps
+ //CheckQA() ;
+
+ /*
// local reconstruction
if (!fRunLocalReconstruction.IsNull()) {
if (!RunLocalReconstruction(fRunLocalReconstruction)) {
if (fStopOnError) {CleanUp(); return kFALSE;}
}
}
-// if (!fRunVertexFinder && fRunTracking.IsNull() &&
-// fFillESD.IsNull()) return kTRUE;
+ */
// get vertexer
if (fRunVertexFinder && !CreateVertexer()) {
AliError("No diamond profile found in OCDB!");
}
+ entry = 0;
+ entry = AliCDBManager::Instance()
+ ->Get("GRP/Calib/MeanVertexTPC");
+
+ if(entry) {
+ fDiamondProfileTPC = dynamic_cast<AliESDVertex*> (entry->GetObject());
+ } else {
+ AliError("No diamond profile found in OCDB!");
+ }
+
AliVertexerTracks tVertexer(AliTracker::GetBz());
- if(fDiamondProfile) tVertexer.SetVtxStart(fDiamondProfile);
+ if(fDiamondProfile && fMeanVertexConstraint) tVertexer.SetVtxStart(fDiamondProfile);
- // loop over events
-
if (fRawReader) fRawReader->RewindEvents();
- TString detStr(fFillESD) ;
ProcInfo_t ProcInfo;
gSystem->GetProcInfo(&ProcInfo);
AliInfo(Form("Current memory usage %d %d", ProcInfo.fMemResident, ProcInfo.fMemVirtual));
- // checking the QA of previous steps
- CheckQA() ;
-
+
+ //Initialize the QA and start of cycle for out-of-cycle QA
+ if (fRunQA) {
+ TString detStr(fFillESD);
+ for (Int_t iDet = 0; iDet < fgkNDetectors; iDet++) {
+ if (!IsSelected(fgkDetectorName[iDet], detStr)) continue;
+ AliQADataMakerRec *qadm = GetQADataMaker(iDet);
+ if (!qadm) continue;
+ AliInfo(Form("Initializing the QA data maker for %s",
+ fgkDetectorName[iDet]));
+ qadm->Init(AliQA::kRECPOINTS, AliCDBManager::Instance()->GetRun());
+ qadm->Init(AliQA::kESDS, AliCDBManager::Instance()->GetRun());
+ // if (!fInLoopQA) {
+// qadm->StartOfCycle(AliQA::kRECPOINTS);
+// qadm->StartOfCycle(AliQA::kESDS,"same");
+// }
+ }
+ }
+ if (fRunGlobalQA) {
+ AliQADataMakerRec *qadm = GetQADataMaker(AliQA::kGLOBAL);
+ AliInfo(Form("Initializing the global QA data maker"));
+ TObjArray *arr=
+ qadm->Init(AliQA::kRECPOINTS, AliCDBManager::Instance()->GetRun());
+ AliTracker::SetResidualsArray(arr);
+ qadm->Init(AliQA::kESDS, AliCDBManager::Instance()->GetRun());
+ if (!fInLoopQA) {
+ qadm->StartOfCycle(AliQA::kRECPOINTS, sameQACycle);
+ qadm->StartOfCycle(AliQA::kESDS, "same");
+ }
+ }
+
+ //Initialize the Plane Efficiency framework
+ if (fRunPlaneEff && !InitPlaneEff()) {
+ if(fStopOnError) {CleanUp(file, fileOld); return kFALSE;}
+ }
+
+ //******* The loop over events
for (Int_t iEvent = 0; iEvent < fRunLoader->GetNumberOfEvents(); iEvent++) {
if (fRawReader) fRawReader->NextEvent();
if ((iEvent < fFirstEvent) || ((fLastEvent >= 0) && (iEvent > fLastEvent))) {
if (treeOld) {
esd->ReadFromTree(treeOld);
treeOld->GetEntry(iEvent);
+ tree->Fill();
}
- tree->Fill();
if (hlttreeOld) {
esd->ReadFromTree(hlttreeOld);
hlttreeOld->GetEntry(iEvent);
+ hlttree->Fill();
}
- hlttree->Fill();
continue;
}
AliInfo(Form("processing event %d", iEvent));
+
+ //Start of cycle for the in-loop QA
+ if (fInLoopQA) {
+ if (fRunQA) {
+ TString detStr(fFillESD);
+ for (Int_t iDet = 0; iDet < fgkNDetectors; iDet++) {
+ if (!IsSelected(fgkDetectorName[iDet], detStr)) continue;
+ AliQADataMakerRec *qadm = GetQADataMaker(iDet);
+ if (!qadm) continue;
+ qadm->StartOfCycle(AliQA::kRECPOINTS, sameQACycle);
+ qadm->StartOfCycle(AliQA::kESDS, "same") ;
+ }
+ }
+ if (fRunGlobalQA) {
+ AliQADataMakerRec *qadm = GetQADataMaker(AliQA::kGLOBAL);
+ qadm->StartOfCycle(AliQA::kRECPOINTS, sameQACycle);
+ qadm->StartOfCycle(AliQA::kESDS, "same");
+ }
+ }
+
fRunLoader->GetEvent(iEvent);
char aFileName[256];
fRunLoader->GetHeader()->GetEventNrInRun());
if (!gSystem->AccessPathName(aFileName)) continue;
- // local reconstruction
+ // local signle event reconstruction
if (!fRunLocalReconstruction.IsNull()) {
if (!RunLocalEventReconstruction(fRunLocalReconstruction)) {
if (fStopOnError) {CleanUp(file, fileOld); return kFALSE;}
}
}
-
esd->SetRunNumber(fRunLoader->GetHeader()->GetRun());
hltesd->SetRunNumber(fRunLoader->GetHeader()->GetRun());
esd->SetEventNumberInFile(fRunLoader->GetHeader()->GetEventNrInRun());
// HLT tracking
if (!fRunTracking.IsNull()) {
if (fRunHLTTracking) {
- hltesd->SetVertex(esd->GetVertex());
+ hltesd->SetPrimaryVertexSPD(esd->GetVertex());
if (!RunHLTTracking(hltesd)) {
if (fStopOnError) {CleanUp(file, fileOld); return kFALSE;}
}
}
}
-// if (!fFillESD.IsNull())
-// RunQA(fFillESD.Data(), esd);
-
// fill Event header information from the RawEventHeader
if (fRawReader){FillRawEventHeaderESD(esd);}
file->cd();
- //Try to improve the reconstructed primary vertex position using the tracks
- AliESDVertex *pvtx=0;
- Bool_t dovertex=kTRUE;
- TObject* obj = fOptions.FindObject("ITS");
+ //
+ // Propagate track to the beam pipe (if not laready done by ITS)
+ //
+ const Int_t ntracks = esd->GetNumberOfTracks();
+ const Double_t kBz = esd->GetMagneticField();
+ const Double_t kRadius = 2.8; //something less than the beam pipe radius
+
+ TObjArray trkArray;
+ UShort_t *selectedIdx=new UShort_t[ntracks];
+
+ for (Int_t itrack=0; itrack<ntracks; itrack++){
+ const Double_t kMaxStep = 5; //max step over the material
+ Bool_t ok;
+
+ AliESDtrack *track = esd->GetTrack(itrack);
+ if (!track) continue;
+
+ AliExternalTrackParam *tpcTrack =
+ (AliExternalTrackParam *)track->GetTPCInnerParam();
+ ok = kFALSE;
+ if (tpcTrack)
+ ok = AliTracker::
+ PropagateTrackTo(tpcTrack,kRadius,track->GetMass(),kMaxStep,kTRUE);
+
+
+
+ if (ok) {
+ Int_t n=trkArray.GetEntriesFast();
+ selectedIdx[n]=track->GetID();
+ trkArray.AddLast(tpcTrack);
+ }
+
+ if (track->GetX() < kRadius) continue;
+
+ ok = AliTracker::
+ PropagateTrackTo(track,kRadius,track->GetMass(),kMaxStep,kTRUE);
+ if (ok) {
+ track->RelateToVertex(esd->GetPrimaryVertexSPD(), kBz, kRadius);
+ }
+ }
+
+ //
+ // Improve the reconstructed primary vertex position using the tracks
+ //
+ TObject *obj = fOptions.FindObject("ITS");
if (obj) {
TString optITS = obj->GetTitle();
if (optITS.Contains("cosmics") || optITS.Contains("COSMICS"))
- dovertex=kFALSE;
+ fRunVertexFinderTracks=kFALSE;
+ }
+ if (fRunVertexFinderTracks) {
+ // TPC + ITS primary vertex
+ tVertexer.SetITSrefitRequired();
+ if(fDiamondProfile && fMeanVertexConstraint) {
+ tVertexer.SetVtxStart(fDiamondProfile);
+ } else {
+ tVertexer.SetConstraintOff();
+ }
+ AliESDVertex *pvtx=tVertexer.FindPrimaryVertex(esd);
+ if (pvtx) {
+ if (pvtx->GetStatus()) {
+ esd->SetPrimaryVertex(pvtx);
+ for (Int_t i=0; i<ntracks; i++) {
+ AliESDtrack *t = esd->GetTrack(i);
+ t->RelateToVertex(pvtx, kBz, kRadius);
+ }
+ }
+ }
+
+ // TPC-only primary vertex
+ tVertexer.SetITSrefitNotRequired();
+ if(fDiamondProfileTPC && fMeanVertexConstraint) {
+ tVertexer.SetVtxStart(fDiamondProfileTPC);
+ } else {
+ tVertexer.SetConstraintOff();
+ }
+ pvtx=tVertexer.FindPrimaryVertex(&trkArray,selectedIdx);
+ if (pvtx) {
+ if (pvtx->GetStatus()) {
+ esd->SetPrimaryVertexTPC(pvtx);
+ Int_t nsel=trkArray.GetEntriesFast();
+ for (Int_t i=0; i<nsel; i++) {
+ AliExternalTrackParam *t =
+ (AliExternalTrackParam *)trkArray.UncheckedAt(i);
+ t->PropagateToDCA(pvtx, kBz, kRadius);
+ }
+ }
+ }
+
}
- if(dovertex) pvtx=tVertexer.FindPrimaryVertex(esd);
+ delete[] selectedIdx;
+
if(fDiamondProfile) esd->SetDiamond(fDiamondProfile);
- if (pvtx)
- if (pvtx->GetStatus()) {
- // Store the improved primary vertex
- esd->SetPrimaryVertex(pvtx);
- // Propagate the tracks to the DCA to the improved primary vertex
- Double_t somethingbig = 777.;
- Double_t bz = esd->GetMagneticField();
- Int_t nt=esd->GetNumberOfTracks();
- while (nt--) {
- AliESDtrack *t = esd->GetTrack(nt);
- t->RelateToVertex(pvtx, bz, somethingbig);
- }
- }
if (fRunV0Finder) {
// V0 finding
// write ESD
if (fCleanESD) CleanESD(esd);
+
+ if (fRunGlobalQA) {
+ AliQADataMakerRec *qadm = GetQADataMaker(AliQA::kGLOBAL);
+ if (qadm) qadm->Exec(AliQA::kESDS, esd);
+ }
+
if (fWriteESDfriend) {
esdf->~AliESDfriend();
new (esdf) AliESDfriend(); // Reset...
esdf->~AliESDfriend();
new (esdf) AliESDfriend(); // Reset...
}
- // esdf->Reset();
- // delete esdf; esdf = 0;
- // ESD QA
gSystem->GetProcInfo(&ProcInfo);
AliInfo(Form("Event %d -> Current memory usage %d %d",iEvent, ProcInfo.fMemResident, ProcInfo.fMemVirtual));
- }
- detStr = fFillESD ;
-// // write quality assurance ESDs data (one entry for all events)
-// for (Int_t iDet = 0; iDet < fgkNDetectors; iDet++) {
-// if (!IsSelected(fgkDetectorName[iDet], detStr))
-// continue;
-// AliQADataMaker * qadm = GetQADataMaker(iDet);
-// if (!qadm) continue;
-// qadm->EndOfCycle(AliQA::kRECPOINTS);
-// qadm->EndOfCycle(AliQA::kESDS);
-// qadm->Finish();
-// }
+
+ // End of cycle for the in-loop QA
+ if (fInLoopQA) {
+ if (fRunQA) {
+ RunQA(fFillESD.Data(), esd);
+ TString detStr(fFillESD);
+ for (Int_t iDet = 0; iDet < fgkNDetectors; iDet++) {
+ if (!IsSelected(fgkDetectorName[iDet], detStr))
+ continue;
+ AliQADataMakerRec * qadm = GetQADataMaker(iDet);
+ if (!qadm)
+ continue;
+ qadm->EndOfCycle(AliQA::kRECPOINTS);
+ qadm->EndOfCycle(AliQA::kESDS);
+ qadm->Finish();
+ }
+ }
+ if (fRunGlobalQA) {
+ AliQADataMakerRec *qadm = GetQADataMaker(AliQA::kGLOBAL);
+ if (qadm) {
+ qadm->EndOfCycle(AliQA::kRECPOINTS);
+ qadm->EndOfCycle(AliQA::kESDS);
+ qadm->Finish();
+ }
+ }
+ }
+ }
+ //******** End of the loop over events
+
+
tree->GetUserInfo()->Add(esd);
hlttree->GetUserInfo()->Add(hltesd);
- const TMap *cdbMap = AliCDBManager::Instance()->GetStorageMap();
- const TList *cdbList = AliCDBManager::Instance()->GetRetrievedIds();
+ const TMap *cdbMap = AliCDBManager::Instance()->GetStorageMap();
+ const TList *cdbList = AliCDBManager::Instance()->GetRetrievedIds();
+
+ TMap *cdbMapCopy = new TMap(cdbMap->GetEntries());
+ cdbMapCopy->SetOwner(1);
+ cdbMapCopy->SetName("cdbMap");
+ TIter iter(cdbMap->GetTable());
+
+ TPair* pair = 0;
+ while((pair = dynamic_cast<TPair*> (iter.Next()))){
+ TObjString* keyStr = dynamic_cast<TObjString*> (pair->Key());
+ TObjString* valStr = dynamic_cast<TObjString*> (pair->Value());
+ cdbMapCopy->Add(new TObjString(keyStr->GetName()), new TObjString(valStr->GetName()));
+ }
+
+ TList *cdbListCopy = new TList();
+ cdbListCopy->SetOwner(1);
+ cdbListCopy->SetName("cdbList");
+
+ TIter iter2(cdbList);
+
+ AliCDBId* id=0;
+ while((id = dynamic_cast<AliCDBId*> (iter2.Next()))){
+ cdbListCopy->Add(new TObjString(id->ToString().Data()));
+ }
+
+ tree->GetUserInfo()->Add(cdbMapCopy);
+ tree->GetUserInfo()->Add(cdbListCopy);
- TMap *cdbMapCopy = new TMap(cdbMap->GetEntries());
- cdbMapCopy->SetOwner(1);
- cdbMapCopy->SetName("cdbMap");
- TIter iter(cdbMap->GetTable());
-
- TPair* pair = 0;
- while((pair = dynamic_cast<TPair*> (iter.Next()))){
- TObjString* keyStr = dynamic_cast<TObjString*> (pair->Key());
- TObjString* valStr = dynamic_cast<TObjString*> (pair->Value());
- cdbMapCopy->Add(new TObjString(keyStr->GetName()), new TObjString(valStr->GetName()));
- }
-
- TList *cdbListCopy = new TList();
- cdbListCopy->SetOwner(1);
- cdbListCopy->SetName("cdbList");
-
- TIter iter2(cdbList);
-
- AliCDBId* id=0;
- while((id = dynamic_cast<AliCDBId*> (iter2.Next()))){
- cdbListCopy->Add(id->Clone());
- }
-
- tree->GetUserInfo()->Add(cdbMapCopy);
- tree->GetUserInfo()->Add(cdbListCopy);
if(fESDPar.Contains("ESD.par")){
AliInfo("Attaching ESD.par to Tree");
file->cd();
+
if (fWriteESDfriend)
tree->SetBranchStatus("ESDfriend*",0);
// we want to have only one tree version number
tree->Write(tree->GetName(),TObject::kOverwrite);
hlttree->Write();
+// Finish with Plane Efficiency evaluation: before of CleanUp !!!
+ if (fRunPlaneEff && !FinishPlaneEff()) {
+ AliWarning("Finish PlaneEff evaluation failed");
+ }
+
+ gROOT->cd();
+ CleanUp(file, fileOld);
+
if (fWriteAOD) {
+ TFile *esdFile = TFile::Open("AliESDs.root", "READONLY");
TFile *aodFile = TFile::Open("AliAOD.root", "RECREATE");
- ESDFile2AODFile(file, aodFile);
+ ESDFile2AODFile(esdFile, aodFile);
aodFile->Close();
+ esdFile->Close();
}
- gROOT->cd();
- CleanUp(file, fileOld);
-
// Create tags for the events in the ESD tree (the ESD tree is always present)
// In case of empty events the tags will contain dummy values
AliESDTagCreator *esdtagCreator = new AliESDTagCreator();
aodtagCreator->CreateAODTags(fFirstEvent,fLastEvent,fGRPList);
}
- //QA
- if ( fRunQA ) {
- AliQADataMakerSteer qas ;
- if (fRawReader)
- qas.Run(AliQA::kRAWS, input) ;
- qas.Run(AliQA::kRECPOINTS) ;
- qas.Reset() ;
- qas.Run(AliQA::kESDS) ;
+ //Finish QA and end of cycle for out-of-loop QA
+ if (!fInLoopQA) {
+ if (fRunQA) {
+ qas.Run(fRunLocalReconstruction.Data(), AliQA::kRECPOINTS, sameQACycle);
+ //qas.Reset() ;
+ qas.Run(fRunTracking.Data(), AliQA::kESDS, sameQACycle);
+ }
+ if (fRunGlobalQA) {
+ AliQADataMakerRec *qadm = GetQADataMaker(AliQA::kGLOBAL);
+ if (qadm) {
+ qadm->EndOfCycle(AliQA::kRECPOINTS);
+ qadm->EndOfCycle(AliQA::kESDS);
+ qadm->Finish();
+ }
+ }
}
+
+ // Cleanup of CDB manager: cache and active storages!
+ AliCDBManager::Instance()->ClearCache();
+
+
return kTRUE;
}
//_____________________________________________________________________________
-Bool_t AliReconstruction::RunLocalReconstruction(const TString& detectors)
+Bool_t AliReconstruction::RunLocalReconstruction(const TString& /*detectors*/)
{
// run the local reconstruction
static Int_t eventNr=0;
Bool_t AliReconstruction::RunLocalEventReconstruction(const TString& detectors)
{
// run the local reconstruction
+
static Int_t eventNr=0;
AliCodeTimerAuto("")
AliWarning(Form("No loader is defined for %s!",fgkDetectorName[iDet]));
continue;
}
-
// conversion of digits
if (fRawReader && reconstructor->HasDigitConversion()) {
AliInfo(Form("converting raw data digits into root objects for %s",
loader->WriteDigits("OVERWRITE");
loader->UnloadDigits();
}
-
// local reconstruction
AliInfo(Form("running reconstruction for %s", fgkDetectorName[iDet]));
AliCodeTimerAuto(Form("running reconstruction for %s", fgkDetectorName[iDet]));
loader->UnloadDigits();
}
-// AliQADataMaker * qadm = GetQADataMaker(iDet);
-// if (qadm) {
-// AliCodeTimerStart(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
-// AliInfo(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
-//
-// if (qadm->IsCycleDone() ) {
-// qadm->EndOfCycle(AliQA::kRECPOINTS) ;
-// qadm->EndOfCycle(AliQA::kESDS) ;
-// qadm->StartOfCycle(AliQA::kRECPOINTS) ;
-// qadm->StartOfCycle(AliQA::kESDS, "same") ;
-// }
-// qadm->Exec(AliQA::kRECPOINTS, clustersTree) ;
-// AliCodeTimerStop(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
-// }
+ // In-loop QA for local reconstrucion
+ if (fRunQA && fInLoopQA) {
+ AliQADataMakerRec * qadm = GetQADataMaker(iDet);
+ if (qadm) {
+ //AliCodeTimerStart
+ //(Form("Running QA data maker for %s", fgkDetectorName[iDet]));
+ //AliInfo
+ //(Form("Running QA data maker for %s", fgkDetectorName[iDet]));
+
+ qadm->Exec(AliQA::kRECPOINTS, clustersTree) ;
+
+ //AliCodeTimerStop
+ //(Form("Running QA data maker for %s", fgkDetectorName[iDet]));
+ }
+ }
loader->WriteRecPoints("OVERWRITE");
loader->UnloadRecPoints();
AliWarning("no vertex reconstructed");
vertex = new AliESDVertex(vtxPos, vtxErr);
}
- esd->SetVertex(vertex);
+ esd->SetPrimaryVertexSPD(vertex);
// if SPD multiplicity has been determined, it is stored in the ESD
AliMultiplicity *mult = fVertexer->GetMultiplicity();
if(mult)esd->SetMultiplicity(mult);
return kFALSE;
}
- // create Tracks
- fLoader[iDet]->LoadTracks("update");
- fLoader[iDet]->CleanTracks();
- fLoader[iDet]->MakeTracksContainer();
-
// read RecPoints
fLoader[iDet]->LoadRecPoints("read");
+
tracker->LoadClusters(fLoader[iDet]->TreeR());
Int_t rv = tracker->Clusters2Tracks(esd);
- fLoader[iDet]->UnloadRecPoints();
-
if ( rv )
{
AliError(Form("%s Clusters2Tracks failed", fgkDetectorName[iDet]));
return kFALSE;
}
- tracker->UnloadClusters();
-
fLoader[iDet]->UnloadRecPoints();
- fLoader[iDet]->WriteTracks("OVERWRITE");
- fLoader[iDet]->UnloadTracks();
-
+ tracker->UnloadClusters();
+
delete tracker;
return kTRUE;
}
// pass 2: ALL backwards
+
for (Int_t iDet = 0; iDet < fgkNDetectors; iDet++) {
if (!fTracker[iDet]) continue;
AliDebug(1, Form("%s back propagation", fgkDetectorName[iDet]));
}
// run tracking
+ if (iDet>1) // start filling residuals for the "outer" detectors
+ if (fRunGlobalQA) AliTracker::SetFillResiduals(kTRUE);
+
if (fTracker[iDet]->PropagateBack(esd) != 0) {
AliError(Form("%s backward propagation failed", fgkDetectorName[iDet]));
// return kFALSE;
}
AliSysInfo::AddStamp(Form("Tracking1%s_%d",fgkDetectorName[iDet],eventNr), iDet,3, eventNr);
}
+ //stop filling residuals for the "outer" detectors
+ if (fRunGlobalQA) AliTracker::SetFillResiduals(kFALSE);
// write space-points to the ESD in case alignment data output
// is switched on
WriteAlignmentData(esd);
// pass 3: TRD + TPC + ITS refit inwards
+
for (Int_t iDet = 2; iDet >= 0; iDet--) {
if (!fTracker[iDet]) continue;
AliDebug(1, Form("%s inward refit", fgkDetectorName[iDet]));
// run tracking
+ if (iDet<2) // start filling residuals for TPC and ITS
+ if (fRunGlobalQA) AliTracker::SetFillResiduals(kTRUE);
+
if (fTracker[iDet]->RefitInward(esd) != 0) {
AliError(Form("%s inward refit failed", fgkDetectorName[iDet]));
// return kFALSE;
}
+ // run postprocessing
+ if (fTracker[iDet]->PostProcess(esd) != 0) {
+ AliError(Form("%s postprocessing failed", fgkDetectorName[iDet]));
+ // return kFALSE;
+ }
if (fCheckPointLevel > 1) {
WriteESD(esd, Form("%s.refit", fgkDetectorName[iDet]));
}
fLoader[iDet]->UnloadRecPoints();
AliSysInfo::AddStamp(Form("RUnloadCluster%s_%d",fgkDetectorName[iDet],eventNr), iDet,5, eventNr);
}
- //
- // Propagate track to the vertex - if not done by ITS
- //
- Int_t ntracks = esd->GetNumberOfTracks();
- for (Int_t itrack=0; itrack<ntracks; itrack++){
- const Double_t kRadius = 3; // beam pipe radius
- const Double_t kMaxStep = 5; // max step
- const Double_t kMaxD = 123456; // max distance to prim vertex
- Double_t fieldZ = AliTracker::GetBz(); //
- AliESDtrack * track = esd->GetTrack(itrack);
- if (!track) continue;
- if (track->IsOn(AliESDtrack::kITSrefit)) continue;
- AliTracker::PropagateTrackTo(track,kRadius,track->GetMass(),kMaxStep,kTRUE);
- track->RelateToVertex(esd->GetVertex(),fieldZ, kMaxD);
- }
+ // stop filling residuals for TPC and ITS
+ if (fRunGlobalQA) AliTracker::SetFillResiduals(kFALSE);
+
eventNr++;
return kTRUE;
}
// Remove the data which are not needed for the physics analysis.
//
- AliInfo("Cleaning the ESD...");
Int_t nTracks=esd->GetNumberOfTracks();
- AliInfo(Form("Number of ESD tracks before cleaning %d",nTracks));
+ Int_t nV0s=esd->GetNumberOfV0s();
+ AliInfo
+ (Form("Number of ESD tracks and V0s before cleaning: %d %d",nTracks,nV0s));
- Float_t cleanPars[]={fDmax,fZmax};
+ Float_t cleanPars[]={fV0DCAmax,fV0CsPmin,fDmax,fZmax};
Bool_t rc=esd->Clean(cleanPars);
nTracks=esd->GetNumberOfTracks();
- AliInfo(Form("Number of ESD tracks after cleaning %d",nTracks));
+ nV0s=esd->GetNumberOfV0s();
+ AliInfo
+ (Form("Number of ESD tracks and V0s after cleaning %d %d",nTracks,nV0s));
return rc;
}
AliCodeTimerAuto("")
static Int_t eventNr=0;
TString detStr = detectors;
+
for (Int_t iDet = 0; iDet < fgkNDetectors; iDet++) {
- if (!IsSelected(fgkDetectorName[iDet], detStr)) continue;
+ if (!IsSelected(fgkDetectorName[iDet], detStr)) continue;
AliReconstructor* reconstructor = GetReconstructor(iDet);
if (!reconstructor) continue;
-
if (!ReadESD(esd, fgkDetectorName[iDet])) {
AliDebug(1, Form("filling ESD for %s", fgkDetectorName[iDet]));
TTree* clustersTree = NULL;
AliInfo("Filling trigger information into the ESD");
+ AliCentralTrigger *aCTP = NULL;
+
if (fRawReader) {
AliCTPRawStream input(fRawReader);
if (!input.Next()) {
}
esd->SetTriggerMask(input.GetClassMask());
esd->SetTriggerCluster(input.GetClusterMask());
+
+ aCTP = new AliCentralTrigger();
+ TString configstr("");
+ if (!aCTP->LoadConfiguration(configstr)) { // Load CTP config from OCDB
+ AliError("No trigger configuration found in OCDB! The trigger classes information will no be stored in ESD!");
+ return kFALSE;
+ }
}
else {
AliRunLoader *runloader = AliRunLoader::GetRunLoader();
if (runloader) {
if (!runloader->LoadTrigger()) {
- AliCentralTrigger *aCTP = runloader->GetTrigger();
+ aCTP = runloader->GetTrigger();
esd->SetTriggerMask(aCTP->GetClassMask());
esd->SetTriggerCluster(aCTP->GetClusterMask());
}
}
}
+ // Now fill the trigger class names into AliESDRun object
+ AliTriggerConfiguration *config = aCTP->GetConfiguration();
+ if (!config) {
+ AliError("No trigger configuration has been found! The trigger classes information will no be stored in ESD!");
+ return kFALSE;
+ }
+
+ const TObjArray& classesArray = config->GetClasses();
+ Int_t nclasses = classesArray.GetEntriesFast();
+ for( Int_t j=0; j<nclasses; j++ ) {
+ AliTriggerClass* trclass = (AliTriggerClass*)classesArray.At( j );
+ Int_t trindex = (Int_t)TMath::Log2(trclass->GetMask());
+ esd->SetTriggerClass(trclass->GetName(),trindex);
+ }
+
return kTRUE;
}
}
delete fVertexer;
fVertexer = NULL;
- delete fDiamondProfile;
- fDiamondProfile = NULL;
+
+ if(!(AliCDBManager::Instance()->GetCacheFlag())) {
+ delete fDiamondProfile;
+ fDiamondProfile = NULL;
+ delete fDiamondProfileTPC;
+ fDiamondProfileTPC = NULL;
+ delete fGRPList;
+ fGRPList = NULL;
+ }
- delete fGRPList;
- fGRPList = NULL;
delete fRunLoader;
fRunLoader = NULL;
delete fRawReader;
fRawReader = NULL;
+ if (fParentRawReader) delete fParentRawReader;
+ fParentRawReader=NULL;
if (file) {
file->Close();
header->SetZDCP1Energy (esd->GetZDCP1Energy() );
header->SetZDCN2Energy (esd->GetZDCN2Energy() );
header->SetZDCP2Energy (esd->GetZDCP2Energy() );
- header->SetZDCEMEnergy (esd->GetZDCEMEnergy() );
+ header->SetZDCEMEnergy (esd->GetZDCEMEnergy(0),esd->GetZDCEMEnergy(1));
header->SetRefMultiplicity (nTracks);
header->SetRefMultiplicityPos(nPosTracks);
header->SetRefMultiplicityNeg(nTracks - nPosTracks);
Int_t nV0s = esd->GetNumberOfV0s();
Int_t nCascades = esd->GetNumberOfCascades();
Int_t nKinks = esd->GetNumberOfKinks();
- Int_t nVertices = nV0s + nCascades + nKinks + 1 /* = prim. vtx*/;
- Int_t nJets = 0;
+ Int_t nVertices = nV0s + 2*nCascades /*could lead to two vertices, one V0 and the Xi */+ nKinks + 1 /* = prim. vtx*/;
+ Int_t nJets = 0;
Int_t nCaloClus = esd->GetNumberOfCaloClusters();
Int_t nFmdClus = 0;
Int_t nPmdClus = esd->GetNumberOfPmdTracks();
// add it to the V0 array as well
Double_t d0[2] = { 999., 99.};
new(V0s[jV0s++]) AliAODv0(vV0, 999., 99., p_pos, p_neg, d0); // to be refined
- } // end of the loop on V0s
+ }
+ V0s.Expand(jV0s);
+ // end of the loop on V0s
// Kinks: it is a big mess the access to the information in the kinks
// The loop is on the tracks in order to find the mother and daugther of each kink
}
}
}
+ vertices.Expand(jVertices);
// Tracks (primary and orphan)
for (Int_t nTrack = 0; nTrack < nTracks; ++nTrack) {
else
aodTrack->SetChi2MatchTrigger(0.);
}
-
+ tracks.Expand(jTracks); // remove 'empty slots' due to unwritten tracks
+
// Access to the AOD container of PMD clusters
TClonesArray &pmdClusters = *(aod->GetPmdClusters());
Int_t jPmdClusters=0;
// Access to the AOD container of clusters
TClonesArray &caloClusters = *(aod->GetCaloClusters());
Int_t jClusters=0;
-
- // Calo Clusters
- TArrayS EMCCellNumber(15000);
- TArrayD EMCCellAmplitude(15000);
- Int_t nEMCCells = 0;
- const Float_t fEMCAmpScale = 1./500;
for (Int_t iClust=0; iClust<nCaloClus; ++iClust) {
else if (cluster->GetClusterType() == AliESDCaloCluster::kEMCALClusterv1) {
ttype = AliAODCluster::kEMCALClusterv1;
}
- else if (cluster->GetClusterType() == AliESDCaloCluster::kEMCALPseudoCluster) {
- // Collect raw tower info
- for (Int_t iDig = 0; iDig < cluster->GetNumberOfDigits(); iDig++) {
- EMCCellNumber[nEMCCells] = cluster->GetDigitIndex()->At(iDig);
- EMCCellAmplitude[nEMCCells] = fEMCAmpScale*cluster->GetDigitAmplitude()->At(iDig);
- nEMCCells++;
- }
- // don't write cluster data (it's just a pseudo cluster, holding the tower information)
- continue;
- }
+
AliAODCaloCluster *caloCluster = new(caloClusters[jClusters++]) AliAODCaloCluster(id,
nLabel,
caloCluster->SetCaloCluster(); // to be refined!
- } // end of loop on calo clusters
+ }
+ caloClusters.Expand(jClusters); // resize TObjArray to 'remove' slots for pseudo clusters
+ // end of loop on calo clusters
+
+ // fill EMCAL cell info
+ if (esd->GetEMCALCells()) { // protection against missing ESD information
+ AliESDCaloCells &esdEMcells = *(esd->GetEMCALCells());
+ Int_t nEMcell = esdEMcells.GetNumberOfCells() ;
+
+ AliAODCaloCells &aodEMcells = *(aod->GetEMCALCells());
+ aodEMcells.CreateContainer(nEMcell);
+ aodEMcells.SetType(AliAODCaloCells::kEMCAL);
+ for (Int_t iCell = 0; iCell < nEMcell; iCell++) {
+ aodEMcells.SetCell(iCell,esdEMcells.GetCellNumber(iCell),esdEMcells.GetAmplitude(iCell));
+ }
+ aodEMcells.Sort();
+ }
- // fill EMC cell info
- AliAODCaloCells &EMCCells = *(aod->GetCaloCells());
- EMCCells.CreateContainer(nEMCCells);
- EMCCells.SetType(AliAODCaloCells::kEMCAL);
- for (Int_t iCell = 0; iCell < nEMCCells; iCell++) {
- EMCCells.SetCell(iCell,EMCCellNumber[iCell],EMCCellAmplitude[iCell]);
+ // fill PHOS cell info
+ if (esd->GetPHOSCells()) { // protection against missing ESD information
+ AliESDCaloCells &esdPHcells = *(esd->GetPHOSCells());
+ Int_t nPHcell = esdPHcells.GetNumberOfCells() ;
+
+ AliAODCaloCells &aodPHcells = *(aod->GetPHOSCells());
+ aodPHcells.CreateContainer(nPHcell);
+ aodPHcells.SetType(AliAODCaloCells::kPHOS);
+ for (Int_t iCell = 0; iCell < nPHcell; iCell++) {
+ aodPHcells.SetCell(iCell,esdPHcells.GetCellNumber(iCell),esdPHcells.GetAmplitude(iCell));
+ }
+ aodPHcells.Sort();
}
- EMCCells.Sort();
// tracklets
AliAODTracklets &SPDTracklets = *(aod->GetTracklets());
AliTrackPoint p;
Int_t isp = 0;
Int_t isp2 = 0;
- while (isp < nspdet) {
+ while (isp2 < nspdet) {
Bool_t isvalid;
- if(IsSelected(fgkDetectorName[iDet],fUseTrackingErrorsForAlignment)) {
- isvalid = tracker->GetTrackPointTrackingError(idx[isp2],p,track);
+ TString dets = fgkDetectorName[iDet];
+ if ((fUseTrackingErrorsForAlignment.CompareTo(dets) == 0) ||
+ fUseTrackingErrorsForAlignment.BeginsWith(dets+" ") ||
+ fUseTrackingErrorsForAlignment.EndsWith(" "+dets) ||
+ fUseTrackingErrorsForAlignment.Contains(" "+dets+" ")) {
+ isvalid = tracker->GetTrackPointTrackingError(idx[isp2],p,track);
} else {
isvalid = tracker->GetTrackPoint(idx[isp2],p);
}
}
+//_____________________________________________________________________________
+AliQADataMakerRec * AliReconstruction::GetQADataMaker(Int_t iDet)
+{
+ // get the quality assurance data maker object and the loader for a detector
+ if (fQADataMaker[iDet])
+ return fQADataMaker[iDet];
+
+ AliQADataMakerRec * qadm = NULL;
+ if (iDet == fgkNDetectors) { //Global QA
+ qadm = new AliGlobalQADataMaker();
+ fQADataMaker[iDet] = qadm;
+ return qadm;
+ }
+
+ // load the QA data maker object
+ TPluginManager* pluginManager = gROOT->GetPluginManager();
+ TString detName = fgkDetectorName[iDet];
+ TString qadmName = "Ali" + detName + "QADataMakerRec";
+ if (gAlice && !gAlice->GetDetector(detName) && (detName != "HLT"))
+ return NULL;
+
+ // first check if a plugin is defined for the quality assurance data maker
+ TPluginHandler* pluginHandler = pluginManager->FindHandler("AliQADataMakerRec", detName);
+ // if not, add a plugin for it
+ if (!pluginHandler) {
+ AliDebug(1, Form("defining plugin for %s", qadmName.Data()));
+ TString libs = gSystem->GetLibraries();
+ if (libs.Contains("lib" + detName + "base.so") ||
+ (gSystem->Load("lib" + detName + "base.so") >= 0)) {
+ pluginManager->AddHandler("AliQADataMakerRec", detName,
+ qadmName, detName + "qadm", qadmName + "()");
+ } else {
+ pluginManager->AddHandler("AliQADataMakerRec", detName,
+ qadmName, detName, qadmName + "()");
+ }
+ pluginHandler = pluginManager->FindHandler("AliQADataMakerRec", detName);
+ }
+ if (pluginHandler && (pluginHandler->LoadPlugin() == 0)) {
+ qadm = (AliQADataMakerRec *) pluginHandler->ExecPlugin(0);
+ }
+
+ fQADataMaker[iDet] = qadm;
+
+ return qadm;
+}
//_____________________________________________________________________________
-//AliQADataMaker * AliReconstruction::GetQADataMaker(Int_t iDet)
-//{
-// get the quality assurance data maker object and the loader for a detector
-//
-// if (fQADataMaker[iDet])
-// return fQADataMaker[iDet];
-//
-// // load the QA data maker object
-// TPluginManager* pluginManager = gROOT->GetPluginManager();
-// TString detName = fgkDetectorName[iDet];
-// TString qadmName = "Ali" + detName + "QADataMaker";
-// if (gAlice && !gAlice->GetDetector(detName) && (detName != "HLT"))
-// return NULL;
-//
-// AliQADataMaker * qadm = NULL;
-// // first check if a plugin is defined for the quality assurance data maker
-// TPluginHandler* pluginHandler = pluginManager->FindHandler("AliQADataMaker", detName);
-// // if not, add a plugin for it
-// if (!pluginHandler) {
-// AliDebug(1, Form("defining plugin for %s", qadmName.Data()));
-// TString libs = gSystem->GetLibraries();
-// if (libs.Contains("lib" + detName + "base.so") ||
-// (gSystem->Load("lib" + detName + "base.so") >= 0)) {
-// pluginManager->AddHandler("AliQADataMaker", detName,
-// qadmName, detName + "qadm", qadmName + "()");
-// } else {
-// pluginManager->AddHandler("AliQADataMaker", detName,
-// qadmName, detName, qadmName + "()");
-// }
-// pluginHandler = pluginManager->FindHandler("AliQADataMaker", detName);
-// }
-// if (pluginHandler && (pluginHandler->LoadPlugin() == 0)) {
-// qadm = (AliQADataMaker *) pluginHandler->ExecPlugin(0);
-// }
-// if (qadm) {
-// AliInfo(Form("Initializing quality assurance data maker for %s", fgkDetectorName[iDet]));
-// qadm->Init(AliQA::kRECPOINTS, AliCDBManager::Instance()->GetRun(), GetQACycles(fgkDetectorName[iDet]));
-// qadm->StartOfCycle(AliQA::kRECPOINTS);
-// qadm->Init(AliQA::kESDS, AliCDBManager::Instance()->GetRun());
-// qadm->StartOfCycle(AliQA::kESDS, "same") ;
-// fQADataMaker[iDet] = qadm;
-// }
-//
-// return qadm;
-//}
-//
-//_____________________________________________________________________________
-//Bool_t AliReconstruction::RunQA(const char* detectors, AliESDEvent *& esd)
-//{
-// // run the Quality Assurance data producer
-//
-// AliCodeTimerAuto("")
-// TString detStr = detectors;
-// for (Int_t iDet = 0; iDet < fgkNDetectors; iDet++) {
-// if (!IsSelected(fgkDetectorName[iDet], detStr))
-// continue;
-// AliQADataMaker * qadm = GetQADataMaker(iDet);
-// if (!qadm)
-// continue;
-// AliCodeTimerStart(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
-// AliInfo(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
-//
-// qadm->Exec(AliQA::kESDS, esd) ;
-// qadm->Increment() ;
-//
-// AliCodeTimerStop(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
-// }
-// if ((detStr.CompareTo("ALL") != 0) && !detStr.IsNull()) {
-// AliError(Form("the following detectors were not found: %s",
-// detStr.Data()));
-// if (fStopOnError)
-// return kFALSE;
-// }
-//
-// return kTRUE;
-//
-//}
-//
+Bool_t AliReconstruction::RunQA(const char* detectors, AliESDEvent *& esd)
+{
+ // run the Quality Assurance data producer
+
+ AliCodeTimerAuto("")
+ TString detStr = detectors;
+ for (Int_t iDet = 0; iDet < fgkNDetectors; iDet++) {
+ if (!IsSelected(fgkDetectorName[iDet], detStr))
+ continue;
+ AliQADataMakerRec * qadm = GetQADataMaker(iDet);
+ if (!qadm)
+ continue;
+ AliCodeTimerStart(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
+ AliInfo(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
+
+ qadm->Exec(AliQA::kESDS, esd) ;
+ qadm->Increment() ;
+
+ AliCodeTimerStop(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
+ }
+ if ((detStr.CompareTo("ALL") != 0) && !detStr.IsNull()) {
+ AliError(Form("the following detectors were not found: %s",
+ detStr.Data()));
+ if (fStopOnError)
+ return kFALSE;
+ }
+
+ return kTRUE;
+
+}
//_____________________________________________________________________________
void AliReconstruction::CheckQA()
// check the QA of SIM for this run and remove the detectors
// with status Fatal
- TString newDetList ;
+ TString newRunLocalReconstruction ;
+ TString newRunTracking ;
+ TString newFillESD ;
+
for (Int_t iDet = 0; iDet < AliQA::kNDET; iDet++) {
TString detName(AliQA::GetDetName(iDet)) ;
- if ( fRunLocalReconstruction.Contains(AliQA::GetDetName(iDet)) ||
- fRunLocalReconstruction.Contains("ALL") ) {
- AliQA * qa = AliQA::Instance(AliQA::DETECTORINDEX(iDet)) ;
- if ( qa->IsSet(AliQA::DETECTORINDEX(iDet), AliQA::kSIM, AliQA::kFATAL)) {
+ AliQA * qa = AliQA::Instance(AliQA::DETECTORINDEX_t(iDet)) ;
+ if ( qa->IsSet(AliQA::DETECTORINDEX_t(iDet), AliQA::kSIM, AliQA::kFATAL)) {
AliInfo(Form("QA status for %s in Hits and/or SDIGITS and/or Digits was Fatal; No reconstruction performed", detName.Data())) ;
- } else if ( qa->IsSet(AliQA::DETECTORINDEX(iDet), AliQA::kSIM, AliQA::kERROR)) {
- AliError(Form("QA status for %s in Hits and/or SDIGITS and/or Digits was ERROR", detName.Data())) ;
- newDetList += detName ;
- newDetList += " " ;
- } else if ( qa->IsSet(AliQA::DETECTORINDEX(iDet), AliQA::kSIM, AliQA::kWARNING) ) {
- AliWarning(Form("QA status for %s in Hits and/or SDIGITS and/or Digits was WARNING", detName.Data())) ;
- newDetList += detName ;
- newDetList += " " ;
- } else if ( qa->IsSet(AliQA::DETECTORINDEX(iDet), AliQA::kSIM, AliQA::kINFO) ) {
- AliInfo(Form("QA status for %s in Hits and/or SDIGITS and/or Digits was INFO", detName.Data())) ;
- newDetList += detName ;
- newDetList += " " ;
- } else {
- newDetList += detName ;
- newDetList += " " ;
+ } else {
+ if ( fRunLocalReconstruction.Contains(AliQA::GetDetName(iDet)) ||
+ fRunLocalReconstruction.Contains("ALL") ) {
+ newRunLocalReconstruction += detName ;
+ newRunLocalReconstruction += " " ;
+ }
+ if ( fRunTracking.Contains(AliQA::GetDetName(iDet)) ||
+ fRunTracking.Contains("ALL") ) {
+ newRunTracking += detName ;
+ newRunTracking += " " ;
+ }
+ if ( fFillESD.Contains(AliQA::GetDetName(iDet)) ||
+ fFillESD.Contains("ALL") ) {
+ newFillESD += detName ;
+ newFillESD += " " ;
}
}
}
- fRunLocalReconstruction = newDetList ;
+ fRunLocalReconstruction = newRunLocalReconstruction ;
+ fRunTracking = newRunTracking ;
+ fFillESD = newFillESD ;
}
//_____________________________________________________________________________
}
return index ;
}
+//_____________________________________________________________________________
+Bool_t AliReconstruction::FinishPlaneEff() {
+ //
+ // Here execute all the necessary operationis, at the end of the tracking phase,
+ // in case that evaluation of PlaneEfficiencies was required for some detector.
+ // E.g., write into a DataBase file the PlaneEfficiency which have been evaluated.
+ //
+ // This Preliminary version works only FOR ITS !!!!!
+ // other detectors (TOF,TRD, etc. have to develop their specific codes)
+ //
+ // Input: none
+ // Return: kTRUE if all operations have been done properly, kFALSE otherwise
+ //
+ Bool_t ret=kFALSE;
+ //for (Int_t iDet = 0; iDet < fgkNDetectors; iDet++) {
+ for (Int_t iDet = 0; iDet < 1; iDet++) { // for the time being only ITS
+ //if (!IsSelected(fgkDetectorName[iDet], detStr)) continue;
+ if(fTracker[iDet]) {
+ AliPlaneEff *planeeff=fTracker[iDet]->GetPlaneEff();
+ ret=planeeff->WriteIntoCDB();
+ if(planeeff->GetCreateHistos()) {
+ TString name="PlaneEffHisto";
+ name+=fgkDetectorName[iDet];
+ name+=".root";
+ ret*=planeeff->WriteHistosToFile(name,"RECREATE");
+ }
+ }
+ }
+ return ret;
+}
+//_____________________________________________________________________________
+Bool_t AliReconstruction::InitPlaneEff() {
+//
+ // Here execute all the necessary operations, before of the tracking phase,
+ // for the evaluation of PlaneEfficiencies, in case required for some detectors.
+ // E.g., read from a DataBase file a first evaluation of the PlaneEfficiency
+ // which should be updated/recalculated.
+ //
+ // This Preliminary version will work only FOR ITS !!!!!
+ // other detectors (TOF,TRD, etc. have to develop their specific codes)
+ //
+ // Input: none
+ // Return: kTRUE if all operations have been done properly, kFALSE otherwise
+ //
+ AliWarning(Form("Implementation of this method not yet done !! Method return kTRUE"));
+ return kTRUE;
+}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff