TProofPlayerRemote Class Reference

#include <TProofPlayer.h>

Inheritance diagram for TProofPlayerRemote:

TProofPlayer TProofPlayer TVirtualProofPlayer TVirtualProofPlayer TVirtualProofPlayer TVirtualProofPlayer TQObject TObject TQObject TObject TQObject TObject TQObject TObject TQObject TObject TQObject TObject TQObject TObject TQObject TObject TProofPlayerLite TProofPlayerLite TProofPlayerSuperMaster TProofPlayerSuperMaster List of all members.

Public Member Functions

 TProofPlayerRemote (TProof *proof=0)
virtual ~TProofPlayerRemote ()
virtual Long64_t Process (TDSet *set, const char *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
virtual Long64_t Finalize (Bool_t force=kFALSE, Bool_t sync=kFALSE)
virtual Long64_t Finalize (TQueryResult *qr)
Long64_t DrawSelect (TDSet *set, const char *varexp, const char *selection, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
void RedirectOutput (Bool_t on=kTRUE)
void StopProcess (Bool_t abort, Int_t timeout=-1)
void StoreOutput (TList *out)
virtual void StoreFeedback (TObject *slave, TList *out)
Int_t Incorporate (TObject *obj, TList *out, Bool_t &merged)
TObject * HandleHistogram (TObject *obj)
Int_t AddOutputObject (TObject *obj)
void AddOutput (TList *out)
virtual void MergeOutput ()
void Progress (Long64_t total, Long64_t processed)
void Progress (TSlave *, Long64_t total, Long64_t processed)
void Progress (Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)
void Progress (TSlave *, Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)
void Progress (TProofProgressInfo *pi)
void Progress (TSlave *, TProofProgressInfo *pi)
void Feedback (TList *objs)
TDSetElement * GetNextPacket (TSlave *slave, TMessage *r)
TVirtualPacketizer * GetPacketizer () const
Bool_t IsClient () const
void SetInitTime ()
 TProofPlayerRemote (TProof *proof=0)
virtual ~TProofPlayerRemote ()
virtual Long64_t Process (TDSet *set, const char *selector, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
virtual Long64_t Finalize (Bool_t force=kFALSE, Bool_t sync=kFALSE)
virtual Long64_t Finalize (TQueryResult *qr)
Long64_t DrawSelect (TDSet *set, const char *varexp, const char *selection, Option_t *option="", Long64_t nentries=-1, Long64_t firstentry=0)
void RedirectOutput (Bool_t on=kTRUE)
void StopProcess (Bool_t abort, Int_t timeout=-1)
void StoreOutput (TList *out)
virtual void StoreFeedback (TObject *slave, TList *out)
Int_t Incorporate (TObject *obj, TList *out, Bool_t &merged)
TObject * HandleHistogram (TObject *obj)
Int_t AddOutputObject (TObject *obj)
void AddOutput (TList *out)
virtual void MergeOutput ()
void Progress (Long64_t total, Long64_t processed)
void Progress (TSlave *, Long64_t total, Long64_t processed)
void Progress (Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)
void Progress (TSlave *, Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)
void Progress (TProofProgressInfo *pi)
void Progress (TSlave *, TProofProgressInfo *pi)
void Feedback (TList *objs)
TDSetElement * GetNextPacket (TSlave *slave, TMessage *r)
TVirtualPacketizer * GetPacketizer () const
Bool_t IsClient () const
void SetInitTime ()

Protected Member Functions

virtual Bool_t HandleTimer (TTimer *timer)
Int_t InitPacketizer (TDSet *dset, Long64_t nentries, Long64_t first, const char *defpackunit, const char *defpackdata)
TList * MergeFeedback ()
Bool_t MergeOutputFiles ()
void NotifyMemory (TObject *obj)
void SetLastMergingMsg (TObject *obj)
virtual Bool_t SendSelector (const char *selector_file)
TProof * GetProof () const
void SetupFeedback ()
void StopFeedback ()
void SetSelectorDataMembersFromOutputList ()
virtual Bool_t HandleTimer (TTimer *timer)
Int_t InitPacketizer (TDSet *dset, Long64_t nentries, Long64_t first, const char *defpackunit, const char *defpackdata)
TList * MergeFeedback ()
Bool_t MergeOutputFiles ()
void NotifyMemory (TObject *obj)
void SetLastMergingMsg (TObject *obj)
virtual Bool_t SendSelector (const char *selector_file)
TProof * GetProof () const
void SetupFeedback ()
void StopFeedback ()
void SetSelectorDataMembersFromOutputList ()

Protected Attributes

TProof * fProof
TList * fOutputLists
TList * fFeedback
TList * fFeedbackLists
TVirtualPacketizer * fPacketizer
Bool_t fMergeFiles
TDSet * fDSet
ErrorHandlerFunc_t fErrorHandler
 tdset for current processing
TProof * fProof
TList * fOutputLists
TList * fFeedback
TList * fFeedbackLists
TVirtualPacketizer * fPacketizer
TDSet * fDSet

Detailed Description

Definition at line 256 of file TProofPlayer.h.

Constructor & Destructor Documentation

TProofPlayerRemote::TProofPlayerRemote ( TProof *  proof = 0  )  [inline]

Definition at line 283 of file TProofPlayer.h.

References TProofPlayer::fProgressStatus.

virtual TProofPlayerRemote::~TProofPlayerRemote (  )  [virtual]

TProofPlayerRemote::TProofPlayerRemote ( TProof *  proof = 0  )  [inline]

Definition at line 283 of file TProofPlayer.h.

References TProofPlayer::fProgressStatus.

virtual TProofPlayerRemote::~TProofPlayerRemote (  )  [virtual]

Member Function Documentation

Bool_t TProofPlayerRemote::HandleTimer ( TTimer *  timer  )  [protected, virtual]

Reimplemented from TObject.

Definition at line 3060 of file TProofPlayer.cxx.

References fb, fFeedback, fFeedbackLists, TList::FindObject(), TProofServ::GetSocket(), gProofServ, TObject::Info(), kFALSE, kPROOF_FEEDBACK, kTRUE, m, MergeFeedback(), name, o, PDB, TList::Remove(), TSocket::Send(), and StoreFeedback().

Referenced by TProofPlayerSuperMaster::HandleTimer(), and Process().

Int_t TProofPlayerRemote::InitPacketizer ( TDSet *  dset,
Long64_t  nentries,
Long64_t  first,
const char *  defpackunit,
const char *  defpackdata 
) [protected]

Definition at line 1358 of file TProofPlayer.cxx.

References TStatus::Add(), TList::Add(), AddOutputObject(), TString::Data(), TObject::Error(), TMethodCall::Execute(), fDSet, TProofPlayer::fExitStatus, fi, TList::FindObject(), TProofPlayer::fInput, Form(), fPacketizer, TProofPlayer::fProgressStatus, fProof, gDebug, TClass::GetClass(), TFileInfo::GetCurrentUrl(), TDSetElement::GetFileInfo(), TProof::GetListOfActiveSlaves(), TDSet::GetListOfElements(), TNamed::GetName(), TProofPlayer::GetOutput(), TProof::GetParameter(), TProof::GetRunStatus(), TCollection::GetSize(), TDSet::GetType(), TUrl::GetUrl(), TDSetElement::GetValid(), gProofServ, TObject::Info(), TMethodCall::InitWithPrototype(), TMethodCall::IsValid(), TVirtualPacketizer::IsValid(), TVirtualProofPlayer::kAborted, TDSet::kEmpty, kFALSE, TVirtualProofPlayer::kFinished, TDSet::kMultiDSet, TProof::kRunning, TDSet::kSomeInvalid, kTRUE, TDSet::kValidityChecked, Long64_t, TDSet::Lookup(), PDB, TList::Remove(), TDSet::Remove(), TObject::ResetBit(), TMethodCall::ResetParam(), SafeDelete, TProofServ::SendAsynMessage(), TCollection::SetOwner(), TMethodCall::SetParam(), and TObject::TestBit().

Referenced by Process(), and TProofPlayerLite::Process().

TList * TProofPlayerRemote::MergeFeedback (  )  [protected]

Definition at line 2856 of file TProofPlayer.cxx.

References TMethodCall::Execute(), fb, fFeedbackLists, TH1::GetBuffer(), TH1::GetBufferLength(), TH1::GetEntries(), TCollection::GetName(), TCollection::GetSize(), TMap::GetValue(), h, TObject::Info(), TMethodCall::InitWithPrototype(), TMethodCall::IsValid(), list, o, PDB, and TMethodCall::SetParam().

Referenced by HandleTimer(), and TProofPlayerLite::HandleTimer().

Bool_t TProofPlayerRemote::MergeOutputFiles (  )  [protected]

Definition at line 1826 of file TProofPlayer.cxx.

References TList::Add(), TObject::Error(), fc, fMergeFiles, TString::Format(), TProofOutputFile::GetDir(), TProofOutputFile::GetFileCollection(), TProofOutputFile::GetFileMerger(), TProofOutputFile::GetFileName(), TProofOutputFile::GetOutputFileName(), TCollection::GetSize(), TObjString::GetString(), TNamed::GetTitle(), TProofOutputFile::GetTypeOpt(), gSystem, TProofOutputFile::IsMerge(), TProofOutputFile::IsMerged(), TProofOutputFile::IsRegister(), TProofOutputFile::kOverwrite, kTRUE, TProofOutputFile::kVerify, o, TProofOutputFile::Print(), TString::Remove(), TProofOutputFile::ResetFileCollection(), and TSystem::Unlink().

Referenced by TProofPlayerLite::Finalize(), and Finalize().

void TProofPlayerRemote::NotifyMemory ( TObject *  obj  )  [protected]

Definition at line 2589 of file TProofPlayer.cxx.

References fProof, TSystem::GetProcInfo(), gSystem, TObject::Info(), IsClient(), TProof::IsLite(), pi, and RedirectOutput().

Referenced by AddOutput(), and AddOutputObject().

void TProofPlayerRemote::SetLastMergingMsg ( TObject *  obj  )  [protected]

Definition at line 2608 of file TProofPlayer.cxx.

References TString::Format(), and TProofServ::SetLastMsg().

Referenced by AddOutput(), and AddOutputObject().

Bool_t TProofPlayerRemote::SendSelector ( const char *  selector_file  )  [protected, virtual]

Definition at line 2161 of file TProofPlayer.cxx.

References TSystem::AccessPathName(), TSystem::BaseName(), TString::BeginsWith(), TString::Contains(), TString::Data(), TSystem::DirName(), TSystem::ExpandPathName(), fProof, gDebug, TROOT::GetMacroPath(), gSystem, h, TObject::Info(), TString::Insert(), TProof::kBinary, TProof::kCp, TProof::kCpBin, kFALSE, TProof::kForward, kReadPermission, kTRUE, TString::Last(), TString::Remove(), TProof::SendFile(), TROOT::SetMacroPath(), and TSystem::SplitAclicMode().

Referenced by Process().

TProof* TProofPlayerRemote::GetProof (  )  const [inline, protected]

Definition at line 277 of file TProofPlayer.h.

References fProof.

void TProofPlayerRemote::SetupFeedback (  )  [protected, virtual]

Reimplemented from TProofPlayer.

Definition at line 3025 of file TProofPlayer.cxx.

References fFeedback, TList::FindObject(), TProofPlayer::fInput, TProof::GetParameter(), TCollection::GetSize(), TObject::Info(), IsClient(), kTRUE, PDB, and SafeDelete.

Referenced by Process(), and TProofPlayerSuperMaster::SetupFeedback().

void TProofPlayerRemote::StopFeedback (  )  [protected, virtual]

Reimplemented from TProofPlayer.

Definition at line 3048 of file TProofPlayer.cxx.

References TObject::Info(), PDB, and SafeDelete.

Referenced by Process(), and TProofPlayerLite::Process().

void TProofPlayerRemote::SetSelectorDataMembersFromOutputList (  )  [protected]

Definition at line 1924 of file TProofPlayer.cxx.

References TOutputListSelectorDataMap::FindInList(), PDB, TOutputListSelectorDataMap::SetDataMembers(), and TObject::Warning().

Referenced by TProofPlayerLite::Finalize(), and Finalize().

Long64_t TProofPlayerRemote::Process ( TDSet *  set,
const char *  selector,
Option_t *  option = "",
Long64_t  nentries = -1,
Long64_t  firstentry = 0 
) [virtual]

Reimplemented from TProofPlayer.

Definition at line 1611 of file TProofPlayer.cxx.

References TProof::Activate(), TList::Add(), TSystem::BaseName(), TProof::Broadcast(), TProof::Collect(), TList::Delete(), emsg(), TObject::Error(), fDSet, TProofPlayer::fExitStatus, fFeedbackLists, Finalize(), TList::FindObject(), TProofPlayer::fInput, TProof::fLogFileName, fOutputLists, fPacketizer, TProofPlayer::fProgressStatus, fProof, TProof::fProtocol, TProof::fRedirLog, TProof::fSeqNum, gEnv, TVirtualPacketizer::GetBytesRead(), TDSet::GetDirectory(), TDSet::GetEntryList(), TProofPlayer::GetExitStatus(), TVirtualPacketizer::GetInitTime(), TDSet::GetObjName(), TProof::GetParallel(), TProof::GetParameter(), TVirtualPacketizer::GetProcTime(), TProof::GetQueryMode(), TSelector::GetSelector(), TVirtualPacketizer::GetTotalEntries(), TDSet::GetType(), TEnv::GetValue(), gProofServ, gSystem, HandleTimer(), TObject::Info(), InitPacketizer(), IsClient(), TProof::IsLite(), TProofServ::IsMaster(), TProof::IsMaster(), TProofServ::IsParallel(), TProof::IsSync(), TVirtualProofPlayer::kAborted, TDSet::kEmpty, kFALSE, TVirtualProofPlayer::kFinished, kPROOF_PROCESS, TProof::kSync, kTRUE, Long64_t, TEnv::Lookup(), num, PDB, Printf(), TSystem::RedirectOutput(), TProofProgressStatus::Reset(), TProof::ResetMergePrg(), SafeDelete, TProof::SendInputData(), TProof::SendInputDataFile(), SendSelector(), TObject::SetBit(), TProof::SetParameter(), TPerfStats::Setup(), SetupFeedback(), TDSet::SetWriteV3(), TPerfStats::Start(), StopFeedback(), TObject::TestBit(), and TObject::Warning().

Referenced by DrawSelect().

Long64_t TProofPlayerRemote::Finalize ( Bool_t  force = kFALSE,
Bool_t  sync = kFALSE 
) [virtual]

Reimplemented from TProofPlayer.

Definition at line 1940 of file TProofPlayer.cxx.

References TStatus::Add(), TList::Add(), AddOutputObject(), TProofPlayer::DrawCanvas(), TProofPlayer::fExitStatus, TProof::FinalizationDone(), TProof::Finalize(), TProofPlayer::fInput, Form(), fOutputLists, fPacketizer, fProof, TVirtualPacketizer::GetConfigParams(), TVirtualPacketizer::GetFailedPackets(), TDSetElement::GetFileInfo(), TProofPlayer::GetOutput(), TProofServ::GetPrefix(), TVirtualPacketizer::GetProgressPerf(), gProofServ, TObject::Info(), IsClient(), TProof::IsMaster(), TProof::IsParallel(), TVirtualProofPlayer::kAborted, kFALSE, TVirtualPacketizer::kIsTree, kTRUE, Long64_t, MergeOutput(), MergeOutputFiles(), o, output(), PDB, TProofPlayer::ReinitSelector(), SafeDelete, TVirtualPacketizer::SetFailedPackets(), TCollection::SetName(), SetSelectorDataMembersFromOutputList(), TPerfStats::Stop(), TObject::TestBit(), type, and TObject::Warning().

Referenced by TProofPlayerLite::Finalize(), Finalize(), and Process().

Long64_t TProofPlayerRemote::Finalize ( TQueryResult *  qr  )  [virtual]

Reimplemented from TProofPlayer.

Definition at line 2090 of file TProofPlayer.cxx.

References TList::Delete(), Finalize(), TProof::fLogFileName, fOutputLists, fProof, TProof::fProtocol, TQueryResult::GetOutputList(), gSystem, TObject::Info(), IsClient(), TQueryResult::IsFinalized(), Long64_t, o, out, PDB, TSystem::RedirectOutput(), TProofPlayer::RestorePreviousQuery(), TProofPlayer::SetCurrentQuery(), SetSelectorDataMembersFromOutputList(), and StoreOutput().

Long64_t TProofPlayerRemote::DrawSelect ( TDSet *  set,
const char *  varexp,
const char *  selection,
Option_t *  option = "",
Long64_t  nentries = -1,
Long64_t  firstentry = 0 
) [virtual]

Reimplemented from TProofPlayer.

Definition at line 3150 of file TProofPlayer.cxx.

References TList::Add(), TProof::AddFeedback(), TList::Clear(), TObject::Error(), TList::FindObject(), TProofPlayer::fInput, fProof, TProofPlayer::GetDrawArgs(), kFALSE, Long64_t, n, o, Process(), TList::Remove(), TProof::RemoveFeedback(), and TCollection::SetOwner().

void TProofPlayerRemote::RedirectOutput ( Bool_t  on = kTRUE  ) 

Definition at line 2485 of file TProofPlayer.cxx.

References TProofServ::ErrorHandler(), fErrorHandler, TProof::fLogFileW, fProof, SetErrorHandler(), and TProofServ::SetErrorHandlerFile().

Referenced by NotifyMemory().

void TProofPlayerRemote::StopProcess ( Bool_t  abort,
Int_t  timeout = -1 
) [virtual]

Reimplemented from TProofPlayer.

Definition at line 2351 of file TProofPlayer.cxx.

References TProofPlayer::fExitStatus, fPacketizer, TVirtualProofPlayer::kAborted, TVirtualProofPlayer::kStopped, kTRUE, and TVirtualPacketizer::StopProcess().

void TProofPlayerRemote::StoreOutput ( TList *  out  )  [virtual]

Reimplemented from TProofPlayer.

Definition at line 2782 of file TProofPlayer.cxx.

References TEventList::Add(), TList::Add(), TObject::Error(), fDSet, TList::FindObject(), fOutputLists, TEventList::GetList(), TDSet::GetListOfElements(), TEventList::GetN(), TNamed::GetName(), i, TObject::Info(), kFALSE, list, Long64_t, num, out, PDB, and TCollection::SetOwner().

Referenced by Finalize().

void TProofPlayerRemote::StoreFeedback ( TObject *  slave,
TList *  out 
) [virtual]

Reimplemented from TProofPlayer.

Definition at line 2964 of file TProofPlayer.cxx.

References TList::Add(), Feedback(), fFeedbackLists, TList::FindObject(), TObject::Info(), IsClient(), kFALSE, ord, out, PDB, and TCollection::SetOwner().

Referenced by HandleTimer().

Int_t TProofPlayerRemote::Incorporate ( TObject *  obj,
TList *  out,
Bool_t &  merged 
)

Definition at line 2617 of file TProofPlayer.cxx.

References TList::Add(), xmlio::Class, TObject::ClassName(), TObject::Error(), TMethodCall::Execute(), TList::FindObject(), fProof, TObject::GetName(), HandleHistogram(), TObject::Info(), TObject::InheritsFrom(), TMethodCall::InitWithPrototype(), TProof::IsLite(), TMethodCall::IsValid(), kFALSE, TProof::kIsClient, kTRUE, PDB, TMethodCall::SetParam(), and TObject::TestBit().

Referenced by AddOutput(), and AddOutputObject().

TObject * TProofPlayerRemote::HandleHistogram ( TObject *  obj  ) 

Definition at line 2687 of file TProofPlayer.cxx.

References TList::Add(), TList::FindObject(), TH1::FindObject(), fOutputLists, TH1::GetBuffer(), TH1::GetBufferLength(), TH1::GetEntries(), TProofServ::GetMsgSizeHWM(), gProofServ, h, TObject::Info(), kFALSE, kTRUE, list, PDB, and TCollection::SetOwner().

Referenced by Incorporate().

Int_t TProofPlayerRemote::AddOutputObject ( TObject *  obj  )  [virtual]

Reimplemented from TProofPlayer.

Definition at line 2364 of file TProofPlayer.cxx.

References TEventList::Add(), TObject::Error(), fDSet, fMergeFiles, Form(), gDebug, gEnv, TSystem::Getenv(), TProofOutputFile::GetFileName(), TEventList::GetList(), TDSet::GetListOfElements(), TEventList::GetN(), TCollection::GetName(), TNamed::GetName(), TProofOutputFile::GetOutputFileName(), TProofServ::GetSessionDir(), TEnv::GetValue(), gProofServ, gSystem, TSystem::HostName(), i, Incorporate(), TObject::Info(), IsClient(), TProofOutputFile::IsMerge(), kTRUE, Long64_t, NotifyMemory(), num, PDB, TProofOutputFile::Print(), Printf(), SafeDelete, SetLastMergingMsg(), and TProofOutputFile::SetOutputFileName().

Referenced by Finalize(), and InitPacketizer().

void TProofPlayerRemote::AddOutput ( TList *  out  )  [virtual]

Reimplemented from TProofPlayer.

Definition at line 2501 of file TProofPlayer.cxx.

References TEventList::Add(), TObject::Error(), fDSet, TEventList::GetList(), TDSet::GetListOfElements(), TEventList::GetN(), TNamed::GetName(), i, Incorporate(), TObject::Info(), kTRUE, Long64_t, NotifyMemory(), num, out, PDB, and SetLastMergingMsg().

void TProofPlayerRemote::MergeOutput (  )  [virtual]

Reimplemented from TProofPlayer.

Definition at line 2231 of file TProofPlayer.cxx.

References TMethodCall::Execute(), fOutputLists, TObject::Info(), TMethodCall::InitWithPrototype(), TMethodCall::IsValid(), list, PDB, SafeDelete, and TMethodCall::SetParam().

Referenced by TProofPlayerLite::Finalize(), and Finalize().

void TProofPlayerRemote::Progress ( Long64_t  total,
Long64_t  processed 
) [virtual]

Reimplemented from TProofPlayer.

Definition at line 2278 of file TProofPlayer.cxx.

References fProof, TProofServ::GetSocket(), gProofServ, IsClient(), kPROOF_PROGRESS, m, TProof::Progress(), and TSocket::Send().

Referenced by TProofPlayerSuperMaster::Progress(), and Progress().

void TProofPlayerRemote::Progress ( TSlave *  ,
Long64_t  total,
Long64_t  processed 
) [inline, virtual]

Reimplemented from TProofPlayer.

Definition at line 307 of file TProofPlayer.h.

References Progress().

void TProofPlayerRemote::Progress ( Long64_t  total,
Long64_t  processed,
Long64_t  bytesread,
Float_t  initTime,
Float_t  procTime,
Float_t  evtrti,
Float_t  mbrti 
) [virtual]

Reimplemented from TProofPlayer.

Definition at line 2293 of file TProofPlayer.cxx.

References fProof, TProofServ::GetSocket(), gProofServ, TObject::Info(), IsClient(), kPROOF_PROGRESS, m, PDB, TProof::Progress(), and TSocket::Send().

void TProofPlayerRemote::Progress ( TSlave *  ,
Long64_t  total,
Long64_t  processed,
Long64_t  bytesread,
Float_t  initTime,
Float_t  procTime,
Float_t  evtrti,
Float_t  mbrti 
) [inline, virtual]

Reimplemented from TProofPlayer.

Definition at line 312 of file TProofPlayer.h.

References Progress().

void TProofPlayerRemote::Progress ( TProofProgressInfo *  pi  )  [virtual]

Reimplemented from TProofPlayer.

Definition at line 2315 of file TProofPlayer.cxx.

References fProof, TProofServ::GetSocket(), gProofServ, TObject::Info(), IsClient(), kPROOF_PROGRESS, m, PDB, pi, TProof::Progress(), TSocket::Send(), and TObject::Warning().

void TProofPlayerRemote::Progress ( TSlave *  ,
TProofProgressInfo *  pi 
) [inline, virtual]

Reimplemented from TProofPlayer.

Definition at line 318 of file TProofPlayer.h.

References pi, and Progress().

void TProofPlayerRemote::Feedback ( TList *  objs  )  [virtual]

Reimplemented from TProofPlayer.

Definition at line 2343 of file TProofPlayer.cxx.

References TProof::Feedback(), and fProof.

Referenced by TProofPlayerLite::HandleTimer(), and StoreFeedback().

TDSetElement * TProofPlayerRemote::GetNextPacket ( TSlave *  slave,
TMessage *  r 
) [virtual]

Reimplemented from TProofPlayer.

Definition at line 3118 of file TProofPlayer.cxx.

References fPacketizer, TDSetElement::GetDirectory(), TDSetElement::GetFileName(), TDSetElement::GetFirst(), TSlave::GetName(), TVirtualPacketizer::GetNextPacket(), TDSetElement::GetNum(), TDSetElement::GetObjName(), TSlave::GetOrdinal(), TObject::Info(), PDB, and SetInitTime().

TVirtualPacketizer* TProofPlayerRemote::GetPacketizer (  )  const [inline, virtual]

Reimplemented from TProofPlayer.

Definition at line 321 of file TProofPlayer.h.

References fPacketizer.

Bool_t TProofPlayerRemote::IsClient (  )  const [virtual]

Reimplemented from TProofPlayer.

Definition at line 3142 of file TProofPlayer.cxx.

References fProof, kFALSE, TProof::kIsClient, and TObject::TestBit().

Referenced by AddOutputObject(), Finalize(), NotifyMemory(), Process(), Progress(), TProofPlayerSuperMaster::SetupFeedback(), SetupFeedback(), and StoreFeedback().

void TProofPlayerRemote::SetInitTime (  )  [virtual]

Reimplemented from TProofPlayer.

Definition at line 3221 of file TProofPlayer.cxx.

References fPacketizer, and TVirtualPacketizer::SetInitTime().

Referenced by GetNextPacket().

virtual Bool_t TProofPlayerRemote::HandleTimer ( TTimer *  timer  )  [protected, virtual]

Reimplemented from TObject.

Int_t TProofPlayerRemote::InitPacketizer ( TDSet *  dset,
Long64_t  nentries,
Long64_t  first,
const char *  defpackunit,
const char *  defpackdata 
) [protected]

TList* TProofPlayerRemote::MergeFeedback (  )  [protected]

Bool_t TProofPlayerRemote::MergeOutputFiles (  )  [protected]

void TProofPlayerRemote::NotifyMemory ( TObject *  obj  )  [protected]

void TProofPlayerRemote::SetLastMergingMsg ( TObject *  obj  )  [protected]

virtual Bool_t TProofPlayerRemote::SendSelector ( const char *  selector_file  )  [protected, virtual]

TProof* TProofPlayerRemote::GetProof (  )  const [inline, protected]

Definition at line 277 of file TProofPlayer.h.

References fProof.

void TProofPlayerRemote::SetupFeedback (  )  [protected, virtual]

Reimplemented from TProofPlayer.

void TProofPlayerRemote::StopFeedback (  )  [protected, virtual]

Reimplemented from TProofPlayer.

void TProofPlayerRemote::SetSelectorDataMembersFromOutputList (  )  [protected]

virtual Long64_t TProofPlayerRemote::Process ( TDSet *  set,
const char *  selector,
Option_t *  option = "",
Long64_t  nentries = -1,
Long64_t  firstentry = 0 
) [virtual]

Reimplemented from TProofPlayer.

virtual Long64_t TProofPlayerRemote::Finalize ( Bool_t  force = kFALSE,
Bool_t  sync = kFALSE 
) [virtual]

Reimplemented from TProofPlayer.

virtual Long64_t TProofPlayerRemote::Finalize ( TQueryResult *  qr  )  [virtual]

Reimplemented from TProofPlayer.

Long64_t TProofPlayerRemote::DrawSelect ( TDSet *  set,
const char *  varexp,
const char *  selection,
Option_t *  option = "",
Long64_t  nentries = -1,
Long64_t  firstentry = 0 
) [virtual]

Reimplemented from TProofPlayer.

void TProofPlayerRemote::RedirectOutput ( Bool_t  on = kTRUE  ) 

void TProofPlayerRemote::StopProcess ( Bool_t  abort,
Int_t  timeout = -1 
) [virtual]

Reimplemented from TProofPlayer.

void TProofPlayerRemote::StoreOutput ( TList *  out  )  [virtual]

Reimplemented from TProofPlayer.

virtual void TProofPlayerRemote::StoreFeedback ( TObject *  slave,
TList *  out 
) [virtual]

Reimplemented from TProofPlayer.

Int_t TProofPlayerRemote::Incorporate ( TObject *  obj,
TList *  out,
Bool_t &  merged 
)

TObject* TProofPlayerRemote::HandleHistogram ( TObject *  obj  ) 

Int_t TProofPlayerRemote::AddOutputObject ( TObject *  obj  )  [virtual]

Reimplemented from TProofPlayer.

void TProofPlayerRemote::AddOutput ( TList *  out  )  [virtual]

Reimplemented from TProofPlayer.

virtual void TProofPlayerRemote::MergeOutput (  )  [virtual]

Reimplemented from TProofPlayer.

void TProofPlayerRemote::Progress ( Long64_t  total,
Long64_t  processed 
) [virtual]

Reimplemented from TProofPlayer.

void TProofPlayerRemote::Progress ( TSlave *  ,
Long64_t  total,
Long64_t  processed 
) [inline, virtual]

Reimplemented from TProofPlayer.

Definition at line 307 of file TProofPlayer.h.

References Progress().

void TProofPlayerRemote::Progress ( Long64_t  total,
Long64_t  processed,
Long64_t  bytesread,
Float_t  initTime,
Float_t  procTime,
Float_t  evtrti,
Float_t  mbrti 
) [virtual]

Reimplemented from TProofPlayer.

void TProofPlayerRemote::Progress ( TSlave *  ,
Long64_t  total,
Long64_t  processed,
Long64_t  bytesread,
Float_t  initTime,
Float_t  procTime,
Float_t  evtrti,
Float_t  mbrti 
) [inline, virtual]

Reimplemented from TProofPlayer.

Definition at line 312 of file TProofPlayer.h.

References Progress().

void TProofPlayerRemote::Progress ( TProofProgressInfo *  pi  )  [virtual]

Reimplemented from TProofPlayer.

void TProofPlayerRemote::Progress ( TSlave *  ,
TProofProgressInfo *  pi 
) [inline, virtual]

Reimplemented from TProofPlayer.

Definition at line 318 of file TProofPlayer.h.

References pi, and Progress().

void TProofPlayerRemote::Feedback ( TList *  objs  )  [virtual]

Reimplemented from TProofPlayer.

TDSetElement* TProofPlayerRemote::GetNextPacket ( TSlave *  slave,
TMessage *  r 
) [virtual]

Reimplemented from TProofPlayer.

TVirtualPacketizer* TProofPlayerRemote::GetPacketizer (  )  const [inline, virtual]

Reimplemented from TProofPlayer.

Definition at line 321 of file TProofPlayer.h.

References fPacketizer.

Bool_t TProofPlayerRemote::IsClient (  )  const [virtual]

Reimplemented from TProofPlayer.

void TProofPlayerRemote::SetInitTime (  )  [virtual]

Reimplemented from TProofPlayer.

Member Data Documentation

TProof* TProofPlayerRemote::fProof [protected]

Definition at line 259 of file TProofPlayer.h.

Referenced by DrawSelect(), Feedback(), TProofPlayerLite::Finalize(), Finalize(), GetProof(), Incorporate(), InitPacketizer(), IsClient(), TProofPlayerLite::MakeSelector(), NotifyMemory(), Process(), TProofPlayerLite::Process(), Progress(), RedirectOutput(), and SendSelector().

TList* TProofPlayerRemote::fOutputLists [protected]

Definition at line 260 of file TProofPlayer.h.

Referenced by TProofPlayerLite::Finalize(), Finalize(), HandleHistogram(), MergeOutput(), Process(), TProofPlayerLite::Process(), and StoreOutput().

TList* TProofPlayerRemote::fFeedback [protected]

Definition at line 261 of file TProofPlayer.h.

Referenced by HandleTimer(), TProofPlayerLite::HandleTimer(), TProofPlayerLite::SetupFeedback(), and SetupFeedback().

TList* TProofPlayerRemote::fFeedbackLists [protected]

Definition at line 262 of file TProofPlayer.h.

Referenced by HandleTimer(), TProofPlayerLite::HandleTimer(), MergeFeedback(), Process(), StoreFeedback(), and TProofPlayerLite::StoreFeedback().

TVirtualPacketizer* TProofPlayerRemote::fPacketizer [protected]

Definition at line 263 of file TProofPlayer.h.

Referenced by Finalize(), GetNextPacket(), GetPacketizer(), InitPacketizer(), Process(), TProofPlayerLite::Process(), SetInitTime(), and StopProcess().

Bool_t TProofPlayerRemote::fMergeFiles [protected]

Definition at line 264 of file TProofPlayer.h.

Referenced by AddOutputObject(), and MergeOutputFiles().

TDSet* TProofPlayerRemote::fDSet [protected]

Definition at line 265 of file TProofPlayer.h.

Referenced by AddOutput(), AddOutputObject(), InitPacketizer(), Process(), TProofPlayerLite::Process(), and StoreOutput().

ErrorHandlerFunc_t TProofPlayerRemote::fErrorHandler [protected]

tdset for current processing

Definition at line 266 of file TProofPlayer.h.

Referenced by RedirectOutput().

TProof* TProofPlayerRemote::fProof [protected]

Definition at line 259 of file TProofPlayer.h.

TList* TProofPlayerRemote::fOutputLists [protected]

Definition at line 260 of file TProofPlayer.h.

TList* TProofPlayerRemote::fFeedback [protected]

Definition at line 261 of file TProofPlayer.h.

TList* TProofPlayerRemote::fFeedbackLists [protected]

Definition at line 262 of file TProofPlayer.h.

TVirtualPacketizer* TProofPlayerRemote::fPacketizer [protected]

Definition at line 263 of file TProofPlayer.h.

TDSet* TProofPlayerRemote::fDSet [protected]

Definition at line 265 of file TProofPlayer.h.

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