class TVirtualPacketizer: public TObject
TVirtualPacketizer The packetizer is a load balancing object created for each query. It generates packets to be processed on PROOF worker servers. A packet is an event range (begin entry and number of entries) or object range (first object and number of objects) in a TTree (entries) or a directory (objects) in a file. 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. TVirtualPacketizer includes common parts of PROOF packetizers. Look in subclasses for details. The default packetizer is TPacketizerAdaptive. To use an alternative one, for instance - the TPacketizer, call: proof->SetParameter("PROOF_Packetizer", "TPacketizer");
Function Members (Methods)
public:
| virtual | ~TVirtualPacketizer() |
| void | TObject::AbstractMethod(const char* method) const |
| virtual Int_t | AddProcessed(TSlave*, TProofProgressStatus*, Double_t, TList**) |
| virtual void | TObject::AppendPad(Option_t* option = "") |
| virtual void | TObject::Browse(TBrowser* b) |
| static TClass* | Class() |
| virtual const char* | TObject::ClassName() const |
| virtual void | TObject::Clear(Option_t* = "") |
| virtual TObject* | TObject::Clone(const char* newname = "") const |
| virtual Int_t | TObject::Compare(const TObject* obj) const |
| virtual void | TObject::Copy(TObject& object) const |
| virtual void | TObject::Delete(Option_t* option = "")MENU |
| virtual Int_t | TObject::DistancetoPrimitive(Int_t px, Int_t py) |
| virtual void | TObject::Draw(Option_t* option = "") |
| virtual void | TObject::DrawClass() constMENU |
| virtual TObject* | TObject::DrawClone(Option_t* option = "") constMENU |
| virtual void | TObject::Dump() constMENU |
| virtual void | TObject::Error(const char* method, const char* msgfmt) const |
| virtual void | TObject::Execute(const char* method, const char* params, Int_t* error = 0) |
| virtual void | TObject::Execute(TMethod* method, TObjArray* params, Int_t* error = 0) |
| virtual void | TObject::ExecuteEvent(Int_t event, Int_t px, Int_t py) |
| virtual void | TObject::Fatal(const char* method, const char* msgfmt) const |
| virtual TObject* | TObject::FindObject(const char* name) const |
| virtual TObject* | TObject::FindObject(const TObject* obj) const |
| virtual Int_t | GetActiveWorkers() |
| Long64_t | GetBytesRead() const |
| Double_t | GetCumProcTime() const |
| virtual Float_t | GetCurrentRate(Bool_t& all) |
| virtual Option_t* | TObject::GetDrawOption() const |
| static Long_t | TObject::GetDtorOnly() |
| Long64_t | GetEntriesProcessed() const |
| virtual Int_t | GetEstEntriesProcessed(Float_t, Long64_t& ent, Long64_t& bytes, Long64_t& calls) |
| TList* | GetFailedPackets() |
| virtual const char* | TObject::GetIconName() const |
| Float_t | GetInitTime() const |
| virtual const char* | TObject::GetName() const |
| virtual TDSetElement* | GetNextPacket(TSlave* sl, TMessage* r) |
| virtual char* | TObject::GetObjectInfo(Int_t px, Int_t py) const |
| static Bool_t | TObject::GetObjectStat() |
| virtual Option_t* | TObject::GetOption() const |
| Float_t | GetProcTime() const |
| Long64_t | GetReadCalls() const |
| TProofProgressStatus* | GetStatus() |
| virtual const char* | TObject::GetTitle() const |
| Long64_t | GetTotalEntries() const |
| virtual UInt_t | TObject::GetUniqueID() const |
| virtual ULong_t | TObject::Hash() const |
| virtual void | TObject::Info(const char* method, const char* msgfmt) const |
| virtual Bool_t | TObject::InheritsFrom(const char* classname) const |
| virtual Bool_t | TObject::InheritsFrom(const TClass* cl) const |
| virtual void | TObject::Inspect() constMENU |
| void | TObject::InvertBit(UInt_t f) |
| virtual TClass* | IsA() const |
| virtual Bool_t | TObject::IsEqual(const TObject* obj) const |
| virtual Bool_t | TObject::IsFolder() const |
| Bool_t | TObject::IsOnHeap() const |
| virtual Bool_t | TObject::IsSortable() const |
| Bool_t | IsValid() const |
| Bool_t | TObject::IsZombie() const |
| virtual void | TObject::ls(Option_t* option = "") const |
| virtual void | MarkBad(TSlave*, TProofProgressStatus*, TList**) |
| void | TObject::MayNotUse(const char* method) const |
| virtual Bool_t | TObject::Notify() |
| static void | TObject::operator delete(void* ptr) |
| static void | TObject::operator delete(void* ptr, void* vp) |
| static void | TObject::operator delete[](void* ptr) |
| static void | TObject::operator delete[](void* ptr, void* vp) |
| void* | TObject::operator new(size_t sz) |
| void* | TObject::operator new(size_t sz, void* vp) |
| void* | TObject::operator new[](size_t sz) |
| void* | TObject::operator new[](size_t sz, void* vp) |
| virtual void | TObject::Paint(Option_t* option = "") |
| virtual void | TObject::Pop() |
| virtual void | TObject::Print(Option_t* option = "") const |
| virtual Int_t | TObject::Read(const char* name) |
| virtual void | TObject::RecursiveRemove(TObject* obj) |
| void | TObject::ResetBit(UInt_t f) |
| virtual void | TObject::SaveAs(const char* filename = "", Option_t* option = "") constMENU |
| virtual void | TObject::SavePrimitive(basic_ostream<char,char_traits<char> >& out, Option_t* option = "") |
| void | TObject::SetBit(UInt_t f) |
| void | TObject::SetBit(UInt_t f, Bool_t set) |
| virtual void | TObject::SetDrawOption(Option_t* option = "")MENU |
| static void | TObject::SetDtorOnly(void* obj) |
| void | SetFailedPackets(TList* list) |
| virtual void | SetInitTime() |
| static void | TObject::SetObjectStat(Bool_t stat) |
| void | SetProgressStatus(TProofProgressStatus* st) |
| virtual void | TObject::SetUniqueID(UInt_t uid) |
| virtual void | ShowMembers(TMemberInspector& insp, char* parent) |
| virtual void | StopProcess(Bool_t abort) |
| virtual void | Streamer(TBuffer& b) |
| void | StreamerNVirtual(TBuffer& b) |
| virtual void | TObject::SysError(const char* method, const char* msgfmt) const |
| Bool_t | TObject::TestBit(UInt_t f) const |
| Int_t | TObject::TestBits(UInt_t f) const |
| virtual void | TObject::UseCurrentStyle() |
| virtual void | TObject::Warning(const char* method, const char* msgfmt) const |
| virtual Int_t | TObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0) |
| virtual Int_t | TObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0) const |
protected:
| TVirtualPacketizer(TList* input, TProofProgressStatus* st = 0) | |
| virtual void | TObject::DoError(int level, const char* location, const char* fmt, va_list va) const |
| Long64_t | GetEntries(Bool_t tree, TDSetElement* e) |
| void | TObject::MakeZombie() |
private:
| TVirtualPacketizer(const TVirtualPacketizer&) | |
| TDSetElement* | CreateNewPacket(TDSetElement* base, Long64_t first, Long64_t num) |
| virtual Bool_t | HandleTimer(TTimer* timer) |
| void | operator=(const TVirtualPacketizer&) |
Data Members
public:
| enum EUseEstOpt { | kEstOff | |
| kEstCurrent | ||
| kEstAverage | ||
| }; | ||
| enum EStatusBits { | kIsInitializing | |
| kIsDone | ||
| }; | ||
| enum TObject::EStatusBits { | kCanDelete | |
| kMustCleanup | ||
| kObjInCanvas | ||
| kIsReferenced | ||
| kHasUUID | ||
| kCannotPick | ||
| kNoContextMenu | ||
| kInvalidObject | ||
| }; | ||
| enum TObject::[unnamed] { | kIsOnHeap | |
| kNotDeleted | ||
| kZombie | ||
| kBitMask | ||
| kSingleKey | ||
| kOverwrite | ||
| kWriteDelete | ||
| }; |
private:
| Long_t | fCircN | Circularity |
| TNtupleD* | fCircProg | Keeps circular info for "instantenous" |
| TList* | fFailedPackets | a list of packets that failed while processing |
| Float_t | fInitTime | time before processing |
| Float_t | fProcTime | time since start of processing |
| TTimer* | fProgress | progress updates timer |
| TProofProgressStatus* | fProgressStatus | pointer to status in the player. |
| Long_t | fStartTime | time offset |
| Float_t | fTimeUpdt | time between updates |
| Long64_t | fTotalEntries | total number of entries to be distributed; |
| TVirtualPacketizer::EUseEstOpt | fUseEstOpt | Control usage of estimated values for the progress info |
Class Charts
Function documentation
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. The function returns a new created objects which have to be deleted.
TVirtualPacketizer(const TVirtualPacketizer& )
void operator=(const TVirtualPacketizer& )
Long64_t GetEntriesProcessed() const
{ return (fProgressStatus? fProgressStatus->GetEntries() : 0); }Int_t GetEstEntriesProcessed(Float_t , Long64_t& ent, Long64_t& bytes, Long64_t& calls)
{ ent = GetEntriesProcessed(); bytes = GetBytesRead(); calls = GetReadCalls(); return 0; }Float_t GetCurrentRate(Bool_t& all)
{ all = kTRUE; return (fProgressStatus? fProgressStatus->GetCurrentRate() : 0.); }Int_t AddProcessed(TSlave* , TProofProgressStatus* , Double_t , TList** )
{ return fProgressStatus; }