Inheritance diagram for TPacketizerAdaptive::TSlaveStat:
Public Member Functions | |
TSlaveStat (TSlave *slave) | |
~TSlaveStat () | |
TFileNode * | GetFileNode () const |
Long64_t | GetEntriesProcessed () const |
Double_t | GetProcTime () const |
TFileStat * | GetCurFile () |
void | SetFileNode (TFileNode *node) |
void | UpdateRates (TProofProgressStatus *st) |
Float_t | GetAvgRate () |
Float_t | GetCurRate () |
Int_t | GetLocalEventsLeft () |
TList * | GetProcessedSubSet () |
TProofProgressStatus * | GetProgressStatus () |
TProofProgressStatus * | AddProcessed (TProofProgressStatus *st=0) |
Private Attributes | |
TFileNode * | fFileNode |
TFileStat * | fCurFile |
TDSetElement * | fCurElem |
Long64_t | fCurProcessed |
Float_t | fCurProcTime |
TList * | fDSubSet |
Friends | |
class | TPacketizerAdaptive |
Definition at line 335 of file TPacketizerAdaptive.cxx.
TPacketizerAdaptive::TSlaveStat::TSlaveStat | ( | TSlave * | slave | ) |
Definition at line 367 of file TPacketizerAdaptive.cxx.
References TObject::ClassName(), TString::Contains(), TString::Data(), fDSubSet, TVirtualPacketizer::TVirtualSlaveStat::fSlave, TVirtualPacketizer::TVirtualSlaveStat::fStatus, TVirtualPacketizer::TVirtualSlaveStat::fWrkFQDN, TSlave::GetName(), gSystem, TSystem::HostName(), TObject::Info(), PDB, and TCollection::SetOwner().
TPacketizerAdaptive::TSlaveStat::~TSlaveStat | ( | ) |
Definition at line 391 of file TPacketizerAdaptive.cxx.
References fDSubSet, TVirtualPacketizer::TVirtualSlaveStat::fStatus, and SafeDelete.
TFileNode* TPacketizerAdaptive::TSlaveStat::GetFileNode | ( | ) | const [inline] |
Definition at line 350 of file TPacketizerAdaptive.cxx.
References fFileNode.
Referenced by TPacketizerAdaptive::GetNextPacket(), and TPacketizerAdaptive::ValidateFiles().
Long64_t TPacketizerAdaptive::TSlaveStat::GetEntriesProcessed | ( | ) | const [inline] |
Reimplemented from TVirtualPacketizer::TVirtualSlaveStat.
Definition at line 351 of file TPacketizerAdaptive.cxx.
References TVirtualPacketizer::TVirtualSlaveStat::fStatus, and TProofProgressStatus::GetEntries().
Referenced by AddProcessed(), TPacketizerAdaptive::AddProcessed(), TPacketizerAdaptive::GetCurrentRate(), TPacketizerAdaptive::GetEstEntriesProcessed(), and UpdateRates().
Double_t TPacketizerAdaptive::TSlaveStat::GetProcTime | ( | ) | const [inline] |
Reimplemented from TVirtualPacketizer::TVirtualSlaveStat.
Definition at line 352 of file TPacketizerAdaptive.cxx.
References TVirtualPacketizer::TVirtualSlaveStat::fStatus, and TProofProgressStatus::GetProcTime().
Referenced by UpdateRates().
TFileStat* TPacketizerAdaptive::TSlaveStat::GetCurFile | ( | ) | [inline] |
void TPacketizerAdaptive::TSlaveStat::SetFileNode | ( | TFileNode * | node | ) | [inline] |
Definition at line 354 of file TPacketizerAdaptive.cxx.
References fFileNode.
Referenced by TPacketizerAdaptive::GetNextPacket(), TPacketizerAdaptive::Reset(), and TPacketizerAdaptive::ValidateFiles().
void TPacketizerAdaptive::TSlaveStat::UpdateRates | ( | TProofProgressStatus * | st | ) |
Definition at line 400 of file TPacketizerAdaptive.cxx.
References TObject::Error(), fCurFile, fCurProcessed, fCurProcTime, TVirtualPacketizer::TVirtualSlaveStat::fStatus, TProofProgressStatus::GetEntries(), GetEntriesProcessed(), TPacketizerAdaptive::TFileStat::GetNode(), GetProcTime(), TProofProgressStatus::GetProcTime(), TPacketizerAdaptive::TFileNode::IncProcessed(), TPacketizerAdaptive::TFileStat::IsDone(), SafeDelete, and TProofProgressStatus::SetLastEntries().
Referenced by TPacketizerAdaptive::AddProcessed().
Float_t TPacketizerAdaptive::TSlaveStat::GetAvgRate | ( | ) | [inline] |
Reimplemented from TVirtualPacketizer::TVirtualSlaveStat.
Definition at line 356 of file TPacketizerAdaptive.cxx.
References TVirtualPacketizer::TVirtualSlaveStat::fStatus, and TProofProgressStatus::GetRate().
Referenced by TPacketizerAdaptive::CalculatePacketSize(), TPacketizerAdaptive::GetEstEntriesProcessed(), and TPacketizerAdaptive::GetNextPacket().
Float_t TPacketizerAdaptive::TSlaveStat::GetCurRate | ( | ) | [inline] |
Definition at line 357 of file TPacketizerAdaptive.cxx.
References fCurProcessed, and fCurProcTime.
Referenced by TPacketizerAdaptive::CalculatePacketSize(), and TPacketizerAdaptive::GetEstEntriesProcessed().
Int_t TPacketizerAdaptive::TSlaveStat::GetLocalEventsLeft | ( | ) | [inline] |
Definition at line 359 of file TPacketizerAdaptive.cxx.
References fFileNode, and TPacketizerAdaptive::TFileNode::GetEventsLeftPerSlave().
Referenced by TPacketizerAdaptive::GetNextPacket().
TList* TPacketizerAdaptive::TSlaveStat::GetProcessedSubSet | ( | ) | [inline] |
Definition at line 361 of file TPacketizerAdaptive.cxx.
References fDSubSet.
Referenced by TPacketizerAdaptive::MarkBad().
TProofProgressStatus* TPacketizerAdaptive::TSlaveStat::GetProgressStatus | ( | ) | [inline] |
Reimplemented from TVirtualPacketizer::TVirtualSlaveStat.
Definition at line 362 of file TPacketizerAdaptive.cxx.
References TVirtualPacketizer::TVirtualSlaveStat::fStatus.
Referenced by TPacketizerAdaptive::GetCurrentRate(), TPacketizerAdaptive::GetEstEntriesProcessed(), and TPacketizerAdaptive::MarkBad().
TProofProgressStatus * TPacketizerAdaptive::TSlaveStat::AddProcessed | ( | TProofProgressStatus * | st = 0 |
) | [virtual] |
Implements TVirtualPacketizer::TVirtualSlaveStat.
Definition at line 422 of file TPacketizerAdaptive.cxx.
References TList::Add(), TObject::Error(), fCurElem, fDSubSet, TVirtualPacketizer::TVirtualSlaveStat::fStatus, TProofProgressStatus::GetEntries(), GetEntriesProcessed(), TDSetElement::GetNum(), and TDSetElement::SetNum().
Referenced by TPacketizerAdaptive::AddProcessed().
friend class TPacketizerAdaptive [friend] |
Reimplemented from TVirtualPacketizer::TVirtualSlaveStat.
Definition at line 337 of file TPacketizerAdaptive.cxx.
Definition at line 340 of file TPacketizerAdaptive.cxx.
Referenced by GetFileNode(), GetLocalEventsLeft(), and SetFileNode().
Definition at line 341 of file TPacketizerAdaptive.cxx.
Referenced by TPacketizerAdaptive::GetActiveWorkers(), GetCurFile(), TPacketizerAdaptive::GetNextPacket(), TPacketizerAdaptive::MarkBad(), TPacketizerAdaptive::Reset(), UpdateRates(), and TPacketizerAdaptive::ValidateFiles().
Definition at line 342 of file TPacketizerAdaptive.cxx.
Referenced by AddProcessed(), TPacketizerAdaptive::AddProcessed(), TPacketizerAdaptive::GetNextPacket(), and TPacketizerAdaptive::MarkBad().
Definition at line 343 of file TPacketizerAdaptive.cxx.
Referenced by GetCurRate(), and UpdateRates().
Definition at line 344 of file TPacketizerAdaptive.cxx.
Referenced by GetCurRate(), and UpdateRates().
TList* TPacketizerAdaptive::TSlaveStat::fDSubSet [private] |
Definition at line 345 of file TPacketizerAdaptive.cxx.
Referenced by AddProcessed(), GetProcessedSubSet(), TSlaveStat(), and ~TSlaveStat().