TPacketizerMulti Class Reference

#include <TPacketizerMulti.h>

Inheritance diagram for TPacketizerMulti:

TVirtualPacketizer TVirtualPacketizer TObject TObject TObject TObject List of all members.

Public Member Functions

 TPacketizerMulti (TDSet *dset, TList *slaves, Long64_t first, Long64_t num, TList *input, TProofProgressStatus *st)
virtual ~TPacketizerMulti ()
TDSetElement * GetNextPacket (TSlave *wrk, TMessage *r)
Int_t GetEstEntriesProcessed (Float_t f, Long64_t &ent, Long64_t &bytes, Long64_t &calls)
Float_t GetCurrentRate (Bool_t &all)
void StopProcess (Bool_t abort)
void MarkBad (TSlave *wrk, TProofProgressStatus *st, TList **missing)
Int_t AddProcessed (TSlave *wrk, TProofProgressStatus *st, Double_t lat, TList **missing)
Int_t GetActiveWorkers ()
 TPacketizerMulti (TDSet *dset, TList *slaves, Long64_t first, Long64_t num, TList *input, TProofProgressStatus *st)
virtual ~TPacketizerMulti ()
TDSetElement * GetNextPacket (TSlave *wrk, TMessage *r)
Int_t GetEstEntriesProcessed (Float_t f, Long64_t &ent, Long64_t &bytes, Long64_t &calls)
Float_t GetCurrentRate (Bool_t &all)
void StopProcess (Bool_t abort)
void MarkBad (TSlave *wrk, TProofProgressStatus *st, TList **missing)
Int_t AddProcessed (TSlave *wrk, TProofProgressStatus *st, Double_t lat, TList **missing)
Int_t GetActiveWorkers ()

Private Member Functions

 TPacketizerMulti ()
 TPacketizerMulti (const TPacketizerMulti &)
void operator= (const TPacketizerMulti &)
TVirtualPacketizer * CreatePacketizer (TDSet *dset, TList *wrks, Long64_t first, Long64_t num, TList *input, TProofProgressStatus *st)
 TPacketizerMulti ()
 TPacketizerMulti (const TPacketizerMulti &)
void operator= (const TPacketizerMulti &)
TVirtualPacketizer * CreatePacketizer (TDSet *dset, TList *wrks, Long64_t first, Long64_t num, TList *input, TProofProgressStatus *st)

Private Attributes

TList * fPacketizers
TIter * fPacketizersIter
TVirtualPacketizer * fCurrent
TMap * fAssignedPack
TList * fPacketizers
TIter * fPacketizersIter
TVirtualPacketizer * fCurrent
TMap * fAssignedPack

Detailed Description

Definition at line 41 of file TPacketizerMulti.h.

Constructor & Destructor Documentation

TPacketizerMulti::TPacketizerMulti (  )  [private]

TPacketizerMulti::TPacketizerMulti ( const TPacketizerMulti &   )  [private]

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

TPacketizerMulti::~TPacketizerMulti (  )  [virtual]

Definition at line 136 of file TPacketizerMulti.cxx.

References fAssignedPack, fCurrent, fPacketizers, kFALSE, kTRUE, SafeDelete, and TCollection::SetOwner().

TPacketizerMulti::TPacketizerMulti (  )  [private]

TPacketizerMulti::TPacketizerMulti ( const TPacketizerMulti &   )  [private]

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

virtual TPacketizerMulti::~TPacketizerMulti (  )  [virtual]

Member Function Documentation

void TPacketizerMulti::operator= ( const TPacketizerMulti &   )  [private]

TVirtualPacketizer * TPacketizerMulti::CreatePacketizer ( TDSet *  dset,
TList *  wrks,
Long64_t  first,
Long64_t  num,
TList *  input,
TProofProgressStatus *  st 
) [private]

Definition at line 232 of file TPacketizerMulti.cxx.

References TList::Add(), TString::Data(), TObject::Error(), TMethodCall::Execute(), TClass::GetClass(), TDSetElement::GetFileInfo(), TDSet::GetListOfElements(), TProof::GetParameter(), TCollection::GetSize(), TDSetElement::GetValid(), TObject::Info(), TMethodCall::InitWithPrototype(), TMethodCall::IsValid(), TVirtualPacketizer::IsValid(), TDSet::kEmpty, kFALSE, TDSet::kSomeInvalid, kTRUE, TDSet::kValidityChecked, Long64_t, TDSet::Lookup(), TMethodCall::ResetParam(), SafeDelete, TMethodCall::SetParam(), and TObject::TestBit().

