79#define kPEX_STOPPED 1001
80#define kPEX_ABORTED 1002
128 if (
gDebug > 0) printf(
"TDispatchTimer::Notify: called!\n");
157 if (
gDebug > 0) printf(
"TProctimeTimer::Notify: called!\n");
187 :
TTimer(((to <= 0 || to > 864000) ? 10 : to * 1000),
kFALSE)
190 Info (
"TStopTimer",
"enter: %d, timeout: %d", abort, to);
207 if (
gDebug > 0) printf(
"TStopTimer::Notify: called!\n");
227 : fAutoBins(0), fOutput(0), fSelector(0), fCreateSelObj(
kTRUE), fSelectorClass(0),
228 fFeedbackTimer(0), fFeedbackPeriod(2000),
229 fEvIter(0), fSelStatus(0),
230 fTotalEvents(0), fReadBytesRun(0), fReadCallsRun(0), fProcessedRun(0),
231 fQueryResults(0), fQuery(0), fPreviousQuery(0), fDrawQueries(0),
232 fMaxDrawQueries(1), fStopTimer(0), fDispatchTimer(0),
233 fProcTimeTimer(0), fProcTime(0),
235 fSaveMemThreshold(-1), fSavePartialResults(
kFALSE), fSaveResultsPerPacket(
kFALSE)
248 initLimitsFinder =
kTRUE;
290 Info (
"StopProcess",
"abort: %d, timeout: %d", abort, timeout);
295 if (abort ==
kTRUE) {
335 Info (
"SetStopTimer",
"%s timer STARTED (timeout: %d)",
336 (abort ?
"ABORT" :
"STOP"), timeout);
339 Info (
"SetStopTimer",
"timer STOPPED");
350 Warning(
"AddQueryResult",
"query undefined - do nothing");
355 if (!(
q->IsDraw())) {
431 if (ref && strlen(ref) > 0) {
505 Info(
"ReinitSelector",
"query undefined - do nothing");
511 if (selec.
Length() <= 0) {
512 Info(
"ReinitSelector",
"selector name undefined - do nothing");
525 if (!stdselec && !compselec) {
532 TMD5 *md5icur = 0, *md5iold = 0, *md5hcur = 0, *md5hold = 0;
546 if (md5hcur && md5hold && md5icur && md5iold)
547 if (*md5hcur == *md5hold && *md5icur == *md5iold)
554 if (selc)
delete [] selc;
586 selec += opt(
id + 1, opt.
Length());
589 Info(
"ReinitSelector",
"problems locating or exporting selector files");
637 Info(
"ReinitSelector",
"compiled selector re-init failed:"
638 " automatic reload unsuccessful:"
639 " please load manually the correct library");
655 if (ipathold.
Length() > 0)
786 Info(
"SavePartialResults",
"partial result saving disabled");
792 Error(
"SavePartialResults",
"gProofServ undefined: something really wrong going on!!!");
796 Error(
"SavePartialResults",
"fOutput undefined: something really wrong going on!!!");
801 Info(
"SavePartialResults",
"start saving partial results {%d,%d,%d,%d}",
805 PDB(kOutput, 2)
Info(
"SavePartialResults",
"fEvIter: %p",
fEvIter);
808 PDB(kOutput, 2)
Info(
"SavePartialResults",
"list of packets: %p, sz: %d",
809 packets, (packets ? packets->
GetSize(): -1));
812 const char *oopt =
"UPDATE";
841 if (packetsDir) packetsDir->
cd();
851 while ((o = nxo())) {
855 if (!strncmp(o->
GetName(),
"PROOF_", 6))
continue;
859 if (!strcmp(o->
GetName(),
"MissingFiles"))
continue;
865 if (!
d || (
d && !
d->InheritsFrom(
"TFile"))) {
890 if (queryend) torm.
Add(o);
917 if (!strcmp(
TUrl(oname,
kTRUE).GetProtocol(),
"file")) {
930 oname.
Form(
"<datadir>/%s", baseName.
Data());
950 if (queryend && torm.
GetSize() > 0) {
957 Info(
"SavePartialResults",
"partial results saved to file");
968 if (selector_file && strlen(selector_file)) {
986 Error(
"AssertSelector",
"cannot load: %s", selector_file );
991 Info(
"AssertSelector",
"Processing via filename (%s)", selector_file);
993 Error(
"AssertSelector",
"no TSelector object define : cannot continue!");
996 Info(
"AssertSelector",
"Processing via TSelector object");
1027 PDB(kGlobal,1)
Info(
"Process",
"Enter");
1038 Error(
"Process",
"cannot assert the selector object");
1065 while ((
e = dset->
Next())) {
1073 Int_t useTreeCache = 1;
1075 if (useTreeCache > -1 && useTreeCache < 2)
1076 gEnv->
SetValue(
"ProofPlayer.UseTreeCache", useTreeCache);
1084 Int_t useParallelUnzip = 0;
1086 if (useParallelUnzip > -1 && useParallelUnzip < 2)
1087 gEnv->
SetValue(
"ProofPlayer.UseParallelUnzip", useParallelUnzip);
1090 Int_t dontCacheFiles = 0;
1092 if (dontCacheFiles == 1)
1105 opt =
gEnv->
GetValue(
"ProofPlayer.SavePartialResults", 0);
1118 Info(
"Process",
"memory threshold for saving objects to file set to %ld kB",
1121 Error(
"Process",
"cannot get SysInfo_t (!)");
1126 PDB(kLoop,1)
Info(
"Process",
"Call Begin(0)");
1131 PDB(kLoop,1)
Info(
"Process",
"Call Begin(0)");
1135 PDB(kLoop,1)
Info(
"Process",
"Call SlaveBegin(0)");
1143 Error(
"Process",
"exception %d caught", excode);
1150 Warning(
"Process",
"problems seetting up file-object swapping");
1159 Info(
"Process",
"Looping over Process()");
1186 TString lastMsg(
"(unfortunately no detailed info is available about current packet)");
1189 if (!
CheckMemUsage(singleshot, warnHWMres, warnHWMvir, wmsg)) {
1199 }
else if (!wmsg.
IsNull()) {
1203 TPair *currentElem = 0;
1230 lastMsg =
"check logs for possible stacktrace - last cycle:";
1234 lastMsg.
Form(
"while processing dset:'%s', file:'%s'"
1235 " - check logs for possible stacktrace - last event:", dset->
GetName(), fn.
Data());
1248 if (maxproctime > 0) {
1255 if (refnum < 0 && maxproctime <= 0) {
1256 wmsg.
Form(
"neither entries nor max proc time specified:"
1257 " risk of infinite loop: processing aborted");
1268 while (refnum < 0 || num--) {
1285 Info(
"Process",
"max proc time reached (%ld msecs): packet processing stopped:\n%s",
1286 maxproctime, lastMsg.
Data());
1304 Info(
"Process",
"Call ProcessCut(%lld)", entry);
1307 Info(
"Process",
"Call ProcessFill(%lld)", entry);
1312 Info(
"Process",
"Call Process(%lld)", entry);
1318 Info(
"Process",
"packet processing aborted following the"
1319 " selector settings:\n%s", lastMsg.
Data());
1328 if (!
CheckMemUsage(memlogfreq, warnHWMres, warnHWMvir, wmsg)) {
1365 Info(
"Process",
"received stop-process signal");
1369 Info(
"Process",
"received abort-process signal");
1372 Error(
"Process",
"exception %d caught", excode);
1381 TPair *currentElem = 0;
1384 delete currentElem->
Key();
1393 if (!wmsg.
IsNull())
Warning(
"Process",
"%s (%s)", wmsg.
Data(), shrc ?
"warn" :
"hwm");
1415 Warning(
"Process",
"problems saving the results to file");
1425 while ((o = nxo())) {
1431 const char *dir = of->
GetDir();
1432 if (!dir || (dir && strlen(dir) <= 0)) {
1434 }
else if (dir && strlen(dir) > 0) {
1436 if (!strcmp(u.
GetHost(),
"localhost") || !strcmp(u.
GetHost(),
"127.0.0.1") ||
1437 !strcmp(u.
GetHost(),
"localhost.localdomain")) {
1450 PDB(kLoop,1)
Info(
"Process",
"Call Terminate()");
1453 PDB(kLoop,1)
Info(
"Process",
"Call SlaveTerminate()");
1456 PDB(kLoop,1)
Info(
"Process",
"Call Terminate()");
1489 Error(
"Process",
"selector object undefiend!");
1516 if (mfreq > 0 && processed%mfreq == 0) {
1522 Info(
"CheckMemUsage|Svc",
"Memory %ld virtual %ld resident event %lld",
1529 wmsg.
Form(
"using more than %d%% of allowed virtual memory (%ld kB)"
1535 wmsg.
Form(
"using more than %d%% of allowed virtual memory (%ld kB)",
1543 wmsg.
Form(
"using more than %d%% of allowed resident memory (%ld kB)"
1550 wmsg.
Form(
"using more than %d%% of allowed both virtual and resident memory ({%ld,%ld} kB)",
1553 wmsg.
Form(
"using more than %d%% of allowed resident memory (%ld kB)",
1701 if (!gDrawCanvasHook) {
1703 TString drawlib =
"libProofDraw";
1713 Warning(
"DrawCanvas",
"can't find DrawCanvas");
1715 Warning(
"DrawCanvas",
"can't load %s", drawlib.
Data());
1717 Warning(
"DrawCanvas",
"can't locate %s", drawlib.
Data());
1719 if (gDrawCanvasHook && obj)
1720 return (*gDrawCanvasHook)(obj);
1733 static Int_t (*gGetDrawArgsHook)(
const char *,
const char *,
Option_t *,
1737 if (!gGetDrawArgsHook) {
1739 TString drawlib =
"libProofDraw";
1747 gGetDrawArgsHook = (
Int_t (*)(
const char *,
const char *,
Option_t *,
1750 Warning(
"GetDrawArgs",
"can't find GetDrawArgs");
1752 Warning(
"GetDrawArgs",
"can't load %s", drawlib.
Data());
1754 Warning(
"GetDrawArgs",
"can't locate %s", drawlib.
Data());
1756 if (gGetDrawArgsHook)
1757 return (*gGetDrawArgsHook)(var,
sel, opt, selector, objname);
1767 static void (*gFeedBackCanvasHook)(
const char *,
Bool_t) = 0;
1770 if (!gFeedBackCanvasHook) {
1772 TString drawlib =
"libProofDraw";
1780 gFeedBackCanvasHook = (
void (*)(
const char *,
Bool_t))(
f);
1782 Warning(
"FeedBackCanvas",
"can't find FeedBackCanvas");
1784 Warning(
"FeedBackCanvas",
"can't load %s", drawlib.
Data());
1786 Warning(
"FeedBackCanvas",
"can't locate %s", drawlib.
Data());
1788 if (gFeedBackCanvasHook) (*gFeedBackCanvasHook)(
name,
create);
1820 if (fNumMergers <= 0 && fProof->fMergersCount > 0)
1856 Error(
"Process",
"selector object undefiend!");
1917 const char *defpackdata)
1920 PDB(kGlobal,1)
Info(
"Process",
"Enter");
1925 Int_t honebyone = 1;
1927 honebyone =
gEnv->
GetValue(
"ProofPlayer.MergeTH1OneByOne", 1);
1933 TList *listOfMissingFiles = 0;
1942 packetizer = defpackunit;
1944 Info(
"InitPacketizer",
"using alternate packetizer: %s", packetizer.
Data());
1949 Error(
"InitPacketizer",
"class '%s' not found", packetizer.
Data());
1957 Error(
"InitPacketizer",
1958 "cannot find correct constructor for '%s'", cl->
GetName());
1973 Error(
"InitPacketizer",
"received stop/abort request");
1979 packetizer =
"TPacketizerMulti";
1984 Error(
"InitPacketizer",
"class '%s' not found", packetizer.
Data());
1992 Error(
"InitPacketizer",
"cannot find correct constructor for '%s'", cl->
GetName());
2018 listOfMissingFiles =
new TList;
2027 Error(
"InitPacketizer",
"received stop/abort request");
2036 Error(
"InitPacketizer",
"No files from the data set were found - Aborting");
2038 if (listOfMissingFiles) {
2048 packetizer = defpackdata;
2050 Info(
"InitPacketizer",
"using alternate packetizer: %s", packetizer.
Data());
2055 Error(
"InitPacketizer",
"class '%s' not found", packetizer.
Data());
2063 Error(
"InitPacketizer",
"cannot find correct constructor for '%s'", cl->
GetName());
2084 Error(
"InitPacketizer",
"cannot construct '%s'", cl->
GetName());
2090 Error(
"InitPacketizer",
2091 "instantiated packetizer object '%s' is invalid", cl->
GetName());
2112 if (!listOfMissingFiles)
2113 listOfMissingFiles =
new TList;
2123 if (listOfMissingFiles && listOfMissingFiles->
GetSize() > 0) {
2124 TIter missingFiles(listOfMissingFiles);
2130 msg =
Form(
"File not found: %s - skipping!",
2133 msg =
Form(
"File not found: %s - skipping!", fi->
GetName());
2140 listOfMissingFiles->
SetName(
"MissingFiles");
2150 msg =
Form(
" About %.2f %c of the requested files (%d out of %d) were missing or unusable; details in"
2151 " the 'missingFiles' list", xb * 100.,
'%', nbad, nbad + ngood);
2154 " +++ About %.2f %c of the requested files (%d out of %d) are missing or unusable; details in"
2155 " the 'MissingFiles' list\n"
2156 " +++", xb * 100.,
'%', nbad, nbad + ngood);
2178 PDB(kGlobal,1)
Info(
"Process",
"Enter");
2184 Error(
"Process",
"No progress status");
2221 TList *inputtmp = 0;
2225 PDB(kPacketizer,1)
Info(
"Process",
"Create Proxy TDSet");
2232 Error(
"Process",
"cannot init the packetizer");
2247 if (clf.
IsDigit()) { memlogfreq = clf.
Atoi(); mrc = 0; }
2250 if (memlogfreq == 0) {
2252 if (memlogfreq <= 0) memlogfreq = 1;
2260 Warning(
"Process",
"could not forward input data: %s", emsg.
Data());
2265 Warning(
"Process",
"could not attach to histogram 'PROOF_ProcPcktHist'");
2268 Info(
"Process",
"attached to histogram 'PROOF_ProcPcktHist' to record"
2269 " packets being processed");
2303 Info(
"Process",
"starting new query");
2326 while ((o = nxi())) {
2330 inputtmp =
new TList;
2344 PDB(kLoop,1)
Info(
"Process",
"Call Begin(0)");
2379 mesg << set << fn <<
fInput << opt << num << fst << evl << sync << enl;
2380 (*fProcessMessage) << set << fn <<
fInput << opt << num << fst << evl << sync << enl;
2382 mesg << set << fn <<
fInput << opt << num << fst << evl << sync;
2385 Warning(
"Process",
"entry lists not supported by the server");
2392 PDB(kGlobal,1)
Info(
"Process",
"Broadcast called: %d workers notified", nb);
2405 Info(
"Process|Svc",
"Start merging Memory information");
2412 PDB(kGlobal,1)
Info(
"Process",
"Asynchronous processing:"
2413 " activating CollectInputFrom");
2422 PDB(kGlobal,1)
Info(
"Process",
"Calling Collect");
2447 PDB(kGlobal,1)
Info(
"Process",
"Synchronous processing: calling Collect");
2451 Info(
"Process",
"switching to the asynchronous mode ...");
2489 TIter nxi(inputtmp);
2511 Error(
"Process",
"selector object undefined");
2536 Error(
"Process",
"Should not happen: fProcessMessage=%p fProof=%p fPacketizer=%p",
2542 Error(
"Process",
"Invalid call");
2547 Info(
"Process",
"Preparing %d new worker(s) to process", workers->
GetEntries());
2562 Info(
"Process",
"Adding new workers to the packetizer");
2564 Error(
"Process",
"Cannot add new workers to the packetizer!");
2569 Info(
"Process",
"Broadcasting process message to new workers");
2592 while ((o = nxo())) {
2603 Error(
"MergeOutputFiles",
"file merger is null in TProofOutputFile! Protocol error?");
2621 if (outfile.
Contains(
"<datadir>/")) {
2667 outfilerem.
Insert(0, srv);
2675 Error(
"MergeOutputFiles",
"cannot open the output file");
2680 if (!filemerger->
Merge()) {
2681 Error(
"MergeOutputFiles",
"cannot merge the output files");
2687 TIter next(fileList);
2699 filemerger->
Reset();
2709 pf->
Merge(&dumlist);
2714 Error(
"MergeOutputFiles",
"file collection is null in TProofOutputFile! Protocol error?");
2735 if (!rmList) rmList =
new TList;
2744 if (rmList && rmList->
GetSize() > 0) {
2747 while((o = nxo())) {
2754 PDB(kOutput,1)
Info(
"MergeOutputFiles",
"done!");
2771 PDB(kOutput,1)
Warning(
"SetSelectorDataMembersFromOutputList",
2772 "failed to find map object in output list!");
2794 PDB(kGlobal,1)
Info(
"Finalize",
"Calling Merge Output to finalize the output list");
2813 PDB(kOutput,1)
Info(
"Finalize",
"Calling Merge Output");
2837 if (!listOfMissingFiles) {
2838 listOfMissingFiles =
new TList;
2839 listOfMissingFiles->
SetName(
"MissingFiles");
2865 Info(
"Finalize",
"problems reinitializing selector \"%s\"",
2874 failedPackets->SetName(
"FailedPackets");
2879 status->
Add(
"Some packets were not processed! Check the the"
2880 " 'FailedPackets' list in the output list");
2889 while(
TObject* obj = next()) {
2896 Warning(
"Finalize",
"undefined output list in the selector! Protocol error?");
2908 PDB(kLoop,1)
Info(
"Finalize",
"Call Terminate()");
2930 Warning(
"Finalize",
"current TQueryResult object is undefined!");
2960 PDB(kGlobal,1)
Info(
"Process",
"exit");
2975 PDB(kGlobal,1)
Info(
"Finalize(TQueryResult *)",
"Enter");
2978 Info(
"Finalize(TQueryResult *)",
2979 "method to be executed only on the clients");
2984 Info(
"Finalize(TQueryResult *)",
"query undefined");
2989 Info(
"Finalize(TQueryResult *)",
"query already finalized");
3013 Info(
"Finalize(TQueryResult *)",
"outputlist is empty");
3022 out->Add(o->
Clone());
3047 if (!selector_file) {
3048 Info(
"SendSelector",
"Invalid input: selector (file) name undefined");
3054 Info(
"SendSelector",
"selector name '%s' does not contain a '.':"
3055 " nothing to send, it will be loaded from a library", selector_file);
3060 TString selec = selector_file;
3092 Info(
"SendSelector",
3093 "header file not found: tried: %s %s",
h.Data(), header.
Data());
3100 Info(
"SendSelector",
"problems sending implementation file %s", selec.
Data());
3104 Info(
"SendSelector",
"problems sending header file %s", header.
Data());
3116 PDB(kOutput,1)
Info(
"MergeOutput",
"Enter");
3124 while ( (list = (
TList *) next()) ) {
3127 obj = list->
First();
3132 if ( list->
IsEmpty() )
continue;
3142 while ( (obj = list->
First()) ) {
3152 PDB(kOutput,1)
Info(
"MergeOutput",
"fOutputLists empty");
3169 while ((obj = nxo())) {
3173 PDB(kOutput,2)
Info(
"MergeOutput",
"found TProofOutputFile '%s'", obj->
GetName());
3175 PDB(kOutput,2)
Info(
"MergeOutput",
"outputfilename: '%s'", dir.
Data());
3178 PDB(kOutput,2)
Info(
"MergeOutput",
"dir: '%s'", dir.
Data());
3187 PDB(kOutput,2)
Info(
"MergeOutput",
"rawdir: '%s'", dir.
Data());
3222 PDB(kOutput,2)
Info(
"MergeOutput",
"output object '%s' is not a TProofOutputFile", obj->
GetName());
3228 TIter nxrm(&rmlist);
3229 while ((obj = nxrm()))
3236 if (saveMemValues) {
3273 Info(
"Progress",
"%lld %lld %lld %f %f %f %f",
total, processed, bytesread,
3274 initTime, procTime, evtrti, mbrti);
3281 m <<
total << processed << bytesread << initTime << procTime << evtrti << mbrti;
3309 Warning(
"Progress",
"TProofProgressInfo object undefined!");
3347 Info(
"AddOutputObject",
"Enter: %p (%s)", obj, obj ? obj->
ClassName() :
"undef");
3351 PDB(kOutput,1)
Info(
"AddOutputObject",
"Invalid input (obj == 0x0)");
3364 if (elists && !strcmp(elists->
GetName(),
"PROOF_EventListsList")) {
3371 TIter nxevl(elists);
3373 while ((evl =
dynamic_cast<TEventList *
> (nxevl()))) {
3379 while ((elem =
dynamic_cast<TDSetElement *
> (nxelem()))) {
3384 Error(
"AddOutputObject",
"Found an event list for %s, but no object with"
3385 " the same name in the TDSet", evl->
GetName());
3394 for (
Int_t i = 0; i < num; i++)
3460 if (!of.
EndsWith(
".merger")) of +=
".merger";
3482 return (merged ? 1 : 0);
3509 PDB(kOutput,1)
Info(
"AddOutput",
"Enter");
3513 PDB(kOutput,1)
Info(
"AddOutput",
"Invalid input (out == 0x0)");
3523 TList *elists =
dynamic_cast<TList *
> (out->FindObject(
"PROOF_EventListsList"));
3531 TIter nxevl(elists);
3533 while ((evl =
dynamic_cast<TEventList *
> (nxevl()))) {
3539 while ((elem =
dynamic_cast<TDSetElement *
> (nxelem()))) {
3544 Error(
"AddOutput",
"Found an event list for %s, but no object with"
3545 " the same name in the TDSet", evl->
GetName());
3554 for (
Int_t i = 0; i < num; i++)
3563 out->Remove(elists);
3575 while ((obj = nxo())) {
3601 Info(
"NotifyMemory|Svc",
"Memory %ld virtual %ld resident after merging object %s",
3634 Info(
"Incorporate",
"enter: obj: %p (%s), list: %p",
3635 newobj, newobj ? newobj->
ClassName() :
"undef", outlist);
3638 if (!newobj || !outlist) {
3639 Error(
"Incorporate",
"Invalid inputs: obj: %p, list: %p", newobj, outlist);
3649 PDB(kOutput,1)
Info(
"Incorporate",
"histogram object '%s' merged", newobj->
GetName());
3651 PDB(kOutput,1)
Info(
"Incorporate",
"histogram object '%s' added to the"
3652 " appropriate list for delayed merging", newobj->
GetName());
3663 outlist->
Add(newobj);
3684 outlist->
Add(newobj);
3697 TH1 *
h =
dynamic_cast<TH1 *
>(obj);
3711 Int_t nent =
h->GetBufferLength();
3712 PDB(kOutput,2)
Info(
"HandleHistogram",
"h:%s ent:%d, buffer size: %d",
3713 h->GetName(), nent,
h->GetBufferSize());
3718 PDB(kOutput,2)
Info(
"HandleHistogram",
"create fOutputLists");
3743 while ((href = (
TH1 *) nxh())) {
3758 while ((href = (
TH1 *) nxh())) {
3779 Int_t hsz =
h->GetNbinsX() *
h->GetNbinsY() *
h->GetNbinsZ();
3814 if (!h0 || !
h1)
return rc;
3816 TAxis *a0 = 0, *a1 = 0;
3821 if (a0->
GetNbins() == a1->GetNbins())
3830 if (a0->
GetNbins() == a1->GetNbins())
3840 if (a0->
GetNbins() == a1->GetNbins())
3854 PDB(kOutput,1)
Info(
"StoreOutput",
"Enter");
3857 PDB(kOutput,1)
Info(
"StoreOutput",
"Leave (empty)");
3865 PDB(kOutput,2)
Info(
"StoreOutput",
"Create fOutputLists");
3870 TList* lists =
dynamic_cast<TList*
> (out->FindObject(
"PROOF_EventListsList"));
3877 while ( (aList =
dynamic_cast<TEventList*
> (it())) ) {
3881 while ( (elem =
dynamic_cast<TDSetElement*
> (nxe())) ) {
3886 Error(
"StoreOutput",
"found the EventList for %s, but no object with that name "
3887 "in the TDSet", aList->
GetName());
3896 for (
int i = 0; i < num; i++)
3899 mainList->
Add(aList);
3905 while( (obj = next()) ) {
3906 PDB(kOutput,2)
Info(
"StoreOutput",
"find list for '%s'", obj->
GetName() );
3910 PDB(kOutput,2)
Info(
"StoreOutput",
"list for '%s' not found (creating)", obj->
GetName());
3920 PDB(kOutput,1)
Info(
"StoreOutput",
"leave");
3929 Info(
"MergeFeedback",
"Enter");
3933 Info(
"MergeFeedback",
"Leave (no output)");
3943 while ( (map = (
TMap*) next()) ) {
3953#ifndef R__TH1MERGEFIXED
3957 while (
TObject *key = keys() ) {
3959 TH1 *
h =
dynamic_cast<TH1 *
>(o);
3960#ifndef R__TH1MERGEFIXED
3965 if (
h && !strncmp(o->
GetName(),
"PROOF_",6)) {
3966 if (
h->GetNbinsX() > nbmx) {
3967 nbmx=
h->GetNbinsX();
3975 while ((href = (
TH1 *)nxh())) {
3976 if (
h->GetBuffer()) {
3993#ifdef R__TH1MERGEFIXED
4016 while ( (obj = list->
First()) ) {
4026 Info(
"MergeFeedback",
"Leave (%d object(s))", fb->
GetSize());
4037 Info(
"StoreFeedback",
"Enter");
4041 Info(
"StoreFeedback",
"Leave (empty)");
4053 PDB(kFeedback,2)
Info(
"StoreFeedback",
"Create fFeedbackLists");
4061 const char *ord = ((
TSlave*) slave)->GetOrdinal();
4064 while( (obj = next()) ) {
4066 Info(
"StoreFeedback",
"%s: Find '%s'", ord, obj->
GetName() );
4070 Info(
"StoreFeedback",
"%s: map for '%s' not found (creating)", ord, obj->
GetName());
4077 Info(
"StoreFeedback",
"%s: removing previous value", ord);
4082 map->
Add(slave, obj);
4089 Info(
"StoreFeedback",
"Leave");
4101 PDB(kFeedback,1)
Info(
"SetupFeedback",
"\"FeedbackList\" %sfound",
4122 PDB(kFeedback,1)
Info(
"StopFeedback",
"Stop Timer");
4132 PDB(kFeedback,2)
Info(
"HandleTimer",
"Entry");
4170 PDB(kFeedback,2)
Info(
"HandleTimer",
"Sending %d objects", fb->
GetSize());
4211 Info(
"GetNextPacket",
"%s (%s): '%s' '%s' '%s' %lld %lld",
4213 e->GetDirectory(),
e->GetObjName(),
e->GetFirst(),
e->GetNum());
4253 Error(
"DrawSelect",
"parsing arguments");
4258 TNamed *selectionobj =
new TNamed(
"selection", selection);
4264 while ((o = nxi())) {
4276 if (objname ==
"") objname =
"htemp";
4290 delete selectionobj;
4294 TIter nxsi(savedInput);
4295 while ((o = nxsi()))
4325 Info(
"SetupFeedback",
"\"FeedbackList\" found: %d objects", fb->
GetSize());
4328 Info(
"SetupFeedback",
"\"FeedbackList\" NOT found");
4331 if (fb == 0 || fb->
GetSize() == 0)
return;
4352 PDB(kFeedback,1)
Info(
"StopFeedback",
"Stop Timer");
4362 PDB(kFeedback,2)
Info(
"HandleTimer",
"Entry");
4399 if (o != 0) fb->
Add(o);
4403 PDB(kFeedback,2)
Info(
"HandleTimer",
"Sending %d objects", fb->
GetSize());
4433 PDB(kGlobal, 1)
Info(
"HandleGetTreeHeader",
"empty TDSet");
4438 t = (
TTree*)
f->Get(
e->GetObjName());
4445 while ((
e = dset->
Next()) != 0) {
4450 entries +=
t1->GetEntries();
4461 answ <<
TString(
"Success") << t;
4463 answ <<
TString(
"Failed") << t;
4486 PDB(kGlobal,1)
Info(
"Process",
"Enter");
4489 if (!proof)
return -1;
4497 Error(
"Process",
"sending selector %s", selector_file);