27#include "RConfigure.h"
83 Double_t res = par[0] + par[1] * xx[0];
92 Double_t res = par[0] + par[1] * xx[0] + par[2] * xx[0] * xx[0];
101 Double_t res = par[0] / xx[0] + par[1];
110 Double_t res = par[0] / xx[0] + par[1] + par[2] * xx[0];
119 Double_t sat = par[0] / par[1] * (xx[0] * par[1] / par[2] - 1.);
120 if (xx[0] < par[2] / par[1]) sat = 0.;
121 Double_t res = par[0] * xx[0] / (1. + sat);
136 Double_t rio = par[0] / par[3] * xx[0];
137 if (xx[0] > par[3]) rio = par[0];
143 Double_t res = 1. / (1./par[4] + 1./rio + 1./rcpu);
186 : fUnlinkOutfile(
kFALSE), fProofDS(0), fOutFile(0),
187 fNtries(4), fHistType(0), fNHist(16), fReadType(0),
188 fDataSet(
"BenchDataSet"), fNFilesWrk(2), fReleaseCache(
kTRUE),
190 fRunCPU(0), fRunDS(0), fDS(0), fDebug(
kFALSE), fDescription(0)
194 Error(
"TProofBench",
"specifying a PROOF master url is mandatory - cannot continue");
198 Error(
"TProofBench",
"could not open a valid PROOF session - cannot continue");
207 Error(
"TProofBench",
"dynamic mode: you must specify the max number of workers");
215 Error(
"TProofBench",
"dynamic mode: wrong specification of the max number of"
216 " workers ('%s')",
n->GetTitle());
223 Error(
"TProofBench",
"wrong max number of workers ('%d')",
fNumWrkMax);
241 Warning(
"TProofBench",
"problems opening '%s' - ignoring: use SetOutFile to try"
242 " again or with another file", outfile);
269 const char *
mode = 0;
276 Warning(
"OpenOutFile",
"problems opening '%s' - ignoring: use SetOutFile to try"
282 if (!strcmp(
mode,
"RECREATE")) {
318 Warning(
"SetOutFile",
"problems opening '%s' - ignoring: use SetOutFile to try"
319 " again or with another file", outfile);
414 if (!fout || (fout && fout->
IsZombie())) {
415 ::Error(
"DrawCPU",
"could not open file '%s' ...", outfile);
420 TString description(
"<not available>");
422 if (nmdesc) description = nmdesc->
GetTitle();
432 const char *dirn = (isX) ?
"RunCPUx" :
"RunCPU";
435 ::Error(
"DrawCPU",
"could not find directory '%s' ...", dirn);
443 const char *lx = (isX) ?
"_x" :
"";
444 const char *ln = (isNorm) ?
"Norm" :
"Prof";
445 hprofn.
Form(
"%s%s_CPU_QR_Evts", ln, lx);
446 hmaxn.
Form(
"%s%s_CPU_PS_MaxEvts", ln, lx);
449 Double_t ami = -1., amx = -1., mmi = -1., mmx = -1.;
450 Int_t kamx = -1, kmmx = -1, nbins = -1;
460 ::Error(
"DrawCPU",
"could not find '%s' ...", hprofn.
Data());
474 ::Warning(
"DrawCPU",
"could not find '%s': feature added in 5.34/11", hmaxn.
Data());
483 if (mmx > ymx) ymx = mmx;
484 if ((ymi > 0 && mmi < ymi) || (ymi < 0.)) ymi = mmi;
490 TCanvas *cpu =
new TCanvas(
"cpu",
"Rate vs wrks",204,69,1050,502);
491 cpu->
Range(-3.106332,0.7490716,28.1362,1.249867);
525 if (verbose) grav->
Print();
527 leg->AddEntry(grav,
"Average",
"P");
538 if (verbose) grmx->
Print();
540 grmx->
Draw(
"lpSAME");
544 leg->AddEntry(grmx,
"Maximum",
"P");
553 if (nbins > 5) xmi = 1.5;
572 }
else if (dofit == 2) {
611 printf(
"* ************************************************************ *\n");
613 printf(
"* Cluster: %s\n", description.
Data());
614 printf(
"* Performance measurement from scalability plot: *\n");
616 printf(
"* rate max: %.3f\tmegaRNGPS (@ %d workers)\n", ymx/1000000, kmx);
618 printf(
"* per-worker rate: %.3f\tmegaRNGPS \n", normrate/1000000);
619 printf(
"* ************************************************************ *\n");
621 printf(
"* ************************************************************ *\n");
623 printf(
"* Cluster: %s\n", description.
Data());
625 printf(
"* Per-worker rate from normalized plot: %.3f\tmegaRNGPS\n", normrate/1000000);
626 printf(
"* ************************************************************ *\n");
644 if (!
d || !pfn || (pfn && strlen(pfn) <= 0)) {
645 ::Error(
"TProofBench::GetGraph",
"directory or name not defined!");
649 TList *keylist =
d->GetListOfKeys();
652 while ((key = (
TKey *) nxk())) {
660 ::Error(
"TProofBench::GetGraph",
"TProfile for '%s' not found in directory '%s'", pfn,
d->GetName());
673 for (
Int_t k = 1;k <= nb; k++) {
683 if (yy < ymi) ymi = yy;
684 if (yy > ymx) { ymx = yy; kmx = k; }
751 if (fMtime < fd->
fMtime)
return -1;
768 ::Error(
"TProofBench::GetPerfSpecs",
"path '%s' could not be stat'ed - abort", pp.Data());
776 ::Error(
"TProofBench::GetPerfSpecs",
"directory path '%s' could nto be open - abort", pp.Data());
781 if (!strcmp(ent,
".") || !strcmp(ent,
".."))
continue;
782 fn.
Form(
"%s/%s", pp.Data(), ent);
785 fn +=
"?filetype=raw";
789 if (!
f->ReadBuffer(rr, 4)) {
790 if (!strncmp(rr,
"root", 4)) {
794 TString desc(
"<no decription>");
796 if (nmdesc) desc = nmdesc->
GetTitle();
797 if (
f->GetListOfKeys()->FindObject(
"RunCPU"))
799 if (
f->GetListOfKeys()->FindObject(
"RunCPUx"))
802 ::Warning(
"TProofBench::GetPerfSpecs",
"problems opening '%s'", fn.
Data());
809 ::Error(
"TProofBench::GetPerfSpecs",
810 "path '%s' not a regular file nor a directory - abort", pp.Data());
819 fn +=
"?filetype=raw";
823 if (!(
f->ReadBuffer(rr, 4))) {
824 if (!strncmp(rr,
"root", 4)) {
827 if (
f->GetListOfKeys()->FindObject(
"RunCPU")) oo =
"std:";
828 if (
f->GetListOfKeys()->FindObject(
"RunCPUx")) oo =
"stdx:";
833 emsg.
Form(
"path '%s' does not contain the relevant dirs - abort", fn.
Data());
836 emsg.
Form(
"path '%s' cannot be open - abort", fn.
Data());
839 emsg.
Form(
"'%s' is not a ROOT file - abort", fn.
Data());
842 emsg.
Form(
"could not read first 4 bytes from '%s' - abort", fn.
Data());
846 emsg.
Form(
"path '%s' cannot be open in raw mode - abort", fn.
Data());
849 emsg.
Form(
"path '%s' cannot be stated - abort", fn.
Data());
852 ::Error(
"TProofBench::GetPerfSpecs",
"%s", emsg.
Data());
863 }
else if (filels.
GetSize() > 1) {
866 Printf(
"Several possible files found:");
872 if (
a.IsNull() ||
a[0] ==
'\n')
a.Form(
"%d", idx-1);
878 ::Error(
"TProofBench::GetPerfSpecs",
"chosen index '%d' does not exist - abort", idx);
883 ::Error(
"TProofBench::GetPerfSpecs",
884 "path '%s' is a directory but no ROOT file found in it - abort", pp.Data());
980 const char *opt,
const char *
type,
Bool_t verbose,
985 if (!fout || (fout && fout->
IsZombie())) {
986 ::Error(
"DrawDataSet",
"could not open file '%s' ...", outfile);
991 TString description(
"<not available>");
993 if (nmdesc) description = nmdesc->
GetTitle();
1002 const char *dirn = (isX) ?
"RunDataReadx" :
"RunDataRead";
1005 ::Error(
"DrawCPU",
"could not find directory '%s' ...", dirn);
1013 const char *lx = (isX) ?
"_x" :
"";
1014 const char *ln = (isNorm) ?
"Norm" :
"Prof";
1016 if (
type && !strcmp(
type,
"evts")) {
1017 hprofn.
Form(
"%s%s_DataRead_QR_Evts", ln, lx);
1018 hmaxn.
Form(
"%s%s_DataRead_PS_MaxEvts", ln, lx);
1021 hprofn.
Form(
"%s%s_DataRead_QR_IO", ln, lx);
1022 hmaxn.
Form(
"%s%s_DataRead_PS_MaxIO", ln, lx);
1026 Double_t ami = -1., amx = -1., mmi = -1., mmx = -1.;
1027 Int_t kamx = -1, kmmx = -1, nbins = -1;
1037 ::Error(
"DrawCPU",
"could not find '%s' ...", hprofn.
Data());
1052 ::Warning(
"DrawCPU",
"could not find '%s': feature added in 5.34/11", hmaxn.
Data());
1061 if (mmx > ymx) ymx = mmx;
1062 if ((ymi > 0 && mmi < ymi) || (ymi < 0.)) ymi = mmi;
1068 TCanvas *cpu =
new TCanvas(
"dataset",
"Rate vs wrks",204,69,1050,502);
1069 cpu->
Range(-3.106332,0.7490716,28.1362,1.249867);
1071 TH1F *hgr =
new TH1F(
"Graph-DataSet",
" Data Read speed-up", nbins*4,
xmin,
xmax);
1107 if (verbose) grav->
Print();
1109 leg->AddEntry(grav,
"Average",
"P");
1120 if (verbose) grmx->
Print();
1122 grmx->
Draw(
"lpSAME");
1126 leg->AddEntry(grmx,
"Maximum",
"P");
1136 if (nbins > 5) xmi = 1.5;
1147 }
else if (dofit > 1) {
1165 printf(
"* ************************************************************ *\n");
1167 printf(
"* Cluster: %s\n", description.
Data());
1168 printf(
"* Performance measurement from scalability plot: *\n");
1171 printf(
"* rate max: %.3f\tMB/s (@ %d workers)\n", ymx, kmx);
1173 printf(
"* per-worker rate: %.3f\tMB/s \n", normrate);
1175 printf(
"* rate max: %.3f\tevts/s (@ %d workers)\n", ymx, kmx);
1177 printf(
"* ************************************************************ *\n");
1191 const char *opt,
Bool_t verbose)
1195 if (!fout || (fout && fout->
IsZombie())) {
1196 ::Error(
"DrawEfficiency",
"could not open file '%s' ...", outfile);
1201 TString description(
"<not available>");
1203 if (nmdesc) description = nmdesc->
GetTitle();
1207 const char *dirs[4] = {
"RunCPU",
"RunCPUx",
"RunDataRead",
"RunDataReadx"};
1208 const char *labs[4] = {
"CPU",
"CPU",
"DataRead",
"DataRead"};
1209 Int_t fst = 0, lst = 3;
1212 }
else if (oo ==
"cpux") {
1215 }
else if (oo.BeginsWith(
"data")) {
1216 if (oo.EndsWith(
"x")) {
1224 const char *dirn = 0;
1226 for (
Int_t i = fst; i <= lst; i++) {
1234 ::Error(
"DrawEfficiency",
"could not find directory ...");
1242 hprof.
Form(
"Prof_%s_CPU_eff", ln.
Data());
1245 Int_t kmx = -1, nbins = -1;
1251 ::Error(
"DrawEfficiency",
"could not find '%s' ...", hprof.
Data());
1258 TCanvas *cpu =
new TCanvas(
"efficiency",
"efficiency vs wrks",204,69,1050,502);
1259 cpu->
Range(-3.106332,0.7490716,28.1362,1.249867);
1261 TH1F *hgr =
new TH1F(
"Graph-Efficiency",
"CPU effectiveness", nbins*4,
xmin,
xmax);
1287 printf(
"* ************************************************************ *\n");
1289 printf(
"* Cluster: %s\n", description.
Data());
1290 printf(
"* CPU effectiveness measurement: *\n");
1292 printf(
"* effectiveness max: %.3f (@ %d workers)\n", ymx, kmx);
1294 printf(
"* ************************************************************ *\n");
1347 if (dset && strlen(dset) > 0)
fDataSet = dset;
1355 Info(
"MakeDataSet",
"uploading '%s' ...", par.
Data());
1357 Error(
"MakeDataSet",
"problems uploading '%s' - cannot continue", par.
Data());
1367 Error(
"MakeDataSet",
"you should load the class '%s' before running the benchmark",
fDataGenSel.
Data());
1375 Info(
"MakeDataSet",
"Uploading '%s' ...", par.
Data());
1377 Error(
"MakeDataSet",
"problems uploading '%s' - cannot continue", par.
Data());
1380 Info(
"MakeDataSet",
"Enabling '%s' ...", par.
Data());
1382 Error(
"MakeDataSet",
"problems enabling '%s' - cannot continue", par.
Data());
1396 if (fnroot && strlen(fnroot) > 0) {
1414 TIter nxnd(nodesmap);
1418 while ((obj = nxnd()) != 0) {
1419 if ((wli =
dynamic_cast<TList *
>(nodesmap->
GetValue(obj)))) {
1433 filesmap->
SetName(
"PROOF_FilesToProcess");
1440 Int_t oldnotass = -1;
1445 Long64_t ne = (nevt > 0) ? nevt : 30000;
1458 if (oldnotass != -1)
1474 while ((obj = nxout())) {
1490 Warning(
"MakeDataSet",
"problems registering '%s'", dset);
1492 Warning(
"MakeDataSet",
"dataset '%s' is empty!", dset);
1495 Warning(
"MakeDataSet",
"PROOF output list is empty!");
1523 Error(
"CopyDataSet",
"no PROOF found - cannot continue");
1527 Error(
"CopyDataSet",
"dataset '%s' does not exist", dset);
1531 if (isatty(0) != 0 && isatty(1) != 0) {
1532 Printf(
"Target dataset '%s' exists already:"
1533 " do you want to remove it first?", dsetdst);
1534 const char *
a = Getline(
"[Y,n] ");
1536 if (
a[0] ==
'Y' ||
a[0] ==
'y' ||
a[0] ==
'\n') {
1537 Info(
"CopyDataSet",
"removing dataset '%s' ...", dsetdst);
1543 Error(
"CopyDataSet",
"destination dataset '%s' does already exist: remove it first", dsetdst);
1551 Error(
"CopyDataSet",
"problems retrieving TFileCollection for dataset '%s'", dset);
1560 Info(
"CopyDataSet",
"adding info for file '%s'", fn.
Data());
1568 Error(
"CopyDataSet",
"problems copying files of dataset '%s' to dest dir '%s'", dset, destdir);
1577 Error(
"CopyDataSet",
"problems registering and verifying '%s'", dsetdst);
1594 Error(
"SetProofDS",
"trying to set an invalid PROOF instance");
Option_t Option_t TPoint TPoint const char mode
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char Pixmap_t Pixmap_t PictureAttributes_t attr const char char ret_data h unsigned char height h Atom_t Int_t ULong_t ULong_t unsigned char prop_list Atom_t Atom_t Atom_t Time_t type
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char mx
const char *const kPROOF_BenchDataSelPar
const char *const kPROOF_BenchParDir
const char *const kPROOF_BenchSelDataGenDef
Double_t funp2(Double_t *xx, Double_t *par)
Simple polynomial 2nd degree.
Double_t funcpuv(Double_t *xx, Double_t *par)
Function with varying Rcpu.
Double_t funcpuvn(Double_t *xx, Double_t *par)
Function with varying Rcpu normalized.
Double_t funp1n(Double_t *xx, Double_t *par)
Normalized 1st degree.
Double_t funio(Double_t *xx, Double_t *par)
I/O saturated rate function.
Double_t funiov(Double_t *xx, Double_t *par)
I/O saturated rate function with varying Rcpu.
Double_t funp1(Double_t *xx, Double_t *par)
Simple polynomial 1st degree.
Double_t funp2n(Double_t *xx, Double_t *par)
Normalized 2nd degree.
void Printf(const char *fmt,...)
Formats a string in a circular formatting buffer and prints the string.
R__EXTERN TStyle * gStyle
Bool_t R_ISREG(Int_t mode)
Bool_t R_ISDIR(Int_t mode)
R__EXTERN TSystem * gSystem
virtual void SetTitleOffset(Float_t offset=1)
Set distance between the axis and the axis title.
virtual void SetLabelSize(Float_t size=0.04)
Set size of axis labels.
virtual void SetTitleSize(Float_t size=0.04)
Set size of axis title.
virtual void SetFillColor(Color_t fcolor)
Set the fill area color.
virtual void SetLineColor(Color_t lcolor)
Set the line color.
virtual void SetMarkerColor(Color_t mcolor=1)
Set the marker color.
virtual void SetMarkerStyle(Style_t mstyle=1)
Set the marker style.
virtual void SetMarkerSize(Size_t msize=1)
Set the marker size.
const char * GetTitle() const override
Returns title of object.
void CenterTitle(Bool_t center=kTRUE)
Center axis title.
static TClass * GetClass(const char *name, Bool_t load=kTRUE, Bool_t silent=kFALSE)
Static method returning pointer to TClass of the specified class name.
void SetName(const char *name)
const char * GetName() const override
Return name of this collection.
virtual void SetOwner(Bool_t enable=kTRUE)
Set whether this collection is the owner (enable==true) of its content.
void Print(Option_t *option="") const override
Default print for collections, calls Print(option, 1).
virtual Int_t GetSize() const
Return the capacity of the collection, i.e.
This class stores the date and time with a precision of one second in an unsigned 32 bit word (950130...
Int_t GetDate() const
Return date in form of 19971224 (i.e. 24/12/1997)
Bool_t cd() override
Change current directory to "this" directory.
TObject * Get(const char *namecycle) override
Return pointer to object identified by namecycle.
Describe directory structure in memory.
virtual Double_t Derivative(Double_t x, Double_t *params=nullptr, Double_t epsilon=0.001) const
Returns the first derivative of the function at point x, computed by Richardson's extrapolation metho...
void Print(Option_t *option="") const override
This method must be overridden when a class wants to print itself.
virtual void SetParNames(const char *name0="p0", const char *name1="p1", const char *name2="p2", const char *name3="p3", const char *name4="p4", const char *name5="p5", const char *name6="p6", const char *name7="p7", const char *name8="p8", const char *name9="p9", const char *name10="p10")
Set up to 10 parameter names.
virtual void SetParameter(Int_t param, Double_t value)
virtual Double_t GetParameter(Int_t ipar) const
Class that contains a list of TFileInfo's and accumulated meta data information about its entries.
Int_t Update(Long64_t avgsize=-1)
Update accumulated information about the elements of the collection (e.g.
Long64_t GetNFiles() const
void Print(Option_t *option="") const override
Prints the contents of the TFileCollection.
Int_t Add(TFileInfo *info)
Add TFileInfo to the collection.
Class describing a generic file including meta information.
TUrl * GetCurrentUrl() const
Return the current url.
A ROOT file is a suite of consecutive data records (TKey instances) with a well defined format.
static TFile * Open(const char *name, Option_t *option="", const char *ftitle="", Int_t compress=ROOT::RCompressionSetting::EDefaults::kUseCompiledDefault, Int_t netopt=0)
Create / open a file.
void Close(Option_t *option="") override
Close a file.
A TGraphErrors is a TGraph with error bars.
void Print(Option_t *chopt="") const override
Print graph and errors values.
virtual void SetPointError(Double_t ex, Double_t ey)
Set ex and ey values for point pointed by the mouse.
virtual void SetPoint(Int_t i, Double_t x, Double_t y)
Set x and y values for point number i.
virtual TFitResultPtr Fit(const char *formula, Option_t *option="", Option_t *goption="", Axis_t xmin=0, Axis_t xmax=0)
Fit this graph with function with name fname.
void SetName(const char *name="") override
Set graph name.
void Draw(Option_t *chopt="") override
Draw this graph with its current attributes.
virtual void SetHistogram(TH1F *h)
1-D histogram with a float per channel (see TH1 documentation)}
virtual void SetDirectory(TDirectory *dir)
By default, when a histogram is created, it is added to the list of histogram objects in the current ...
virtual Double_t GetBinCenter(Int_t bin) const
Return bin center for 1D histogram.
virtual Int_t GetNbinsX() const
virtual void SetMaximum(Double_t maximum=-1111)
virtual void SetMinimum(Double_t minimum=-1111)
virtual Double_t GetBinWidth(Int_t bin) const
Return bin width for 1D histogram.
virtual void SetStats(Bool_t stats=kTRUE)
Set statistics option on/off.
THashList implements a hybrid collection class consisting of a hash table and a list to store TObject...
Book space in a file, create I/O buffers, to fill them, (un)compress them.
This class displays a legend box (TPaveText) containing several legend entries.
TObject * FindObject(const char *name) const override
Find an object in this list using its name.
void Add(TObject *obj) override
TObject * Remove(TObject *obj) override
Remove object from the list.
TObject * First() const override
Return the first object in the list. Returns 0 when list is empty.
TObject * At(Int_t idx) const override
Returns the object at position idx. Returns 0 if idx is out of range.
TMap implements an associative array of (key,value) pairs using a THashTable for efficient retrieval ...
void Add(TObject *obj) override
This function may not be used (but we need to provide it since it is a pure virtual in TCollection).
TObject * GetValue(const char *keyname) const
Returns a pointer to the value associated with keyname as name of the key.
The TNamed class is the base class for all named ROOT classes.
virtual void SetTitle(const char *title="")
Set the title of the TNamed.
const char * GetName() const override
Returns name of object.
const char * GetTitle() const override
Returns title of object.
Collectable string class.
Mother of all ROOT objects.
virtual const char * GetName() const
Returns name of object.
virtual void Warning(const char *method, const char *msgfmt,...) const
Issue warning message.
R__ALWAYS_INLINE Bool_t IsZombie() const
virtual Int_t Write(const char *name=nullptr, Int_t option=0, Int_t bufsize=0)
Write this object to the current directory.
void SetBit(UInt_t f, Bool_t set)
Set or unset the user status bits as specified in f.
virtual void Error(const char *method, const char *msgfmt,...) const
Issue error message.
@ kInvalidObject
if object ctor succeeded but object should not be used
virtual void Info(const char *method, const char *msgfmt,...) const
Issue info message.
void Range(Double_t x1, Double_t y1, Double_t x2, Double_t y2) override
Set world coordinate system for the pad.
Double_t GetBinContent(Int_t bin) const override
Return bin content of a Profile histogram.
Double_t GetBinError(Int_t bin) const override
Return bin error of a Profile histogram.
Handle operations on datasets used by ProofBench.
Int_t CopyFiles(const char *dset, const char *destdir)
Copy the files of dataset 'dset' to another directory Return 0 on success, -1 on error.
Int_t RemoveFiles(const char *dset)
Physically remove the dataset 'dset', i.e.
Int_t ReleaseCache(const char *dset)
Release memory cache for dataset 'dset' Return 0 on success, -1 on error.
CPU-intensive PROOF benchmark test generates events and fill 1, 2, or 3-D histograms.
void Run(Long64_t nevents, Int_t start, Int_t stop, Int_t step, Int_t ntries, Int_t debug, Int_t draw)
Run benchmark Input parameters nevents: Number of events to run per file.
I/O-intensive PROOF benchmark test reads in event files distributed on the cluster.
void SetReleaseCache(Bool_t on=kTRUE)
void Run(Long64_t, Int_t, Int_t, Int_t, Int_t, Int_t, Int_t)
virtual void SetParList(const char *pars)
virtual void SetSelName(const char *sel)
virtual void SetSelOption(const char *opt)
Steering class for PROOF benchmarks.
static void AssertFittingFun(Double_t mi, Double_t mx)
Make sure that the fitting functions are defined.
void CloseOutFile()
Close output file.
Int_t CopyDataSet(const char *dset, const char *dsetdst, const char *destdir)
Copy the files of dataset 'dset' to 'destdir' and create a new dataset named 'dsetdst' decribing them...
static void DrawCPU(const char *outfile, const char *opt="std:", Bool_t verbose=kFALSE, Int_t dofit=0, Int_t n0=-1, Int_t n1=-1)
Draw the CPU speedup plot.
Int_t RunCPUx(Long64_t nevents=-1, Int_t start=-1, Int_t stop=-1)
Perform the CPU run scanning over the number of workers per node Return 0 on success,...
Int_t SetOutFile(const char *outfile, Bool_t verbose=kTRUE)
Set the output file Return 0 on success, -1 on error.
Int_t MakeDataSet(const char *dset=0, Long64_t nevt=-1, const char *fnroot="event", Bool_t regenerate=kFALSE)
Create the largest dataset for the run.
Int_t RunDataSetx(const char *dset="BenchDataSet", Int_t start=1, Int_t stop=-1)
Perform a test using dataset 'dset' scanning over the number of workers per node.
Int_t RunDataSet(const char *dset="BenchDataSet", Int_t start=1, Int_t stop=-1, Int_t step=1)
Perform a test using dataset 'dset' Return 0 on success, -1 on error Open the file for the results.
static void DrawDataSet(const char *outfile, const char *opt="std:", const char *type="mbs", Bool_t verbose=kFALSE, Int_t dofit=0, Int_t n0=-1, Int_t n1=-1)
Draw the CPU speedup plot.
TProofBenchRunCPU * fRunCPU
static void GetPerfSpecs(const char *path=".", Int_t degfit=1)
Get performance specs.
static void DrawEfficiency(const char *outfile, const char *opt="", Bool_t verbose=kFALSE)
Draw the efficiency plot.
void SetProofDS(TProof *p)
Set the PROOF instance to be used for dataset operations, like releasing cache ......
Int_t RemoveDataSet(const char *dset)
Physically remove the dataset 'dset', i.e.
Int_t OpenOutFile(Bool_t wrt=kFALSE, Bool_t verbose=kTRUE)
Set the otuput file Return 0 on success, -1 on error.
TProofBenchRunDataRead * fRunDS
Int_t RunCPU(Long64_t nevents=-1, Int_t start=-1, Int_t stop=-1, Int_t step=-1)
Perform the CPU run Return 0 on success, -1 on error.
Int_t ReleaseCache(const char *dset)
Release memory cache for dataset 'dset' Return 0 on success, -1 on error.
TProofBench(const char *url, const char *outfile="<default>", const char *proofopt=0)
Constructor: check PROOF and load selectors PAR.
static TGraphErrors * GetGraph(TDirectory *d, const char *pfn, Int_t &nb, Double_t &xmi, Double_t &xmx, Double_t &ymi, Double_t &ymx, Int_t &kmx, TProfile *&pf)
Get from TDirectory 'd' the TProfile named 'pfn' and create the graph.
virtual ~TProofBench()
Destructor.
PROOF worker node information
TMap * GetMapOfNodes() const
This class controls a Parallel ROOT Facility, PROOF, cluster.
Int_t UploadPackage(const char *par, EUploadPackageOpt opt=kUntar, TList *workers=0)
Upload a PROOF archive (PAR file).
void Close(Option_t *option="")
Close all open slave servers.
TObject * GetParameter(const char *par) const
Get specified parameter.
static TProof * Open(const char *url=0, const char *conffile=0, const char *confdir=0, Int_t loglevel=0)
Start a PROOF session on a specific cluster.
virtual Bool_t RegisterDataSet(const char *name, TFileCollection *dataset, const char *optStr="")
Register the 'dataSet' on the cluster under the current user, group and the given 'dataSetName'.
void DeleteParameters(const char *wildcard)
Delete the input list parameters specified by a wildcard (e.g.
void SetParameter(const char *par, const char *value)
Set input list parameter.
Int_t GetParallel() const
Returns number of slaves active in parallel mode.
TList * GetOutputList()
Get list with all object created during processing (see Process()).
virtual TFileCollection * GetDataSet(const char *dataset, const char *optStr="")
Get a list of TFileInfo objects describing the files of the specified dataset.
static const TList * GetEnvVars()
Get environemnt variables.
virtual Long64_t Process(TDSet *dset, const char *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
Process a data set (TDSet) using the specified selector (.C) file or Tselector object Entry- or event...
virtual Bool_t ExistsDataSet(const char *dataset)
Returns kTRUE if 'dataset' exists, kFALSE otherwise.
void AddInput(TObject *obj)
Add objects that might be needed during the processing of the selector (see Process()).
TList * GetInputList()
Get input list.
Bool_t UseDynamicStartup() const
const char * GetMaster() const
Int_t EnablePackage(const char *package, Bool_t notOnClient=kFALSE, TList *workers=0)
Enable specified package.
static const TString & GetEtcDir()
Get the sysconfig directory in the installation. Static utility function.
const char * GetName() const
Returns name of object.
A sorted doubly linked list.
void Add(TObject *obj) override
Add object in sorted list.
Int_t Atoi() const
Return integer value of string.
const char * Data() const
Bool_t IsDigit() const
Returns true if all characters in string are digits (0-9) or white spaces, i.e.
TString & ReplaceAll(const TString &s1, const TString &s2)
TObjArray * Tokenize(const TString &delim) const
This function is used to isolate sequential tokens in a TString.
Bool_t BeginsWith(const char *s, ECaseCompare cmp=kExact) const
static TString Format(const char *fmt,...)
Static method which formats a string using a printf style format descriptor and return a TString.
void Form(const char *fmt,...)
Formats a string using a printf style format descriptor.
Bool_t Contains(const char *pat, ECaseCompare cmp=kExact) const
void SetOptTitle(Int_t tit=1)
virtual void * OpenDirectory(const char *name)
Open a directory. Returns 0 if directory does not exist.
int GetPathInfo(const char *path, Long_t *id, Long_t *size, Long_t *flags, Long_t *modtime)
Get info about a file: id, size, flags, modification time.
virtual Bool_t AccessPathName(const char *path, EAccessMode mode=kFileExists)
Returns FALSE if one can access a file using the specified access mode.
virtual const char * GetDirEntry(void *dirp)
Get a directory entry. Returns 0 if no more entries.
virtual const char * BaseName(const char *pathname)
Base name of a file name. Base name of /user/root is root.
virtual const char * HostName()
Return the system's host name.
virtual Bool_t IsAbsoluteFileName(const char *dir)
Return true if dir is an absolute pathname.
virtual const char * WorkingDirectory()
Return working directory.
virtual TString GetDirName(const char *pathname)
Return the directory name in pathname.
virtual int Unlink(const char *name)
Unlink, i.e.
The TTimeStamp encapsulates seconds and ns since EPOCH.
const char * AsString(const Option_t *option="") const
Return the date & time as a string.
This class represents a WWW compatible URL.
const char * GetFile() const
const char * GetHost() const
const char * GetProtocol() const
Int_t Compare(const TObject *o) const
Compare abstract method.
fileDesc(const char *n, const char *o, Long_t t, const char *d)