library: libProof
#include "TProofPlayer.h"

TProofPlayer

class description - header file - source file
viewCVS header - viewCVS source

class TProofPlayer: public TObject, public TQObject

Inheritance Inherited Members Includes Libraries
Class Charts

Function Members (Methods)

Display options:
Show inherited
Show non-public
public:
TProofPlayer()
virtual~TProofPlayer()
voidTObject::AbstractMethod(const char* method) const
virtual voidAddEventsProcessed(Long64_t ev)
virtual voidAddInput(TObject* inp)
virtual voidAddOutput(TList* out)
virtual Int_tAddOutputObject(TObject* obj)
virtual voidAddQueryResult(TQueryResult* q)
virtual voidTObject::AppendPad(Option_t* option = "")
virtual voidTObject::Browse(TBrowser* b)
virtual voidTQObject::ChangedBy(const char* method)
static TClass*Class()
virtual const char*TObject::ClassName() const
virtual voidTObject::Clear(Option_t* = "")
virtual voidClearInput()
virtual TObject*TObject::Clone(const char* newname = "") const
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
virtual voidTObject::Delete(Option_t* option = "")
virtual voidTQObject::Destroyed()
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() const
virtual TObject*TObject::DrawClone(Option_t* option = "") const
virtual Long64_tDrawSelect(TDSet* set, const char* varexp, const char* selection, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
virtual voidTObject::Dump() const
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 voidFeedback(TList* objs)
virtual Long64_tFinalize(TQueryResult* qr)
virtual Long64_tFinalize(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*GetCurrentQuery() const
virtual Option_t*TObject::GetDrawOption() const
static Long_tTObject::GetDtorOnly()
virtual Long64_tGetEventsProcessed() const
virtual TProofPlayer::EExitStatusGetExitStatus() const
virtual const char*TObject::GetIconName() const
virtual TList*GetInputList() const
TList*TQObject::GetListOfClassSignals() const
TList*TQObject::GetListOfConnections() const
virtual TList*GetListOfResults() const
TList*TQObject::GetListOfSignals() const
virtual const char*TObject::GetName() const
virtual TDSetElement*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*GetOutput(const char* name) const
virtual TList*GetOutputList() const
virtual TQueryResult*GetQueryResult(const char* ref)
virtual const char*TObject::GetTitle() const
virtual UInt_tTObject::GetUniqueID() const
virtual voidHandleAbortTimer()
virtual voidHandleStopTimer()
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() const
voidTObject::InvertBit(UInt_t f)
virtual TClass*IsA() const
virtual Bool_tIsClient() 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)
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_tProcess(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0, TEventList* evl = 0)
virtual voidProgress(Long64_t total, Long64_t processed)
virtual voidProgress(TSlave*, Long64_t total, Long64_t processed)
virtual voidProgress(Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)
virtual Int_tTObject::Read(const char* name)
virtual voidTObject::RecursiveRemove(TObject* obj)
virtual Int_tReinitSelector(TQueryResult* qr)
virtual voidRemoveQueryResult(const char* ref)
voidTObject::ResetBit(UInt_t f)
virtual voidRestorePreviousQuery()
virtual voidTObject::SaveAs(const char* filename = "", Option_t* option = "") const
virtual voidTObject::SavePrimitive(ostream& out, Option_t* option = "")
voidTObject::SetBit(UInt_t f)
voidTObject::SetBit(UInt_t f, Bool_t set)
virtual voidSetCurrentQuery(TQueryResult* q)
virtual voidTObject::SetDrawOption(Option_t* option = "")
static voidTObject::SetDtorOnly(void* obj)
virtual voidSetMaxDrawQueries(Int_t max)
static voidTObject::SetObjectStat(Bool_t stat)
virtual voidSetStopTimer(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 voidStopFeedback()
virtual voidStopProcess(Bool_t abort, Int_t timeout = -1)
virtual voidStoreFeedback(TObject* slave, TList* out)
virtual voidStoreOutput(TList* out)
virtual voidStreamer(TBuffer& b)
voidStreamerNVirtual(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
voidUpdateAutoBin(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 void*GetSender()
virtual const char*TQObject::GetSenderClassName() const
voidTObject::MakeZombie()
virtual voidSetupFeedback()

Data Members

public:
enum 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:
TList*fInput-> list with input objects
TList*fOutputlist with output objects
TSelector*fSelector! the latest selector
TClass*fSelectorClass! class of the latest selector
TTimer*fFeedbackTimer! timer for sending intermediate results
TEventIter*fEvIter! iterator on events or objects
TStatus*fSelStatus! status of query in progress
TProofPlayer::EExitStatusfExitStatusexit status
Long64_tfEventsProcessednumber of events processed
Long64_tfTotalEventsnumber of events requested
TList*fQueryResultsList of TQueryResult
TQueryResult*fQueryInstance of TQueryResult currently processed
TQueryResult*fPreviousQueryPrevious instance of TQueryResult processed
Int_tfDrawQueriesNumber of Draw queries in the list
Int_tfMaxDrawQueriesMax number of Draw queries kept
TTimer*fStopTimerTimer associated with a stop request
TMutex*fStopTimerMtxTo protect the stop timer
TList*TQObject::fListOfSignals! list of signals from this object
TList*TQObject::fListOfConnections! list of connections to this object
private:
TList*fAutoBinsMap of min/max values by name for slaves

Class Description

                                                                      
 TProofPlayer
TProofPlayer()
 Default ctor.
~TProofPlayer()
 Destructor.
void StopProcess(Bool_t abort, Int_t timeout)
 Stop the process after this event. If timeout is positive, start
 a timer firing after timeout seconds to hard-stop time-expensive
 events.
void SetStopTimer(Bool_t on, Bool_t abort, Int_t timeout)
 Enable/disable the timer to stop/abort processing.
 The 'timeout' is in seconds.
void HandleStopTimer()
 Handle the signal coming from the expiration of the timer
 associated with a stop request; this is set when receiving a STOP
 process request to hard stop long time-expensive events.
 We raise an exception which will be processed in the
 event loop.
void HandleAbortTimer()
 Handle the signal coming from the expiration of the timer
 associated with an abort request.
 We raise an exception which will be processed in the
 event loop.
void AddQueryResult(TQueryResult *q)
 Add query result to the list, making sure that there are no
 duplicates.
void RemoveQueryResult(const char *ref)
 Remove all query result instances referenced 'ref' from
 the list of results.
TQueryResult * GetQueryResult(const char *ref)
 Get query result instances referenced 'ref' from
 the list of results.
void SetCurrentQuery(TQueryResult *q)
 Set current query and save previous value.
void AddInput(TObject *inp)
 Add object to input list.
void ClearInput()
 Clear input list.
TObject * GetOutput(const char *name)
 Get output object by name.
TList * GetOutputList()
 Get output list.
Int_t ReinitSelector(TQueryResult *qr)
 Reinitialize fSelector using the selector files in the query result.
 Needed when Finalize is called after a Process execution for the same
 selector name.
Int_t AddOutputObject(TObject *)
 Incorporate output object (may not be used in this class).
void AddOutput(TList *)
 Incorporate output list (may not be used in this class).
void StoreOutput(TList *)
 Store output list (may not be used in this class).
void StoreFeedback(TObject *, TList *)
 Store feedback list (may not be used in this class).
void Progress(Long64_t /*total*/, Long64_t /*processed*/)
 Report progress (may not be used in this class).
void Progress(Long64_t /*total*/, Long64_t /*processed*/, Long64_t /*bytesread*/, Float_t /*evtRate*/, Float_t /*mbRate*/, Float_t /*evtrti*/, Float_t /*mbrti*/)
 Report progress (may not be used in this class).
void Feedback(TList *)
 Set feedback list (may not be used in this class).
Long64_t Process(TDSet *dset, const char *selector_file, Option_t *option, Long64_t nentries, Long64_t first, TEventList * /*evl*/)
 Process specified TDSet on PROOF worker.
 The return value is -1 in case of error and TSelector::GetStatus() in
 in case of success.
Long64_t Finalize(Bool_t, Bool_t)
 Finalize query (may not be used in this class).
Long64_t Finalize(TQueryResult *)
 Finalize query (may not be used in this class).
void UpdateAutoBin(const char *name, Double_t& xmin, Double_t& xmax, Double_t& ymin, Double_t& ymax, Double_t& zmin, Double_t& zmax)
 Update automatic binning parameters for given object "name".
TDSetElement * GetNextPacket(TSlave *, TMessage *)
 Get next packet (may not be used in this class).
void SetupFeedback()
 Set up feedback (may not be used in this class).
void StopFeedback()
 Stop feedback (may not be used in this class).
Long64_t DrawSelect(TDSet * /*set*/, const char * /*varexp*/, const char * /*selection*/, Option_t * /*option*/, Long64_t /*nentries*/, Long64_t /*firstentry*/)
 Draw (may not be used in this class).
void * GetSender()
{ return this; }
TList * GetInputList()
{ return fInput; }
TList * GetListOfResults()
{ return fQueryResults; }
TQueryResult * GetCurrentQuery()
{ return fQuery; }
void SetMaxDrawQueries(Int_t max)
{ fMaxDrawQueries = max; }
void RestorePreviousQuery()
{ fQuery = fPreviousQuery; }
void Progress(Long64_t total, Long64_t processed)
Bool_t IsClient()
{ return kFALSE; }
EExitStatus GetExitStatus()
{ return fExitStatus; }
Long64_t GetEventsProcessed()
{ return fEventsProcessed; }
void AddEventsProcessed(Long64_t ev)
{ fEventsProcessed += ev; }

Author: Maarten Ballintijn 07/01/02
Last update: root/proof:$Name: $:$Id: TProofPlayer.cxx,v 1.98 2006/12/12 11:20:49 rdm Exp $
Copyright (C) 1995-2001, Rene Brun and Fons Rademakers. *

ROOT page - Class index - Class Hierarchy - Top of the page
This page has been automatically generated. If you have any comments or suggestions about the page layout send a mail to ROOT support, or contact the developers with any questions or problems regarding ROOT.