/usr/include/root/TVirtualProofPlayer.h is in libroot-proof-dev 5.34.19+dfsg-1.2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 | // @(#)root/proof:$Id$
// Author: Fons Rademakers 15/03/07
/*************************************************************************
* Copyright (C) 1995-2007, Rene Brun and Fons Rademakers. *
* All rights reserved. *
* *
* For the licensing terms see $ROOTSYS/LICENSE. *
* For the list of contributors see $ROOTSYS/README/CREDITS. *
*************************************************************************/
#ifndef ROOT_TVirtualProofPlayer
#define ROOT_TVirtualProofPlayer
//////////////////////////////////////////////////////////////////////////
// //
// TVirtualProofPlayer //
// //
// Abstract interface for the PROOF player. //
// See the concrete implementations under 'proofplayer' for details. //
// //
//////////////////////////////////////////////////////////////////////////
#ifndef ROOT_TObject
#include "TObject.h"
#endif
#ifndef ROOT_TQObject
#include "TQObject.h"
#endif
class TDSet;
class TDSetElement;
class TEventList;
class TQueryResult;
class TDrawFeedback;
class TList;
class TSlave;
class TMessage;
class TProof;
class TSocket;
class TVirtualPacketizer;
class TProofProgressStatus;
class TProofProgressInfo;
class TSelector;
class TVirtualProofPlayer : public TObject, public TQObject {
public:
enum EStatusBits { kIsSubmerger = BIT(16) };
// TDSet status bits
enum EExitStatus { kFinished, kStopped, kAborted };
TVirtualProofPlayer() { ResetBit(TVirtualProofPlayer::kIsSubmerger); }
virtual ~TVirtualProofPlayer() { }
virtual Long64_t Process(TDSet *set,
const char *selector, Option_t *option = "",
Long64_t nentries = -1, Long64_t firstentry = 0) = 0;
virtual Long64_t Process(TDSet *set,
TSelector *selector, Option_t *option = "",
Long64_t nentries = -1, Long64_t firstentry = 0) = 0;
virtual Bool_t JoinProcess(TList *workers) = 0;
virtual Long64_t Finalize(Bool_t force = kFALSE, Bool_t sync = kFALSE) = 0;
virtual Long64_t Finalize(TQueryResult *qr) = 0;
virtual Long64_t DrawSelect(TDSet *set, const char *varexp,
const char *selection, Option_t *option = "",
Long64_t nentries = -1, Long64_t firstentry = 0) = 0;
virtual Int_t GetDrawArgs(const char *var, const char *sel, Option_t *opt,
TString &selector, TString &objname) = 0;
virtual void HandleGetTreeHeader(TMessage *mess) = 0;
virtual void HandleRecvHisto(TMessage *mess) = 0;
virtual void StopProcess(Bool_t abort, Int_t timeout = -1) = 0;
virtual void AddInput(TObject *inp) = 0;
virtual void ClearInput() = 0;
virtual TObject *GetOutput(const char *name) const = 0;
virtual TList *GetOutputList() const = 0;
virtual TList *GetInputList() const = 0;
virtual TList *GetListOfResults() const = 0;
virtual void AddQueryResult(TQueryResult *q) = 0;
virtual TQueryResult *GetCurrentQuery() const = 0;
virtual TQueryResult *GetQueryResult(const char *ref) = 0;
virtual void RemoveQueryResult(const char *ref) = 0;
virtual void SetCurrentQuery(TQueryResult *q) = 0;
virtual void SetMaxDrawQueries(Int_t max) = 0;
virtual void RestorePreviousQuery() =0 ;
virtual Int_t AddOutputObject(TObject *obj) = 0;
virtual void AddOutput(TList *out) = 0; // Incorporate a list
virtual void StoreOutput(TList *out) = 0; // Adopts the list
virtual void StoreFeedback(TObject *slave, TList *out) = 0; // Adopts the list
virtual void Progress(Long64_t total, Long64_t processed) = 0; // *SIGNAL*
virtual void Progress(TSlave *, Long64_t total, Long64_t processed) = 0;
virtual void Progress(Long64_t total, Long64_t processed, Long64_t bytesread,
Float_t initTime, Float_t procTime,
Float_t evtrti, Float_t mbrti) = 0; // *SIGNAL*
virtual void Progress(TSlave *, Long64_t total, Long64_t processed,
Long64_t bytesread, Float_t initTime, Float_t procTime,
Float_t evtrti, Float_t mbrti) = 0; // *SIGNAL*
virtual void Progress(TProofProgressInfo *) = 0; // *SIGNAL*
virtual void Progress(TSlave *, TProofProgressInfo *) = 0; // *SIGNAL*
virtual void Feedback(TList *objs) = 0; // *SIGNAL*
virtual TDrawFeedback *CreateDrawFeedback(TProof *p) = 0;
virtual void SetDrawFeedbackOption(TDrawFeedback *f, Option_t *opt) = 0;
virtual void DeleteDrawFeedback(TDrawFeedback *f) = 0;
virtual TDSetElement *GetNextPacket(TSlave *slave, TMessage *r) = 0;
virtual Int_t ReinitSelector(TQueryResult *qr) = 0;
virtual void UpdateAutoBin(const char *name,
Double_t& xmin, Double_t& xmax,
Double_t& ymin, Double_t& ymax,
Double_t& zmin, Double_t& zmax) = 0;
virtual void MergeOutput() = 0;
virtual Bool_t IsClient() const = 0;
virtual EExitStatus GetExitStatus() const = 0;
virtual void SetExitStatus(EExitStatus) = 0;
virtual Long64_t GetEventsProcessed() const = 0;
virtual void AddEventsProcessed(Long64_t ev) = 0;
virtual TProofProgressStatus* GetProgressStatus() const = 0;
virtual void SetDispatchTimer(Bool_t on = kTRUE) = 0;
virtual void SetStopTimer(Bool_t on = kTRUE,
Bool_t abort = kFALSE, Int_t timeout = 0) = 0;
virtual void SetInitTime() = 0;
virtual Long64_t GetCacheSize() = 0;
virtual Int_t GetLearnEntries() = 0;
virtual void UpdateProgressInfo() = 0;
virtual TVirtualPacketizer *GetPacketizer() const { return 0; }
virtual void SetOutputFilePath(const char *fp) = 0;
virtual Int_t SavePartialResults(Bool_t queryend = kFALSE, Bool_t force = kFALSE) = 0;
static TVirtualProofPlayer *Create(const char *player, TProof *p, TSocket *s = 0);
ClassDef(TVirtualProofPlayer,0) // Abstract PROOF player
};
#endif
|