class TXSlave: public TSlave, public TXHandler


TXSlave

This is the version of TSlave for slave servers based on XRD.
See TSlave for details.

Function Members (Methods)

public:

	TXSlave(const char* url, const char* ord, Int_t perf, const char* image, TProof* proof, Int_t stype, const char* workdir, const char* msd)
virtual	~TXSlave()
void	TObject::AbstractMethod(const char* method) const
virtual void	TObject::AppendPad(Option_t* option = "")
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 void	Close(Option_t* opt = "")
virtual Int_t	TSlave::Compare(const TObject* obj) const
virtual void	TObject::Copy(TObject& object) const
virtual void	TObject::Delete(Option_t* option = "")MENU
virtual Int_t	TObject::DistancetoPrimitive(Int_t px, Int_t py)
virtual void	DoError(int level, const char* location, const char* fmt, va_list va) const
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
const char*	TSlave::GetArchCompiler() const
Long64_t	TSlave::GetBytesRead() const
Float_t	TSlave::GetCpuTime() const
virtual Option_t*	TObject::GetDrawOption() const
static Long_t	TObject::GetDtorOnly()
const char*	TSlave::GetGroup() const
virtual const char*	TObject::GetIconName() const
const char*	TSlave::GetImage() const
TFileHandler*	TSlave::GetInputHandler() const
const char*	TSlave::GetMsd() const
virtual const char*	TSlave::GetName() const
virtual char*	TObject::GetObjectInfo(Int_t px, Int_t py) const
static Bool_t	TObject::GetObjectStat()
virtual Option_t*	TObject::GetOption() const
const char*	TSlave::GetOrdinal() const
Int_t	TSlave::GetParallel() const
Int_t	TSlave::GetPerfIdx() const
Int_t	TSlave::GetPort() const
TProof*	TSlave::GetProof() const
const char*	TSlave::GetProofWorkDir() const
Int_t	TSlave::GetProtocol() const
Float_t	TSlave::GetRealTime() const
const char*	TSlave::GetROOTVersion() const
Int_t	TSlave::GetSlaveType() const
TSocket*	TSlave::GetSocket() const
Int_t	TSlave::GetStatus() const
virtual const char*	TObject::GetTitle() const
virtual UInt_t	TObject::GetUniqueID() const
const char*	TSlave::GetUser() const
const char*	TSlave::GetWorkDir() const
virtual Bool_t	HandleError(const void* in = 0)
virtual Bool_t	HandleInput(const void* in = 0)
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
virtual Bool_t	TObject::IsEqual(const TObject* obj) const
virtual Bool_t	TObject::IsFolder() const
Bool_t	TObject::IsOnHeap() const
virtual Bool_t	TSlave::IsSortable() const
virtual Bool_t	TSlave::IsValid() 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()
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	TSlave::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(basic_ostream<char,char_traits<char> >& out, Option_t* option = "")
void	TSlave::SetArchCompiler(const char* ac)
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	TSlave::SetInputHandler(TFileHandler* ih)
virtual void	SetInterruptHandler(Bool_t on = kTRUE)
static void	TObject::SetObjectStat(Bool_t stat)
void	TSlave::SetROOTVersion(const char* rv)
static void	TSlave::SetTXSlaveHook(TSlave_t xslavehook)
virtual void	TObject::SetUniqueID(UInt_t uid)
virtual Int_t	SetupServ(Int_t stype, const char* conffile)
virtual void	ShowMembers(TMemberInspector& insp, char* parent)
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	Touch()
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	FlushSocket()
virtual void	Interrupt(Int_t type)
void	TObject::MakeZombie()
virtual Int_t	Ping()
virtual TObjString*	SendCoordinator(Int_t kind, const char* msg = 0, Int_t int2 = 0)
virtual Int_t	SendGroupPriority(const char* grp, Int_t priority)
virtual void	SetAlias(const char* alias)
void	TSlave::SetSocket(TSocket* s)
virtual void	TSlave::SetStatus(Int_t st)
virtual void	StopProcess(Bool_t abort, Int_t timeout)

private:

static Int_t	GetProofdProtocol(TSocket* s)
void	Init(const char* host, Int_t stype)

Data Members

public:

enum TSlave::ESlaveType {	kMaster
	kSlave
};
enum TSlave::ESlaveStatus {	kInvalid
	kActive
	kInactive
};
enum TObject::EStatusBits {	kCanDelete
	kMustCleanup
	kObjInCanvas
	kIsReferenced
	kHasUUID
	kCannotPick
	kNoContextMenu
	kInvalidObject
};
enum TObject::[unnamed] {	kIsOnHeap
	kNotDeleted
	kZombie
	kBitMask
	kSingleKey
	kOverwrite
	kWriteDelete
};

protected:

TString	TSlave::fArchComp	Build architecture, compiler on worker (e.g. linux-gcc345)
Long64_t	TSlave::fBytesRead	bytes read by slave (info is obtained from slave)
Float_t	TSlave::fCpuTime	CPU time spent executing commands (info obtained from slave)
TString	TSlave::fGroup	slave's group id
TString	TSlave::fImage	slave's image name
TFileHandler*	TSlave::fInput	input handler related to this slave
TString	TSlave::fMsd	mass storage domain of slave
TString	TSlave::fName	slave's hostname
TString	TSlave::fOrdinal	slave's ordinal number
Int_t	TSlave::fParallel	number of active slaves
Int_t	TSlave::fPerfIdx	relative CPU performance index
Int_t	TSlave::fPort	slave's port number
TProof*	TSlave::fProof	proof cluster to which slave belongs
TString	TSlave::fProofWorkDir	base proofserv working directory (info obtained from slave)
Int_t	TSlave::fProtocol	slave's protocol level
TString	TSlave::fROOTVers	ROOT version run by worker
Float_t	TSlave::fRealTime	real time spent executing commands (info obtained from slave)
TSlave::ESlaveType	TSlave::fSlaveType	type of slave (either kMaster or kSlave)
TSocket*	TSlave::fSocket	socket to slave
Int_t	TSlave::fStatus	remote return status
TString	TSlave::fUser	slave's user id
TString	TSlave::fWorkDir	slave's working directory (info obtained from slave)

private:

TSignalHandler*	fIntHandler	interrupt signal handler (ctrl-c)
Bool_t	fValid

Class Charts

Inheritance Inherited Members Includes Libraries

Function documentation

void DoError(int level, const char* location, const char* fmt, va_list va) const

 Interface to ErrorHandler (protected).

TXSlave(const char* url, const char* ord, Int_t perf, const char* image, TProof* proof, Int_t stype, const char* workdir, const char* msd)

 Create a PROOF slave object. Called via the TProof ctor.

void Init(const char* host, Int_t stype)

 Init a PROOF slave object. Called via the TXSlave ctor.
 The Init method is technology specific and is overwritten by derived
 classes.

Int_t SetupServ(Int_t stype, const char* conffile)

 Init a PROOF slave object. Called via the TXSlave ctor.
 The Init method is technology specific and is overwritten by derived
 classes.

~TXSlave()

 Destroy slave.

void Close(Option_t* opt = "")

 Close slave socket.

Int_t Ping()

 Ping the remote master or slave servers.
 Returns 0 if ok, -1 if it did not ping or in case of error

void Touch()

 Touch the client admin file to proof we are alive.

void Interrupt(Int_t type)

 Send interrupt to master or slave servers.
 Returns 0 if ok, -1 in case of error

void StopProcess(Bool_t abort, Int_t timeout)

 Sent stop/abort request to PROOF server. It will be
 processed asynchronously by a separate thread.

Int_t GetProofdProtocol(TSocket* s)

 Find out the remote proofd protocol version.
 Returns -1 in case of error.

TObjString * SendCoordinator(Int_t kind, const char* msg = 0, Int_t int2 = 0)

 Send message to intermediate coordinator.
 If any output is due, this is returned as a generic message

void SetAlias(const char* alias)

 Set an alias for this session. If reconnection is supported, the alias
 will be communicated to the remote coordinator so that it can be recovered
 when reconnecting

Int_t SendGroupPriority(const char* grp, Int_t priority)

 Communicate to the coordinator the priprity of the group to which the
 user belongs
 Return 0 on success

Bool_t HandleError(const void* in = 0)

 Handle error on the input socket

Bool_t HandleInput(const void* in = 0)

 Handle asynchronous input on the socket

void SetInterruptHandler(Bool_t on = kTRUE)

 Set/Unset the interrupt handler

void FlushSocket()

 Clean any input on the socket