#include <TChain.h>
#include <TFileCollection.h>
+#include <TEntryList.h>
+#include "TGridCollection.h"
+#include <TPluginManager.h>
+#include <TROOT.h>
+#include <TSystem.h>
+#include <TFile.h>
+#include <TKey.h>
+#include <TGrid.h>
+#include <TGridResult.h>
#include "AliRawReaderChain.h"
-#include "AliRawEvent.h"
+#include "AliRawVEvent.h"
+#include "AliLog.h"
ClassImp(AliRawReaderChain)
+TString AliRawReaderChain::fgSearchPath = "/alice/data";
+
AliRawReaderChain::AliRawReaderChain() :
AliRawReaderRoot(),
fChain(NULL)
// default constructor
}
-AliRawReaderChain::AliRawReaderChain(const char* listFileName) :
+AliRawReaderChain::AliRawReaderChain(const char* fileName) :
AliRawReaderRoot(),
fChain(NULL)
{
// create raw-reader objects which takes as an input a root chain
-// from the file list found in 'listFileName'
-
- TFileCollection collection("RAW",
- "Collection with raw-data files",
- listFileName);
+// either from the file list found in 'fileName' (IsCollection = true)
+// or from entry list found in 'filename' (IsCollection = false)
+// The entry-list syntax follows root convetion: filename.root/listname
fChain = new TChain("RAW");
- if (!fChain->AddFileInfoList((TCollection*)(collection.GetList()))) {
- Error("AliRawReaderChain","Bad file list in collection, the chain is empty");
- return;
+
+ TString fileNameStr = fileName;
+ if (fileNameStr.EndsWith(".xml")) {
+
+ TGridCollection *collection = NULL;
+ TPluginManager* pluginManager = gROOT->GetPluginManager();
+ TPluginHandler* pluginHandler = pluginManager->FindHandler("TGridCollection", "alice");
+ if (!pluginHandler) {
+ pluginManager->AddHandler("TGridCollection", "alice",
+ "AliXMLCollection", "ANALYSISalice", "AliXMLCollection(const char*)");
+ pluginHandler = pluginManager->FindHandler("TGridCollection", "alice");
+ }
+ gSystem->Load("libANALYSIS");
+ if (pluginHandler && (pluginHandler->LoadPlugin() == 0)) {
+ collection = (TGridCollection*)pluginHandler->ExecPlugin(1,fileNameStr.Data());
+ }
+ else {
+ fIsValid = kFALSE;
+ return;
+ }
+ collection->Reset();
+ Bool_t elistsExist = kFALSE;
+ TEntryList *elist = new TEntryList();
+ while (collection->Next()) {
+ fChain->Add(collection->GetTURL(""));
+ TEntryList *list = (TEntryList *)collection->GetEntryList("");
+ if (list) {
+ list->SetTreeName("RAW");
+ list->SetFileName(collection->GetTURL(""));
+ elist->Add(list);
+ elistsExist = kTRUE;
+ }
+ }
+ if (elistsExist) {
+ fChain->SetEntryList(elist,"ne");
+ }
+ else {
+ Info("AliRawReaderChain", "no entry lists found in %s. Using all entries", fileNameStr.Data());
+ delete elist;
+ }
}
+ else if (fileNameStr.EndsWith(".root")) {
- fChain->SetBranchStatus("*",1);
+ TDirectory* dir = gDirectory;
+ TFile *listFile = TFile::Open(fileNameStr.Data());
+ dir->cd();
+ if (!listFile || !listFile->IsOpen()) {
+ Error("AliRawReaderChain", "could not open file %s", fileNameStr.Data());
+ fIsValid = kFALSE;
+ return;
+ }
+
+ TEntryList *elist = NULL;
+ TKey *key = NULL;
+ TIter nextkey(listFile->GetListOfKeys());
+ while ((key=(TKey*)nextkey())){
+ if (strcmp("TEntryList", key->GetClassName())==0){
+ elist = (TEntryList*)key->ReadObj();
+ }
+ }
+ if (!elist) {
+ Error("AliRawReaderChain", "no TEntryList found in %s", fileNameStr.Data());
+ fIsValid = kFALSE;
+ return;
+ }
- fEvent = new AliRawEvent;
- fChain->SetBranchAddress("rawevent", &fEvent);
+ TEntryList *templist = NULL;
+ TList *elists = elist->GetLists();
+ TIter next(elists);
+ while((templist = (TEntryList*)next())){
+ Info("AliRawReaderChain", "%s added to the chain", templist->GetFileName());
+ fChain->Add(templist->GetFileName());
+ }
+ fChain->SetEntryList(elist,"ne");
+ }
+ else {
+
+ TFileCollection collection("RAW",
+ "Collection with raw-data files",
+ fileNameStr.Data());
+
+ if (!fChain->AddFileInfoList((TCollection*)(collection.GetList()))) {
+ Error("AliRawReaderChain","Bad file list in collection, the chain is empty");
+ fIsValid = kFALSE;
+ return;
+ }
+ }
+
+ fChain->SetBranchStatus("*",1);
+ fChain->SetBranchAddress("rawevent",&fEvent,&fBranch);
}
AliRawReaderChain::AliRawReaderChain(TFileCollection *collection) :
fChain = new TChain("RAW");
if (!fChain->AddFileInfoList((TCollection*)(collection->GetList()))) {
Error("AliRawReaderChain","Bad file list in collection, the chain is empty");
+ fIsValid = kFALSE;
return;
}
fChain->SetBranchStatus("*",1);
-
- fEvent = new AliRawEvent;
- fChain->SetBranchAddress("rawevent", &fEvent);
+ fChain->SetBranchAddress("rawevent",&fEvent,&fBranch);
}
AliRawReaderChain::AliRawReaderChain(TChain *chain) :
// create raw-reader objects which takes as an input a root chain
// from a root file collection
+ if (!fChain) {
+ fIsValid = kFALSE;
+ return;
+ }
+
fChain->SetBranchStatus("*",1);
+ fChain->SetBranchAddress("rawevent",&fEvent,&fBranch);
+}
- fEvent = new AliRawEvent;
- fChain->SetBranchAddress("rawevent", &fEvent);
+AliRawReaderChain::AliRawReaderChain(TEntryList *elist) :
+ AliRawReaderRoot(),
+ fChain(NULL)
+{
+// create raw-reader objects which takes as an input a root chain
+// from a root file collection
+
+ if (!elist) {
+ fIsValid = kFALSE;
+ return;
+ }
+
+ fChain = new TChain("RAW");
+
+ TEntryList *templist = NULL;
+ TList *elists = elist->GetLists();
+ TIter next(elists);
+ while((templist = (TEntryList*)next())){
+ fChain->Add(templist->GetFileName());
+ }
+ fChain->SetEntryList(elist,"ne");
+
+ fChain->SetBranchStatus("*",1);
+ fChain->SetBranchAddress("rawevent",&fEvent,&fBranch);
+}
+
+AliRawReaderChain::AliRawReaderChain(Int_t runNumber) :
+ AliRawReaderRoot(),
+ fChain(NULL)
+{
+// create raw-reader objects which takes as an input a root chain
+// with the raw-data files for a given run
+// It queries alien FC in order to do that and therefore
+// it needs alien API to be enabled
+
+ if (runNumber <= 0) {
+ Error("AliRawReaderChain","Bad run number:%d",runNumber);
+ fIsValid = kFALSE;
+ }
+
+ if (!gGrid) TGrid::Connect("alien://");
+ if (!gGrid) {
+ fIsValid = kFALSE;
+ return;
+ }
+
+ if (fgSearchPath.IsNull()) fgSearchPath = "/alice/data";
+ TGridResult *res = gGrid->Query(fgSearchPath.Data(),Form("%09d/raw/*%09d*.root",runNumber,runNumber));
+ Int_t nFiles = res->GetEntries();
+ if (!nFiles) {
+ Error("AliRawReaderChain","No raw-data files found for run %d",runNumber);
+ fIsValid = kFALSE;
+ delete res;
+ return;
+ }
+
+ fChain = new TChain("RAW");
+ for (Int_t i = 0; i < nFiles; i++) {
+ TString filename = res->GetKey(i, "turl");
+ if(filename == "") continue;
+ fChain->Add(filename.Data());
+ }
+ delete res;
+
+ fChain->SetBranchStatus("*",1);
+ fChain->SetBranchAddress("rawevent",&fEvent,&fBranch);
}
+
AliRawReaderChain::AliRawReaderChain(const AliRawReaderChain& rawReader) :
AliRawReaderRoot(rawReader),
fChain(rawReader.fChain)
do {
delete fEvent;
- fEvent = new AliRawEvent;
- TBranch *branch = fChain->GetBranch("rawevent");
- if (!branch)
+ fEvent = NULL;
+ fEventHeader = NULL;
+ Long64_t treeEntry = fChain->LoadTree(fEventIndex+1);
+ if (!fBranch)
return kFALSE;
- if (branch->GetEntry(fEventIndex+1) <= 0)
+ if (fBranch->GetEntry(treeEntry) <= 0)
return kFALSE;
+ fEventHeader = fEvent->GetHeader();
fEventIndex++;
} while (!IsEventSelected());
fEventNumber++;
fEventIndex = -1;
delete fEvent;
- fEvent = new AliRawEvent;
+ fEvent = NULL;
+ fEventHeader = NULL;
fEventNumber = -1;
return Reset();
}
if (!fChain || !fChain->GetListOfFiles()->GetEntriesFast()) return kFALSE;
delete fEvent;
- fEvent = new AliRawEvent;
- TBranch *branch = fChain->GetBranch("rawevent");
- if (!branch)
+ fEvent = NULL;
+ fEventHeader = NULL;
+ Long64_t treeEntry = fChain->LoadTree(event);
+ if (!fBranch)
return kFALSE;
- if (branch->GetEntry(event) <= 0)
+ if (fBranch->GetEntry(treeEntry) <= 0)
return kFALSE;
+ fEventHeader = fEvent->GetHeader();
fEventIndex = event;
fEventNumber++;
return Reset();
}
+
+Int_t AliRawReaderChain::GetNumberOfEvents() const
+{
+ // Get the total number of events in the chain
+ // of raw-data files
+
+ if (!fChain) return -1;
+
+ return fChain->GetEntries();
+}
+
+void AliRawReaderChain::SetSearchPath(const char* path)
+{
+ // set alien query search path
+ AliInfoGeneral("SetSearchPath",Form("Setting search path to \"%s\" (was \"%s\")",path,fgSearchPath.Data()));
+ fgSearchPath = path;
+}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff