//ROOT
#include <Riostream.h>
+#include <TEntryList.h>
+#include <TList.h>
+#include <TMap.h>
+#include <TObjArray.h>
+#include <TObjString.h>
#include <TString.h>
-#include <TEventList.h>
+#include <TXMLEngine.h>
#include "AliXMLCollection.h"
//___________________________________________________________________________
AliXMLCollection::AliXMLCollection() :
- TObject(),
+ TGridCollection(),
+ fXmlFile(),
+ fEventList(0),
+ fEventListIter(0),
+ fCurrent(0),
fCollectionName(),
- fout()
-{
+ fout() {
//Default constructor
}
+//___________________________________________________________________________
+AliXMLCollection::AliXMLCollection(const char *localcollectionfile) {
+ // Create Alien event collection, by reading collection for the specified
+ // file.
+
+ fXmlFile = localcollectionfile;
+ fEventList = new TList();
+ fEventList->SetOwner(kTRUE);
+ fEventListIter = new TIter(fEventList);
+ fCurrent = 0;
+ if (localcollectionfile!=0) {
+ ParseXML();
+ }
+}
+
+//___________________________________________________________________________
+AliXMLCollection::AliXMLCollection(const AliXMLCollection& collection):
+ TGridCollection(collection),
+ fXmlFile(collection.fXmlFile),
+ fCollectionName(collection.fCollectionName) {
+ //copy constructor
+
+ if (collection.fEventList) fEventList = new TList();
+ if (collection.fEventListIter) fEventListIter = new TIter(fEventList);
+ if (collection.fCurrent) fCurrent = 0;
+}
+
//___________________________________________________________________________
AliXMLCollection::~AliXMLCollection() {
//Destructor
+ if(fEventList) delete fEventList;
+ if(fEventListIter) delete fEventListIter;
}
//___________________________________________________________________________
// Open the output stream
fout.open(xmlName);
fout<<"<?xml version=\"1.0\"?>\n";
- fout<<"<tags>\n";
+ fout<<"<alien>\n";
fout<<" "<<collectionHeader<<"\n";
return kTRUE;
}
//___________________________________________________________________________
-Bool_t AliXMLCollection::WriteBody(Int_t counter, const char* guid, TEventList *list) {
+Bool_t AliXMLCollection::WriteBody(Int_t counter, const char* guid, const char* lfn, const char* turl, TEntryList *list) {
//Writes the body of the xml collection
TString listline;
for(Int_t i = 0; i < list->GetN(); i++) {
line1 += "guid=\"";
line1 += guid;
line1 += "\" ";
- line1 += "eventlist=\"";
+ line1 += "lfn=\"";
+ line1 += lfn;
+ line1 += "\" ";
+ line1 += "turl=\"";
+ line1 += turl;
+ line1 += "\" ";
+ line1 += "evlist=\"";
line1 += listline;
line1 += "\"";
line1 += " />";
Bool_t AliXMLCollection::Export() {
//Closes the stream
fout<<" "<<"</collection>\n";
- fout<<"</tags>\n";
+ fout<<"</alien>\n";
fout.close();
return kTRUE;
}
+
+//___________________________________________________________________________
+void AliXMLCollection::Reset() {
+ // Reset file iterator.
+
+ fEventListIter->Reset();
+ fCurrent = 0;
+}
+
+//___________________________________________________________________________
+TMap *AliXMLCollection::Next() {
+ // Return next event file map.
+
+ fCurrent = (TMap*)fEventListIter->Next();
+ return fCurrent;
+}
+
+//___________________________________________________________________________
+const char *AliXMLCollection::GetTURL(const char* filename) const {
+ // Get a file's transport URL (TURL). Returns 0 in case of error.
+
+ if (fCurrent) {
+ TMap *obj = (TMap*)fCurrent->GetValue(filename);
+ if (obj) {
+ if (obj->GetValue("turl")) {
+ return ( ((TObjString*)obj->GetValue("turl"))->GetName());
+ }
+ }
+ }
+ Error("GetTURL","cannot get TURL of file %s",filename);
+ return 0;
+}
+
+//___________________________________________________________________________
+const char *AliXMLCollection::GetGUID(const char* filename) const {
+ // Get a file's transport UID. Returns 0 in case of error.
+
+ if (fCurrent) {
+ TMap *obj = (TMap*)fCurrent->GetValue(filename);
+ if (obj) {
+ if (obj->GetValue("guid")) {
+ return ( ((TObjString*)obj->GetValue("guid"))->GetName());
+ }
+ }
+ }
+ Error("GetGUID","cannot get GUID of file %s",filename);
+ return 0;
+}
+
+//___________________________________________________________________________
+TEntryList *AliXMLCollection::GetEventList(const char *filename) const {
+ // Get a file's event list. Returns 0 in case of error.
+
+ if (fCurrent) {
+ TMap *obj = (TMap *) fCurrent->GetValue(filename);
+ if (obj) {
+ if (obj->GetValue("evlist")) {
+ return ((TEntryList *) obj->GetValue("evlist"));
+ }
+ }
+ }
+ Error("GetEvList", "cannot get evelist of file %s", filename);
+ return 0;
+}
+
+//___________________________________________________________________________
+Bool_t AliXMLCollection::Remove(TMap * map) {
+ // Return next event file map.
+ if (fEventList->Remove(map)) {
+ return kTRUE;
+ } else {
+ return kFALSE;
+ }
+}
+
+//___________________________________________________________________________
+const char *AliXMLCollection::GetLFN(const char* ) const {
+ // Get a file's LFN. Returns 0 in case of error.
+
+ if (fCurrent) {
+ TMap *obj = (TMap *) fCurrent->GetValue("");
+ if (obj) {
+ if (obj->GetValue("lfn")) {
+ return (((TObjString *) obj->GetValue("lfn"))->GetName());
+ }
+ }
+ }
+ Error("GetLFN", "cannot get LFN");
+ return 0;
+}
+
+//__________________________________________________________________________
+Bool_t AliXMLCollection::OverlapCollection(AliXMLCollection * comparator) {
+ // return kTRUE if comparator overlaps with this
+ if ((!comparator)) return kFALSE;
+
+ loopagain:
+ // loop over col1 and try to find it in col2
+ this->Reset();
+ // loop over all elements in reference (=this)
+ TMap *overlapmap;
+ while ((overlapmap = this->Next())) {
+ comparator->Reset();
+ Bool_t found = kFALSE;
+ // try to find in the comparator collection
+ while ((comparator->Next())) {
+ TString s1 = this->GetLFN("");
+ TString s2 = comparator->GetLFN("");
+ if (s1 == s2) {
+ found = kTRUE;
+ break;
+ }
+ }
+ if (!found) {
+ this->Remove(overlapmap);
+ goto loopagain;
+ }
+ }
+ return kTRUE;
+}
+
+//___________________________________________________________________________
+AliXMLCollection *AliXMLCollection::Open(const char *localcollectionfile) {
+ // Static method used to create an Alien event collection, by reading
+ // collection for the specified file.
+
+ AliXMLCollection *collection = new AliXMLCollection(localcollectionfile);
+ return collection;
+}
+
+//___________________________________________________________________________
+void AliXMLCollection::ParseXML() {
+ // Parse event file collection XML file.
+
+ TXMLEngine xml;
+
+ XMLDocPointer_t xdoc = xml.ParseFile(fXmlFile);
+ if (!xdoc) {
+ Error("ParseXML","cannot parse the xml file %s",fXmlFile.Data());
+ return;
+ }
+
+ XMLNodePointer_t xalien = xml.DocGetRootElement(xdoc);
+ if (!xalien) {
+ Error("ParseXML","cannot find the <alien> tag in %s",fXmlFile.Data());
+ return;
+ }
+
+ XMLNodePointer_t xcollection = xml.GetChild(xalien);
+ if (!xcollection) {
+ Error("ParseXML","cannot find the <collection> tag in %s",fXmlFile.Data());
+ return;
+ }
+
+ XMLNodePointer_t xevent = xml.GetChild(xcollection);;
+ if (!xevent) {
+ Error("ParseXML","cannot find the <event> tag in %s",fXmlFile.Data());
+ return;
+ }
+ if (!xevent) return;
+
+ do {
+ if (xml.GetAttr(xevent, "name")) {
+ TMap *files = new TMap();
+
+ // files
+ XMLNodePointer_t xfile = xml.GetChild(xevent);
+ if (!xfile) continue;
+
+ Bool_t firstfile=kTRUE;
+ do {
+ // here we have an event file
+ // get the attributes;
+ xml.GetAttr(xfile, "lfn");
+ xml.GetAttr(xfile, "turl");
+
+ TMap *attributes = new TMap();
+ TObjString *oname = new TObjString(xml.GetAttr(xfile,"name"));
+ TObjString *oturl = new TObjString(xml.GetAttr(xfile,"turl"));
+ TObjString *olfn = new TObjString(xml.GetAttr(xfile,"lfn"));
+ TObjString *oguid = new TObjString(xml.GetAttr(xfile,"guid"));
+ TObjString *oevlist = new TObjString(xml.GetAttr(xfile, "evlist"));
+ printf("Collection: %s - The Eventlist is %s\n",fXmlFile.Data(),oevlist->GetName());
+ if (oevlist->GetName() != "") {
+ TEntryList *xmlevlist = new TEntryList(oturl->GetName(), oguid->GetName());
+ TString stringevlist = oevlist->GetName();
+ TObjArray *evlist = stringevlist.Tokenize(",");
+ for (Int_t n = 0; n < evlist->GetEntries(); n++) xmlevlist->Enter(atol(((TObjString *) evlist->At(n))->GetName()));
+ attributes->Add(new TObjString("evlist"), xmlevlist);
+ }
+
+ attributes->Add(new TObjString("name"),oname);
+ attributes->Add(new TObjString("turl"),oturl);
+ attributes->Add(new TObjString("lfn"),olfn);
+ attributes->Add(new TObjString("guid"),oguid);
+ files->Add(new TObjString(xml.GetAttr(xfile,"name")) , attributes);
+
+ // we add the first file always as a file without name to the map
+ if (firstfile) {
+ files->Add(new TObjString(""),attributes);
+ firstfile=kFALSE;
+ }
+ } while ((xfile = xml.GetNext(xfile)));
+ fEventList->Add(files);
+ }
+ } while ((xevent = xml.GetNext(xevent)));
+}
+
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff