ROOT logo
ROOT » PROOF » PROOFX » TXSlave

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()
voidTObject::AbstractMethod(const char* method) const
virtual voidTObject::AppendPad(Option_t* option = "")
virtual voidTObject::Browse(TBrowser* b)
static TClass*Class()
virtual const char*TObject::ClassName() const
virtual voidTObject::Clear(Option_t* = "")
virtual TObject*TObject::Clone(const char* newname = "") const
virtual voidClose(Option_t* opt = "")
virtual Int_tTSlave::Compare(const TObject* obj) const
virtual voidTObject::Copy(TObject& object) const
virtual voidTObject::Delete(Option_t* option = "")MENU
virtual Int_tTObject::DistancetoPrimitive(Int_t px, Int_t py)
virtual voidDoError(int level, const char* location, const char* fmt, va_list va) const
virtual voidTObject::Draw(Option_t* option = "")
virtual voidTObject::DrawClass() constMENU
virtual TObject*TObject::DrawClone(Option_t* option = "") constMENU
virtual voidTObject::Dump() constMENU
virtual voidTObject::Error(const char* method, const char* msgfmt) const
virtual voidTObject::Execute(const char* method, const char* params, Int_t* error = 0)
virtual voidTObject::Execute(TMethod* method, TObjArray* params, Int_t* error = 0)
virtual voidTObject::ExecuteEvent(Int_t event, Int_t px, Int_t py)
virtual voidTObject::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_tTSlave::GetBytesRead() const
Float_tTSlave::GetCpuTime() const
virtual Option_t*TObject::GetDrawOption() const
static Long_tTObject::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_tTObject::GetObjectStat()
virtual Option_t*TObject::GetOption() const
const char*TSlave::GetOrdinal() const
Int_tTSlave::GetParallel() const
Int_tTSlave::GetPerfIdx() const
Int_tTSlave::GetPort() const
TProof*TSlave::GetProof() const
const char*TSlave::GetProofWorkDir() const
Int_tTSlave::GetProtocol() const
Float_tTSlave::GetRealTime() const
const char*TSlave::GetROOTVersion() const
const char*TSlave::GetSessionTag() const
Int_tTSlave::GetSlaveType() const
TSocket*TSlave::GetSocket() const
Int_tTSlave::GetStatus() const
virtual const char*TObject::GetTitle() const
virtual UInt_tTObject::GetUniqueID() const
const char*TSlave::GetUser() const
const char*TSlave::GetWorkDir() const
virtual Bool_tHandleError(const void* in = 0)
virtual Bool_tHandleInput(const void* in = 0)
virtual Bool_tTObject::HandleTimer(TTimer* timer)
virtual ULong_tTObject::Hash() const
virtual voidTObject::Info(const char* method, const char* msgfmt) const
virtual Bool_tTObject::InheritsFrom(const char* classname) const
virtual Bool_tTObject::InheritsFrom(const TClass* cl) const
virtual voidTObject::Inspect() constMENU
voidTObject::InvertBit(UInt_t f)
virtual TClass*IsA() const
virtual Bool_tTObject::IsEqual(const TObject* obj) const
virtual Bool_tTObject::IsFolder() const
Bool_tTObject::IsOnHeap() const
virtual Bool_tTSlave::IsSortable() const
virtual Bool_tTSlave::IsValid() const
Bool_tTObject::IsZombie() const
virtual voidTObject::ls(Option_t* option = "") const
voidTObject::MayNotUse(const char* method) const
virtual Bool_tTObject::Notify()
voidTObject::Obsolete(const char* method, const char* asOfVers, const char* removedFromVers) const
static voidTObject::operator delete(void* ptr)
static voidTObject::operator delete(void* ptr, void* vp)
static voidTObject::operator delete[](void* ptr)
static voidTObject::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 voidTObject::Paint(Option_t* option = "")
virtual voidTObject::Pop()
virtual voidTSlave::Print(Option_t* option = "") const
virtual Int_tTObject::Read(const char* name)
virtual voidTObject::RecursiveRemove(TObject* obj)
voidTObject::ResetBit(UInt_t f)
virtual voidTObject::SaveAs(const char* filename = "", Option_t* option = "") constMENU
virtual voidTObject::SavePrimitive(ostream& out, Option_t* option = "")
voidTSlave::SetArchCompiler(const char* ac)
voidTObject::SetBit(UInt_t f)
voidTObject::SetBit(UInt_t f, Bool_t set)
virtual voidTObject::SetDrawOption(Option_t* option = "")MENU
static voidTObject::SetDtorOnly(void* obj)
voidTSlave::SetInputHandler(TFileHandler* ih)
virtual voidSetInterruptHandler(Bool_t on = kTRUE)
static voidTObject::SetObjectStat(Bool_t stat)
voidTSlave::SetROOTVersion(const char* rv)
voidTSlave::SetSessionTag(const char* st)
static voidTSlave::SetTXSlaveHook(TSlave_t xslavehook)
virtual voidTObject::SetUniqueID(UInt_t uid)
virtual Int_tSetupServ(Int_t stype, const char* conffile)
virtual voidShowMembers(TMemberInspector& insp)
virtual voidStreamer(TBuffer& b)
voidStreamerNVirtual(TBuffer& b)
virtual voidTObject::SysError(const char* method, const char* msgfmt) const
Bool_tTObject::TestBit(UInt_t f) const
Int_tTObject::TestBits(UInt_t f) const
virtual voidTouch()
virtual voidTObject::UseCurrentStyle()
virtual voidTObject::Warning(const char* method, const char* msgfmt) const
virtual Int_tTObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0)
virtual Int_tTObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0) const
protected:
virtual voidFlushSocket()
virtual voidInterrupt(Int_t type)
voidTObject::MakeZombie()
virtual Int_tPing()
virtual TObjString*SendCoordinator(Int_t kind, const char* msg = 0, Int_t int2 = 0)
virtual Int_tSendGroupPriority(const char* grp, Int_t priority)
virtual voidSetAlias(const char* alias)
voidTSlave::SetSocket(TSocket* s)
virtual voidTSlave::SetStatus(Int_t st)
virtual voidStopProcess(Bool_t abort, Int_t timeout)
private:
static Int_tGetProofdProtocol(TSocket* s)
voidInit(const char* host, Int_t stype)
voidParseBuffer()

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:
TStringTSlave::fArchCompBuild architecture, compiler on worker (e.g. linux-gcc345)
Long64_tTSlave::fBytesReadbytes read by slave (info is obtained from slave)
Float_tTSlave::fCpuTimeCPU time spent executing commands (info obtained from slave)
TStringTSlave::fGroupslave's group id
TStringTSlave::fImageslave's image name
TFileHandler*TSlave::fInputinput handler related to this slave
TStringTSlave::fMsdmass storage domain of slave
TStringTSlave::fNameslave's hostname
TStringTSlave::fOrdinalslave's ordinal number
Int_tTSlave::fParallelnumber of active slaves
Int_tTSlave::fPerfIdxrelative CPU performance index
Int_tTSlave::fPortslave's port number
TProof*TSlave::fProofproof cluster to which slave belongs
TStringTSlave::fProofWorkDirbase proofserv working directory (info obtained from slave)
Int_tTSlave::fProtocolslave's protocol level
TStringTSlave::fROOTVersROOT version run by worker
Float_tTSlave::fRealTimereal time spent executing commands (info obtained from slave)
TStringTSlave::fSessionTagunique tag for ths worker process
TSlave::ESlaveTypeTSlave::fSlaveTypetype of slave (either kMaster or kSlave)
TSocket*TSlave::fSocketsocket to slave
Int_tTSlave::fStatusremote return status
TStringTSlave::fUserslave's user id
TStringTSlave::fWorkDirslave's working directory (info obtained from slave)
private:
TSignalHandler*fIntHandlerinterrupt signal handler (ctrl-c)
Bool_tfValid

Class Charts

Inheritance Inherited Members Includes Libraries
Class Charts

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.
void ParseBuffer()
 Parse fBuffer after a connection attempt
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