39 const char *
id,
const char *
subid,
46 if ((
h =
gROOT->GetPluginManager()->FindHandler(
"TVirtualMonitoringWriter",
"MonaLisa"))) {
47 if (
h->LoadPlugin() != -1) {
143 Error(
"SendSummary",
"invalid instance: do nothing!");
152 Error(
"SendSummary",
"records list undefined or empty!");
157 PDB(kMonitoring,1)
Info(
"SendSummary",
"preparing (qid: '%s')",
id);
173 while ((o =
nxr())) {
180 Info(
"SendSummary",
"sending (%d entries)",
xrecs->GetSize());
204 return (
rc ? 0 : -1);
239 const char *begin,
const char *
qid)
242 Error(
"SendDataSetInfo",
"invalid instance: do nothing!");
251 Error(
"SendDataSetInfo",
"query id (tag) undefined!");
256 Error(
"SendDataSetInfo",
"TDSet object undefined! (qid: '%s')",
qid);
261 Info(
"SendDataSetInfo",
"preparing (qid: '%s')",
qid);
267 while ((
dss.Tokenize(
ds,
from ,
"[,| ]"))) {
279 while ((o =
nxe())) {
281 dse =
e->GetDataSet();
291 }
else if ((
dsete =
dynamic_cast<TDSet *
>(o))) {
293 Info(
"SendDataSetInfo",
"dset '%s' (%d files)",
297 dse =
ee->GetDataSet();
310 Warning(
"SendDataSetInfo",
"ignoring unknown element type: '%s'", o->
ClassName());
321 if (!
dsfi.IsNull() &&
dsfi !=
"TFileInfo") {
325 fn =
fi->GetCurrentUrl()->GetUrl();
326 if (
plet->fDSet &&
plet->fDSet->GetListOfElements() &&
327 !(
plet->fDSet->GetListOfElements()->FindObject(
fn)))
plet->fFiles += 1;
353 Info(
"SendDataSetInfo",
"sending (%d entries)",
plets.GetSize());
367 return (
rc ? 0 : -1);
402 const char *begin,
const char *
qid)
405 Error(
"SendFileInfo",
"invalid instance: do nothing!");
414 Error(
"SendFileInfo",
"query id (tag) undefined!");
419 Error(
"SendFileInfo",
"TDSet object undefined! (qid: '%s')",
qid);
423 PDB(kMonitoring,1)
Info(
"SendFileInfo",
"preparing (qid: '%s')",
qid);
452 Info(
"SendFileInfo",
"sending (%d entries)",
453 dset->GetListOfElements()->GetSize());
463 while ((o =
nxe())) {
468 if (
hmiss.FindObject(
fne)) status = 0;
475 }
else if ((
dsete =
dynamic_cast<TDSet *
>(o))) {
477 Info(
"SendFileInfo",
"dset '%s' (%d files)",
484 if (
hmiss.FindObject(
fne)) status = 0;
493 Warning(
"SendFileInfo",
"ignoring unknown element type: '%s'", o->
ClassName());
498 return (
rc ? 0 : -1);
ROOT::Detail::TRangeCast< T, true > TRangeDynCast
TRangeDynCast is an adapter class that allows the typed iteration through a TCollection.
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t recs
R__EXTERN TSystem * gSystem
Manages an element of a TDSet.
This class implements a data set to be used for PROOF processing.
Class describing a generic file including meta information.
THashList implements a hybrid collection class consisting of a hash table and a list to store TObject...
void Add(TObject *obj) override
The TNamed class is the base class for all named ROOT classes.
Collectable string class.
Mother of all ROOT objects.
virtual const char * GetName() const
Returns name of object.
R__ALWAYS_INLINE Bool_t TestBit(UInt_t f) const
virtual const char * ClassName() const
Returns name of class to which the object belongs.
virtual void Warning(const char *method, const char *msgfmt,...) const
Issue warning message.
R__ALWAYS_INLINE Bool_t IsZombie() const
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.
TProofMonSenderML(const char *serv, const char *tag, const char *id=0, const char *subid=0, const char *opt="")
Main constructor.
Int_t SendDataSetInfo(TDSet *, TList *, const char *, const char *) override
Post information about the processed dataset(s).
~TProofMonSenderML() override
Destructor.
Int_t SendFileInfo(TDSet *, TList *, const char *, const char *) override
Post information about the requested files.
Int_t SendSummary(TList *, const char *) override
Send summary record.
TVirtualMonitoringWriter * fWriter
Provides the interface for PROOF monitoring to different writers.
UInt_t Hash(ECaseCompare cmp=kExact) const
Return hash value.
virtual const char * BaseName(const char *pathname)
Base name of a file name. Base name of /user/root is root.
virtual TString GetDirName(const char *pathname)
Return the directory name in pathname.
This class represents a WWW compatible URL.
const char * GetFile() const
virtual Bool_t SendParameters(TList *, const char *=nullptr)
virtual void Verbose(Bool_t)