TPacketGenerator
class description - source file - inheritance tree
private:
TPacketGenerator TPacketGenerator()
TPacketGenerator TPacketGenerator(const TPacketGenerator&)
void Init()
void operator=(const TPacketGenerator&)
public:
TPacketGenerator TPacketGenerator(Stat_t firstEntry, Stat_t lastEntry, TTree* tree, TList* slaves)
TPacketGenerator TPacketGenerator(Stat_t firstEntry, Stat_t lastEntry, Int_t packetSize, TList* slaves)
virtual void ~TPacketGenerator()
static TClass* Class()
Stat_t GetEntriesProcessed() const
Stat_t GetEntriesProcessed(TSlave* sl) const
Int_t GetInitialPacketSize() const
Stat_t GetLastEntry() const
Stat_t GetNextEntry() const
Bool_t GetNextPacket(TSlave* sl, Int_t& nentry, Stat_t& first)
Int_t GetNoPackets() const
TList* GetPackets() const
virtual TClass* IsA() const
virtual void Print(Option_t* option) const
void Reset(Stat_t firstEntry, Stat_t lastEntry, TList* slaves)
void SetMinPacketSize(Int_t minps)
virtual void ShowMembers(TMemberInspector& insp, char* parent)
virtual void Streamer(TBuffer& b)
void StreamerNVirtual(TBuffer& b)
private:
Stat_t fNextEntry next entry to be processed
Stat_t fLastEntry last entry to be processed
Stat_t fEntriesProcessed number of entries processed
Int_t fInitialPacketSize initial packet size
Int_t fMinPacketSize minimum packet size
Int_t fSmallestPacket smallest packet generated
TTime fMinTimeDiff time difference between last two packets for fastest slave
Int_t fMaxOrd highest ordinal slave number
TTree* fTree tree or chain being processed
TList* fSlaves list of slaves
Stat_t* fEntriesPerSlave array containing number of entries processed per slave
TObjArray* fLastPackets pointer to the last packet for each slave
TList* fPackets list of packets that have been processed
TPacketGenerator
This class generates packets to be processed on PROOF slave servers.
A packet is an entry range (begin entry and number of entries).
Packets are generated taking into account the performance of the
remote machine, the time it took to process a previous packet on
the remote machine, the locality of the database files, etc.
TPacketGenerator()
Private default ctor.
TPacketGenerator(Stat_t firstEntry, Stat_t lastEntry, TTree *tree, TList *slaves)
Initialize TPacketGenerator using a TTree and a list of slave processors.
TPacketGenerator(Stat_t firstEntry, Stat_t lastEntry, Int_t packetSize, TList *slaves)
Initialize TPacketGenerator using the total number of entries, the
initial packet size and the list of slaves.
~TPacketGenerator()
TPacketGenerator dtor. Deletes the list of packets.
void Init()
Initialize the TPacketGenerator. Called by the ctors.
Stat_t GetEntriesProcessed(TSlave *sl) const
Return number of entries processed by slave sl.
Bool_t GetNextPacket(TSlave *sl, Int_t &nentry, Stat_t &first)
Get next packet for slave sl. Returns kTRUE and sets first and nentry.
In case no more packets return kFALSE (and set first and nentry == 0).
The packet size for a slave is a linear function of the time diff between
the processing of two packets relative to the fastest slave (i.e. the one
with the smallest time diff). The fastest slave always processes
packets of size fTree->GetPacketSize() (or of the size specified in
the TPacketGenerator ctor).
Int_t GetNoPackets() const
Number of packets generated.
void Print(Option_t *option) const
Prints info about the packet generator. If option is "all", print also
info about all packets.
void Reset(Stat_t firstEntry, Stat_t lastEntry, TList *slaves)
Reset the packet generator for a new cycle.
void SetMinPacketSize(Int_t minps)
Set minimum packet size. The default is 20% of the initial packet size
(in case of TTree's the initial packet size is set in via
TTree::SetPacketSize() and its default is 100).
Inline Functions
void operator=(const TPacketGenerator&)
TPacketGenerator TPacketGenerator(Stat_t firstEntry, Stat_t lastEntry, Int_t packetSize, TList* slaves)
Stat_t GetEntriesProcessed(TSlave* sl) const
Int_t GetInitialPacketSize() const
Stat_t GetNextEntry() const
TList* GetPackets() const
Stat_t GetLastEntry() const
TClass* Class()
TClass* IsA() const
void ShowMembers(TMemberInspector& insp, char* parent)
void Streamer(TBuffer& b)
void StreamerNVirtual(TBuffer& b)
Author: Fons Rademakers 28/03/97
Last update: root/treeplayer:$Name: $:$Id: TPacketGenerator.cxx,v 1.3 2000/12/13 16:45:36 brun Exp $
Copyright (C) 1995-2000, Rene Brun and Fons Rademakers. *
ROOT page - Class index - Top of the page
This page has been automatically generated. If you have any comments or suggestions about the page layout send a mail to ROOT support, or contact the developers with any questions or problems regarding ROOT.