class TPacketizerFile: public TVirtualPacketizer


TPacketizerFile

This packetizer generates packets which contain a single file path
to be used in process. Used for tasks generating files, like in
PROOF bench.

Function Members (Methods)

public:

	TPacketizerFile(TList* workers, Long64_t, TList* input, TProofProgressStatus* st = 0)
virtual	~TPacketizerFile()
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* wrk, 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:

	TPacketizerFile()
	TPacketizerFile(const TPacketizerFile&)
void	operator=(const TPacketizerFile&)

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	No.files processed or being processed.
TMap*	fFiles	Files to be produced/processed per node
TList*	fIters	Iterators on the file lists per node
TList*	fNotAssigned	List of files not assigned to a specific node
Bool_t	fProcNotAssigned	Whether to process files not asdigned to a worker
TStopwatch*	fStopwatch	For measuring the start time of each packet

Class Charts

Inheritance Inherited Members Includes Libraries

Function documentation

TPacketizerFile(TList* workers, Long64_t , TList* input, TProofProgressStatus* st = 0)

 Constructor

~TPacketizerFile()

 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* wrk, TMessage* r)

 Get next packet

TPacketizerFile()

 : fFiles(0), fIters(0), fAssigned(0), fStopwatch(0) { }

TPacketizerFile(const TPacketizerFile& )

void operator=(const TPacketizerFile& )

Int_t GetActiveWorkers()

{ return -1; }