class TProofPlayerLocal: public TProofPlayer
TProofPlayer This internal class and its subclasses steer the processing in PROOF. Instances of the TProofPlayer class are created on the worker nodes per session and do the processing. Instances of its subclass - TProofPlayerRemote are created per each query on the master(s) and on the client. On the master(s), TProofPlayerRemote coordinate processing, check the dataset, create the packetizer and take care of merging the results of the workers. The instance on the client collects information on the input (dataset and selector), it invokes the Begin() method and finalizes the query by calling Terminate().
Function Members (Methods)
public:
| virtual | ~TProofPlayerLocal() |
| void | TObject::AbstractMethod(const char* method) const |
| virtual void | TProofPlayer::AddEventsProcessed(Long64_t ev) |
| virtual void | TProofPlayer::AddInput(TObject* inp) |
| virtual void | TProofPlayer::AddOutput(TList* out) |
| virtual Int_t | TProofPlayer::AddOutputObject(TObject* obj) |
| virtual void | TProofPlayer::AddQueryResult(TQueryResult* q) |
| virtual void | TObject::AppendPad(Option_t* option = "") |
| static Bool_t | TQObject::AreAllSignalsBlocked() |
| Bool_t | TQObject::AreSignalsBlocked() const |
| static Bool_t | TQObject::BlockAllSignals(Bool_t b) |
| Bool_t | TQObject::BlockSignals(Bool_t b) |
| virtual void | TObject::Browse(TBrowser* b) |
| virtual void | TQObject::ChangedBy(const char* method)SIGNAL |
| static TClass* | Class() |
| virtual const char* | TObject::ClassName() const |
| virtual void | TObject::Clear(Option_t* = "") |
| virtual void | TProofPlayer::ClearInput() |
| virtual TObject* | TObject::Clone(const char* newname = "") const |
| void | TQObject::CollectClassSignalLists(TList& list, TClass* cls) |
| virtual Int_t | TObject::Compare(const TObject* obj) const |
| Bool_t | TQObject::Connect(const char* signal, const char* receiver_class, void* receiver, const char* slot) |
| static Bool_t | TQObject::Connect(TQObject* sender, const char* signal, const char* receiver_class, void* receiver, const char* slot) |
| static Bool_t | TQObject::Connect(const char* sender_class, const char* signal, const char* receiver_class, void* receiver, const char* slot) |
| virtual void | TQObject::Connected(const char*) |
| virtual void | TObject::Copy(TObject& object) const |
| static TVirtualProofPlayer* | TVirtualProofPlayer::Create(const char* player, TProof* p, TSocket* s = 0) |
| virtual TDrawFeedback* | TProofPlayer::CreateDrawFeedback(TProof* p) |
| virtual void | TObject::Delete(Option_t* option = "")MENU |
| virtual void | TProofPlayer::DeleteDrawFeedback(TDrawFeedback* f) |
| virtual void | TQObject::Destroyed()SIGNAL |
| Bool_t | TQObject::Disconnect(const char* signal = 0, void* receiver = 0, const char* slot = 0) |
| static Bool_t | TQObject::Disconnect(TQObject* sender, const char* signal = 0, void* receiver = 0, const char* slot = 0) |
| static Bool_t | TQObject::Disconnect(const char* class_name, const char* signal, void* receiver = 0, const char* slot = 0) |
| virtual void | TQObject::Disconnected(const char*) |
| virtual Int_t | TObject::DistancetoPrimitive(Int_t px, Int_t py) |
| virtual void | TObject::Draw(Option_t* option = "") |
| virtual void | TObject::DrawClass() constMENU |
| virtual TObject* | TObject::DrawClone(Option_t* option = "") constMENU |
| virtual Long64_t | TProofPlayer::DrawSelect(TDSet* set, const char* varexp, const char* selection, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0) |
| virtual void | TObject::Dump() constMENU |
| void | TQObject::Emit(const char* signal) |
| void | TQObject::Emit(const char* signal, Long_t* paramArr) |
| void | TQObject::Emit(const char* signal, const char* params) |
| void | TQObject::Emit(const char* signal, Double_t param) |
| void | TQObject::Emit(const char* signal, Long_t param) |
| void | TQObject::Emit(const char* signal, Long64_t param) |
| void | TQObject::Emit(const char* signal, Bool_t param) |
| void | TQObject::Emit(const char* signal, Char_t param) |
| void | TQObject::Emit(const char* signal, UChar_t param) |
| void | TQObject::Emit(const char* signal, Short_t param) |
| void | TQObject::Emit(const char* signal, UShort_t param) |
| void | TQObject::Emit(const char* signal, Int_t param) |
| void | TQObject::Emit(const char* signal, UInt_t param) |
| void | TQObject::Emit(const char* signal, ULong_t param) |
| void | TQObject::Emit(const char* signal, ULong64_t param) |
| void | TQObject::Emit(const char* signal, Float_t param) |
| void | TQObject::EmitVA(const char* signal, Int_t nargs, va_list va) |
| void | TQObject::EmitVA<>(const char* signal_name, Int_t) |
| virtual void | TObject::Error(const char* method, const char* msgfmt) const |
| virtual void | TObject::Execute(const char* method, const char* params, Int_t* error = 0) |
| virtual void | TObject::Execute(TMethod* method, TObjArray* params, Int_t* error = 0) |
| virtual void | TObject::ExecuteEvent(Int_t event, Int_t px, Int_t py) |
| virtual void | TObject::Fatal(const char* method, const char* msgfmt) const |
| virtual void | TProofPlayer::Feedback(TList* objs)SIGNAL |
| void | TProofPlayer::FeedBackCanvas(const char* name, Bool_t create) |
| virtual Long64_t | TProofPlayer::Finalize(TQueryResult* qr) |
| virtual Long64_t | TProofPlayer::Finalize(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 Long64_t | TProofPlayer::GetCacheSize() |
| virtual TQueryResult* | TProofPlayer::GetCurrentQuery() const |
| virtual Int_t | TProofPlayer::GetDrawArgs(const char* var, const char* sel, Option_t* opt, TString& selector, TString& objname) |
| virtual Option_t* | TObject::GetDrawOption() const |
| static Long_t | TObject::GetDtorOnly() |
| virtual Long64_t | TProofPlayer::GetEventsProcessed() const |
| virtual TVirtualProofPlayer::EExitStatus | TProofPlayer::GetExitStatus() const |
| virtual const char* | TObject::GetIconName() const |
| virtual TList* | TProofPlayer::GetInputList() const |
| virtual Int_t | TProofPlayer::GetLearnEntries() |
| TList* | TQObject::GetListOfClassSignals() const |
| TList* | TQObject::GetListOfConnections() const |
| virtual TList* | TProofPlayer::GetListOfResults() const |
| TList* | TQObject::GetListOfSignals() const |
| virtual const char* | TObject::GetName() const |
| virtual TDSetElement* | TProofPlayer::GetNextPacket(TSlave* slave, TMessage* r) |
| virtual char* | TObject::GetObjectInfo(Int_t px, Int_t py) const |
| static Bool_t | TObject::GetObjectStat() |
| virtual Option_t* | TObject::GetOption() const |
| virtual TObject* | TProofPlayer::GetOutput(const char* name) const |
| virtual TList* | TProofPlayer::GetOutputList() const |
| virtual TVirtualPacketizer* | TProofPlayer::GetPacketizer() const |
| virtual TProofProgressStatus* | TProofPlayer::GetProgressStatus() const |
| virtual TQueryResult* | TProofPlayer::GetQueryResult(const char* ref) |
| virtual const char* | TObject::GetTitle() const |
| virtual UInt_t | TObject::GetUniqueID() const |
| virtual void | TProofPlayer::HandleGetTreeHeader(TMessage* mess) |
| virtual void | TProofPlayer::HandleRecvHisto(TMessage* mess) |
| virtual Bool_t | TObject::HandleTimer(TTimer* timer) |
| virtual Bool_t | TQObject::HasConnection(const char* signal_name) const |
| virtual ULong_t | TObject::Hash() const |
| virtual void | TQObject::HighPriority(const char* signal_name, const char* slot_name = 0) |
| virtual void | TObject::Info(const char* method, const char* msgfmt) const |
| virtual Bool_t | TObject::InheritsFrom(const char* classname) const |
| virtual Bool_t | TObject::InheritsFrom(const TClass* cl) const |
| virtual void | TObject::Inspect() constMENU |
| void | TObject::InvertBit(UInt_t f) |
| virtual TClass* | IsA() const |
| virtual Bool_t | IsClient() const |
| virtual Bool_t | TObject::IsEqual(const TObject* obj) const |
| virtual Bool_t | TObject::IsFolder() const |
| Bool_t | TObject::IsOnHeap() const |
| virtual Bool_t | TObject::IsSortable() const |
| Bool_t | TObject::IsZombie() const |
| virtual Bool_t | TProofPlayer::JoinProcess(TList* workers) |
| virtual void | TQObject::LowPriority(const char* signal_name, const char* slot_name = 0) |
| virtual void | TObject::ls(Option_t* option = "") const |
| void | TObject::MayNotUse(const char* method) const |
| virtual void | TQObject::Message(const char* msg)SIGNAL |
| virtual Bool_t | TObject::Notify() |
| virtual Int_t | TQObject::NumberOfConnections() const |
| virtual Int_t | TQObject::NumberOfSignals() const |
| void | TObject::Obsolete(const char* method, const char* asOfVers, const char* removedFromVers) const |
| void | TObject::operator delete(void* ptr) |
| void | TObject::operator delete(void* ptr, void* vp) |
| void | TObject::operator delete[](void* ptr) |
| void | TObject::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) |
| TProofPlayerLocal& | operator=(const TProofPlayerLocal&) |
| virtual void | TObject::Paint(Option_t* option = "") |
| virtual void | TObject::Pop() |
| virtual void | TObject::Print(Option_t* option = "") const |
| Long64_t | Process(const char* selector, Long64_t nentries = -1, Option_t* option = "") |
| Long64_t | Process(TSelector* selector, Long64_t nentries = -1, Option_t* option = "") |
| virtual Long64_t | Process(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0) |
| virtual Long64_t | Process(TDSet* set, TSelector* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0) |
| virtual void | TProofPlayer::Progress(TProofProgressInfo* pi)SIGNAL |
| virtual void | TProofPlayer::Progress(Long64_t total, Long64_t processed)SIGNAL |
| virtual void | TProofPlayer::Progress(TSlave*, TProofProgressInfo* pi)SIGNAL |
| virtual void | TProofPlayer::Progress(TSlave*, Long64_t total, Long64_t processed) |
| virtual void | TProofPlayer::Progress(Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)SIGNAL |
| virtual void | TProofPlayer::Progress(TSlave*, Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)SIGNAL |
| virtual Int_t | TObject::Read(const char* name) |
| virtual void | TObject::RecursiveRemove(TObject* obj) |
| virtual Int_t | TProofPlayer::ReinitSelector(TQueryResult* qr) |
| virtual void | TProofPlayer::RemoveQueryResult(const char* ref) |
| void | TObject::ResetBit(UInt_t f) |
| virtual void | TProofPlayer::RestorePreviousQuery() |
| virtual void | TObject::SaveAs(const char* filename = "", Option_t* option = "") constMENU |
| virtual Int_t | TProofPlayer::SavePartialResults(Bool_t queryend = kFALSE, Bool_t force = kFALSE) |
| virtual void | TObject::SavePrimitive(ostream& out, Option_t* option = "") |
| void | TObject::SetBit(UInt_t f) |
| void | TObject::SetBit(UInt_t f, Bool_t set) |
| virtual void | TProofPlayer::SetCurrentQuery(TQueryResult* q) |
| virtual void | TProofPlayer::SetDispatchTimer(Bool_t on = kTRUE) |
| virtual void | TProofPlayer::SetDrawFeedbackOption(TDrawFeedback* f, Option_t* opt) |
| virtual void | TObject::SetDrawOption(Option_t* option = "")MENU |
| static void | TObject::SetDtorOnly(void* obj) |
| virtual void | TProofPlayer::SetExitStatus(TVirtualProofPlayer::EExitStatus st) |
| virtual void | TProofPlayer::SetInitTime() |
| virtual void | TProofPlayer::SetMaxDrawQueries(Int_t max) |
| static void | TObject::SetObjectStat(Bool_t stat) |
| virtual void | TProofPlayer::SetOutputFilePath(const char* fp) |
| void | TProofPlayer::SetProcessing(Bool_t on = kTRUE) |
| virtual void | TProofPlayer::SetStopTimer(Bool_t on = kTRUE, Bool_t abort = kFALSE, Int_t timeout = 0) |
| virtual void | TObject::SetUniqueID(UInt_t uid) |
| virtual void | ShowMembers(TMemberInspector& insp) const |
| virtual void | TProofPlayer::StopProcess(Bool_t abort, Int_t timeout = -1) |
| virtual void | TProofPlayer::StoreFeedback(TObject* slave, TList* out) |
| virtual void | TProofPlayer::StoreOutput(TList* out) |
| virtual void | Streamer(TBuffer&) |
| void | StreamerNVirtual(TBuffer& ClassDef_StreamerNVirtual_b) |
| virtual void | TObject::SysError(const char* method, const char* msgfmt) const |
| Bool_t | TObject::TestBit(UInt_t f) const |
| Int_t | TObject::TestBits(UInt_t f) const |
| TProofPlayerLocal(Bool_t client = kTRUE) | |
| TProofPlayerLocal(const TProofPlayerLocal&) | |
| virtual void | TProofPlayer::UpdateAutoBin(const char* name, Double_t& xmin, Double_t& xmax, Double_t& ymin, Double_t& ymax, Double_t& zmin, Double_t& zmax) |
| virtual void | TProofPlayer::UpdateProgressInfo() |
| virtual void | TObject::UseCurrentStyle() |
| virtual void | TObject::Warning(const char* method, const char* msgfmt) const |
| virtual Int_t | TObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0) |
| virtual Int_t | TObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0) const |
protected:
| Int_t | TProofPlayer::AssertSelector(const char* selector_file) |
| static Int_t | TQObject::CheckConnectArgs(TQObject* sender, TClass* sender_class, const char* signal, TClass* receiver_class, const char* slot) |
| Bool_t | TProofPlayer::CheckMemUsage(Long64_t& mfreq, Bool_t& w80r, Bool_t& w80v, TString& wmsg) |
| static TString | TQObject::CompressName(const char* method_name) |
| static Bool_t | TQObject::ConnectToClass(TQObject* sender, const char* signal, TClass* receiver_class, void* receiver, const char* slot) |
| static Bool_t | TQObject::ConnectToClass(const char* sender_class, const char* signal, TClass* receiver_class, void* receiver, const char* slot) |
| virtual void | TObject::DoError(int level, const char* location, const char* fmt, va_list va) const |
| virtual Int_t | TProofPlayer::DrawCanvas(TObject* obj) |
| virtual void* | TProofPlayer::GetSender() |
| virtual const char* | TQObject::GetSenderClassName() const |
| void | TObject::MakeZombie() |
| void | TProofPlayer::MapOutputListToDataMembers() const |
| virtual void | TProofPlayer::MergeOutput() |
| virtual void | SetupFeedback() |
| virtual void | StopFeedback() |
Data Members
public:
protected:
| Bool_t | TProofPlayer::fCreateSelObj | ! kTRUE when fSelector has been created locally |
| TTimer* | TProofPlayer::fDispatchTimer | Dispatch pending events while processing |
| Int_t | TProofPlayer::fDrawQueries | Number of Draw queries in the list |
| TEventIter* | TProofPlayer::fEvIter | ! iterator on events or objects |
| TVirtualProofPlayer::EExitStatus | TProofPlayer::fExitStatus | exit status |
| Long_t | TProofPlayer::fFeedbackPeriod | ! period (ms) for sending intermediate results |
| TTimer* | TProofPlayer::fFeedbackTimer | ! timer for sending intermediate results |
| TList* | TProofPlayer::fInput | -> list with input objects |
| TList* | TQObject::fListOfConnections | ! list of connections to this object |
| TList* | TQObject::fListOfSignals | ! list of signals from this object |
| Int_t | TProofPlayer::fMaxDrawQueries | Max number of Draw queries kept |
| THashList* | TProofPlayer::fOutput | list with output objects |
| TFile* | TProofPlayer::fOutputFile | TFile object attached to fOutputFilePath |
| TString | TProofPlayer::fOutputFilePath | Path to file with (partial) results of the query |
| TQueryResult* | TProofPlayer::fPreviousQuery | Previous instance of TQueryResult processed |
| TStopwatch* | TProofPlayer::fProcTime | Packet proc time |
| TTimer* | TProofPlayer::fProcTimeTimer | Notifies reaching of allowed max proc time |
| Long64_t | TProofPlayer::fProcessedRun | ! Events processed in this run |
| TProofProgressStatus* | TProofPlayer::fProgressStatus | the progress status object; |
| TQueryResult* | TProofPlayer::fQuery | Instance of TQueryResult currently processed |
| TList* | TProofPlayer::fQueryResults | List of TQueryResult |
| Long64_t | TProofPlayer::fReadBytesRun | ! Bytes read in this run |
| Long64_t | TProofPlayer::fReadCallsRun | ! Read calls in this run |
| Long_t | TProofPlayer::fSaveMemThreshold | Threshold for saving output to file |
| Bool_t | TProofPlayer::fSavePartialResults | Whether to save the partial results |
| Bool_t | TProofPlayer::fSaveResultsPerPacket | Whether to save partial results after each packet |
| TStatus* | TProofPlayer::fSelStatus | ! status of query in progress |
| TSelector* | TProofPlayer::fSelector | ! the latest selector |
| TClass* | TProofPlayer::fSelectorClass | ! class of the latest selector |
| Bool_t | TQObject::fSignalsBlocked | ! flag used for suppression of signals |
| TTimer* | TProofPlayer::fStopTimer | Timer associated with a stop request |
| TMutex* | TProofPlayer::fStopTimerMtx | To protect the stop timer |
| Long64_t | TProofPlayer::fTotalEvents | number of events requested |
| static Bool_t | TQObject::fgAllSignalsBlocked | flag used for suppression of all signals |
| static THashList* | TProofPlayer::fgDrawInputPars | List of input parameters to be kept on drawing actions |
private:
| Bool_t | fIsClient |
Class Charts
Function documentation
void SetupFeedback()
public: // fix for broken compilers so TCleanup can call StopFeedback()
Long64_t Process(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)