98 TSocket() : fAddress(), fBytesRecv(0), fBytesSent(0), fCompress(0),
99 fLocalAddress(), fRemoteProtocol(), fSecContext(0), fService(),
100 fServType(
kSOCKD), fSocket(-1), fTcpWindowSize(0), fUrl(),
101 fBitsInfo(), fUUIDs(0), fLastUsageMtx(0), fLastUsage() { }
117 TSocket(
const char *host,
const char *service,
Int_t tcpwindowsize = -1);
169 void SetUrl(
const char *url) { fUrl = url; }
Int_t GetServType() const
void SetRemoteProtocol(Int_t rproto)
virtual Bool_t IsValid() const
Bool_t RecvStreamerInfos(TMessage *mess)
Receive a message containing streamer infos.
Int_t GetCompressionLevel() const
UInt_t GetBytesRecv() const
void SetCompressionSettings(Int_t settings=1)
Used to specify the compression level and algorithm: settings = 100 * algorithm + level...
virtual Int_t Reconnect()
Bool_t RecvProcessIDs(TMessage *mess)
Receive a message containing process ids.
virtual Int_t Send(const TMessage &mess)
Send a TMessage object.
virtual Int_t SetOption(ESockOptions opt, Int_t val)
Set socket options.
static Int_t fgClientProtocol
virtual Int_t Recv(TMessage *&mess)
Receive a TMessage object.
This class represents an Internet Protocol (IP) address.
This class implements a mutex interface.
static ULong64_t GetSocketBytesRecv()
Get total number of bytes received via all sockets.
void SendStreamerInfos(const TMessage &mess)
Check if TStreamerInfo must be sent.
virtual Int_t SendObject(const TObject *obj, Int_t kind=kMESS_OBJECT)
Send an object.
void SetSecContext(TSecContext *ctx)
Option_t * GetOption() const
TInetAddress fLocalAddress
void SetServType(Int_t st)
TTimeStamp GetLastUsage()
virtual Int_t SendRaw(const void *buffer, Int_t length, ESendRecvOptions opt=kDefault)
Send a raw buffer of specified length.
TVirtualMutex * fLastUsageMtx
#define ClassDef(name, id)
The TNamed class is the base class for all named ROOT classes.
const char * GetUrl() const
static TSocket * CreateAuthSocket(const char *user, const char *host, Int_t port, Int_t size=0, Int_t tcpwindowsize=-1, TSocket *s=0, Int_t *err=0)
Creates a socket or a parallel socket and authenticates to the remote server specified in 'url' on re...
void Set()
Set Date/Time to current time as reported by the system.
Int_t GetRemoteProtocol() const
void SetCompressionLevel(Int_t level=1)
See comments for function SetCompressionSettings.
virtual Int_t GetLocalPort()
Return the local port # to which the socket is bound.
void SetDescriptor(Int_t desc)
virtual void Close(Option_t *opt="")
Close the socket.
virtual Int_t Select(Int_t interest=kRead, Long_t timeout=-1)
Waits for this socket to change status.
UInt_t GetBytesSent() const
Class providing the PROOF server.
static void NetError(const char *where, Int_t error)
Print error string depending on error code.
static ULong64_t GetSocketBytesSent()
Get total number of bytes sent via all sockets.
Int_t GetCompressionAlgorithm() const
void SetCompressionAlgorithm(Int_t algorithm=0)
See comments for function SetCompressionSettings.
#define R__LOCKGUARD2(mutex)
virtual TInetAddress GetLocalInetAddress()
Return internet address of local host to which the socket is bound.
TSocket & operator=(const TSocket &)
unsigned long long ULong64_t
The TTimeStamp encapsulates seconds and ns since EPOCH.
virtual Option_t * GetOption() const
virtual Bool_t IsAuthenticated() const
Mother of all ROOT objects.
static ULong64_t fgBytesSent
Int_t GetErrorCode() const
Returns error code.
TSecContext * GetSecContext() const
void SendProcessIDs(const TMessage &mess)
Check if TProcessIDs must be sent.
virtual Int_t GetDescriptor() const
static ULong64_t fgBytesRecv
static Int_t GetClientProtocol()
Static method returning supported client protocol.
TInetAddress GetInetAddress() const
void SetUrl(const char *url)
Int_t GetCompressionSettings() const
Int_t GetTcpWindowSize() const
void SetService(const char *service)
Class describing a PROOF worker server.
virtual Int_t RecvRaw(void *buffer, Int_t length, ESendRecvOptions opt=kDefault)
Receive a raw buffer of specified length bytes.
const char * GetService() const
TSecContext * fSecContext
Bool_t Authenticate(const char *user)
Authenticated the socket with specified user.