12 #ifndef ROOT_TVirtualPacketizer
13 #define ROOT_TVirtualPacketizer
42 #ifndef ROOT_TProofProgressStatus
virtual Int_t AddProcessed(TSlave *, TProofProgressStatus *, Double_t, TList **)
TNtuple * GetProgressPerf(Bool_t steal=kFALSE)
Double_t GetCurrentRate() const
Get current rate. Rteunr the average rate if the current is not defined.
const char * GetOrdinal() const
virtual Float_t GetCurrentRate(Bool_t &all)
TProofProgressStatus * fStatus
virtual void MarkBad(TSlave *, TProofProgressStatus *, TList **)
A simple TTree restricted to a list of double variables only.
Long64_t GetBytesRead() const
Basic time type with millisecond precision.
virtual void SetInitTime()
Set the initialization time.
virtual Bool_t HandleTimer(TTimer *timer)
Send progress message to client.
Long64_t GetEntriesProcessed() const
Double_t GetProcTime() const
virtual void StopProcess(Bool_t abort, Bool_t stoptimer=kFALSE)
Stop process.
const char * Data() const
Double_t GetCumProcTime() const
TDSetElement * CreateNewPacket(TDSetElement *base, Long64_t first, Long64_t num)
Creates a new TDSetElement from from base packet starting from the first entry with num entries...
#define ClassDef(name, id)
void SetProgressStatus(TProofProgressStatus *st)
TVirtualPacketizer(TList *input, TProofProgressStatus *st=0)
Long64_t GetBytesRead() const
virtual Int_t GetEstEntriesProcessed(Float_t, Long64_t &ent, Long64_t &bytes, Long64_t &calls)
TMap * GetSlaveStats() const
TProofProgressStatus * fProgressStatus
void SetTotalEntries(Long64_t ent)
Float_t GetProcTime() const
A simple TTree restricted to a list of float variables only.
virtual Int_t AssignWork(TDSet *, Long64_t, Long64_t)
Long64_t GetTotalEntries() const
Handles synchronous and a-synchronous timer events.
Double_t GetProcTime() const
Long64_t GetReadCalls() const
Long64_t GetEntries() const
TList * GetFailedPackets()
virtual ~TVirtualPacketizer()
Destructor.
Long64_t GetEntries(Bool_t tree, TDSetElement *e)
Get entries.
TMap implements an associative array of (key,value) pairs using a THashTable for efficient retrieval ...
virtual TDSetElement * GetNextPacket(TSlave *sl, TMessage *r)
Get next packet.
void SetFailedPackets(TList *list)
Mother of all ROOT objects.
Long64_t GetReadCalls() const
const char * GetOrdinal() const
void operator=(const TVirtualPacketizer &)
virtual Int_t GetActiveWorkers()
TProofProgressStatus * GetStatus()
TList * GetConfigParams(Bool_t steal=kFALSE)
Float_t GetInitTime() const
TProofProgressStatus * GetProgressStatus()
virtual TProofProgressStatus * AddProcessed(TProofProgressStatus *st)=0
const char * GetName() const
Returns name of object.
Long64_t GetEntriesProcessed() const
virtual Int_t AddWorkers(TList *workers)
Adds new workers.