TPacketizer Class Reference

#include <TPacketizer.h>

Inheritance diagram for TPacketizer:

List of all members.

Public Member Functions
	TPacketizer (TDSet *dset, TList *slaves, Long64_t first, Long64_t num, TList *input, TProofProgressStatus *st)
virtual	~TPacketizer ()
TDSetElement *	GetNextPacket (TSlave *sl, TMessage *r)
Long64_t	GetEntriesProcessed (TSlave *sl) const
Float_t	GetCurrentRate (Bool_t &all)
Int_t	GetActiveWorkers ()
	TPacketizer (TDSet *dset, TList *slaves, Long64_t first, Long64_t num, TList *input, TProofProgressStatus *st)
virtual	~TPacketizer ()
TDSetElement *	GetNextPacket (TSlave *sl, TMessage *r)
Long64_t	GetEntriesProcessed (TSlave *sl) const
Float_t	GetCurrentRate (Bool_t &all)
Int_t	GetActiveWorkers ()
Private Member Functions
	TPacketizer ()
	TPacketizer (const TPacketizer &)
void	operator= (const TPacketizer &)
TFileNode *	NextUnAllocNode ()
void	RemoveUnAllocNode (TFileNode *)
TFileNode *	NextActiveNode ()
void	RemoveActiveNode (TFileNode *)
TFileStat *	GetNextUnAlloc (TFileNode *node=0)
TFileStat *	GetNextActive ()
void	RemoveActive (TFileStat *file)
void	Reset ()
void	ValidateFiles (TDSet *dset, TList *slaves, Long64_t maxent=-1, Bool_t byfile=kFALSE)
	TPacketizer ()
	TPacketizer (const TPacketizer &)
void	operator= (const TPacketizer &)
TFileNode *	NextUnAllocNode ()
void	RemoveUnAllocNode (TFileNode *)
TFileNode *	NextActiveNode ()
void	RemoveActiveNode (TFileNode *)
TFileStat *	GetNextUnAlloc (TFileNode *node=0)
TFileStat *	GetNextActive ()
void	RemoveActive (TFileStat *file)
void	Reset ()
void	ValidateFiles (TDSet *dset, TList *slaves, Long64_t maxent=-1, Bool_t byfile=kFALSE)
Private Attributes
TList *	fPackets
TList *	fFileNodes
TList *	fUnAllocated
TList *	fActive
TMap *	fSlaveStats
Long64_t	fPacketSize
Int_t	fMaxPerfIdx
Long_t	fMaxSlaveCnt
Int_t	fPacketAsAFraction
TList *	fPackets
TList *	fFileNodes
TList *	fUnAllocated
TList *	fActive
TMap *	fSlaveStats
Classes
class	TFileNode
class	TFileStat
class	TSlaveStat

---

Detailed Description

Definition at line 41 of file TPacketizer.h.

---

Constructor & Destructor Documentation

TPacketizer::TPacketizer

(

)

[private]

TPacketizer::TPacketizer

(

const TPacketizer &

)

[private]

TPacketizer::TPacketizer	(	TDSet *	dset,
		TList *	slaves,
		Long64_t	first,
		Long64_t	num,
		TList *	input,
		TProofProgressStatus *	st
	)

TPacketizer::~TPacketizer

(

)

[virtual]

Definition at line 545 of file TPacketizer.cxx.

References TMap::DeleteValues(), fActive, fFileNodes, fPackets, fSlaveStats, fUnAllocated, and SafeDelete.

TPacketizer::TPacketizer

(

)

[private]

TPacketizer::TPacketizer

(

const TPacketizer &

)

[private]

TPacketizer::TPacketizer	(	TDSet *	dset,
		TList *	slaves,
		Long64_t	first,
		Long64_t	num,
		TList *	input,
		TProofProgressStatus *	st
	)

virtual TPacketizer::~TPacketizer

(

)

[virtual]

---

Member Function Documentation

void TPacketizer::operator=

(

const TPacketizer &

)

[private]

TPacketizer::TFileNode * TPacketizer::NextUnAllocNode

(

)

[private]

Definition at line 588 of file TPacketizer.cxx.

References TList::First(), fMaxSlaveCnt, fUnAllocated, TPacketizer::TFileNode::GetSlaveCnt(), TObject::Info(), PDB, TCollection::Print(), and TList::Sort().

