library: libProof #include "TProofPlayer.h" |
TProofPlayerRemote
class description - source file - inheritance tree (.pdf)
private:
TList* MergeFeedback()
protected:
TProof* GetProof() const
virtual Bool_t HandleTimer(TTimer* timer)
virtual Bool_t SendSelector(const char* selector_file)
virtual void SetupFeedback()
virtual void StopFeedback()
public:
TProofPlayerRemote(TProof* proof = 0)
TProofPlayerRemote(const TProofPlayerRemote&)
virtual ~TProofPlayerRemote()
static TClass* Class()
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 TDSetElement* GetNextPacket(TSlave* slave, TMessage* r)
virtual TClass* IsA() const
virtual Bool_t IsClient() const
void MergeOutput()
TProofPlayerRemote& operator=(const TProofPlayerRemote&)
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 void ShowMembers(TMemberInspector& insp, char* parent)
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)
private:
TProof* fProof link to associated PROOF session
TList* fOutputLists results returned by slaves
TList* fFeedback reference for use on master
TList* fFeedbackLists intermediate results
TVirtualPacketizer* fPacketizer transform TDSet into packets for slaves
TDSet* fDSet !tdset for current processing
TProofPlayer
~TProofPlayerRemote()
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.
Returns -1 in case error, 0 otherwise.
Long64_t Finalize(Bool_t force, Bool_t sync)
Finalize a query.
Returns -1 in case error, 0 otherwise.
Long64_t Finalize(TQueryResult *qr)
Finalize the results of a query already processed
Bool_t SendSelector(const char* selector_file)
Send the selector file to the slave nodes
void MergeOutput()
Merge objects in output the lists.
void Progress(Long64_t total, Long64_t processed)
void Feedback(TList *objs)
void StopProcess(Bool_t abort)
void StoreOutput(TList *out)
TList* MergeFeedback()
Merge feedback lists.
void StoreFeedback(TObject *slave, TList *out)
Store feedback results from the specified slave.
void SetupFeedback()
Setup reporting of feedback objects.
void StopFeedback()
Stop reporting of feedback objects.
Bool_t HandleTimer(TTimer *)
Send feedback objects to client.
TDSetElement* GetNextPacket(TSlave *slave, TMessage *r)
Get next packet for specified slave.
Bool_t IsClient() const
Is the player running on the client?
Long64_t DrawSelect(TDSet *set, const char *varexp,
const char *selection, Option_t *option,
Long64_t nentries, Long64_t firstentry)
Inline Functions
TProof* GetProof() const
TProofPlayerRemote TProofPlayerRemote(TProof* proof = 0)
void Progress(TSlave*, Long64_t total, Long64_t processed)
TClass* Class()
TClass* IsA() const
void ShowMembers(TMemberInspector& insp, char* parent)
void Streamer(TBuffer& b)
void StreamerNVirtual(TBuffer& b)
TProofPlayerRemote TProofPlayerRemote(const TProofPlayerRemote&)
TProofPlayerRemote& operator=(const TProofPlayerRemote&)
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.