class TProofPlayerSuperMaster: public TProofPlayerRemote


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:

	TProofPlayerSuperMaster(TProof* proof = 0)
virtual	~TProofPlayerSuperMaster()
void	TObject::AbstractMethod(const char* method) const
virtual void	TProofPlayer::AddEventsProcessed(Long64_t ev)
virtual void	TVirtualProofPlayer::AddEventsProcessed(Long64_t ev)
virtual void	TProofPlayer::AddInput(TObject* inp)
virtual void	TVirtualProofPlayer::AddInput(TObject* inp)
virtual void	TProofPlayerRemote::AddOutput(TList* out)
virtual void	TProofPlayer::AddOutput(TList* out)
virtual void	TVirtualProofPlayer::AddOutput(TList* out)
virtual Int_t	TProofPlayerRemote::AddOutputObject(TObject* obj)
virtual Int_t	TProofPlayer::AddOutputObject(TObject* obj)
virtual void	TProofPlayer::AddQueryResult(TQueryResult* q)
virtual void	TVirtualProofPlayer::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()
static TClass*	TProofPlayerRemote::Class()
static TClass*	TProofPlayer::Class()
static TClass*	TVirtualProofPlayer::Class()
static TClass*	TQObject::Class()
static TClass*	TObject::Class()
virtual const char*	TObject::ClassName() const
virtual void	TObject::Clear(Option_t* = "")
virtual void	TProofPlayer::ClearInput()
virtual void	TVirtualProofPlayer::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 TDrawFeedback*	TVirtualProofPlayer::CreateDrawFeedback(TProof* p)
virtual void	TObject::Delete(Option_t* option = "")MENU
virtual void	TProofPlayer::DeleteDrawFeedback(TDrawFeedback* f)
virtual void	TVirtualProofPlayer::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	TProofPlayerRemote::DrawSelect(TDSet* set, const char* varexp, const char* selection, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
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 Long64_t	TVirtualProofPlayer::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)
void	TQObject::EmitVA(const char* signal, Int_t nargs, va_list va)
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	TProofPlayerRemote::Feedback(TList* objs)SIGNAL
virtual Long64_t	TProofPlayerRemote::Finalize(TQueryResult* qr)
virtual Long64_t	TProofPlayer::Finalize(TQueryResult* qr)
virtual Long64_t	TVirtualProofPlayer::Finalize(TQueryResult* qr)
virtual Long64_t	TProofPlayerRemote::Finalize(Bool_t force = kFALSE, Bool_t sync = kFALSE)
virtual Long64_t	TProofPlayer::Finalize(Bool_t force = kFALSE, Bool_t sync = kFALSE)
virtual Long64_t	TVirtualProofPlayer::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 TQueryResult*	TProofPlayer::GetCurrentQuery() const
virtual TQueryResult*	TVirtualProofPlayer::GetCurrentQuery() const
virtual Int_t	TProofPlayer::GetDrawArgs(const char* var, const char* sel, Option_t* opt, TString& selector, TString& objname)
virtual Int_t	TVirtualProofPlayer::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 Long64_t	TVirtualProofPlayer::GetEventsProcessed() const
virtual TVirtualProofPlayer::EExitStatus	TProofPlayer::GetExitStatus() const
virtual TVirtualProofPlayer::EExitStatus	TVirtualProofPlayer::GetExitStatus() const
virtual const char*	TObject::GetIconName() const
virtual TList*	TProofPlayer::GetInputList() const
virtual TList*	TVirtualProofPlayer::GetInputList() const
TList*	TQObject::GetListOfClassSignals() const
TList*	TQObject::GetListOfConnections() const
virtual TList*	TProofPlayer::GetListOfResults() const
virtual TList*	TVirtualProofPlayer::GetListOfResults() const
TList*	TQObject::GetListOfSignals() const
virtual const char*	TObject::GetName() const
virtual TDSetElement*	TProofPlayerRemote::GetNextPacket(TSlave* slave, TMessage* r)
virtual TDSetElement*	TProofPlayer::GetNextPacket(TSlave* slave, TMessage* r)
virtual TDSetElement*	TVirtualProofPlayer::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 TObject*	TVirtualProofPlayer::GetOutput(const char* name) const
virtual TList*	TProofPlayer::GetOutputList() const
virtual TList*	TVirtualProofPlayer::GetOutputList() const
virtual TVirtualPacketizer*	TProofPlayerRemote::GetPacketizer() const
virtual TVirtualPacketizer*	TProofPlayer::GetPacketizer() const
virtual TVirtualPacketizer*	TVirtualProofPlayer::GetPacketizer() const
virtual TProofProgressStatus*	TProofPlayer::GetProgressStatus() const
virtual TProofProgressStatus*	TVirtualProofPlayer::GetProgressStatus() const
virtual TQueryResult*	TProofPlayer::GetQueryResult(const char* ref)
virtual TQueryResult*	TVirtualProofPlayer::GetQueryResult(const char* ref)
virtual const char*	TObject::GetTitle() const
virtual UInt_t	TObject::GetUniqueID() const
virtual void	TProofPlayer::HandleGetTreeHeader(TMessage* mess)
virtual void	TVirtualProofPlayer::HandleGetTreeHeader(TMessage* mess)
TObject*	TProofPlayerRemote::HandleHistogram(TObject* obj)
virtual void	TProofPlayer::HandleRecvHisto(TMessage* mess)
virtual void	TVirtualProofPlayer::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)
Int_t	TProofPlayerRemote::Incorporate(TObject* obj, TList* out, Bool_t& merged)
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 TClass*	TProofPlayerRemote::IsA() const
virtual TClass*	TProofPlayer::IsA() const
virtual TClass*	TVirtualProofPlayer::IsA() const
virtual TClass*	TQObject::IsA() const
virtual TClass*	TObject::IsA() const
virtual Bool_t	TProofPlayerRemote::IsClient() const
virtual Bool_t	TProofPlayer::IsClient() const
virtual Bool_t	TVirtualProofPlayer::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
static void	TQObject::LoadRQ_OBJECT()
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
void	TProofPlayerRemote::MergeOutput()
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
static void	TObject::operator delete(void* ptr)
static void	TObject::operator delete(void* ptr, void* vp)
static void	TObject::operator delete[](void* ptr)
static 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)
TObject&	TObject::operator=(const TObject& rhs)
virtual void	TObject::Paint(Option_t* option = "")
virtual void	TObject::Pop()
virtual void	TObject::Print(Option_t* option = "") const
virtual Long64_t	Process(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
virtual Long64_t	TProofPlayerRemote::Process(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
virtual Long64_t	TProofPlayer::Process(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
virtual Long64_t	TVirtualProofPlayer::Process(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)
virtual void	Progress(Long64_t total, Long64_t processed)
virtual void	TProofPlayerRemote::Progress(Long64_t total, Long64_t processed)SIGNAL
virtual void	Progress(TSlave* sl, Long64_t total, Long64_t processed)
virtual void	TProofPlayerRemote::Progress(TSlave*, Long64_t total, Long64_t processed)
virtual void	Progress(Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)
virtual void	TProofPlayerRemote::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	Progress(TSlave* sl, Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)
virtual void	TProofPlayerRemote::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)
void	TProofPlayerRemote::RedirectOutput(Bool_t on = kTRUE)
virtual Int_t	TProofPlayer::ReinitSelector(TQueryResult* qr)
virtual void	TProofPlayer::RemoveQueryResult(const char* ref)
virtual void	TVirtualProofPlayer::RemoveQueryResult(const char* ref)
void	TObject::ResetBit(UInt_t f)
virtual void	TProofPlayer::RestorePreviousQuery()
virtual void	TVirtualProofPlayer::RestorePreviousQuery()
virtual void	TObject::SaveAs(const char* filename = "", Option_t* option = "") constMENU
virtual void	TObject::SavePrimitive(basic_ostream<char,char_traits<char> >& 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	TVirtualProofPlayer::SetCurrentQuery(TQueryResult* q)
virtual void	TProofPlayer::SetDispatchTimer(Bool_t on = kTRUE)
virtual void	TVirtualProofPlayer::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	TProofPlayerRemote::SetInitTime()
virtual void	TProofPlayer::SetInitTime()
virtual void	TVirtualProofPlayer::SetInitTime()
virtual void	TProofPlayer::SetMaxDrawQueries(Int_t max)
virtual void	TVirtualProofPlayer::SetMaxDrawQueries(Int_t max)
static void	TObject::SetObjectStat(Bool_t stat)
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	TVirtualProofPlayer::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, char* parent)
virtual void	TProofPlayerRemote::ShowMembers(TMemberInspector& insp, char* parent)
virtual void	TProofPlayer::ShowMembers(TMemberInspector& insp, char* parent)
virtual void	TVirtualProofPlayer::ShowMembers(TMemberInspector& insp, char* parent)
virtual void	TQObject::ShowMembers(TMemberInspector& insp, char* parent)
virtual void	TObject::ShowMembers(TMemberInspector& insp, char* parent)
virtual void	TProofPlayer::StopFeedback()
virtual void	TProofPlayerRemote::StopProcess(Bool_t abort, Int_t timeout = -1)
virtual void	TProofPlayer::StopProcess(Bool_t abort, Int_t timeout = -1)
virtual void	TVirtualProofPlayer::StopProcess(Bool_t abort, Int_t timeout = -1)
virtual void	TProofPlayerRemote::StoreFeedback(TObject* slave, TList* out)
virtual void	TProofPlayer::StoreFeedback(TObject* slave, TList* out)
virtual void	TVirtualProofPlayer::StoreFeedback(TObject* slave, TList* out)
virtual void	TProofPlayerRemote::StoreOutput(TList* out)
virtual void	TProofPlayer::StoreOutput(TList* out)
virtual void	TVirtualProofPlayer::StoreOutput(TList* out)
virtual void	Streamer(TBuffer& b)
virtual void	TProofPlayerRemote::Streamer(TBuffer& b)
virtual void	TProofPlayer::Streamer(TBuffer& b)
virtual void	TVirtualProofPlayer::Streamer(TBuffer& b)
virtual void	TQObject::Streamer(TBuffer& b)
virtual void	TObject::Streamer(TBuffer& b)
void	StreamerNVirtual(TBuffer& b)
void	TProofPlayerRemote::StreamerNVirtual(TBuffer& b)
void	TProofPlayer::StreamerNVirtual(TBuffer& b)
void	TVirtualProofPlayer::StreamerNVirtual(TBuffer& b)
void	TObject::StreamerNVirtual(TBuffer& 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
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	TVirtualProofPlayer::UpdateAutoBin(const char* name, Double_t& xmin, Double_t& xmax, Double_t& ymin, Double_t& ymax, Double_t& zmin, Double_t& zmax)
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:

static Int_t	TQObject::CheckConnectArgs(TQObject* sender, TClass* sender_class, const char* signal, TClass* receiver_class, const char* slot)
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)
TProof*	TProofPlayerRemote::GetProof() const
virtual void*	TProofPlayer::GetSender()
virtual void*	TQObject::GetSender()
virtual const char*	TQObject::GetSenderClassName() const
virtual Bool_t	HandleTimer(TTimer* timer)
virtual Bool_t	TProofPlayerRemote::HandleTimer(TTimer* timer)
Int_t	TProofPlayerRemote::InitPacketizer(TDSet* dset, Long64_t nentries, Long64_t first, const char* defpackunit, const char* defpackdata)
void	TObject::MakeZombie()
TList*	TProofPlayerRemote::MergeFeedback()
Bool_t	TProofPlayerRemote::MergeOutputFiles()
virtual Bool_t	TProofPlayerRemote::SendSelector(const char* selector_file)
virtual void	SetupFeedback()
virtual void	TProofPlayerRemote::StopFeedback()

Data Members

private:

enum TProofPlayer::EStatusBits {	kDispatchOneEvent
	kIsProcessing
};
enum TVirtualProofPlayer::EExitStatus {	kFinished
	kStopped
	kAborted
};
enum TObject::EStatusBits {	kCanDelete
	kMustCleanup
	kObjInCanvas
	kIsReferenced
	kHasUUID
	kCannotPick
	kNoContextMenu
	kInvalidObject
};
enum TObject::[unnamed] {	kIsOnHeap
	kNotDeleted
	kZombie
	kBitMask
	kSingleKey
	kOverwrite
	kWriteDelete
};

protected:

TDSet*	TProofPlayerRemote::fDSet	!tdset for current processing
TTimer*	TProofPlayer::fDispatchTimer	Dispatch pending events while processing
Int_t	TProofPlayer::fDrawQueries	Number of Draw queries in the list
void*	TProofPlayerRemote::fErrorHandler	Store previous handler when redirecting output
TEventIter*	TProofPlayer::fEvIter	! iterator on events or objects
TVirtualProofPlayer::EExitStatus	TProofPlayer::fExitStatus	exit status
TList*	TProofPlayerRemote::fFeedback	reference for use on master
TList*	TProofPlayerRemote::fFeedbackLists	intermediate results
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
Bool_t	TProofPlayerRemote::fMergeFiles	is True when merging output files centrally is needed
TList*	TProofPlayer::fOutput	list with output objects
TList*	TProofPlayerRemote::fOutputLists	results returned by slaves
TVirtualPacketizer*	TProofPlayerRemote::fPacketizer	transform TDSet into packets for slaves
TQueryResult*	TProofPlayer::fPreviousQuery	Previous instance of TQueryResult processed
TProofProgressStatus*	TProofPlayer::fProgressStatus	the progress status object;
TProof*	TProofPlayerRemote::fProof	link to associated PROOF session
TQueryResult*	TProofPlayer::fQuery	Instance of TQueryResult currently processed
TList*	TProofPlayer::fQueryResults	List of TQueryResult
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

private:

Bool_t	fReturnFeedback
TArrayL64	fSlaveBytesRead
TArrayF	fSlaveEvtRti
TArrayF	fSlaveInitTime
TArrayF	fSlaveMBRti
TArrayF	fSlaveProcTime
TArrayL64	fSlaveProgress
TArrayL64	fSlaveTotals
TList	fSlaves

Class Charts

Inheritance Inherited Members Includes Libraries

Function documentation

Long64_t Process(TDSet* set, const char* selector, Option_t* option = "", Long64_t nentries = -1, Long64_t firstentry = 0)

 Process specified TDSet on PROOF. Runs on super master.
 The return value is -1 in case of error and TSelector::GetStatus() in
 in case of success.

void Progress(TSlave* sl, Long64_t total, Long64_t processed)

 Report progress.

void Progress(TSlave* sl, Long64_t total, Long64_t processed, Long64_t bytesread, Float_t initTime, Float_t procTime, Float_t evtrti, Float_t mbrti)

 Report progress.

Bool_t HandleTimer(TTimer* timer)

 Send progress and feedback to client.

void SetupFeedback()

 Setup reporting of feedback objects and progress messages.

void Progress(Long64_t total, Long64_t processed)

void Progress(TSlave* sl, Long64_t total, Long64_t processed)

{ Progress(total, processed); }

TProofPlayerSuperMaster(TProof* proof = 0)

{ }

virtual ~TProofPlayerSuperMaster()

{ }