Referenced by GetNextUnAlloc().

void TPacketizer::RemoveUnAllocNode

(

TFileNode *

)

[private]

Definition at line 609 of file TPacketizer.cxx.

References fUnAllocated, and TList::Remove().

Referenced by GetNextUnAlloc().

TPacketizer::TFileNode * TPacketizer::NextActiveNode

(

)

[private]

Definition at line 633 of file TPacketizer.cxx.

References fActive, TList::First(), fMaxSlaveCnt, TPacketizer::TFileNode::GetSlaveCnt(), TObject::Info(), PDB, TCollection::Print(), and TList::Sort().

Referenced by GetNextActive().

void TPacketizer::RemoveActiveNode

(

TFileNode *

)

[private]

Definition at line 664 of file TPacketizer.cxx.

References fActive, and TList::Remove().

Referenced by GetNextActive(), and RemoveActive().

TPacketizer::TFileStat * TPacketizer::GetNextUnAlloc

(

TFileNode *

node = 0

)

[private]

Definition at line 561 of file TPacketizer.cxx.

References TList::Add(), fActive, TList::FindObject(), TPacketizer::TFileNode::GetNextUnAlloc(), NextUnAllocNode(), and RemoveUnAllocNode().

Referenced by GetNextPacket(), and ValidateFiles().

TPacketizer::TFileStat * TPacketizer::GetNextActive

(

)

[private]

Definition at line 617 of file TPacketizer.cxx.

References TPacketizer::TFileNode::GetNextActive(), NextActiveNode(), and RemoveActiveNode().

Referenced by GetNextPacket().

void TPacketizer::RemoveActive

(

TFileStat *

file

)

[private]

Definition at line 653 of file TPacketizer.cxx.

References TPacketizer::TFileStat::GetNode(), TPacketizer::TFileNode::GetNumberOfActiveFiles(), TPacketizer::TFileNode::RemoveActive(), and RemoveActiveNode().

Referenced by GetNextPacket(), and ValidateFiles().

void TPacketizer::Reset

(

)

[private]

Definition at line 672 of file TPacketizer.cxx.

References TCollection::AddAll(), TList::Clear(), fActive, TPacketizer::TSlaveStat::fCurFile, fFileNodes, TList::FindObject(), fSlaveStats, fUnAllocated, TVirtualPacketizer::TVirtualSlaveStat::GetName(), TMap::GetValue(), TPacketizer::TFileNode::IncMySlaveCnt(), TIter::Next(), TPacketizer::TFileNode::Reset(), and TPacketizer::TSlaveStat::SetFileNode().

Referenced by ClassImp().

void TPacketizer::ValidateFiles	(	TDSet *	dset,
		TList *	slaves,
		Long64_t	maxent = -1,
		Bool_t	byfile = kFALSE
	)			[private]

Definition at line 701 of file TPacketizer.cxx.

References TMonitor::Activate(), TMap::Add(), TMonitor::Add(), TList::Add(), TCollection::AddAll(), TBuffer::BufferSize(), TMonitor::DeActivate(), TMonitor::DeActivateAll(), TPacketizer::TFileNode::DecSlaveCnt(), entries, TObject::Error(), TPacketizer::TSlaveStat::fCurFile, TList::First(), Form(), fSlaveStats, TVirtualPacketizer::fValid, TMonitor::GetActive(), TDSetElement::GetDirectory(), TPacketizer::TFileStat::GetElement(), TDSetElement::GetEntries(), TDSetElement::GetEntryList(), TDSetElement::GetFileName(), TPacketizer::TSlaveStat::GetFileNode(), TDSetElement::GetFirst(), TMonitor::GetListOfActives(), TDSet::GetListOfElements(), TSlave::GetName(), TVirtualPacketizer::TVirtualSlaveStat::GetName(), GetNextUnAlloc(), TPacketizer::TFileStat::GetNode(), TDSetElement::GetNum(), TDSetElement::GetObjName(), TSlave::GetOrdinal(), TCollection::GetSize(), TSlave::GetSocket(), TProofServ::GetSocket(), TNamed::GetTitle(), TMap::GetValue(), gProof, gProofServ, TPacketizer::TFileNode::IncSlaveCnt(), TObject::Info(), TDSetElement::Invalidate(), TDSet::IsTree(), TSocket::IsValid(), kFALSE, kPROOF_FATAL, kPROOF_GETENTRIES, kPROOF_MESSAGE, TDSet::kSomeInvalid, kTRUE, TBuffer::Length(), Long64_t, m, n, TIter::Next(), PDB, TSocket::Recv(), TList::Remove(), RemoveActive(), TIter::Reset(), s, TMonitor::Select(), TSocket::Send(), TProof::SendDataSetStatus(), TObject::SetBit(), TPacketizer::TFileStat::SetDone(), TPacketizer::TSlaveStat::SetFileNode(), TDSetElement::SetNum(), TDSetElement::SetTDSetOffset(), TNamed::SetTitle(), TDSetElement::SetValid(), TObject::Warning(), TMessage::What(), and what.

