ROOT logo
ROOT » PROOF » PROOFPLAYER » TProofPlayerLocal

class TProofPlayerLocal: public TProofPlayer


TProofPlayer

 This internal class and its subclasses steer the processing in PROOF.
Instances of the TProofPlayer class are created on the worker nodes
per session and do the processing.
Instances of its subclass - TProofPlayerRemote are created per each
query on the master(s) and on the client. On the master(s),
TProofPlayerRemote coordinate processing, check the dataset, create
the packetizer and take care of merging the results of the workers.
The instance on the client collects information on the input
(dataset and selector), it invokes the Begin() method and finalizes
the query by calling Terminate().

Function Members (Methods)

public:
TProofPlayerLocal(Bool_t client = kTRUE)
virtual~TProofPlayerLocal()
voidTObject::AbstractMethod(const char* method) const
virtual voidTProofPlayer::AddEventsProcessed(Long64_t ev)
virtual voidTVirtualProofPlayer::AddEventsProcessed(Long64_t ev)
virtual voidTProofPlayer::AddInput(TObject* inp)
virtual voidTVirtualProofPlayer::AddInput(TObject* inp)
virtual voidTProofPlayer::AddOutput(TList* out)
virtual voidTVirtualProofPlayer::AddOutput(TList* out)
virtual Int_tTProofPlayer::AddOutputObject(TObject* obj)
virtual Int_tTVirtualProofPlayer::AddOutputObject(TObject* obj)
virtual voidTProofPlayer::AddQueryResult(TQueryResult* q)
virtual voidTVirtualProofPlayer::AddQueryResult(TQueryResult* q)
virtual voidTObject::AppendPad(Option_t* option = "")
static Bool_tTQObject::AreAllSignalsBlocked()
Bool_tTQObject::AreSignalsBlocked() const
static Bool_tTQObject::BlockAllSignals(Bool_t b)
Bool_tTQObject::BlockSignals(Bool_t b)
virtual voidTObject::Browse(TBrowser* b)
virtual voidTQObject::ChangedBy(const char* method)SIGNAL
static TClass*Class()
static TClass*TProofPlayer::Class()
static TClass*TVirtualProofPlayer::Class()
static TClass*TQObject::Class()
static TClass*TObject::Class()
virtual const char*TObject::ClassName() const
virtual voidTObject::Clear(Option_t* = "")
virtual voidTProofPlayer::ClearInput()
virtual voidTVirtualProofPlayer::ClearInput()
virtual TObject*TObject::Clone(const char* newname = "") const
voidTQObject::CollectClassSignalLists(TList& list, TClass* cls)
virtual Int_tTObject::Compare(const TObject* obj) const
Bool_tTQObject::Connect(const char* signal, const char* receiver_class, void* receiver, const char* slot)
static Bool_tTQObject::Connect(TQObject* sender, const char* signal, const char* receiver_class, void* receiver, const char* slot)
static Bool_tTQObject::Connect(const char* sender_class, const char* signal, const char* receiver_class, void* receiver, const char* slot)
virtual voidTQObject::Connected(const char*)
virtual voidTObject::Copy(TObject& object) const
static TVirtualProofPlayer*TVirtualProofPlayer::Create(const char* player, TProof* p, TSocket* s = 0)
virtual TDrawFeedback*TProofPlayer::CreateDrawFeedback(TProof* p)
virtual TDrawFeedback*TVirtualProofPlayer::CreateDrawFeedback(TProof* p)
virtual voidTObject::Delete(Option_t* option = "")MENU
virtual voidTProofPlayer::DeleteDrawFeedback(TDrawFeedback* f)
virtual voidTVirtualProofPlayer::DeleteDrawFeedback(TDrawFeedback* f)
virtual voidTQObject::Destroyed()SIGNAL
Bool_tTQObject::Disconnect(const char* signal = 0, void* receiver = 0, const char* slot = 0)
static Bool_tTQObject::Disconnect(TQObject* sender, const char* signal = 0, void* receiver = 0, const char* slot = 0)
static Bool_tTQObject::Disconnect(const char* class_name, const char* signal, void* receiver = 0, const char* slot = 0)
virtual voidTQObject::Disconnected(const char*)
virtual Int_tTObject::DistancetoPrimitive(Int_t px, Int_t py)
virtual voidTObject::Draw(Option_t* option = "")
virtual voidTObject::DrawClass() constMENU
virtual TObject*TObject::DrawClone(Option_t* option = "") constMENU
virtual Long64_tTProofPlayer::DrawSelect(TDSet* set, const char* varexp, const char* selection, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
virtual Long64_tTVirtualProofPlayer::DrawSelect(TDSet* set, const char* varexp, const char* selection, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
virtual voidTObject::Dump() constMENU
voidTQObject::Emit(const char* signal)
voidTQObject::Emit(const char* signal, Long_t* paramArr)
voidTQObject::Emit(const char* signal, const char* params)
voidTQObject::Emit(const char* signal, Double_t param)
voidTQObject::Emit(const char* signal, Long_t param)
voidTQObject::Emit(const char* signal, Long64_t param)
voidTQObject::Emit(const char* signal, Bool_t param)
voidTQObject::Emit(const char* signal, Char_t param)
voidTQObject::Emit(const char* signal, UChar_t param)
voidTQObject::Emit(const char* signal, Short_t param)
voidTQObject::Emit(const char* signal, UShort_t param)
voidTQObject::Emit(const char* signal, Int_t param)
voidTQObject::Emit(const char* signal, UInt_t param)
voidTQObject::Emit(const char* signal, ULong_t param)
voidTQObject::Emit(const char* signal, ULong64_t param)
voidTQObject::Emit(const char* signal, Float_t param)
voidTQObject::EmitVA(const char* signal, Int_t nargs)
voidTQObject::EmitVA(const char* signal, Int_t nargs, va_list va)
virtual voidTObject::Error(const char* method, const char* msgfmt) const
virtual voidTObject::Execute(const char* method, const char* params, Int_t* error = 0)
virtual voidTObject::Execute(TMethod* method, TObjArray* params, Int_t* error = 0)
virtual voidTObject::ExecuteEvent(Int_t event, Int_t px, Int_t py)
virtual voidTObject::Fatal(const char* method, const char* msgfmt) const
virtual voidTProofPlayer::Feedback(TList* objs)SIGNAL
virtual Long64_tTProofPlayer::Finalize(TQueryResult* qr)
virtual Long64_tTVirtualProofPlayer::Finalize(TQueryResult* qr)
virtual Long64_tTProofPlayer::Finalize(Bool_t force = kFALSE, Bool_t sync = kFALSE)
virtual Long64_tTVirtualProofPlayer::Finalize(Bool_t force = kFALSE, Bool_t sync = kFALSE)
virtual TObject*TObject::FindObject(const char* name) const
virtual TObject*TObject::FindObject(const TObject* obj) const
virtual TQueryResult*TProofPlayer::GetCurrentQuery() const
virtual TQueryResult*TVirtualProofPlayer::GetCurrentQuery() const
virtual Int_tTProofPlayer::GetDrawArgs(const char* var, const char* sel, Option_t* opt, TString& selector, TString& objname)
virtual Int_tTVirtualProofPlayer::GetDrawArgs(const char* var, const char* sel, Option_t* opt, TString& selector, TString& objname)
virtual Option_t*TObject::GetDrawOption() const
static Long_tTObject::GetDtorOnly()
virtual Long64_tTProofPlayer::GetEventsProcessed() const
virtual Long64_tTVirtualProofPlayer::GetEventsProcessed() const
virtual TVirtualProofPlayer::EExitStatusTProofPlayer::GetExitStatus() const
virtual TVirtualProofPlayer::EExitStatusTVirtualProofPlayer::GetExitStatus() const
virtual const char*TObject::GetIconName() const
virtual TList*TProofPlayer::GetInputList() const
virtual TList*TVirtualProofPlayer::GetInputList() const
TList*TQObject::GetListOfClassSignals() const
TList*TQObject::GetListOfConnections() const
virtual TList*TProofPlayer::GetListOfResults() const
virtual TList*TVirtualProofPlayer::GetListOfResults() const
TList*TQObject::GetListOfSignals() const
virtual const char*TObject::GetName() const
virtual TDSetElement*TProofPlayer::GetNextPacket(TSlave* slave, TMessage* r)
virtual TDSetElement*TVirtualProofPlayer::GetNextPacket(TSlave* slave, TMessage* r)
virtual char*TObject::GetObjectInfo(Int_t px, Int_t py) const
static Bool_tTObject::GetObjectStat()
virtual Option_t*TObject::GetOption() const
virtual TObject*TProofPlayer::GetOutput(const char* name) const
virtual TObject*TVirtualProofPlayer::GetOutput(const char* name) const
virtual TList*TProofPlayer::GetOutputList() const
virtual TVirtualPacketizer*TProofPlayer::GetPacketizer() const
virtual TVirtualPacketizer*TVirtualProofPlayer::GetPacketizer() const
virtual TProofProgressStatus*TProofPlayer::GetProgressStatus() const
virtual TProofProgressStatus*TVirtualProofPlayer::GetProgressStatus() const
virtual TQueryResult*TProofPlayer::GetQueryResult(const char* ref)
virtual TQueryResult*TVirtualProofPlayer::GetQueryResult(const char* ref)
virtual const char*TObject::GetTitle() const
virtual UInt_tTObject::GetUniqueID() const
virtual voidTProofPlayer::HandleGetTreeHeader(TMessage* mess)
virtual voidTVirtualProofPlayer::HandleGetTreeHeader(TMessage* mess)
virtual voidTProofPlayer::HandleRecvHisto(TMessage* mess)
virtual voidTVirtualProofPlayer::HandleRecvHisto(TMessage* mess)
virtual Bool_tTObject::HandleTimer(TTimer* timer)
virtual Bool_tTQObject::HasConnection(const char* signal_name) const
virtual ULong_tTObject::Hash() const
virtual voidTQObject::HighPriority(const char* signal_name, const char* slot_name = 0)
virtual voidTObject::Info(const char* method, const char* msgfmt) const
virtual Bool_tTObject::InheritsFrom(const char* classname) const
virtual Bool_tTObject::InheritsFrom(const TClass* cl) const
virtual voidTObject::Inspect() constMENU
voidTObject::InvertBit(UInt_t f)
virtual TClass*IsA() const
virtual TClass*TProofPlayer::IsA() const
virtual TClass*TVirtualProofPlayer::IsA() const
virtual TClass*TQObject::IsA() const
virtual TClass*TObject::IsA() const
virtual Bool_tIsClient() const
virtual Bool_tTProofPlayer::IsClient() const
virtual Bool_tTVirtualProofPlayer::IsClient() const
virtual Bool_tTObject::IsEqual(const TObject* obj) const
virtual Bool_tTObject::IsFolder() const
Bool_tTObject::IsOnHeap() const
virtual Bool_tTObject::IsSortable() const
Bool_tTObject::IsZombie() const
static voidTQObject::LoadRQ_OBJECT()
virtual voidTQObject::LowPriority(const char* signal_name, const char* slot_name = 0)
virtual voidTObject::ls(Option_t* option = "") const
voidTObject::MayNotUse(const char* method) const
virtual voidTQObject::Message(const char* msg)SIGNAL
virtual Bool_tTObject::Notify()
virtual Int_tTQObject::NumberOfConnections() const
virtual Int_tTQObject::NumberOfSignals() const
static voidTObject::operator delete(void* ptr)
static voidTObject::operator delete(void* ptr, void* vp)
static voidTObject::operator delete[](void* ptr)
static voidTObject::operator delete[](void* ptr, void* vp)
void*TObject::operator new(size_t sz)
void*TObject::operator new(size_t sz, void* vp)
void*TObject::operator new[](size_t sz)
void*TObject::operator new[](size_t sz, void* vp)
TObject&TObject::operator=(const TObject& rhs)
virtual voidTObject::Paint(Option_t* option = "")
virtual voidTObject::Pop()
virtual voidTObject::Print(Option_t* option = "") const
virtual Long64_tTProofPlayer::Process(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
virtual Long64_tTVirtualProofPlayer::Process(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
virtual voidTProofPlayer::Progress(Long64_t total, Long64_t processed)SIGNAL
virtual voidTProofPlayer::Progress(TSlave*, Long64_t total, Long64_t processed)
virtual voidTProofPlayer::Progress(Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)SIGNAL
virtual voidTProofPlayer::Progress(TSlave*, Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)SIGNAL
virtual Int_tTObject::Read(const char* name)
virtual voidTObject::RecursiveRemove(TObject* obj)
virtual Int_tTProofPlayer::ReinitSelector(TQueryResult* qr)
virtual Int_tTVirtualProofPlayer::ReinitSelector(TQueryResult* qr)
virtual voidTProofPlayer::RemoveQueryResult(const char* ref)
virtual voidTVirtualProofPlayer::RemoveQueryResult(const char* ref)
voidTObject::ResetBit(UInt_t f)
virtual voidTProofPlayer::RestorePreviousQuery()
virtual voidTObject::SaveAs(const char* filename = "", Option_t* option = "") constMENU
virtual voidTObject::SavePrimitive(basic_ostream<char,char_traits<char> >& out, Option_t* option = "")
voidTObject::SetBit(UInt_t f)
voidTObject::SetBit(UInt_t f, Bool_t set)
virtual voidTProofPlayer::SetCurrentQuery(TQueryResult* q)
virtual voidTVirtualProofPlayer::SetCurrentQuery(TQueryResult* q)
virtual voidTProofPlayer::SetDispatchTimer(Bool_t on = kTRUE)
virtual voidTVirtualProofPlayer::SetDispatchTimer(Bool_t on = kTRUE)
virtual voidTProofPlayer::SetDrawFeedbackOption(TDrawFeedback* f, Option_t* opt)
virtual voidTVirtualProofPlayer::SetDrawFeedbackOption(TDrawFeedback* f, Option_t* opt)
virtual voidTObject::SetDrawOption(Option_t* option = "")MENU
static voidTObject::SetDtorOnly(void* obj)
virtual voidTProofPlayer::SetInitTime()
virtual voidTVirtualProofPlayer::SetInitTime()
virtual voidTProofPlayer::SetMaxDrawQueries(Int_t max)
virtual voidTVirtualProofPlayer::SetMaxDrawQueries(Int_t max)
static voidTObject::SetObjectStat(Bool_t stat)
voidTProofPlayer::SetProcessing(Bool_t on = kTRUE)
virtual voidTProofPlayer::SetStopTimer(Bool_t on = kTRUE, Bool_t abort = kFALSE, Int_t timeout = 0)
virtual voidTVirtualProofPlayer::SetStopTimer(Bool_t on = kTRUE, Bool_t abort = kFALSE, Int_t timeout = 0)
virtual voidTObject::SetUniqueID(UInt_t uid)
virtual voidShowMembers(TMemberInspector& insp, char* parent)
virtual voidTProofPlayer::ShowMembers(TMemberInspector& insp, char* parent)
virtual voidTVirtualProofPlayer::ShowMembers(TMemberInspector& insp, char* parent)
virtual voidTQObject::ShowMembers(TMemberInspector& insp, char* parent)
virtual voidTObject::ShowMembers(TMemberInspector& insp, char* parent)
virtual voidTProofPlayer::StopFeedback()
virtual voidTProofPlayer::StopProcess(Bool_t abort, Int_t timeout = -1)
virtual voidTVirtualProofPlayer::StopProcess(Bool_t abort, Int_t timeout = -1)
virtual voidTProofPlayer::StoreFeedback(TObject* slave, TList* out)
virtual voidTVirtualProofPlayer::StoreFeedback(TObject* slave, TList* out)
virtual voidTProofPlayer::StoreOutput(TList* out)
virtual voidTVirtualProofPlayer::StoreOutput(TList* out)
virtual voidStreamer(TBuffer& b)
virtual voidTProofPlayer::Streamer(TBuffer& b)
virtual voidTVirtualProofPlayer::Streamer(TBuffer& b)
voidStreamerNVirtual(TBuffer& b)
voidTProofPlayer::StreamerNVirtual(TBuffer& b)
voidTVirtualProofPlayer::StreamerNVirtual(TBuffer& b)
voidTQObject::StreamerNVirtual(TBuffer& b)
voidTObject::StreamerNVirtual(TBuffer& b)
virtual voidTObject::SysError(const char* method, const char* msgfmt) const
Bool_tTObject::TestBit(UInt_t f) const
Int_tTObject::TestBits(UInt_t f) const
virtual voidTProofPlayer::UpdateAutoBin(const char* name, Double_t& xmin, Double_t& xmax, Double_t& ymin, Double_t& ymax, Double_t& zmin, Double_t& zmax)
virtual voidTVirtualProofPlayer::UpdateAutoBin(const char* name, Double_t& xmin, Double_t& xmax, Double_t& ymin, Double_t& ymax, Double_t& zmin, Double_t& zmax)
virtual voidTObject::UseCurrentStyle()
virtual voidTObject::Warning(const char* method, const char* msgfmt) const
virtual Int_tTObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0)
virtual Int_tTObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0) const
protected:
static Int_tTQObject::CheckConnectArgs(TQObject* sender, TClass* sender_class, const char* signal, TClass* receiver_class, const char* slot)
static Bool_tTQObject::ConnectToClass(TQObject* sender, const char* signal, TClass* receiver_class, void* receiver, const char* slot)
static Bool_tTQObject::ConnectToClass(const char* sender_class, const char* signal, TClass* receiver_class, void* receiver, const char* slot)
virtual voidTObject::DoError(int level, const char* location, const char* fmt, va_list va) const
virtual Int_tTProofPlayer::DrawCanvas(TObject* obj)
virtual void*TProofPlayer::GetSender()
virtual void*TQObject::GetSender()
virtual const char*TQObject::GetSenderClassName() const
voidTObject::MakeZombie()
virtual voidSetupFeedback()
virtual voidTProofPlayer::SetupFeedback()
virtual voidStopFeedback()

Data Members

private:
enum TProofPlayer::EStatusBits { kDispatchOneEvent
kIsProcessing
};
enum TVirtualProofPlayer::EExitStatus { kFinished
kStopped
kAborted
};
enum TObject::EStatusBits { kCanDelete
kMustCleanup
kObjInCanvas
kIsReferenced
kHasUUID
kCannotPick
kNoContextMenu
kInvalidObject
};
enum TObject::[unnamed] { kIsOnHeap
kNotDeleted
kZombie
kBitMask
kSingleKey
kOverwrite
kWriteDelete
};
protected:
TTimer*TProofPlayer::fDispatchTimerDispatch pending events while processing
Int_tTProofPlayer::fDrawQueriesNumber of Draw queries in the list
TEventIter*TProofPlayer::fEvIter! iterator on events or objects
TVirtualProofPlayer::EExitStatusTProofPlayer::fExitStatusexit status
Long_tTProofPlayer::fFeedbackPeriod! period (ms) for sending intermediate results
TTimer*TProofPlayer::fFeedbackTimer! timer for sending intermediate results
TList*TProofPlayer::fInput-> list with input objects
TList*TQObject::fListOfConnections! list of connections to this object
TList*TQObject::fListOfSignals! list of signals from this object
Int_tTProofPlayer::fMaxDrawQueriesMax number of Draw queries kept
TList*TProofPlayer::fOutputlist with output objects
TQueryResult*TProofPlayer::fPreviousQueryPrevious instance of TQueryResult processed
TProofProgressStatus*TProofPlayer::fProgressStatusthe progress status object;
TQueryResult*TProofPlayer::fQueryInstance of TQueryResult currently processed
TList*TProofPlayer::fQueryResultsList of TQueryResult
TStatus*TProofPlayer::fSelStatus! status of query in progress
TSelector*TProofPlayer::fSelector! the latest selector
TClass*TProofPlayer::fSelectorClass! class of the latest selector
Bool_tTQObject::fSignalsBlocked! flag used for suppression of signals
TTimer*TProofPlayer::fStopTimerTimer associated with a stop request
TMutex*TProofPlayer::fStopTimerMtxTo protect the stop timer
Long64_tTProofPlayer::fTotalEventsnumber of events requested
static Bool_tTQObject::fgAllSignalsBlockedflag used for suppression of all signals
private:
Bool_tfIsClient

Class Charts

Inheritance Inherited Members Includes Libraries
Class Charts

Function documentation

void SetupFeedback()
public: // fix for broken compilers so TCleanup can call StopFeedback()
Bool_t IsClient() const
{ return kFALSE; }
TProofPlayerLocal(Bool_t client = kTRUE)
{ }
virtual ~TProofPlayerLocal()
{ }