Quick Links: ROOT Homepage Class Index Class Hierarchy

Source: header file source file viewVC header viewVC source

Sections: class description function members data members class charts

ROOT » PROOF » PROOFPLAYER » TProofPlayerRemote

class TProofPlayerRemote: 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:

	TProofPlayerRemote(TProof* proof = 0)
virtual	~TProofPlayerRemote()
void	TObject::AbstractMethod(const char* method) const
virtual void	TProofPlayer::AddEventsProcessed(Long64_t ev)
virtual void	TProofPlayer::AddInput(TObject* inp)
virtual void	AddOutput(TList* out)
virtual Int_t	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	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	Feedback(TList* objs)SIGNAL
void	TProofPlayer::FeedBackCanvas(const char* name, Bool_t create)
virtual Long64_t	Finalize(TQueryResult* qr)
virtual Long64_t	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*	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*	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)
TObject*	HandleHistogram(TObject* obj)
virtual void	TProofPlayer::HandleRecvHisto(TMessage* mess)
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	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 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
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
virtual void	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 void	Progress(TProofProgressInfo* pi)SIGNAL
virtual void	Progress(Long64_t total, Long64_t processed)SIGNAL
virtual void	Progress(TSlave, TProofProgressInfo pi)SIGNAL
virtual void	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)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)SIGNAL
virtual Int_t	TObject::Read(const char* name)
virtual void	TObject::RecursiveRemove(TObject* obj)
void	RedirectOutput(Bool_t on = kTRUE)
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 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	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	SetInitTime()
virtual void	TProofPlayer::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	TObject::SetUniqueID(UInt_t uid)
virtual void	ShowMembers(TMemberInspector& insp, char* parent)
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)
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	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*	GetProof() const
virtual void*	TProofPlayer::GetSender()
virtual const char*	TQObject::GetSenderClassName() const
virtual Bool_t	HandleTimer(TTimer* timer)
Int_t	InitPacketizer(TDSet* dset, Long64_t nentries, Long64_t first, const char* defpackunit, const char* defpackdata)
void	TObject::MakeZombie()
TList*	MergeFeedback()
Bool_t	MergeOutputFiles()
virtual Bool_t	SendSelector(const char* selector_file)
virtual void	SetupFeedback()
virtual void	StopFeedback()

Data Members

public:

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*	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*	fErrorHandler	Store previous handler when redirecting output
TEventIter*	TProofPlayer::fEvIter	! iterator on events or objects
TVirtualProofPlayer::EExitStatus	TProofPlayer::fExitStatus	exit status
TList*	fFeedback	reference for use on master
TList*	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	fMergeFiles	is True when merging output files centrally is needed
TList*	TProofPlayer::fOutput	list with output objects
TList*	fOutputLists	results returned by slaves
TVirtualPacketizer*	fPacketizer	transform TDSet into packets for slaves
TQueryResult*	TProofPlayer::fPreviousQuery	Previous instance of TQueryResult processed
TProofProgressStatus*	TProofPlayer::fProgressStatus	the progress status object;
TProof*	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
static THashList*	TProofPlayer::fgDrawInputPars	List of input parameters to be kept on drawing actions

Class Charts

Inheritance Inherited Members Includes Libraries

Function documentation

~TProofPlayerRemote()

 Destructor.

Int_t InitPacketizer(TDSet* dset, Long64_t nentries, Long64_t first, const char* defpackunit, const char* defpackdata)

 Init the packetizer
 Return 0 on success (fPacketizer is correctly initialized), -1 on failure.

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

 Process specified TDSet on PROOF.
 This method is called on client and on the PROOF master.
 The return value is -1 in case of an error and TSelector::GetStatus() in
 in case of success.

Bool_t MergeOutputFiles()

 Merge output in files

Long64_t Finalize(Bool_t force = kFALSE, Bool_t sync = kFALSE)

Long64_t Finalize(TQueryResult* qr)

 Finalize the results of a query already processed.

Bool_t SendSelector(const char* selector_file)

 Send the selector file(s) to master or worker nodes.

void MergeOutput()

 Merge objects in output the lists.

void Progress(Long64_t total, Long64_t processed)

 Progress signal.

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

 Progress signal.

void Progress(TProofProgressInfo* pi)

 Progress signal.

void Feedback(TList* objs)

 Feedback signal.

void StopProcess(Bool_t abort, Int_t timeout = -1)

 Stop process after this event.

Int_t AddOutputObject(TObject* obj)

 Incorporate the received object 'obj' into the output list fOutput.
 The latter is created if not existing.
 This method short cuts 'StoreOutput + MergeOutput' optimizing the memory
 consumption.
 Returns -1 in case of error, 1 if the object has been merged into another
 one (so that its ownership has not been taken and can be deleted), and 0
 otherwise.

void RedirectOutput(Bool_t on = kTRUE)

 Control output redirection to TProof::fLogFileW

void AddOutput(TList* out)

 Incorporate the content of the received output list 'out' into the final
 output list fOutput. The latter is created if not existing.
 This method short cuts 'StoreOutput + MergeOutput' limiting the memory
 consumption.

Int_t Incorporate(TObject* obj, TList* out, Bool_t& merged)

 Incorporate object 'newobj' in the list 'outlist'.
 The object is merged with an object of the same name already existing in
 the list, or just added.
 The boolean merged is set to kFALSE when the object is just added to 'outlist';
 this happens if the Merge() method does not exist or if a object named as 'obj'
 is not already in the list. If the obj is not 'merged' than it should not be
 deleted, unless outlist is not owner of its objects.
 Return 0 on success, -1 on error.

TObject * HandleHistogram(TObject* obj)

 Low statistic histograms need a special treatment when using autobin

void StoreOutput(TList* out)

 Store received output list.

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* timer)

 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 = -1, Long64_t firstentry = 0)

 Draw (support for TChain::Draw()).
 Returns -1 in case of error or number of selected events in case of success.

void SetInitTime()

 Set init time

TVirtualPacketizer * GetPacketizer() const

{ return 0; }

void Progress(Long64_t total, Long64_t processed)

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

{ Progress(total, processed); }

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

TProof * GetProof() const

{ return fProof; }

TProofPlayerRemote(TProof* proof = 0)

{ fProgressStatus = new TProofProgressStatus(); }