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,
with the goal of having all workers ending at the same time.

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()
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	TVirtualPacketizer::GetBytesRead() const
TList*	TVirtualPacketizer::GetConfigParams(Bool_t steal = kFALSE)
Double_t	TVirtualPacketizer::GetCumProcTime() const
virtual Float_t	GetCurrentRate(Bool_t& all)
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, Long64_t& calls)
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 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
TNtuple*	TVirtualPacketizer::GetProgressPerf(Bool_t steal = kFALSE)
Long64_t	TVirtualPacketizer::GetReadCalls() const
TMap*	TVirtualPacketizer::GetSlaveStats() const
TProofProgressStatus*	TVirtualPacketizer::GetStatus()
virtual const char*	TObject::GetTitle() const
Long64_t	TVirtualPacketizer::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	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()
void	TObject::Obsolete(const char* method, const char* asOfVers, const char* removedFromVers) const
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(ostream& 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)
void	TVirtualPacketizer::SetTotalEntries(Long64_t ent)
virtual void	TObject::SetUniqueID(UInt_t uid)
virtual void	ShowMembers(TMemberInspector& insp)
virtual void	TVirtualPacketizer::StopProcess(Bool_t abort, Bool_t stoptimer = kFALSE)
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:

TDSetElement*	TVirtualPacketizer::CreateNewPacket(TDSetElement* base, Long64_t first, Long64_t num)
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)
virtual Bool_t	TVirtualPacketizer::HandleTimer(TTimer* timer)
void	TObject::MakeZombie()

private:

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

Data Members

public:

enum TVirtualPacketizer::EUseEstOpt {	kEstOff
	kEstCurrent
	kEstAverage
};
enum TVirtualPacketizer::EStatusBits {	kIsInitializing
	kIsDone
	kIsTree
};
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::fAWLastFill	Whether to fill the last measurement
Int_t	TVirtualPacketizer::fActWrksLast	Active workers at fProcTimeLast
Long_t	TVirtualPacketizer::fCircN	Circularity
TNtupleD*	TVirtualPacketizer::fCircProg	Keeps circular info for "instantenous"
TList*	TVirtualPacketizer::fConfigParams	List of configuration parameters
TString	TVirtualPacketizer::fDataSet	Name of the dataset being processed (for dataset-driven runs)
Float_t	TVirtualPacketizer::fEffSessLast	Number of effective sessions at fProcTimeLast
Float_t	TVirtualPacketizer::fEvtRateLast	Evt rate at fProcTimeLast
TList*	TVirtualPacketizer::fFailedPackets	a list of packets that failed while processing
Float_t	TVirtualPacketizer::fInitTime	time before processing
Float_t	TVirtualPacketizer::fMBsReadLast	MBs read at fProcTimeLast
Double_t	TVirtualPacketizer::fMaxPacketTime	maximum packet time
Double_t	TVirtualPacketizer::fMinPacketTime	minimum packet time
Float_t	TVirtualPacketizer::fProcTime	time since start of processing
Float_t	TVirtualPacketizer::fProcTimeLast	Time of the last measurement
TTimer*	TVirtualPacketizer::fProgress	progress updates timer
TNtuple*	TVirtualPacketizer::fProgressPerf	{Active workers, evt rate, MBs read} as a function of processing time
TProofProgressStatus*	TVirtualPacketizer::fProgressStatus	pointer to status in the player.
Float_t	TVirtualPacketizer::fReportPeriod	Time between reports if nothing changes (estimated proc time / 100)
TMap*	TVirtualPacketizer::fSlaveStats	slave status, keyed by correspondig TSlave
TTime	TVirtualPacketizer::fStartTime	time offset
Bool_t	TVirtualPacketizer::fStop	Termination of Process() requested?
Float_t	TVirtualPacketizer::fTimeUpdt	time between updates
Long64_t	TVirtualPacketizer::fTotalEntries	total number of entries to be distributed;
TVirtualPacketizer::EUseEstOpt	TVirtualPacketizer::fUseEstOpt	Control usage of estimated values for the progress info
Bool_t	TVirtualPacketizer::fValid	Constructed properly?

private:

Long64_t	fAssigned	Entries processed or being processed.
Double_t	fCalibFrac	Size of the calibrating packet as fraction of Ntot/Nwrk
Long64_t	fNumPerWorker	Number of cycles per worker, if this option
TList*	fPackets	All processed packets
Long64_t	fProcessing	Event being processed
TStopwatch*	fStopwatch	For measuring the start time of each packet
TMap*	fWrkStats	Worker status, keyed by correspondig TSlave

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

Float_t GetCurrentRate(Bool_t& all)

 Get Estimation of the current rate; just summing the current rates of
 the active workers

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

 Get next packet

TPacketizerUnit()

 is chosen

TPacketizerUnit(const TPacketizerUnit& )

void operator=(const TPacketizerUnit& )

Int_t GetActiveWorkers()

{ return fWrkStats->GetSize(); }