Referenced by ClassImp().

TDSetElement * TPacketizer::GetNextPacket	(	TSlave *	sl,
		TMessage *	r
	)			[virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 1057 of file TPacketizer.cxx.

References TList::Add(), TPacketizer::TSlaveStat::AddProcessed(), TVirtualPacketizer::CreateNewPacket(), TPacketizer::TFileNode::DecSlaveCnt(), TObject::Error(), TPacketizer::TSlaveStat::fCurElem, TPacketizer::TSlaveStat::fCurFile, TVirtualPerfStats::FileEvent(), fMaxPerfIdx, fPackets, fPacketSize, TVirtualPacketizer::fProgress, TVirtualPacketizer::fProgressStatus, TVirtualPacketizer::TVirtualSlaveStat::fSlave, fSlaveStats, TVirtualPacketizer::fStop, TVirtualPacketizer::fTotalEntries, TVirtualPacketizer::fValid, TProofProgressStatus::GetBytesRead(), TProofProgressStatus::GetCPUTime(), TPacketizer::TFileStat::GetElement(), TProofProgressStatus::GetEntries(), TVirtualPacketizer::TVirtualSlaveStat::GetEntriesProcessed(), TDSetElement::GetEntryList(), TDSetElement::GetFileName(), TPacketizer::TSlaveStat::GetFileNode(), TDSetElement::GetFirst(), TPacketizer::TFileNode::GetName(), TSlave::GetName(), TVirtualPacketizer::TVirtualSlaveStat::GetName(), GetNextActive(), TPacketizer::TFileStat::GetNextEntry(), GetNextUnAlloc(), TPacketizer::TFileStat::GetNode(), TDSetElement::GetNum(), TSlave::GetOrdinal(), TSlave::GetPerfIdx(), TProofProgressStatus::GetProcTime(), TVirtualPacketizer::TVirtualSlaveStat::GetProgressStatus(), TSlave::GetProtocol(), TMap::GetValue(), gPerfStats, TVirtualPacketizer::HandleTimer(), TProofProgressStatus::IncBytesRead(), TProofProgressStatus::IncEntries(), TPacketizer::TFileNode::IncSlaveCnt(), TObject::Info(), TPacketizer::TFileStat::IsDone(), kFALSE, TDSetElement::kNewRun, kTRUE, Long64_t, TPacketizer::TFileStat::MoveNextEntry(), num, TVirtualPerfStats::PacketEvent(), PDB, R__ASSERT, RemoveActive(), TObject::ResetBit(), TObject::SetBit(), TPacketizer::TFileStat::SetDone(), TDSetElement::SetEntryList(), and TPacketizer::TSlaveStat::SetFileNode().

Long64_t TPacketizer::GetEntriesProcessed

(

TSlave *

sl

)

const

Definition at line 1017 of file TPacketizer.cxx.

References fSlaveStats, TVirtualPacketizer::TVirtualSlaveStat::GetEntriesProcessed(), and TMap::GetValue().

Float_t TPacketizer::GetCurrentRate

(

Bool_t &

all

)

[virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 1031 of file TPacketizer.cxx.

References fSlaveStats, TProofProgressStatus::GetCurrentRate(), TVirtualPacketizer::TVirtualSlaveStat::GetEntriesProcessed(), TVirtualPacketizer::TVirtualSlaveStat::GetProgressStatus(), TCollection::GetSize(), TMap::GetValue(), kFALSE, and kTRUE.

Int_t TPacketizer::GetActiveWorkers

(

)

[virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 1228 of file TPacketizer.cxx.

References TPacketizer::TSlaveStat::fCurFile, fSlaveStats, and TMap::GetValue().

void TPacketizer::operator=

(

const TPacketizer &

)

[private]

TFileNode* TPacketizer::NextUnAllocNode

(

)

[private]

void TPacketizer::RemoveUnAllocNode

(

TFileNode *

)

[private]

TFileNode* TPacketizer::NextActiveNode

(

)

[private]

void TPacketizer::RemoveActiveNode

(

TFileNode *

)

[private]

TFileStat* TPacketizer::GetNextUnAlloc

(

TFileNode *

node = 0

)

[private]

TFileStat* TPacketizer::GetNextActive

(

)

[private]

void TPacketizer::RemoveActive

(

TFileStat *

file

)

[private]

void TPacketizer::Reset

(

)

[private]

void TPacketizer::ValidateFiles	(	TDSet *	dset,
		TList *	slaves,
		Long64_t	maxent = -1,
		Bool_t	byfile = kFALSE
	)			[private]

TDSetElement* TPacketizer::GetNextPacket	(	TSlave *	sl,
		TMessage *	r
	)			[virtual]

Reimplemented from TVirtualPacketizer.

Long64_t TPacketizer::GetEntriesProcessed

(

TSlave *

sl

)

const

Float_t TPacketizer::GetCurrentRate

(

Bool_t &

all

)

[virtual]

Reimplemented from TVirtualPacketizer.

Int_t TPacketizer::GetActiveWorkers

(

)

[virtual]

Reimplemented from TVirtualPacketizer.

---

Member Data Documentation

TList* TPacketizer::fPackets [private]

Definition at line 46 of file TPacketizer.h.

Referenced by ClassImp(), GetNextPacket(), and ~TPacketizer().

TList* TPacketizer::fFileNodes [private]

Definition at line 51 of file TPacketizer.h.

Referenced by ClassImp(), Reset(), and ~TPacketizer().

TList* TPacketizer::fUnAllocated [private]

Definition at line 52 of file TPacketizer.h.

Referenced by ClassImp(), NextUnAllocNode(), RemoveUnAllocNode(), Reset(), and ~TPacketizer().

TList* TPacketizer::fActive [private]

Definition at line 53 of file TPacketizer.h.

Referenced by ClassImp(), GetNextUnAlloc(), NextActiveNode(), RemoveActiveNode(), Reset(), and ~TPacketizer().

TMap* TPacketizer::fSlaveStats [private]

Reimplemented from TVirtualPacketizer.

Definition at line 54 of file TPacketizer.h.

Referenced by ClassImp(), GetActiveWorkers(), GetCurrentRate(), GetEntriesProcessed(), GetNextPacket(), Reset(), ValidateFiles(), and ~TPacketizer().

Long64_t TPacketizer::fPacketSize [private]

Definition at line 56 of file TPacketizer.h.

Referenced by ClassImp(), and GetNextPacket().

Int_t TPacketizer::fMaxPerfIdx [private]

Definition at line 59 of file TPacketizer.h.

Referenced by ClassImp(), and GetNextPacket().

Long_t TPacketizer::fMaxSlaveCnt [private]

Definition at line 61 of file TPacketizer.h.

Referenced by ClassImp(), NextActiveNode(), and NextUnAllocNode().

Int_t TPacketizer::fPacketAsAFraction [private]

Definition at line 63 of file TPacketizer.h.

Referenced by ClassImp().

TList* TPacketizer::fPackets [private]

Definition at line 46 of file TPacketizer.h.

TList* TPacketizer::fFileNodes [private]

Definition at line 51 of file TPacketizer.h.

TList* TPacketizer::fUnAllocated [private]

Definition at line 52 of file TPacketizer.h.

TList* TPacketizer::fActive [private]

Definition at line 53 of file TPacketizer.h.

TMap* TPacketizer::fSlaveStats [private]

Reimplemented from TVirtualPacketizer.

Definition at line 54 of file TPacketizer.h.

---

The documentation for this class was generated from the following files:

• include/TPacketizer.h
• proof/proofplayer/inc/TPacketizer.h
• proof/proofplayer/src/TPacketizer.cxx

---