class TPacketizerUnit: public TVirtualPacketizer


TPacketizerUnit

This packetizer generates packets of generic units, representing the
number of times an operation cycle has to be repeated by the worker
node, e.g. the number of Monte carlo events to be generated.
Packets sizes are generated taking into account the performance of
worker nodes, based on the time needed to process previous packets.

Function Members (Methods)

public:

	TPacketizerUnit(TList* slaves, Long64_t num, TList* input, TProofProgressStatus* st = 0)
virtual	~TPacketizerUnit()
void	TObject::AbstractMethod(const char* method) const
virtual Int_t	TVirtualPacketizer::AddProcessed(TSlave, TProofProgressStatus, Double_t, TList**)
virtual void	TObject::AppendPad(Option_t* option = "")
virtual void	TObject::Browse(TBrowser* b)
static TClass*	Class()
static TClass*	TVirtualPacketizer::Class()
static TClass*	TObject::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
Long64_t	TVirtualPacketizer::GetBytesRead() const
Double_t	TVirtualPacketizer::GetCumProcTime() const
Double_t	GetCurrentTime()
virtual Option_t*	TObject::GetDrawOption() const
static Long_t	TObject::GetDtorOnly()
Long64_t	TVirtualPacketizer::GetEntriesProcessed() const
virtual Int_t	TVirtualPacketizer::GetEstEntriesProcessed(Float_t, Long64_t& ent, Long64_t& bytes)
TList*	TVirtualPacketizer::GetFailedPackets()
virtual const char*	TObject::GetIconName() const
Float_t	TVirtualPacketizer::GetInitTime() const
virtual const char*	TObject::GetName() const
virtual TDSetElement*	GetNextPacket(TSlave* sl, TMessage* r)
virtual TDSetElement*	TVirtualPacketizer::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	TVirtualPacketizer::GetProcTime() const
TProofProgressStatus*	TVirtualPacketizer::GetStatus()
virtual const char*	TObject::GetTitle() const
Long64_t	TVirtualPacketizer::GetTotalEntries() const
virtual UInt_t	TObject::GetUniqueID() const
virtual Bool_t	TObject::HandleTimer(TTimer* timer)
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 TClass*	TVirtualPacketizer::IsA() const
virtual TClass*	TObject::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	TVirtualPacketizer::IsValid() const
Bool_t	TObject::IsZombie() const
virtual void	TObject::ls(Option_t* option = "") const
virtual void	TVirtualPacketizer::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)
TObject&	TObject::operator=(const TObject& rhs)
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	TVirtualPacketizer::SetFailedPackets(TList* list)
virtual void	TVirtualPacketizer::SetInitTime()
static void	TObject::SetObjectStat(Bool_t stat)
void	TVirtualPacketizer::SetProgressStatus(TProofProgressStatus* st)
virtual void	TObject::SetUniqueID(UInt_t uid)
virtual void	ShowMembers(TMemberInspector& insp, char* parent)
virtual void	TVirtualPacketizer::ShowMembers(TMemberInspector& insp, char* parent)
virtual void	TObject::ShowMembers(TMemberInspector& insp, char* parent)
virtual void	TVirtualPacketizer::StopProcess(Bool_t abort)
virtual void	Streamer(TBuffer& b)
void	StreamerNVirtual(TBuffer& b)
void	TVirtualPacketizer::StreamerNVirtual(TBuffer& b)
void	TObject::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:

virtual void	TObject::DoError(int level, const char* location, const char* fmt, va_list va) const
Long64_t	TVirtualPacketizer::GetEntries(Bool_t tree, TDSetElement* e)
void	TObject::MakeZombie()

private:

	TPacketizerUnit()
	TPacketizerUnit(const TPacketizerUnit&)
void	operator=(const TPacketizerUnit&)

Data Members

private:

enum TVirtualPacketizer::EUseEstOpt {	kEstOff
	kEstCurrent
	kEstAverage
};
enum TVirtualPacketizer::EStatusBits {	kIsInitializing
	kIsDone
};
enum TObject::EStatusBits {	kCanDelete
	kMustCleanup
	kObjInCanvas
	kIsReferenced
	kHasUUID
	kCannotPick
	kNoContextMenu
	kInvalidObject
};
enum TObject::[unnamed] {	kIsOnHeap
	kNotDeleted
	kZombie
	kBitMask
	kSingleKey
	kOverwrite
	kWriteDelete
};

protected:

Bool_t	TVirtualPacketizer::fStop	Termination of Process() requested?
Bool_t	TVirtualPacketizer::fValid	Constructed properly?

private:

Long64_t	fAssigned	no. entries processed or being processed.
Int_t	fPacketAsAFraction	Used to calculate the packet size
Long64_t	fPacketSize	Global base packet size
TList*	fPackets	all processed packets
Long64_t	fProcessing	Event being processed
TMap*	fSlaveStats	Slave status, keyed by correspondig TSlave
TStopwatch*	fStopwatch	For measuring the start time of each packet
Double_t	fTimeLimit	Packet time limit

Class Charts

Inheritance Inherited Members Includes Libraries

Function documentation

TPacketizerUnit(TList* slaves, Long64_t num, TList* input, TProofProgressStatus* st = 0)

 Constructor

~TPacketizerUnit()

 Destructor.

Double_t GetCurrentTime()

 Get current time

TDSetElement * GetNextPacket(TSlave* sl, TMessage* r)

 Get next packet

TPacketizerUnit()

TPacketizerUnit(const TPacketizerUnit& )

void operator=(const TPacketizerUnit& )