TDSetElement * TPacketizerMulti::GetNextPacket ( TSlave *  wrk,
TMessage *  r 
) [virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 153 of file TPacketizerMulti.cxx.

References TMap::Add(), TObject::Error(), fAssignedPack, fCurrent, TMap::FindObject(), fPacketizersIter, TVirtualPacketizer::fProgress, TVirtualPacketizer::fProgressStatus, TVirtualPacketizer::fTotalEntries, TVirtualPacketizer::fValid, TProofProgressStatus::GetEntries(), TVirtualPacketizer::GetNextPacket(), TSlave::GetOrdinal(), TVirtualPacketizer::GetSlaveStats(), TMap::GetValue(), TVirtualPacketizer::HandleTimer(), TObject::Info(), TIter::Next(), PDB, and SafeDelete.

Int_t TPacketizerMulti::GetEstEntriesProcessed ( Float_t  f,
Long64_t &  ent,
Long64_t &  bytes,
Long64_t &  calls 
) [inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 63 of file TPacketizerMulti.h.

References fCurrent, and TVirtualPacketizer::GetEstEntriesProcessed().

Float_t TPacketizerMulti::GetCurrentRate ( Bool_t &  all  )  [inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 66 of file TPacketizerMulti.h.

References fCurrent, TVirtualPacketizer::GetCurrentRate(), and kTRUE.

void TPacketizerMulti::StopProcess ( Bool_t  abort  )  [inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 68 of file TPacketizerMulti.h.

References fCurrent, and TVirtualPacketizer::StopProcess().

void TPacketizerMulti::MarkBad ( TSlave *  wrk,
TProofProgressStatus *  st,
TList **  missing 
) [inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 70 of file TPacketizerMulti.h.

References fCurrent, and TVirtualPacketizer::MarkBad().

Int_t TPacketizerMulti::AddProcessed ( TSlave *  wrk,
TProofProgressStatus *  st,
Double_t  lat,
TList **  missing 
) [inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 72 of file TPacketizerMulti.h.

References TVirtualPacketizer::AddProcessed(), and fCurrent.

Int_t TPacketizerMulti::GetActiveWorkers (  )  [inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 76 of file TPacketizerMulti.h.

References fCurrent, and TVirtualPacketizer::GetActiveWorkers().

void TPacketizerMulti::operator= ( const TPacketizerMulti &   )  [private]

TVirtualPacketizer* TPacketizerMulti::CreatePacketizer ( TDSet *  dset,
TList *  wrks,
Long64_t  first,
Long64_t  num,
TList *  input,
TProofProgressStatus *  st 
) [private]

TDSetElement* TPacketizerMulti::GetNextPacket ( TSlave *  wrk,
TMessage *  r 
) [virtual]

Reimplemented from TVirtualPacketizer.

Int_t TPacketizerMulti::GetEstEntriesProcessed ( Float_t  f,
Long64_t &  ent,
Long64_t &  bytes,
Long64_t &  calls 
) [inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 63 of file TPacketizerMulti.h.

References fCurrent, and TVirtualPacketizer::GetEstEntriesProcessed().

Float_t TPacketizerMulti::GetCurrentRate ( Bool_t &  all  )  [inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 66 of file TPacketizerMulti.h.

References fCurrent, TVirtualPacketizer::GetCurrentRate(), and kTRUE.

void TPacketizerMulti::StopProcess ( Bool_t  abort  )  [inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 68 of file TPacketizerMulti.h.

References fCurrent, and TVirtualPacketizer::StopProcess().

void TPacketizerMulti::MarkBad ( TSlave *  wrk,
TProofProgressStatus *  st,
TList **  missing 
) [inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 70 of file TPacketizerMulti.h.

References fCurrent, and TVirtualPacketizer::MarkBad().

Int_t TPacketizerMulti::AddProcessed ( TSlave *  wrk,
TProofProgressStatus *  st,
Double_t  lat,
TList **  missing 
) [inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 72 of file TPacketizerMulti.h.

References TVirtualPacketizer::AddProcessed(), and fCurrent.

Int_t TPacketizerMulti::GetActiveWorkers (  )  [inline, virtual]

Reimplemented from TVirtualPacketizer.

Definition at line 76 of file TPacketizerMulti.h.

References fCurrent, and TVirtualPacketizer::GetActiveWorkers().

Member Data Documentation

TList* TPacketizerMulti::fPacketizers [private]

Definition at line 44 of file TPacketizerMulti.h.

Referenced by ~TPacketizerMulti().

TIter* TPacketizerMulti::fPacketizersIter [private]

Definition at line 45 of file TPacketizerMulti.h.

Referenced by GetNextPacket().

TVirtualPacketizer* TPacketizerMulti::fCurrent [private]

Definition at line 46 of file TPacketizerMulti.h.

Referenced by AddProcessed(), GetActiveWorkers(), GetCurrentRate(), GetEstEntriesProcessed(), GetNextPacket(), MarkBad(), StopProcess(), and ~TPacketizerMulti().

TMap* TPacketizerMulti::fAssignedPack [private]

Definition at line 47 of file TPacketizerMulti.h.

Referenced by GetNextPacket(), and ~TPacketizerMulti().

TList* TPacketizerMulti::fPacketizers [private]

Definition at line 44 of file TPacketizerMulti.h.

TIter* TPacketizerMulti::fPacketizersIter [private]

Definition at line 45 of file TPacketizerMulti.h.

TVirtualPacketizer* TPacketizerMulti::fCurrent [private]

Definition at line 46 of file TPacketizerMulti.h.

TMap* TPacketizerMulti::fAssignedPack [private]

Definition at line 47 of file TPacketizerMulti.h.

The documentation for this class was generated from the following files:
Generated on Tue Jul 5 16:43:40 2011 for ROOT_528-00b_version by  doxygen 1.5.1