TPacketGenerator


class description - source file - inheritance tree

class TPacketGenerator : public TObject

    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)

Data Members

    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

Class Description

                                                                      
 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.