TPacketizerUnit Class Reference

#include <TPacketizerUnit.h>

Inheritance diagram for TPacketizerUnit:

List of all members.

Public Member Functions
	TPacketizerUnit (TList *slaves, Long64_t num, TList *input, TProofProgressStatus *st=0)
virtual	~TPacketizerUnit ()
TDSetElement *	GetNextPacket (TSlave *sl, TMessage *r)
Double_t	GetCurrentTime ()
Float_t	GetCurrentRate (Bool_t &all)
Int_t	GetActiveWorkers ()
	TPacketizerUnit (TList *slaves, Long64_t num, TList *input, TProofProgressStatus *st=0)
virtual	~TPacketizerUnit ()
TDSetElement *	GetNextPacket (TSlave *sl, TMessage *r)
Double_t	GetCurrentTime ()
Float_t	GetCurrentRate (Bool_t &all)
Int_t	GetActiveWorkers ()
Private Member Functions
	TPacketizerUnit ()
	TPacketizerUnit (const TPacketizerUnit &)
void	operator= (const TPacketizerUnit &)
	TPacketizerUnit ()
	TPacketizerUnit (const TPacketizerUnit &)
void	operator= (const TPacketizerUnit &)
Private Attributes
TList *	fPackets
TMap *	fSlaveStats
TStopwatch *	fStopwatch
Long64_t	fProcessing
Long64_t	fAssigned
Long64_t	fCalibNum
Long64_t	fNumPerWorker
TList *	fPackets
TMap *	fSlaveStats
TStopwatch *	fStopwatch
Classes
class	TSlaveStat

---

Detailed Description

Definition at line 42 of file TPacketizerUnit.h.

---

Constructor & Destructor Documentation

TPacketizerUnit::TPacketizerUnit

(

)

[private]

TPacketizerUnit::TPacketizerUnit

(

const TPacketizerUnit &

)

[private]

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

TPacketizerUnit::~TPacketizerUnit

(

)

[virtual]

Definition at line 232 of file TPacketizerUnit.cxx.

References TMap::DeleteValues(), fPackets, fSlaveStats, fStopwatch, and SafeDelete.

TPacketizerUnit::TPacketizerUnit

(

)

[private]

TPacketizerUnit::TPacketizerUnit

(

const TPacketizerUnit &

)

[private]

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

virtual TPacketizerUnit::~TPacketizerUnit

(

)

[virtual]

---

Member Function Documentation

void TPacketizerUnit::operator=

(

const TPacketizerUnit &

)

[private]

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

Reimplemented from TVirtualPacketizer.

Definition at line 280 of file TPacketizerUnit.cxx.

References TPacketizerUnit::TSlaveStat::AddProcessed(), TObject::Error(), fAssigned, fCalibNum, TPacketizerUnit::TSlaveStat::fCircNtp, TPacketizerUnit::TSlaveStat::fLastProcessed, TVirtualPacketizer::fMaxPacketTime, fNumPerWorker, fProcessing, TVirtualPacketizer::fProgressStatus, fSlaveStats, TPacketizerUnit::TSlaveStat::fSpeed, TVirtualPacketizer::fStop, TPacketizerUnit::TSlaveStat::fTimeInstant, TVirtualPacketizer::fTotalEntries, TVirtualPacketizer::fValid, TProofProgressStatus::GetBytesRead(), TProofProgressStatus::GetCPUTime(), GetCurrentTime(), TProofProgressStatus::GetEntries(), TTree::GetEntries(), TVirtualPacketizer::TVirtualSlaveStat::GetEntriesProcessed(), TSlave::GetName(), TSlave::GetOrdinal(), TProofProgressStatus::GetProcTime(), TVirtualPacketizer::TVirtualSlaveStat::GetProgressStatus(), TSlave::GetProtocol(), TCollection::GetSize(), TMap::GetValue(), gPerfStats, TVirtualPacketizer::HandleTimer(), TProofProgressStatus::IncEntries(), TObject::Info(), TDSetElement::kEmpty, Long64_t, TMap::MakeIterator(), TMapIter::Next(), TMath::Nint(), num, TVirtualPerfStats::PacketEvent(), PDB, R__ASSERT, SafeDelete, TObject::SetBit(), and TPacketizerUnit::TSlaveStat::UpdatePerformance().

Double_t TPacketizerUnit::GetCurrentTime

(

)

Definition at line 244 of file TPacketizerUnit.cxx.

References TStopwatch::Continue(), fStopwatch, and TStopwatch::RealTime().

Referenced by GetNextPacket().

Float_t TPacketizerUnit::GetCurrentRate

(

Bool_t &

all

)

[virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 254 of file TPacketizerUnit.cxx.

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

Int_t TPacketizerUnit::GetActiveWorkers

(

)

[inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 70 of file TPacketizerUnit.h.

References fSlaveStats, and TCollection::GetSize().

void TPacketizerUnit::operator=

(

const TPacketizerUnit &

)

[private]

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

Reimplemented from TVirtualPacketizer.

Double_t TPacketizerUnit::GetCurrentTime

(

)

Float_t TPacketizerUnit::GetCurrentRate

(

Bool_t &

all

)

[virtual]

Reimplemented from TVirtualPacketizer.

Int_t TPacketizerUnit::GetActiveWorkers

(

)

[inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 70 of file TPacketizerUnit.h.

References fSlaveStats, and TCollection::GetSize().

---

Member Data Documentation

TList* TPacketizerUnit::fPackets [private]

Definition at line 45 of file TPacketizerUnit.h.

Referenced by ClassImp(), and ~TPacketizerUnit().

TMap* TPacketizerUnit::fSlaveStats [private]

Reimplemented from TVirtualPacketizer.

Definition at line 49 of file TPacketizerUnit.h.

Referenced by ClassImp(), GetActiveWorkers(), GetCurrentRate(), GetNextPacket(), and ~TPacketizerUnit().

TStopwatch* TPacketizerUnit::fStopwatch [private]

Definition at line 50 of file TPacketizerUnit.h.

Referenced by ClassImp(), GetCurrentTime(), and ~TPacketizerUnit().

Long64_t TPacketizerUnit::fProcessing [private]

Definition at line 51 of file TPacketizerUnit.h.

Referenced by ClassImp(), and GetNextPacket().

Long64_t TPacketizerUnit::fAssigned [private]

Definition at line 52 of file TPacketizerUnit.h.

Referenced by ClassImp(), and GetNextPacket().

Long64_t TPacketizerUnit::fCalibNum [private]

Definition at line 53 of file TPacketizerUnit.h.

Referenced by ClassImp(), and GetNextPacket().

Long64_t TPacketizerUnit::fNumPerWorker [private]

Definition at line 54 of file TPacketizerUnit.h.

Referenced by ClassImp(), and GetNextPacket().

TList* TPacketizerUnit::fPackets [private]

Definition at line 45 of file TPacketizerUnit.h.

TMap* TPacketizerUnit::fSlaveStats [private]

Reimplemented from TVirtualPacketizer.

Definition at line 49 of file TPacketizerUnit.h.

TStopwatch* TPacketizerUnit::fStopwatch [private]

Definition at line 50 of file TPacketizerUnit.h.

---

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

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

---