// Origin: Panos Christakoglou, UOA-CERN, Panos.Christakoglou@cern.ch
//-----------------------------------------------------------------
+#include <cstdlib>
//ROOT
#include <Riostream.h>
#include <TEntryList.h>
#include <TObjString.h>
#include <TString.h>
#include <TXMLEngine.h>
+#include "AliLog.h"
#include "AliXMLCollection.h"
ClassImp(AliXMLCollection)
-
//___________________________________________________________________________
AliXMLCollection::AliXMLCollection() :
TGridCollection(),
fEventListIter(0),
fCurrent(0),
fCollectionName(),
- fout() {
+ fout(),
+ fTotalEvents(0),
+ fAcceptedEvents(0),
+ fRejectedRun(0),
+ fRejectedLHC(0),
+ fRejectedDet(0),
+ fRejectedEvt(0)
+{
//Default constructor
}
//___________________________________________________________________________
-AliXMLCollection::AliXMLCollection(const char *localcollectionfile) {
+AliXMLCollection::AliXMLCollection(const char *localcollectionfile) :
+ TGridCollection(),
+ fXmlFile(localcollectionfile),
+ fEventList(0),
+ fEventListIter(0),
+ fCurrent(0),
+ fCollectionName(),
+ fout(),
+ fTotalEvents(0),
+ fAcceptedEvents(0),
+ fRejectedRun(0),
+ fRejectedLHC(0),
+ fRejectedDet(0),
+ fRejectedEvt(0)
+ {
// 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) {
+ fEventList(0),
+ fEventListIter(0),
+ fCurrent(0),
+ fCollectionName(collection.fCollectionName),
+ fout(),
+ fTotalEvents(0),
+ fAcceptedEvents(0),
+ fRejectedRun(0),
+ fRejectedLHC(0),
+ fRejectedDet(0),
+ fRejectedEvt(0)
+{
//copy constructor
if (collection.fEventList) fEventList = new TList();
}
//___________________________________________________________________________
-AliXMLCollection::~AliXMLCollection() {
+AliXMLCollection::~AliXMLCollection()
+{
//Destructor
- if(fEventList) delete fEventList;
- if(fEventListIter) delete fEventListIter;
+ delete fEventList;
+ delete fEventListIter;
}
//___________________________________________________________________________
}
//___________________________________________________________________________
-Bool_t AliXMLCollection::WriteBody(Int_t counter, const char* guid, const char* lfn, const char* turl, TEntryList *list) {
+Bool_t AliXMLCollection::WriteSummary(Int_t aTotal, Int_t aAccepted, Int_t aRejRun, Int_t aRejLHC, Int_t aRejDet, Int_t aRejEvt)
+{
+ // Write selection summary
+
+ TString collectionSummary = "<summary";
+ collectionSummary += " acceptedEvents=\"";
+ collectionSummary += aAccepted;
+ collectionSummary += "\" totalEvent=\"";
+ collectionSummary += aTotal;
+ collectionSummary += "\" rejectedRun=\"";
+ collectionSummary += aRejRun;
+ collectionSummary += "\" rejectedLHC=\"";
+ collectionSummary += aRejLHC;
+ collectionSummary += "\" rejectedDet=\"";
+ collectionSummary += aRejDet;
+ collectionSummary += "\" rejectedEvt=\"";
+ collectionSummary += aRejEvt;
+ collectionSummary += "\" />";
+
+ // Open the output stream
+ fout<<" "<<collectionSummary<<"\n";
+
+ return kTRUE;
+}
+
+//___________________________________________________________________________
+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++) {
return kTRUE;
}
+//___________________________________________________________________________
+Bool_t AliXMLCollection::WriteBody(Int_t counter, const char* guid, const char *lfn, const char *turl, TEntryList* list, Int_t accSum, Int_t rejSum)
+{
+ //Writes the body of the xml collection with tag cuts summary
+ TString listline;
+ for(Int_t i = 0; i < list->GetN(); i++) {
+ listline += list->GetEntry(i);
+ listline += ",";
+ }
+ listline = listline(0,listline.Length()-1);
+ TString line0 = "<event name=\"";
+ line0 += counter;
+ line0 += "\">";
+
+ TString line1 = "<file name=\"AliESDs.root\" ";
+ line1 += "guid=\"";
+ line1 += guid;
+ line1 += "\" ";
+ line1 += "lfn=\"";
+ line1 += lfn;
+ line1 += "\" ";
+ line1 += "turl=\"";
+ line1 += turl;
+ line1 += "\" ";
+ line1 += "evlist=\"";
+ line1 += listline;
+ line1 += "\" ";
+ line1 += "cutsumm=\"";
+ line1 += accSum;
+ line1 += ",";
+ line1 += rejSum;
+ line1 += "\"";
+ line1 += " />";
+
+ fout<<" "<<line0<<"\n";
+ fout<<" "<<line1<<"\n";
+ fout<<" </event>\n";
+
+ return kTRUE;
+
+}
//___________________________________________________________________________
Bool_t AliXMLCollection::Export() {
//Closes the stream
}
//___________________________________________________________________________
-const char *AliXMLCollection::GetTURL(const char* filename) const {
+const char *AliXMLCollection::GetTURL(const char* filename) {
// Get a file's transport URL (TURL). Returns 0 in case of error.
if (fCurrent) {
}
}
}
- Error("GetTURL","cannot get TURL of file %s",filename);
+ AliError(Form("cannot get TURL of file %s",filename));
return 0;
}
//___________________________________________________________________________
-const char *AliXMLCollection::GetGUID(const char* filename) const {
+const char *AliXMLCollection::GetGUID(const char* filename) {
// Get a file's transport UID. Returns 0 in case of error.
if (fCurrent) {
}
}
}
- Error("GetGUID","cannot get GUID of file %s",filename);
+ AliError(Form("cannot get GUID of file %s",filename));
return 0;
}
}
}
}
- Error("GetEvList", "cannot get evelist of file %s", filename);
+ AliError(Form("cannot get evelist of file %s", filename));
return 0;
}
}
//___________________________________________________________________________
-const char *AliXMLCollection::GetLFN(const char* ) const {
+const char *AliXMLCollection::GetLFN(const char* ) {
// Get a file's LFN. Returns 0 in case of error.
if (fCurrent) {
}
}
}
- Error("GetLFN", "cannot get LFN");
+ AliError("cannot get LFN");
return 0;
}
//__________________________________________________________________________
-Bool_t AliXMLCollection::OverlapCollection(AliXMLCollection * comparator) {
+const char *AliXMLCollection::GetCutSumm() {
+ // Get a file's tag cuts summary. Returns 0 in case of error.
+
+ if (fCurrent) {
+ TMap *obj = (TMap *) fCurrent->GetValue("");
+ if (obj) {
+ if (obj->GetValue("cutsumm")) {
+ return (((TObjString *) obj->GetValue("cutsumm"))->GetName());
+ }
+ }
+ }
+ AliError("cannot get Tag Cut Summary");
+ return 0;
+
+}
+//__________________________________________________________________________
+Bool_t AliXMLCollection::OverlapCollection(TGridCollection * comparator) {
// return kTRUE if comparator overlaps with this
if ((!comparator)) return kFALSE;
XMLDocPointer_t xdoc = xml.ParseFile(fXmlFile);
if (!xdoc) {
- Error("ParseXML","cannot parse the xml file %s",fXmlFile.Data());
+ AliError(Form("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());
+ AliError(Form("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());
+ AliError(Form("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());
+ AliError(Form("cannot find the <event> tag in %s",fXmlFile.Data()));
return;
}
- if (!xevent) return;
do {
if (xml.GetAttr(xevent, "name")) {
// files
XMLNodePointer_t xfile = xml.GetChild(xevent);
if (!xfile) continue;
-
+
Bool_t firstfile=kTRUE;
do {
// here we have an event file
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() != "") {
+
+ TObjString *oevlist;
+ if (xml.GetAttr(xfile, "evlist"))
+ oevlist = new TObjString(xml.GetAttr(xfile, "evlist"));
+ else
+ oevlist = 0;
+
+ TObjString *otagsumm;
+ if (xml.GetAttr(xfile, "cutsumm"))
+ otagsumm = new TObjString(xml.GetAttr(xfile, "cutsumm"));
+ else
+ otagsumm = 0;
+
+ if (oevlist) {
+ AliDebug(1,Form("Collection: %s - turl: %s eventlist: %s",
+ fXmlFile.Data(),oturl->GetName(),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()));
+ if (strcmp(oevlist->GetName(),"") != 0) {
+ 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("turl"),oturl);
attributes->Add(new TObjString("lfn"),olfn);
attributes->Add(new TObjString("guid"),oguid);
+ if (otagsumm)
+ attributes->Add(new TObjString("cutsumm"),otagsumm);
files->Add(new TObjString(xml.GetAttr(xfile,"name")) , attributes);
// we add the first file always as a file without name to the map
} while ((xfile = xml.GetNext(xfile)));
fEventList->Add(files);
}
+ else {
+ if (xml.GetAttr(xevent, "acceptedEvents")) {
+ // Read list summary
+ fAcceptedEvents = atoi(xml.GetAttr(xevent, "acceptedEvents"));
+ fTotalEvents = atoi(xml.GetAttr(xevent, "totalEvent"));
+ fRejectedRun = atoi(xml.GetAttr(xevent, "rejectedRun"));
+ fRejectedLHC = atoi(xml.GetAttr(xevent, "rejectedLHC"));
+ fRejectedDet = atoi(xml.GetAttr(xevent, "rejectedDet"));
+ fRejectedEvt = atoi(xml.GetAttr(xevent, "rejectedEvt"));
+ }
+ }
} while ((xevent = xml.GetNext(xevent)));
}
+Bool_t AliXMLCollection::GetCollectionSummary(Int_t *aTot, Int_t *aAcc, Int_t *aRejRun, Int_t *aRejLHC, Int_t *aRejDet, Int_t *aRejEvt) const
+{
+ // Return read list summary
+ *aTot = fTotalEvents;
+ *aAcc = fAcceptedEvents;
+ *aRejRun = fRejectedRun;
+ *aRejLHC = fRejectedLHC;
+ *aRejDet = fRejectedDet;
+ *aRejEvt = fRejectedEvt;
+ return kTRUE;
+}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff