23#include "RConfigure.h"
51 fProtocol(0), fSocket(0), fProof(proof),
52 fInput(0), fBytesRead(0), fRealTime(0),
54 fParallel(0), fMsd(
msd)
103 hurl.SetOptions(
"SM");
106 hurl.SetOptions(
"MM");
108 iam =
"Local Client";
109 hurl.SetOptions(
"MC");
111 Error(
"Init",
"Impossible PROOF <-> SlaveType Configuration Requested");
148 for (
TObject *o = next(); o != 0; o = next()) {
152 const char *
p =
def.Data();
159 Info(
"Init",
"** NOT ** Sending kPROOF_SETENV RemoteProtocol : %d",
165 if (
strcmp(buf,
"Okay")) {
185 Error(
"SetupServ",
"failed to receive slave startup message");
198 Error(
"SetupServ",
"failed to send local PROOF protocol");
204 Error(
"SetupServ",
"failed to receive remote PROOF protocol");
211 Error(
"SetupServ",
"incompatible PROOF versions (remote version"
225 Error(
"SetupServ",
"OldAuthSetup: failed to setup authentication");
239 Error(
"SetupServ",
"failed to send ordinal and config info");
289 if (
sc &&
sc->IsActive()) {
294 nscc->GetProtocol() < 9) {
314 Error(
"Compare",
"input is not a TSlave object");
332 if (
myord)
return -1;
344 const char *
sst[] = {
"invalid" ,
"valid",
"inactive" };
376 Printf(
" Security context:");
377 Printf(
" Proofd protocol version:");
383 Printf(
" MB's received:");
419 Error(
"OldAuthSetup",
"can't locate %s",
authlib.Data());
428 Error(
"OldAuthSetup",
"can't find OldSlaveAuthSetup");
476 ::Error(
"TSlave::Create",
"can't locate %s",
proofxlib.Data());
550 Error(
"Interrupt",
"error receiving waste from slave %s",
555 }
else if (
n == -3) {
565 Error(
"Interrupt",
"error receiving OOB from server %s",
593 Error(
"Interrupt",
"error receiving waste (2) from slave %s",
601 Info(
"Interrupt",
"slave %s:%s synchronized: %d bytes discarded",
604 Info(
"Interrupt",
"PROOF synchronized: %d bytes discarded",
nbytes);
646 Info(
"SendCoordinator",
"method not implemented for this communication layer");
658 Info(
"SetAlias",
"method not implemented for this communication layer");
R__EXTERN TApplication * gApplication
const Bool_t kIterBackward
ROOT::Detail::TRangeCast< T, true > TRangeDynCast
TRangeDynCast is an adapter class that allows the typed iteration through a TCollection.
#define R__ASSERT(e)
Checks condition e and reports a fatal error if it's false.
winID h TVirtualViewer3D TVirtualGLPainter p
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char Pixmap_t Pixmap_t PictureAttributes_t attr const char char ret_data h unsigned char height h Atom_t Int_t ULong_t ULong_t unsigned char prop_list Atom_t Atom_t Atom_t Time_t type
const Int_t kPROOF_Protocol
R__EXTERN TVirtualMutex * gROOTMutex
TSlave *(* TSlave_t)(const char *url, const char *ord, Int_t perf, const char *image, TProof *proof, Int_t stype, const char *workdir, const char *msd, Int_t nwk)
Int_t(* OldSlaveAuthSetup_t)(TSocket *, Bool_t, TString, TString)
char * Form(const char *fmt,...)
Formats a string in a circular formatting buffer.
void Printf(const char *fmt,...)
Formats a string in a circular formatting buffer and prints the string.
R__EXTERN TSystem * gSystem
#define R__LOCKGUARD(mutex)
void Add() override
Add file event handler to system file handler list.
const char * GetHostName() const
The TNamed class is the base class for all named ROOT classes.
Collectable string class.
Mother of all ROOT objects.
virtual void Warning(const char *method, const char *msgfmt,...) const
Issue warning message.
virtual void Error(const char *method, const char *msgfmt,...) const
Issue error message.
This class controls a Parallel ROOT Facility, PROOF, cluster.
Int_t Collect(const TSlave *sl, Long_t timeout=-1, Int_t endtype=-1, Bool_t deactonfail=kFALSE)
Collect responses from slave sl.
static const TList * GetEnvVars()
Get environemnt variables.
const char * GetUser() const
virtual const char * AsString(TString &out)
Returns short string with relevant information about this security context.
Class describing a PROOF worker server.
const char * GetName() const override
Returns name of object.
virtual void SetAlias(const char *alias)
Set an alias for this session.
const char * GetWorkDir() const
Float_t GetRealTime() const
static TSlave_t fgTXSlaveHook
const char * GetImage() const
Int_t Compare(const TObject *obj) const override
Used to sort slaves by performance index.
TSlave()
Default constructor used by derived classes.
Long64_t GetBytesRead() const
const char * GetGroup() const
virtual void StopProcess(Bool_t abort, Int_t timeout)
Sent stop/abort request to PROOF server.
const char * GetUser() const
void Init(const char *host, Int_t port, Int_t stype)
Init a PROOF slave object.
static void SetTXSlaveHook(TSlave_t xslavehook)
Set hook to TXSlave ctor.
static TSlave * Create(const char *url, const char *ord, Int_t perf, const char *image, TProof *proof, Int_t stype, const char *workdir, const char *msd, Int_t nwk=1)
Static method returning the appropriate TSlave object for the remote server.
const char * GetSessionTag() const
void SetInputHandler(TFileHandler *ih)
Adopt and register input handler for this slave.
virtual void Interrupt(Int_t type)
Send interrupt OOB byte to master or slave servers.
void Print(Option_t *option="") const override
Printf info about slave.
const char * GetArchCompiler() const
virtual Int_t SetupServ(Int_t stype, const char *conffile)
Init a PROOF slave object.
virtual Int_t Ping()
Ping the remote master or slave servers.
virtual TObjString * SendCoordinator(Int_t kind, const char *msg=0, Int_t int2=0)
Send message to intermediate coordinator.
~TSlave() override
Destroy slave.
const char * GetROOTVersion() const
Float_t GetCpuTime() const
virtual Bool_t IsValid() const
Int_t OldAuthSetup(Bool_t master, TString wconf)
Setup authentication related stuff for old versions.
const char * GetOrdinal() const
virtual void Close(Option_t *opt="")
Close slave socket.
virtual Int_t SetOption(ESockOptions opt, Int_t val)
Set socket options.
UInt_t GetBytesRecv() const
virtual Int_t Recv(TMessage *&mess)
Receive a TMessage object.
Int_t GetRemoteProtocol() const
UInt_t GetBytesSent() const
TInetAddress GetInetAddress() const
virtual Int_t RecvRaw(void *buffer, Int_t length, ESendRecvOptions opt=kDefault)
Receive a raw buffer of specified length bytes.
TSecContext * GetSecContext() const
virtual Int_t SendRaw(const void *buffer, Int_t length, ESendRecvOptions opt=kDefault)
Send a raw buffer of specified length.
Option_t * GetOption() const override
static TSocket * CreateAuthSocket(const char *user, const char *host, Int_t port, Int_t size=0, Int_t tcpwindowsize=-1, TSocket *s=nullptr, Int_t *err=nullptr)
Creates a socket or a parallel socket and authenticates to the remote server specified in 'url' on re...
virtual Int_t Send(const TMessage &mess)
Send a TMessage object.
virtual Bool_t IsAuthenticated() const
const char * Data() const
virtual Func_t DynFindSymbol(const char *module, const char *entry)
Find specific entry point in specified library.
virtual int Load(const char *module, const char *entry="", Bool_t system=kFALSE)
Load a shared library.
virtual void Sleep(UInt_t milliSec)
Sleep milliSec milli seconds.
char * DynamicPathName(const char *lib, Bool_t quiet=kFALSE)
Find a dynamic library called lib using the system search paths.
This class represents a WWW compatible URL.
const char * GetHostFQDN() const
Return fully qualified domain name of url host.
const char * GetProtocol() const