#include <TVirtualPacketizer.h>
Inheritance diagram for TVirtualPacketizer:
Definition at line 61 of file TVirtualPacketizer.h.
enum TVirtualPacketizer::EUseEstOpt [protected] |
Definition at line 67 of file TVirtualPacketizer.h.
enum TVirtualPacketizer::EUseEstOpt [protected] |
Definition at line 67 of file TVirtualPacketizer.h.
TVirtualPacketizer::TVirtualPacketizer | ( | TList * | input, | |
TProofProgressStatus * | st = 0 | |||
) | [protected] |
TVirtualPacketizer::TVirtualPacketizer | ( | const TVirtualPacketizer & | ) | [protected] |
TVirtualPacketizer::~TVirtualPacketizer | ( | ) | [virtual] |
Definition at line 166 of file TVirtualPacketizer.cxx.
References fCircProg, fConfigParams, fFailedPackets, fProgress, fProgressPerf, fProgressStatus, and SafeDelete.
TVirtualPacketizer::TVirtualPacketizer | ( | TList * | input, | |
TProofProgressStatus * | st = 0 | |||
) | [protected] |
TVirtualPacketizer::TVirtualPacketizer | ( | const TVirtualPacketizer & | ) | [protected] |
virtual TVirtualPacketizer::~TVirtualPacketizer | ( | ) | [virtual] |
void TVirtualPacketizer::operator= | ( | const TVirtualPacketizer & | ) | [protected] |
TDSetElement * TVirtualPacketizer::CreateNewPacket | ( | TDSetElement * | base, | |
Long64_t | first, | |||
Long64_t | num | |||
) | [protected] |
Definition at line 246 of file TVirtualPacketizer.cxx.
References TDSetElement::AddFriend(), TString::Data(), fDataSet, TDSetElement::GetDirectory(), TDSetElement::GetFileName(), TDSetElement::GetListOfFriends(), and TDSetElement::GetObjName().
Referenced by TPacketizer::GetNextPacket(), and TPacketizerAdaptive::GetNextPacket().
Long64_t TVirtualPacketizer::GetEntries | ( | Bool_t | tree, | |
TDSetElement * | e | |||
) | [protected] |
Definition at line 179 of file TVirtualPacketizer.cxx.
References TDirectoryFile::cd(), TDirectory::cd(), dir(), entries, TObject::Error(), gDirectory, TDSetElement::GetDirectory(), TFile::GetErrno(), TDSetElement::GetFileName(), TDSetElement::GetObjName(), TCollection::GetSize(), TObject::IsZombie(), Long64_t, TFile::Open(), TKey::ReadObj(), strerror(), and t.
Reimplemented from TObject.
Definition at line 274 of file TVirtualPacketizer.cxx.
References TMath::Abs(), fActWrksLast, far, fAWLastFill, fCircProg, fEffSessLast, fEvtRateLast, TNtuple::Fill(), TNtupleD::Fill(), fInitTime, fMBsReadLast, fProcTime, fProcTimeLast, fProgress, fProgressPerf, fReportPeriod, fStartTime, fTimeUpdt, fTotalEntries, GetActiveWorkers(), TProofServ::GetActSessions(), TNtuple::GetArgs(), TNtupleD::GetArgs(), GetBytesRead(), GetCurrentRate(), TProofServ::GetEffSessions(), TTree::GetEntries(), GetEntriesProcessed(), TTree::GetEntry(), GetEstEntriesProcessed(), TProof::GetPlayer(), TProofServ::GetProtocol(), GetReadCalls(), TProofServ::GetSocket(), gPerfStats, gProof, gProofServ, gSystem, TObject::Info(), kFALSE, kIsDone, kIsInitializing, kPROOF_PROGRESS, kTRUE, Long64_t, m, TSystem::Now(), PDB, pi, TMath::Power(), TVirtualProofPlayer::Progress(), TVirtualPerfStats::RateEvent(), TSocket::Send(), TObject::SetBit(), and TObject::TestBit().
Referenced by TPacketizerMulti::GetNextPacket(), TPacketizer::GetNextPacket(), TPacketizerUnit::GetNextPacket(), TPacketizerAdaptive::GetNextPacket(), and TPacketizerFile::GetNextPacket().
Bool_t TVirtualPacketizer::IsValid | ( | ) | const [inline] |
Definition at line 124 of file TVirtualPacketizer.h.
References fValid.
Referenced by TPacketizerMulti::CreatePacketizer(), and TProofPlayerRemote::InitPacketizer().
Long64_t TVirtualPacketizer::GetEntriesProcessed | ( | ) | const [inline] |
Definition at line 125 of file TVirtualPacketizer.h.
References fProgressStatus, and TProofProgressStatus::GetEntries().
Referenced by TPacketizerAdaptive::CalculatePacketSize(), GetEstEntriesProcessed(), TPacketizerAdaptive::GetEstEntriesProcessed(), and HandleTimer().
virtual Int_t TVirtualPacketizer::GetEstEntriesProcessed | ( | Float_t | , | |
Long64_t & | ent, | |||
Long64_t & | bytes, | |||
Long64_t & | calls | |||
) | [inline, virtual] |
Definition at line 126 of file TVirtualPacketizer.h.
References GetBytesRead(), GetEntriesProcessed(), and GetReadCalls().
Referenced by TPacketizerMulti::GetEstEntriesProcessed(), and HandleTimer().
Definition at line 128 of file TVirtualPacketizer.h.
References fProgressStatus, TProofProgressStatus::GetCurrentRate(), and kTRUE.
Referenced by TPacketizerMulti::GetCurrentRate(), and HandleTimer().
Long64_t TVirtualPacketizer::GetTotalEntries | ( | ) | const [inline] |
Definition at line 129 of file TVirtualPacketizer.h.
References fTotalEntries.
Referenced by TProofPlayerRemote::Process(), and TProofPlayerLite::Process().
TDSetElement * TVirtualPacketizer::GetNextPacket | ( | TSlave * | sl, | |
TMessage * | r | |||
) | [virtual] |
Definition at line 229 of file TVirtualPacketizer.cxx.
References TObject::AbstractMethod().
Referenced by TProofPlayerRemote::GetNextPacket(), and TPacketizerMulti::GetNextPacket().
void TVirtualPacketizer::SetInitTime | ( | ) | [virtual] |
Definition at line 412 of file TVirtualPacketizer.cxx.
References fInitTime, fStartTime, gSystem, TObject::Info(), kIsInitializing, Long64_t, TSystem::Now(), PDB, TObject::ResetBit(), and TObject::TestBit().
Referenced by TProofPlayerRemote::SetInitTime().
void TVirtualPacketizer::StopProcess | ( | Bool_t | abort | ) | [virtual] |
Definition at line 238 of file TVirtualPacketizer.cxx.
Referenced by TPacketizerMulti::StopProcess(), and TProofPlayerRemote::StopProcess().
TList* TVirtualPacketizer::GetFailedPackets | ( | ) | [inline] |
Definition at line 133 of file TVirtualPacketizer.h.
References fFailedPackets.
Referenced by TProofPlayerRemote::Finalize().
void TVirtualPacketizer::SetFailedPackets | ( | TList * | list | ) | [inline] |
Definition at line 134 of file TVirtualPacketizer.h.
References fFailedPackets, and list.
Referenced by TProofPlayerRemote::Finalize().
Long64_t TVirtualPacketizer::GetBytesRead | ( | ) | const [inline] |
Definition at line 136 of file TVirtualPacketizer.h.
References fProgressStatus, and TProofProgressStatus::GetBytesRead().
Referenced by TPacketizerAdaptive::CalculatePacketSize(), GetEstEntriesProcessed(), TPacketizerAdaptive::GetEstEntriesProcessed(), HandleTimer(), TProofPlayerRemote::Process(), and TProofPlayerLite::Process().
Long64_t TVirtualPacketizer::GetReadCalls | ( | ) | const [inline] |
Definition at line 137 of file TVirtualPacketizer.h.
References fProgressStatus, and TProofProgressStatus::GetReadCalls().
Referenced by GetEstEntriesProcessed(), TPacketizerAdaptive::GetEstEntriesProcessed(), and HandleTimer().
Double_t TVirtualPacketizer::GetCumProcTime | ( | ) | const [inline] |
Definition at line 138 of file TVirtualPacketizer.h.
References fProgressStatus, and TProofProgressStatus::GetProcTime().
Referenced by TPacketizerAdaptive::CalculatePacketSize(), and TPacketizerAdaptive::GetNextPacket().
Float_t TVirtualPacketizer::GetInitTime | ( | ) | const [inline] |
Definition at line 139 of file TVirtualPacketizer.h.
References fInitTime.
Referenced by TProofPlayerRemote::Process(), and TProofPlayerLite::Process().
Float_t TVirtualPacketizer::GetProcTime | ( | ) | const [inline] |
Definition at line 140 of file TVirtualPacketizer.h.
References fProcTime.
Referenced by TProofPlayerRemote::Process(), and TProofPlayerLite::Process().
Definition at line 141 of file TVirtualPacketizer.h.
References fProgressPerf, and n.
Referenced by TProofPlayerRemote::Finalize().
Definition at line 143 of file TVirtualPacketizer.h.
References fConfigParams, and l.
Referenced by TProofPlayerRemote::Finalize().
virtual void TVirtualPacketizer::MarkBad | ( | TSlave * | , | |
TProofProgressStatus * | , | |||
TList ** | ||||
) | [inline, virtual] |
Definition at line 145 of file TVirtualPacketizer.h.
Referenced by TProof::HandleInputMessage(), TProof::MarkBad(), and TPacketizerMulti::MarkBad().
virtual Int_t TVirtualPacketizer::AddProcessed | ( | TSlave * | , | |
TProofProgressStatus * | , | |||
Double_t | , | |||
TList ** | ||||
) | [inline, virtual] |
Definition at line 146 of file TVirtualPacketizer.h.
Referenced by TPacketizerMulti::AddProcessed(), and TProof::HandleInputMessage().
TProofProgressStatus* TVirtualPacketizer::GetStatus | ( | ) | [inline] |
void TVirtualPacketizer::SetProgressStatus | ( | TProofProgressStatus * | st | ) | [inline] |
void TVirtualPacketizer::SetTotalEntries | ( | Long64_t | ent | ) | [inline] |
Definition at line 150 of file TVirtualPacketizer.h.
References fTotalEntries.
Referenced by ClassImp().
TMap* TVirtualPacketizer::GetSlaveStats | ( | ) | const [inline] |
Definition at line 152 of file TVirtualPacketizer.h.
References fSlaveStats.
Referenced by TPacketizerMulti::GetNextPacket().
virtual Int_t TVirtualPacketizer::GetActiveWorkers | ( | ) | [inline, virtual] |
Definition at line 154 of file TVirtualPacketizer.h.
Referenced by TPacketizerMulti::GetActiveWorkers(), and HandleTimer().
void TVirtualPacketizer::operator= | ( | const TVirtualPacketizer & | ) | [protected] |
TDSetElement* TVirtualPacketizer::CreateNewPacket | ( | TDSetElement * | base, | |
Long64_t | first, | |||
Long64_t | num | |||
) | [protected] |
Long64_t TVirtualPacketizer::GetEntries | ( | Bool_t | tree, | |
TDSetElement * | e | |||
) | [protected] |
Reimplemented from TObject.
Bool_t TVirtualPacketizer::IsValid | ( | ) | const [inline] |
Long64_t TVirtualPacketizer::GetEntriesProcessed | ( | ) | const [inline] |
Definition at line 125 of file TVirtualPacketizer.h.
References fProgressStatus, and TProofProgressStatus::GetEntries().
virtual Int_t TVirtualPacketizer::GetEstEntriesProcessed | ( | Float_t | , | |
Long64_t & | ent, | |||
Long64_t & | bytes, | |||
Long64_t & | calls | |||
) | [inline, virtual] |
Definition at line 126 of file TVirtualPacketizer.h.
References GetBytesRead(), GetEntriesProcessed(), and GetReadCalls().
Definition at line 128 of file TVirtualPacketizer.h.
References fProgressStatus, TProofProgressStatus::GetCurrentRate(), and kTRUE.
Long64_t TVirtualPacketizer::GetTotalEntries | ( | ) | const [inline] |
virtual TDSetElement* TVirtualPacketizer::GetNextPacket | ( | TSlave * | sl, | |
TMessage * | r | |||
) | [virtual] |
virtual void TVirtualPacketizer::SetInitTime | ( | ) | [virtual] |
virtual void TVirtualPacketizer::StopProcess | ( | Bool_t | abort | ) | [virtual] |
TList* TVirtualPacketizer::GetFailedPackets | ( | ) | [inline] |
void TVirtualPacketizer::SetFailedPackets | ( | TList * | list | ) | [inline] |
Long64_t TVirtualPacketizer::GetBytesRead | ( | ) | const [inline] |
Definition at line 136 of file TVirtualPacketizer.h.
References fProgressStatus, and TProofProgressStatus::GetBytesRead().
Long64_t TVirtualPacketizer::GetReadCalls | ( | ) | const [inline] |
Definition at line 137 of file TVirtualPacketizer.h.
References fProgressStatus, and TProofProgressStatus::GetReadCalls().
Double_t TVirtualPacketizer::GetCumProcTime | ( | ) | const [inline] |
Definition at line 138 of file TVirtualPacketizer.h.
References fProgressStatus, and TProofProgressStatus::GetProcTime().
Float_t TVirtualPacketizer::GetInitTime | ( | ) | const [inline] |
Float_t TVirtualPacketizer::GetProcTime | ( | ) | const [inline] |
virtual void TVirtualPacketizer::MarkBad | ( | TSlave * | , | |
TProofProgressStatus * | , | |||
TList ** | ||||
) | [inline, virtual] |
Definition at line 145 of file TVirtualPacketizer.h.
virtual Int_t TVirtualPacketizer::AddProcessed | ( | TSlave * | , | |
TProofProgressStatus * | , | |||
Double_t | , | |||
TList ** | ||||
) | [inline, virtual] |
Definition at line 146 of file TVirtualPacketizer.h.
TProofProgressStatus* TVirtualPacketizer::GetStatus | ( | ) | [inline] |
void TVirtualPacketizer::SetProgressStatus | ( | TProofProgressStatus * | st | ) | [inline] |
void TVirtualPacketizer::SetTotalEntries | ( | Long64_t | ent | ) | [inline] |
TMap* TVirtualPacketizer::GetSlaveStats | ( | ) | const [inline] |
virtual Int_t TVirtualPacketizer::GetActiveWorkers | ( | ) | [inline, virtual] |
Definition at line 154 of file TVirtualPacketizer.h.
Double_t TVirtualPacketizer::fMinPacketTime [protected] |
Definition at line 74 of file TVirtualPacketizer.h.
Referenced by TPacketizerAdaptive::CalculatePacketSize().
Double_t TVirtualPacketizer::fMaxPacketTime [protected] |
Definition at line 75 of file TVirtualPacketizer.h.
Referenced by TPacketizerAdaptive::CalculatePacketSize(), ClassImp(), and TPacketizerUnit::GetNextPacket().
TList* TVirtualPacketizer::fConfigParams [protected] |
Definition at line 76 of file TVirtualPacketizer.h.
Referenced by ClassImp(), GetConfigParams(), and ~TVirtualPacketizer().
TMap* TVirtualPacketizer::fSlaveStats [protected] |
Definition at line 78 of file TVirtualPacketizer.h.
Referenced by TPacketizerAdaptive::AddProcessed(), TPacketizerAdaptive::CalculatePacketSize(), ClassImp(), TPacketizerAdaptive::GetActiveWorkers(), TPacketizerFile::GetCurrentRate(), TPacketizerAdaptive::GetCurrentRate(), TPacketizerAdaptive::GetEstEntriesProcessed(), TPacketizerAdaptive::GetNextPacket(), TPacketizerFile::GetNextPacket(), GetSlaveStats(), TPacketizerAdaptive::MarkBad(), TPacketizerAdaptive::Reset(), TPacketizerAdaptive::ValidateFiles(), and TPacketizerAdaptive::~TPacketizerAdaptive().
TProofProgressStatus* TVirtualPacketizer::fProgressStatus [protected] |
Definition at line 80 of file TVirtualPacketizer.h.
Referenced by ClassImp(), GetBytesRead(), GetCumProcTime(), GetCurrentRate(), GetEntriesProcessed(), TPacketizerAdaptive::GetEstEntriesProcessed(), TPacketizer::GetNextPacket(), TPacketizerMulti::GetNextPacket(), TPacketizerUnit::GetNextPacket(), TPacketizerAdaptive::GetNextPacket(), TPacketizerFile::GetNextPacket(), GetReadCalls(), GetStatus(), SetProgressStatus(), and ~TVirtualPacketizer().
TTimer* TVirtualPacketizer::fProgress [protected] |
Definition at line 81 of file TVirtualPacketizer.h.
Referenced by ClassImp(), TPacketizer::GetNextPacket(), TPacketizerMulti::GetNextPacket(), TPacketizerAdaptive::GetNextPacket(), HandleTimer(), TPacketizerAdaptive::InitStats(), and ~TVirtualPacketizer().
Long64_t TVirtualPacketizer::fTotalEntries [protected] |
Definition at line 83 of file TVirtualPacketizer.h.
Referenced by TPacketizerAdaptive::CalculatePacketSize(), ClassImp(), TPacketizerAdaptive::GetEstEntriesProcessed(), TPacketizer::GetNextPacket(), TPacketizerMulti::GetNextPacket(), TPacketizerUnit::GetNextPacket(), TPacketizerAdaptive::GetNextPacket(), TPacketizerFile::GetNextPacket(), GetTotalEntries(), HandleTimer(), and SetTotalEntries().
TList* TVirtualPacketizer::fFailedPackets [protected] |
Definition at line 85 of file TVirtualPacketizer.h.
Referenced by GetFailedPackets(), TPacketizerAdaptive::GetNextPacket(), SetFailedPackets(), and ~TVirtualPacketizer().
TTime TVirtualPacketizer::fStartTime [protected] |
Float_t TVirtualPacketizer::fInitTime [protected] |
Definition at line 89 of file TVirtualPacketizer.h.
Referenced by GetInitTime(), HandleTimer(), and SetInitTime().
Float_t TVirtualPacketizer::fProcTime [protected] |
Float_t TVirtualPacketizer::fTimeUpdt [protected] |
TNtupleD* TVirtualPacketizer::fCircProg [protected] |
Definition at line 92 of file TVirtualPacketizer.h.
Referenced by HandleTimer(), and ~TVirtualPacketizer().
Long_t TVirtualPacketizer::fCircN [protected] |
Definition at line 94 of file TVirtualPacketizer.h.
TNtuple* TVirtualPacketizer::fProgressPerf [protected] |
Definition at line 96 of file TVirtualPacketizer.h.
Referenced by GetProgressPerf(), HandleTimer(), and ~TVirtualPacketizer().
Float_t TVirtualPacketizer::fProcTimeLast [protected] |
Int_t TVirtualPacketizer::fActWrksLast [protected] |
Float_t TVirtualPacketizer::fEvtRateLast [protected] |
Float_t TVirtualPacketizer::fMBsReadLast [protected] |
Float_t TVirtualPacketizer::fEffSessLast [protected] |
Bool_t TVirtualPacketizer::fAWLastFill [protected] |
Float_t TVirtualPacketizer::fReportPeriod [protected] |
EUseEstOpt TVirtualPacketizer::fUseEstOpt [protected] |
Definition at line 105 of file TVirtualPacketizer.h.
Referenced by TPacketizerAdaptive::GetEstEntriesProcessed().
Bool_t TVirtualPacketizer::fValid [protected] |
Definition at line 107 of file TVirtualPacketizer.h.
Referenced by ClassImp(), TPacketizer::GetNextPacket(), TPacketizerMulti::GetNextPacket(), TPacketizerUnit::GetNextPacket(), TPacketizerAdaptive::GetNextPacket(), TPacketizerFile::GetNextPacket(), TPacketizerAdaptive::InitStats(), IsValid(), TPacketizer::ValidateFiles(), and TPacketizerAdaptive::ValidateFiles().
Bool_t TVirtualPacketizer::fStop [protected] |
Definition at line 108 of file TVirtualPacketizer.h.
Referenced by TPacketizer::GetNextPacket(), TPacketizerUnit::GetNextPacket(), TPacketizerAdaptive::GetNextPacket(), TPacketizerFile::GetNextPacket(), and StopProcess().
TString TVirtualPacketizer::fDataSet [protected] |
Definition at line 110 of file TVirtualPacketizer.h.
Referenced by ClassImp(), and CreateNewPacket().
TList* TVirtualPacketizer::fConfigParams [protected] |
Definition at line 76 of file TVirtualPacketizer.h.
TMap* TVirtualPacketizer::fSlaveStats [protected] |
Definition at line 78 of file TVirtualPacketizer.h.
TProofProgressStatus* TVirtualPacketizer::fProgressStatus [protected] |
Definition at line 80 of file TVirtualPacketizer.h.
TTimer* TVirtualPacketizer::fProgress [protected] |
Definition at line 81 of file TVirtualPacketizer.h.
TList* TVirtualPacketizer::fFailedPackets [protected] |
Definition at line 85 of file TVirtualPacketizer.h.
TNtupleD* TVirtualPacketizer::fCircProg [protected] |
Definition at line 92 of file TVirtualPacketizer.h.
TNtuple* TVirtualPacketizer::fProgressPerf [protected] |
Definition at line 96 of file TVirtualPacketizer.h.