12 #ifndef ROOT_TPacketizerMulti 13 #define ROOT_TPacketizerMulti 29 #ifndef ROOT_TVirtualPacketizer 69 if (fCurrent) fCurrent->
StopProcess(abort, stoptimer);
72 {
if (fCurrent) fCurrent->
MarkBad(wrk, st, missing);
return; }
74 {
if (fCurrent)
return fCurrent->
AddProcessed(wrk, st, lat, missing);
virtual Int_t AddProcessed(TSlave *, TProofProgressStatus *, Double_t, TList **)
virtual Float_t GetCurrentRate(Bool_t &all)
Float_t GetCurrentRate(Bool_t &all)
virtual void MarkBad(TSlave *, TProofProgressStatus *, TList **)
This class implements a data set to be used for PROOF processing.
void StopProcess(Bool_t abort, Bool_t stoptimer=kFALSE)
Stop process.
virtual void StopProcess(Bool_t abort, Bool_t stoptimer=kFALSE)
Stop process.
Manages an element of a TDSet.
This class allows to do multiple runs in the same query; each run can be a, for example, different dataset or the same dataset with entry list.
#define ClassDef(name, id)
TVirtualPacketizer * CreatePacketizer(TDSet *dset, TList *wrks, Long64_t first, Long64_t num, TList *input, TProofProgressStatus *st)
Create a packetizer for dataset 'dset' Return null on failure.
virtual Int_t GetEstEntriesProcessed(Float_t, Long64_t &ent, Long64_t &bytes, Long64_t &calls)
TDSetElement * GetNextPacket(TSlave *wrk, TMessage *r)
Get next packet from the current packetizer.
void MarkBad(TSlave *wrk, TProofProgressStatus *st, TList **missing)
The packetizer is a load balancing object created for each query.
Int_t GetEstEntriesProcessed(Float_t f, Long64_t &ent, Long64_t &bytes, Long64_t &calls)
TMap implements an associative array of (key,value) pairs using a THashTable for efficient retrieval ...
TVirtualPacketizer * fCurrent
void operator=(const TPacketizerMulti &)
virtual ~TPacketizerMulti()
Destructor.
Int_t AddProcessed(TSlave *wrk, TProofProgressStatus *st, Double_t lat, TList **missing)
virtual Int_t GetActiveWorkers()
Class describing a PROOF worker server.
Container class for processing statistics.