TProofPlayer

class TProofPlayer : public TObject, public TQObject

    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 void HandleAbortTimer()
                           virtual void HandleStopTimer()
                        virtual TClass* IsA() const
                         virtual Bool_t IsClient() const
                       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 SetStopTimer(Bool_t on = kTRUE, Bool_t abort = kFALSE, Int_t timeout = 0)
                           virtual void ShowMembers(TMemberInspector& insp, char* parent)
                           virtual void StopFeedback()
                           virtual void StopProcess(Bool_t abort, Int_t timeout = -1)
                           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)

Data Members

    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
                        TTimer* fStopTimer        Timer associated with a stop request
                        TMutex* fStopTimerMtx     To protect the stop timer

    public:

      static const TProofPlayer::EExitStatus kFinished  
      static const TProofPlayer::EExitStatus kStopped   
      static const TProofPlayer::EExitStatus kAborted   

                                                                      
 TProofPlayer                                                         
                                                                      

 Default ctor.

 Destructor.

 Stop the process after this event. If timeout is positive, start
 a timer firing after timeout seconds to hard-stop time-expensive
 events.

 Enable/disable the timer to stop/abort processing.
 The 'timeout' is in seconds.

 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.

 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.

 Add query result to the list, making sure that there are no
 duplicates.

 Remove all query result instances referenced 'ref' from
 the list of results.

 Get query result instances referenced 'ref' from
 the list of results.

 Set current query and save previous value.

 Add object to input list.

 Clear input list.

 Get output object by name.

 Get output list.

 Reinitialize fSelector using the selector files in the query result.
 Needed when Finalize is called after a Process execution for the same
 selector name.

 Store output list (may not be used in this class).

 Store feedback list (may not be used in this class).

 Set feedback list (may not be used in this class).

{
 Process specified TDSet on PROOF worker. Returns -1 in case of error and
 0 in case of success.

 Finalize query (may not be used in this class).

 Finalize query (may not be used in this class).

 Update automatic binning parameters for given object "name".

 Get next packet (may not be used in this class).

 Set up feedback (may not be used in this class).

 Stop feedback (may not be used in this class).