Logo ROOT  
Reference Guide
 
Loading...
Searching...
No Matches
TSocket.h
Go to the documentation of this file.
1// @(#)root/net:$Id$
2// Author: Fons Rademakers 18/12/96
3
4/*************************************************************************
5 * Copyright (C) 1995-2000, Rene Brun and Fons Rademakers. *
6 * All rights reserved. *
7 * *
8 * For the licensing terms see $ROOTSYS/LICENSE. *
9 * For the list of contributors see $ROOTSYS/README/CREDITS. *
10 *************************************************************************/
11
12#ifndef ROOT_TSocket
13#define ROOT_TSocket
14
15
16//////////////////////////////////////////////////////////////////////////
17// //
18// TSocket //
19// //
20// This class implements client sockets. A socket is an endpoint for //
21// communication between two machines. //
22// The actual work is done via the TSystem class (either TUnixSystem, //
23// or TWinNTSystem). //
24// //
25//////////////////////////////////////////////////////////////////////////
26
27#include "TSystem.h"
28#include "Compression.h"
29#include "TNamed.h"
30#include "TBits.h"
31#include "TInetAddress.h"
32#include "MessageTypes.h"
33#include "TVirtualAuth.h"
34#include "TSecContext.h"
35#include "TTimeStamp.h"
36#include "TVirtualMutex.h"
37
38class TMessage;
39class THostAuth;
40
41class TSocket : public TNamed {
42
43friend class TServerSocket;
44
45public:
46 enum EStatusBits { kIsUnix = BIT(16), // set if unix socket
47 kBrokenConn = BIT(17) // set if conn reset by peer or broken
48 };
49 enum EInterest { kRead = 1, kWrite = 2 };
51
52protected:
57 TInetAddress fAddress; // remote internet address and port #
58 UInt_t fBytesRecv; // total bytes received over this socket
59 UInt_t fBytesSent; // total bytes sent using this socket
60 Int_t fCompress; // Compression level and algorithm
61 TInetAddress fLocalAddress; // local internet address and port #
62 Int_t fRemoteProtocol; // protocol of remote daemon
63 TSecContext *fSecContext; // after a successful Authenticate call
64 // points to related security context
65 TString fService; // name of service (matches remote port #)
66 EServiceType fServType; // remote service type
67 Int_t fSocket; // socket descriptor
68 Int_t fTcpWindowSize; // TCP window size (default 65535);
69 TString fUrl; // needs this for special authentication options
70 TBits fBitsInfo; // bits array to mark TStreamerInfo classes already sent
71 TList *fUUIDs; // list of TProcessIDs already sent through the socket
72
73 TVirtualMutex *fLastUsageMtx; // Protect last usage setting / reading
74 TTimeStamp fLastUsage; // Time stamp of last usage
75
76 static ULong64_t fgBytesRecv; // total bytes received by all socket objects
77 static ULong64_t fgBytesSent; // total bytes sent by all socket objects
78
79 static Int_t fgClientProtocol; // client "protocol" version
80
81 TSocket() : fAddress(), fBytesRecv(0), fBytesSent(0), fCompress(ROOT::RCompressionSetting::EAlgorithm::kUseGlobal),
84 fBitsInfo(), fUUIDs(nullptr), fLastUsageMtx(nullptr), fLastUsage() {}
85
86 Bool_t Authenticate(const char *user);
87 void SetDescriptor(Int_t desc) { fSocket = desc; }
88 void SendStreamerInfos(const TMessage &mess);
90 void SendProcessIDs(const TMessage &mess);
93
94private:
95 TSocket& operator=(const TSocket &) = delete;
96 Option_t *GetOption() const override { return TObject::GetOption(); }
97
98public:
99 TSocket(TInetAddress address, const char *service, Int_t tcpwindowsize = -1);
100 TSocket(TInetAddress address, Int_t port, Int_t tcpwindowsize = -1);
101 TSocket(const char *host, const char *service, Int_t tcpwindowsize = -1);
102 TSocket(const char *host, Int_t port, Int_t tcpwindowsize = -1);
103 TSocket(const char *sockpath);
105 TSocket(Int_t descriptor, const char *sockpath);
106 TSocket(const TSocket &s);
107 virtual ~TSocket() { Close(); }
108
109 virtual void Close(Option_t *opt="");
110 virtual Int_t GetDescriptor() const { return fSocket; }
113 Int_t GetPort() const { return fAddress.GetPort(); }
114 const char *GetService() const { return fService; }
115 Int_t GetServType() const { return (Int_t)fServType; }
116 virtual Int_t GetLocalPort();
117 UInt_t GetBytesSent() const { return fBytesSent; }
118 UInt_t GetBytesRecv() const { return fBytesRecv; }
122 Int_t GetErrorCode() const;
123 virtual Int_t GetOption(ESockOptions opt, Int_t &val);
128 const char *GetUrl() const { return fUrl.Data(); }
129 virtual Bool_t IsAuthenticated() const { return fSecContext ? kTRUE : kFALSE; }
130 virtual Bool_t IsValid() const { return fSocket < 0 ? kFALSE : kTRUE; }
131 virtual Int_t Recv(TMessage *&mess);
132 virtual Int_t Recv(Int_t &status, Int_t &kind);
133 virtual Int_t Recv(char *mess, Int_t max);
134 virtual Int_t Recv(char *mess, Int_t max, Int_t &kind);
135 virtual Int_t RecvRaw(void *buffer, Int_t length, ESendRecvOptions opt = kDefault);
136 virtual Int_t Reconnect() { return -1; }
137 virtual Int_t Select(Int_t interest = kRead, Long_t timeout = -1);
138 virtual Int_t Send(const TMessage &mess);
139 virtual Int_t Send(Int_t kind);
140 virtual Int_t Send(Int_t status, Int_t kind);
141 virtual Int_t Send(const char *mess, Int_t kind = kMESS_STRING);
142 virtual Int_t SendObject(const TObject *obj, Int_t kind = kMESS_OBJECT);
143 virtual Int_t SendRaw(const void *buffer, Int_t length,
148 virtual Int_t SetOption(ESockOptions opt, Int_t val);
151 void SetService(const char *service) { fService = service; }
153 void SetUrl(const char *url) { fUrl = url; }
154
156
157 static Int_t GetClientProtocol();
158
161
162 static TSocket *CreateAuthSocket(const char *user, const char *host,
163 Int_t port, Int_t size = 0,
164 Int_t tcpwindowsize = -1, TSocket *s = nullptr, Int_t *err = nullptr);
165 static TSocket *CreateAuthSocket(const char *url, Int_t size = 0,
166 Int_t tcpwindowsize = -1, TSocket *s = nullptr, Int_t *err = nullptr);
167 static void NetError(const char *where, Int_t error);
168
169 ClassDefOverride(TSocket,0) //This class implements client sockets
170};
171
172//______________________________________________________________________________
174{
175 return (fCompress < 0) ? -1 : fCompress / 100;
176}
177
178//______________________________________________________________________________
180{
181 return (fCompress < 0) ? -1 : fCompress % 100;
182}
183
184//______________________________________________________________________________
186{
187 return (fCompress < 0) ? -1 : fCompress;
188}
189
190#endif
@ kMESS_STRING
@ kMESS_OBJECT
size_t size(const MatrixT &matrix)
retrieve the size of a square matrix
bool Bool_t
Boolean (0=false, 1=true) (bool)
Definition RtypesCore.h:77
int Int_t
Signed integer 4 bytes (int)
Definition RtypesCore.h:59
long Long_t
Signed long integer 4 bytes (long). Size depends on architecture.
Definition RtypesCore.h:68
constexpr Bool_t kFALSE
Definition RtypesCore.h:108
unsigned long long ULong64_t
Portable unsigned long integer 8 bytes.
Definition RtypesCore.h:84
constexpr Bool_t kTRUE
Definition RtypesCore.h:107
const char Option_t
Option string (const char)
Definition RtypesCore.h:80
#define BIT(n)
Definition Rtypes.h:91
#define ClassDefOverride(name, id)
Definition Rtypes.h:348
ROOT::Detail::TRangeCast< T, true > TRangeDynCast
TRangeDynCast is an adapter class that allows the typed iteration through a TCollection.
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 length
ESockOptions
Definition TSystem.h:229
ESendRecvOptions
Definition TSystem.h:242
@ kDefault
Definition TSystem.h:243
#define R__LOCKGUARD2(mutex)
Container of bits.
Definition TBits.h:26
This class represents an Internet Protocol (IP) address.
Int_t GetPort() const
A doubly linked list.
Definition TList.h:38
The TNamed class is the base class for all named ROOT classes.
Definition TNamed.h:29
Mother of all ROOT objects.
Definition TObject.h:41
virtual Option_t * GetOption() const
Definition TObject.h:145
TInetAddress fAddress
Definition TSocket.h:57
Int_t fCompress
Definition TSocket.h:60
virtual Int_t SetOption(ESockOptions opt, Int_t val)
Set socket options.
Definition TSocket.cxx:1005
Int_t fSocket
Definition TSocket.h:67
Int_t GetErrorCode() const
Returns error code.
Definition TSocket.cxx:1027
void SetServType(Int_t st)
Definition TSocket.h:152
TVirtualMutex * fLastUsageMtx
Definition TSocket.h:73
UInt_t GetBytesRecv() const
Definition TSocket.h:118
void SetRemoteProtocol(Int_t rproto)
Definition TSocket.h:149
void SetCompressionLevel(Int_t level=ROOT::RCompressionSetting::ELevel::kUseMin)
See comments for function SetCompressionSettings.
Definition TSocket.cxx:1052
void SendStreamerInfos(const TMessage &mess)
Check if TStreamerInfo must be sent.
Definition TSocket.cxx:641
ESocketErrors
Definition TSocket.h:53
@ kInvalidStillInList
Definition TSocket.h:55
@ kInvalid
Definition TSocket.h:54
TString fUrl
Definition TSocket.h:69
const char * GetService() const
Definition TSocket.h:114
void SetCompressionAlgorithm(Int_t algorithm=ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
See comments for function SetCompressionSettings.
Definition TSocket.cxx:1038
TSocket()
Definition TSocket.h:81
static ULong64_t GetSocketBytesSent()
Get total number of bytes sent via all sockets.
Definition TSocket.cxx:1456
TTimeStamp GetLastUsage()
Definition TSocket.h:127
TString fService
Definition TSocket.h:65
Bool_t RecvStreamerInfos(TMessage *mess)
Receive a message containing streamer infos.
Definition TSocket.cxx:920
EInterest
Definition TSocket.h:49
@ kRead
Definition TSocket.h:49
@ kWrite
Definition TSocket.h:49
virtual Int_t Recv(TMessage *&mess)
Receive a TMessage object.
Definition TSocket.cxx:810
TList * fUUIDs
Definition TSocket.h:71
static Int_t GetClientProtocol()
Static method returning supported client protocol.
Definition TSocket.cxx:1436
TBits fBitsInfo
Definition TSocket.h:70
void SetService(const char *service)
Definition TSocket.h:151
Int_t GetRemoteProtocol() const
Definition TSocket.h:124
UInt_t GetBytesSent() const
Definition TSocket.h:117
Bool_t Authenticate(const char *user)
Authenticated the socket with specified user.
Definition TSocket.cxx:1098
TInetAddress fLocalAddress
Definition TSocket.h:61
Int_t GetTcpWindowSize() const
Definition TSocket.h:126
static ULong64_t fgBytesRecv
Definition TSocket.h:76
EStatusBits
Definition TSocket.h:46
@ kIsUnix
Definition TSocket.h:46
@ kBrokenConn
Definition TSocket.h:47
virtual void Close(Option_t *opt="")
Close the socket.
Definition TSocket.cxx:381
void MarkBrokenConnection()
Close the socket and mark as due to a broken connection.
Definition TSocket.cxx:363
void Touch()
Definition TSocket.h:155
Bool_t RecvProcessIDs(TMessage *mess)
Receive a message containing process ids.
Definition TSocket.cxx:967
void SetUrl(const char *url)
Definition TSocket.h:153
TInetAddress GetInetAddress() const
Definition TSocket.h:111
Int_t GetCompressionLevel() const
Definition TSocket.h:179
virtual Int_t RecvRaw(void *buffer, Int_t length, ESendRecvOptions opt=kDefault)
Receive a raw buffer of specified length bytes.
Definition TSocket.cxx:890
TSecContext * GetSecContext() const
Definition TSocket.h:125
static ULong64_t fgBytesSent
Definition TSocket.h:77
virtual Int_t SendRaw(const void *buffer, Int_t length, ESendRecvOptions opt=kDefault)
Send a raw buffer of specified length.
Definition TSocket.cxx:612
TTimeStamp fLastUsage
Definition TSocket.h:74
void SendProcessIDs(const TMessage &mess)
Check if TProcessIDs must be sent.
Definition TSocket.cxx:676
static Int_t fgClientProtocol
Definition TSocket.h:79
virtual TInetAddress GetLocalInetAddress()
Return internet address of local host to which the socket is bound.
Definition TSocket.cxx:401
TSecContext * fSecContext
Definition TSocket.h:63
virtual Int_t Select(Int_t interest=kRead, Long_t timeout=-1)
Waits for this socket to change status.
Definition TSocket.cxx:435
virtual Int_t GetLocalPort()
Return the local port # to which the socket is bound.
Definition TSocket.cxx:415
virtual ~TSocket()
Definition TSocket.h:107
void SetDescriptor(Int_t desc)
Definition TSocket.h:87
Int_t fTcpWindowSize
Definition TSocket.h:68
Option_t * GetOption() const override
Definition TSocket.h:96
EServiceType
Definition TSocket.h:50
@ kSOCKD
Definition TSocket.h:50
@ kROOTD
Definition TSocket.h:50
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...
Definition TSocket.cxx:1399
static void NetError(const char *where, Int_t error)
Print error string depending on error code.
Definition TSocket.cxx:1444
virtual Int_t GetDescriptor() const
Definition TSocket.h:110
Int_t GetCompressionSettings() const
Definition TSocket.h:185
Int_t GetPort() const
Definition TSocket.h:113
Int_t GetServType() const
Definition TSocket.h:115
EServiceType fServType
Definition TSocket.h:66
TSocket & operator=(const TSocket &)=delete
virtual Int_t SendObject(const TObject *obj, Int_t kind=kMESS_OBJECT)
Send an object.
Definition TSocket.cxx:592
void SetCompressionSettings(Int_t settings=ROOT::RCompressionSetting::EDefaults::kUseCompiledDefault)
Used to specify the compression level and algorithm: settings = 100 * algorithm + level.
Definition TSocket.cxx:1090
void SetSecContext(TSecContext *ctx)
Definition TSocket.h:150
UInt_t fBytesSent
Definition TSocket.h:59
Int_t fRemoteProtocol
Definition TSocket.h:62
UInt_t fBytesRecv
Definition TSocket.h:58
Int_t GetCompressionAlgorithm() const
Definition TSocket.h:173
virtual Bool_t IsValid() const
Definition TSocket.h:130
virtual Int_t Reconnect()
Definition TSocket.h:136
const char * GetUrl() const
Definition TSocket.h:128
virtual Int_t Send(const TMessage &mess)
Send a TMessage object.
Definition TSocket.cxx:514
virtual Bool_t IsAuthenticated() const
Definition TSocket.h:129
static ULong64_t GetSocketBytesRecv()
Get total number of bytes received via all sockets.
Definition TSocket.cxx:1464
Basic string class.
Definition TString.h:138
const char * Data() const
Definition TString.h:384
The TTimeStamp encapsulates seconds and ns since EPOCH.
Definition TTimeStamp.h:45
void Set()
Set Date/Time to current time as reported by the system.
This class implements a mutex interface.
Namespace for new ROOT classes and functions.
@ kUseGlobal
Use the global compression algorithm.
Definition Compression.h:93
@ kUseCompiledDefault
Use the compile-time default setting.
Definition Compression.h:53
@ kUseMin
Compression level reserved when we are not sure what to use (1 is for the fastest compression)
Definition Compression.h:72