library: libProof
#include "TProofPlayer.h" |
TProofPlayer
class description - source file - inheritance tree (.pdf)
protected:
virtual void* GetSender()
virtual void SetupFeedback()
public:
TProofPlayer()
TProofPlayer(const TProofPlayer&)
virtual ~TProofPlayer()
virtual void AddEventsProcessed(Long64_t ev)
virtual void AddInput(TObject* inp)
virtual void AddQueryResult(TQueryResult* q)
static TClass* Class()
virtual void ClearInput()
virtual Long64_t DrawSelect(TDSet* set, const char* varexp, const char* selection, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
virtual void Feedback(TList* objs)
virtual Long64_t Finalize(Bool_t force = kFALSE, Bool_t sync = kFALSE)
virtual Long64_t Finalize(TQueryResult* qr)
virtual Long64_t GetEventsProcessed() const
virtual TProofPlayer::EExitStatus GetExitStatus() const
virtual TList* GetInputList() const
virtual TList* GetListOfResults() const
virtual TDSetElement* GetNextPacket(TSlave* slave, TMessage* r)
virtual TObject* GetOutput(const char* name) const
virtual TList* GetOutputList() const
virtual TQueryResult* GetQueryResult(const char* ref)
virtual TClass* IsA() const
virtual Bool_t IsClient() const
TProofPlayer& operator=(const TProofPlayer&)
virtual Long64_t Process(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0, TEventList* evl = 0)
virtual void Progress(Long64_t total, Long64_t processed)
virtual void Progress(TSlave*, Long64_t total, Long64_t processed)
virtual Int_t ReinitSelector(TQueryResult* qr)
virtual void RemoveQueryResult(const char* ref)
virtual void RestorePreviousQuery()
virtual void SetCurrentQuery(TQueryResult* q)
virtual void SetMaxDrawQueries(Int_t max)
virtual void ShowMembers(TMemberInspector& insp, char* parent)
virtual void StopFeedback()
virtual void StopProcess(Bool_t abort)
virtual void StoreFeedback(TObject* slave, TList* out)
virtual void StoreOutput(TList* out)
virtual void Streamer(TBuffer& b)
void StreamerNVirtual(TBuffer& b)
void UpdateAutoBin(const char* name, Double_t& xmin, Double_t& xmax, Double_t& ymin, Double_t& ymax, Double_t& zmin, Double_t& zmax)
private:
TList* fAutoBins Map of min/max values by name for slaves
protected:
TList* fInput -> list with input objects
TList* fOutput list 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::EExitStatus fExitStatus exit status
Long64_t fEventsProcessed number of events processed
Long64_t fTotalEvents number of events requested
TList* fQueryResults List of TQueryResult
TQueryResult* fQuery Instance of TQueryResult currently processed
TQueryResult* fPreviousQuery Previous instance of TQueryResult processed
Int_t fDrawQueries Number of Draw queries in the list
Int_t fMaxDrawQueries Max number of Draw queries kept
public:
static const TProofPlayer::EExitStatus kFinished
static const TProofPlayer::EExitStatus kStopped
static const TProofPlayer::EExitStatus kAborted
TProofPlayer
TProofPlayer()
: fAutoBins(0), fOutput(0), fSelector(0), fSelectorClass(0),
fFeedbackTimer(0), fEvIter(0), fSelStatus(0), fEventsProcessed(0),
fTotalEvents(0), fQueryResults(0), fQuery(0), fDrawQueries(0),
fMaxDrawQueries(1)
Default ctor.
~TProofPlayer()
void StopProcess(Bool_t abort)
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)
void ClearInput()
TObject* GetOutput(const char *name) const
TList* GetOutputList() const
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
void StoreOutput(TList *)
void StoreFeedback(TObject *, TList *)
void Progress(Long64_t /*total*/, Long64_t /*processed*/)
void Feedback(TList *)
Long64_t Process(TDSet *dset, const char *selector_file,
Option_t *option, Long64_t nentries,
Long64_t first, TEventList * /*evl*/)
Long64_t Finalize(Bool_t, Bool_t)
Long64_t Finalize(TQueryResult *)
void UpdateAutoBin(const char *name,
Double_t& xmin, Double_t& xmax,
Double_t& ymin, Double_t& ymax,
Double_t& zmin, Double_t& zmax)
TDSetElement* GetNextPacket(TSlave *, TMessage *)
void SetupFeedback()
void StopFeedback()
Long64_t DrawSelect(TDSet * /*set*/, const char * /*varexp*/,
const char * /*selection*/, Option_t * /*option*/,
Long64_t /*nentries*/, Long64_t /*firstentry*/)
Inline Functions
void* GetSender()
TList* GetInputList() const
TList* GetListOfResults() const
void SetMaxDrawQueries(Int_t max)
void RestorePreviousQuery()
void Progress(TSlave*, Long64_t total, Long64_t processed)
Bool_t IsClient() const
TProofPlayer::EExitStatus GetExitStatus() const
Long64_t GetEventsProcessed() const
void AddEventsProcessed(Long64_t ev)
TClass* Class()
TClass* IsA() const
void ShowMembers(TMemberInspector& insp, char* parent)
void Streamer(TBuffer& b)
void StreamerNVirtual(TBuffer& b)
TProofPlayer TProofPlayer(const TProofPlayer&)
TProofPlayer& operator=(const TProofPlayer&)
Author: Maarten Ballintijn 07/01/02
Last update: root/proof:$Name: $:$Id: TProofPlayer.cxx,v 1.72 2005/11/11 13:54:20 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.