49 if (!selfile || strlen(selfile) <= 0) {
50 Error(
"MakeSelector",
"input file path or name undefined");
57 Info(
"MakeSelector",
"selector name '%s' does not contain a '.':"
58 " no file to check, it will be loaded from a library", selfile);
60 Error(
"MakeSelector",
"could not create a %s selector", selfile);
85 Error(
"Process",
"selector object undefined");
113 PDB(kGlobal,1)
Info(
"Process",
"Enter");
118 Error(
"Process",
"No progress status");
150 Info(
"Process",
"starting new query");
170 while ((o = nxi())) {
174 inputtmp =
new TList;
188 PDB(kLoop,1)
Info(
"Process",
"Call Begin(0)");
197 Warning(
"Process",
"could not attach to histogram 'PROOF_ProcPcktHist'");
200 Info(
"Process",
"attached to histogram 'PROOF_ProcPcktHist' to record"
201 " packets being processed");
205 PDB(kPacketizer,1)
Info(
"Process",
"Create Proxy TDSet");
211 if (
InitPacketizer(dset, nentries, first,
"TPacketizerUnit",
"TPacketizer") != 0) {
212 Error(
"Process",
"cannot init the packetizer");
227 if (clf.IsDigit()) { memlogfreq = clf.
Atoi(); mrc = 0; }
229 if (memlogfreq == 0) {
231 if (memlogfreq <= 0) memlogfreq = 1;
262 PDB(kGlobal,1)
Info(
"Process",
"Calling Broadcast");
265 mesg << set << fn <<
fInput << opt << num << fst << evl << sync << enl;
266 (*fProcessMessage) << set << fn <<
fInput << opt << num << fst << evl << sync << enl;
268 PDB(kGlobal,1)
Info(
"Process",
"Broadcast called: %d workers notified", nb);
278 PDB(kGlobal,1)
Info(
"Process",
"Asynchronous processing:"
279 " activating CollectInputFrom");
288 PDB(kGlobal,1)
Info(
"Process",
"Synchronous processing: calling Collect");
344 Info(
"Finalize",
"query is undefined!");
360 Info(
"Finalize",
"problems reinitializing selector \"%s\"",
379 Warning(
"Finalize",
"undefined output list in the selector! Protocol error?");
384 PDB(kLoop,1)
Info(
"Finalize",
"Call Terminate()");
407 Warning(
"Finalize",
"current TQueryResult object is undefined!");
435 PDB(kGlobal,1)
Info(
"Finalize",
"exit");
494 Info(
"SetupFeedback",
"\"FeedbackList\" NOT found");
518 Info(
"StoreFeedback",
"Leave (empty)");
523 PDB(kFeedback,2)
Info(
"StoreFeedback",
"Create fFeedbackLists");
532 while( (obj =
next()) ) {
534 Info(
"StoreFeedback",
"Find '%s'", obj->
GetName() );
539 Info(
"StoreFeedback",
"map for '%s' not found (creating)", obj->
GetName());
546 Info(
"StoreFeedback",
"removing previous value");
547 if (map->GetValue(slave))
548 delete map->GetValue(slave);
551 map->Add(slave, obj);
556 Info(
"StoreFeedback",
"Leave");
virtual const char * BaseName(const char *pathname)
Base name of a file name. Base name of /user/root is root.
virtual const char * GetTitle() const
Returns title of object.
This class starts a PROOF session on the local machine: no daemons, client and master merged...
void SetMerging(Bool_t on=kTRUE)
Switch on/off merge timer.
TProofProgressStatus * fProgressStatus
virtual void Delete(Option_t *option="")
Remove all objects from the list AND delete all heap based objects.
Double_t RealTime()
Stop the stopwatch (if it is running) and return the realtime (in seconds) passed between the start a...
EExitStatus fExitStatus
status of query in progress
void Activate(TList *slaves=0)
Activate slave server list.
ClassImp(TSeqCollection) Int_t TSeqCollection TIter next(this)
Return index of object in collection.
Long_t fFeedbackPeriod
timer for sending intermediate results
virtual TList * GetOutputList() const
Collectable string class.
void SetupFeedback()
Setup reporting of feedback objects.
const char * GetObjName() const
TObject * FindObject(const char *name) const
Find object using its name.
This class implements a data set to be used for PROOF processing.
virtual void SetOwner(Bool_t enable=kTRUE)
Set whether this collection is the owner (enable==true) of its content.
void SetParameter(const char *par, const char *value)
Set input list parameter.
virtual void Info(const char *method, const char *msgfmt,...) const
Issue info message.
virtual void MergeOutput(Bool_t savememvalues=kFALSE)
Merge objects in output the lists.
virtual TObject * FindObject(const char *name) const
Find an object in this list using its name.
Int_t Broadcast(const TMessage &mess, TList *slaves)
Broadcast a message to all slaves in the specified list.
Long64_t Process(TDSet *set, const char *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
Process specified TDSet on PROOF.
Long64_t Finalize(Bool_t force=kFALSE, Bool_t sync=kFALSE)
Finalize a query.
TMacro * GetSelecImp() const
virtual void SetInputList(TList *input)
void SetBit(UInt_t f, Bool_t set)
Set or unset the user status bits as specified in f.
TMessage * fProcessMessage
Histogram with packets being processed (owned by TPerfStats)
virtual void StopProcess(Bool_t abort, Bool_t stoptimer=kFALSE)
Stop process.
const char * GetDirectory() const
virtual TObject * Clone(const char *newname="") const
Make a clone of an object using the Streamer facility.
void Stop()
Stop the stopwatch.
THashList implements a hybrid collection class consisting of a hash table and a list to store TObject...
EQueryMode GetQueryMode(Option_t *mode=0) const
Find out the query mode based on the current setting and 'mode'.
Long64_t GetBytesRead() const
void StopFeedback()
Stop reporting of feedback objects.
virtual void Start(Long_t milliSec=-1, Bool_t singleShot=kFALSE)
Starts the timer with a milliSec timeout.
virtual const char * Getenv(const char *env)
Get environment variable.
Int_t Collect(const TSlave *sl, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE)
Collect responses from slave sl.
void ResetMergePrg()
Reset the merge progress notificator.
TList * MergeFeedback()
Merge feedback lists.
Int_t Atoi() const
Return integer value of string.
Bool_t IsParallel() const
virtual void Begin(TTree *)
TClass * fSelectorClass
kTRUE when fSelector has been created locally
Int_t MakeSelector(const char *selfile)
Create the selector object and save the relevant files and binary information in the cache so that th...
virtual void SetOutputList(TList *out, Bool_t adopt=kTRUE)
Set / change the output list.
virtual void Error(const char *method, const char *msgfmt,...) const
Issue error message.
static void Start(TList *input, TList *output)
Initialize PROOF statistics run.
virtual void SetProcessInfo(Long64_t ent, Float_t cpu=0., Long64_t siz=-1, Float_t inittime=0., Float_t proctime=0.)
Set processing info.
TTimer * fFeedbackTimer
class of the latest selector
TObject * GetParameter(const char *par) const
Get specified parameter.
void Feedback(TList *objs)
Feedback signal.
TObject * GetEntryList() const
virtual TList * GetInputList() const
static void Setup(TList *input)
Setup the PROOF input list with requested statistics and tracing options.
Bool_t HandleTimer(TTimer *timer)
Send feedback objects to client.
void Clear(Option_t *option="")
Remove all objects from the list.
R__EXTERN TSystem * gSystem
static Bool_t IsStandardDraw(const char *selec)
Find out if this is a standard selection used for Draw actions (either TSelectorDraw, TProofDraw or deriving from them).
virtual const char * ClassName() const
Returns name of class to which the object belongs.
virtual TObject * Remove(TObject *obj)
Remove object from the list.
Long64_t GetTotalEntries() const
TObject * Remove(TObject *obj)
Remove object from the list.
Bool_t TestBit(UInt_t f) const
char * Form(const char *fmt,...)
A TEventList object is a list of selected events (entries) in a TTree.
Handles synchronous and a-synchronous timer events.
virtual const char * GetName() const
Returns name of object.
virtual void SetFinalized()
Int_t ReinitSelector(TQueryResult *qr)
Reinitialize fSelector using the selector files in the query result.
void SetName(const char *name)
void StoreFeedback(TObject *slave, TList *out)
Store feedback results from the specified slave.
static TSelector * GetSelector(const char *filename)
The code in filename is loaded (interpreted or compiled, see below), filename must contain a valid cl...
virtual Int_t RedirectOutput(const char *name, const char *mode="a", RedirectHandle_t *h=0)
Redirect standard output (stdout, stderr) to the specified file.
TList * GetInputList()
Get input list.
R__EXTERN TProof * gProof
virtual Int_t GetSize() const
virtual const char * GetName() const
Returns name of object.
TMap implements an associative array of (key,value) pairs using a THashTable for efficient retrieval ...
virtual void SendInputDataFile()
Send the input data objects to the master; the objects are taken from the dedicated list and / or the...
EExitStatus GetExitStatus() const
Int_t InitPacketizer(TDSet *dset, Long64_t nentries, Long64_t first, const char *defpackunit, const char *defpackdata)
Init the packetizer Return 0 on success (fPacketizer is correctly initialized), -1 on failure...
virtual void Clear(Option_t *option="")
Remove all objects from the list.
void SetSelectorDataMembersFromOutputList()
Set the selector's data members: find the mapping of data members to otuput list entries in the outpu...
Long64_t Finalize(Int_t query=-1, Bool_t force=kFALSE)
Finalize the qry-th query in fQueries.
virtual void SetOption(const char *option)
virtual Int_t DrawCanvas(TObject *obj)
Draw the object if it is a canvas.
Mother of all ROOT objects.
virtual void Add(TObject *obj)
void SetObject(TObject *object)
Set the object to be notified at time out.
TVirtualPacketizer * fPacketizer
const char * GetType() const
static void Stop()
Terminate the PROOF statistics run.
Bool_t fCreateSelObj
the latest selector
Float_t GetInitTime() const
static void output(int code)
A TSelector object is used by the TTree::Draw, TTree::Scan, TTree::Process to navigate in a TTree and...
A List of entry numbers in a TTree or TChain.
Int_t GetParallel() const
Returns number of slaves active in parallel mode.
virtual Long64_t GetStatus() const
virtual void Warning(const char *method, const char *msgfmt,...) const
Issue warning message.