class TMergerInfo: public TObject


TProof

This class controls a Parallel ROOT Facility, PROOF, cluster.
It fires the worker servers, it keeps track of how many workers are
running, it keeps track of the workers running status, it broadcasts
messages to all workers, it collects results, etc.

Function Members (Methods)

public:

virtual	~TMergerInfo()
void	TObject::AbstractMethod(const char* method) const
void	AddMergedObjects(Int_t objects)
void	AddWorker(TSlave* sl)
virtual void	TObject::AppendPad(Option_t* option = "")
Bool_t	AreAllWorkersAssigned()
Bool_t	AreAllWorkersMerged()
virtual void	TObject::Browse(TBrowser* b)
static TClass*	Class()
virtual const char*	TObject::ClassName() const
virtual void	TObject::Clear(Option_t* = "")
virtual TObject*	TObject::Clone(const char* newname = "") const
virtual Int_t	TObject::Compare(const TObject* obj) const
virtual void	TObject::Copy(TObject& object) const
void	Deactivate()
virtual void	TObject::Delete(Option_t* option = "")MENU
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 void	TObject::Dump() constMENU
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 TObject*	TObject::FindObject(const char* name) const
virtual TObject*	TObject::FindObject(const TObject* obj) const
virtual Option_t*	TObject::GetDrawOption() const
static Long_t	TObject::GetDtorOnly()
virtual const char*	TObject::GetIconName() const
Int_t	GetMergedObjects()
Int_t	GetMergedWorkers()
TSlave*	GetMerger()
virtual const char*	TObject::GetName() const
virtual char*	TObject::GetObjectInfo(Int_t px, Int_t py) const
static Bool_t	TObject::GetObjectStat()
virtual Option_t*	TObject::GetOption() const
Int_t	GetPort()
virtual const char*	TObject::GetTitle() const
virtual UInt_t	TObject::GetUniqueID() const
TList*	GetWorkers()
Int_t	GetWorkersToMerge()
virtual Bool_t	TObject::HandleTimer(TTimer* timer)
virtual ULong_t	TObject::Hash() const
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
Bool_t	IsActive()
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 void	TObject::ls(Option_t* option = "") const
void	TObject::MayNotUse(const char* method) const
virtual Bool_t	TObject::Notify()
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)
virtual void	TObject::Paint(Option_t* option = "")
virtual void	TObject::Pop()
virtual void	TObject::Print(Option_t* option = "") const
virtual Int_t	TObject::Read(const char* name)
virtual void	TObject::RecursiveRemove(TObject* obj)
void	TObject::ResetBit(UInt_t f)
virtual void	TObject::SaveAs(const char* filename = "", Option_t* option = "") constMENU
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	TObject::SetDrawOption(Option_t* option = "")MENU
static void	TObject::SetDtorOnly(void* obj)
void	SetMergedWorker()
static void	TObject::SetObjectStat(Bool_t stat)
virtual void	TObject::SetUniqueID(UInt_t uid)
virtual void	ShowMembers(TMemberInspector& insp) const
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
	TMergerInfo(TSlave* t, Int_t port, Int_t forHowManyWorkers)
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:

virtual void	TObject::DoError(int level, const char* location, const char* fmt, va_list va) const
void	TObject::MakeZombie()

private:

TMergerInfo&	operator=(const TMergerInfo&)
	TMergerInfo(const TMergerInfo&)

Data Members

public:

static TObject::<anonymous>	TObject::kBitMask
static TObject::EStatusBits	TObject::kCanDelete
static TObject::EStatusBits	TObject::kCannotPick
static TObject::EStatusBits	TObject::kHasUUID
static TObject::EStatusBits	TObject::kInvalidObject
static TObject::<anonymous>	TObject::kIsOnHeap
static TObject::EStatusBits	TObject::kIsReferenced
static TObject::EStatusBits	TObject::kMustCleanup
static TObject::EStatusBits	TObject::kNoContextMenu
static TObject::<anonymous>	TObject::kNotDeleted
static TObject::EStatusBits	TObject::kObjInCanvas
static TObject::<anonymous>	TObject::kOverwrite
static TObject::<anonymous>	TObject::kSingleKey
static TObject::<anonymous>	TObject::kWriteDelete
static TObject::<anonymous>	TObject::kZombie

private:

Bool_t	fIsActive	Merger state
Int_t	fMergedObjects	Total number of objects it must accept from other workers
Int_t	fMergedWorkers	Current number of already merged workers
TSlave*	fMerger	Slave that acts as merger
Int_t	fPort	Port number, on which it accepts outputs from other workers
TList*	fWorkers	List of already assigned workers
Int_t	fWorkersToMerge	Number of workers that are merged on this merger

Class Charts

Inheritance Inherited Members Includes Libraries

Function documentation

~TMergerInfo()

 Destructor

void SetMergedWorker()

 Increase number of already merged workers by 1

void AddWorker(TSlave* sl)

 Add new worker to the list of workers to be merged by this merger

Bool_t AreAllWorkersMerged()

 Return if merger has already merged all workers, i.e. if it has finished its merging job

Bool_t AreAllWorkersAssigned()

 Return if the determined number of workers has been already assigned to this merger

TProofInterruptHandler& operator=(const TMergerInfo& )

TMergerInfo(const TMergerInfo& )

TMergerInfo(TSlave* t, Int_t port, Int_t forHowManyWorkers)

{ }

TList * GetWorkers()

{ return fWorkers; }

TSlave * GetMerger()

{ return fMerger; }

Int_t GetPort()

{ return fPort; }

Int_t GetWorkersToMerge()

{ return fWorkersToMerge; }

Int_t GetMergedWorkers()

{ return fMergedWorkers; }

Int_t GetMergedObjects()

{ return fMergedObjects; }

void AddMergedObjects(Int_t objects)

{ fMergedObjects += objects; }

void Deactivate()

{ fIsActive = kFALSE; }

Bool_t IsActive()

{ return fIsActive; }