102 gROOT->GetListOfSockets()->Add(
this);
120 :
TNamed(
addr.GetHostName(),
""), fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
146 gROOT->GetListOfSockets()->Add(
this);
161 :
TNamed(host,
service), fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
185 gROOT->GetListOfSockets()->Add(
this);
204 :
TNamed(
TUrl(
url).GetHost(),
""), fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
233 gROOT->GetListOfSockets()->Add(
this);
245 fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
268 gROOT->GetListOfSockets()->Add(
this);
295 gROOT->GetListOfSockets()->Add(
this);
306 fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
329 gROOT->GetListOfSockets()->Add(
this);
356 gROOT->GetListOfSockets()->Add(
this);
388 gROOT->GetListOfSockets()->Remove(
this);
494 if (str)
mess.WriteString(str);
519 if (
mess.IsReading()) {
520 Error(
"Send",
"cannot send a message used for reading");
535 if (
mess.GetCompressionLevel() > 0)
540 if (
mess.CompBuffer()) {
573 Error(
"Send",
"bad acknowledgement");
595 mess.WriteObject(obj);
642 if (
mess.fInfos &&
mess.fInfos->GetEntries()) {
654 Info(
"SendStreamerInfos",
"sending TStreamerInfo: %s, version = %d",
655 info->GetName(),
info->GetClassVersion());
665 Warning(
"SendStreamerInfos",
"problems sending TStreamerInfo's ...");
677 if (
mess.TestBitNumber(0)) {
699 Info(
"SendProcessIDs",
"sending TProcessID: %s", pid->
GetTitle());
707 Warning(
"SendProcessIDs",
"problems sending TProcessID's ...");
724 if ((
n =
Recv(str, max, kind)) <= 0) {
733 Error(
"Recv",
"got message of wrong kind (expected %d, got %d)",
764 mess->ReadString(str, max);
823 if (
n == 0 ||
n == -5) {
833 char *buf =
new char[
len+
sizeof(
UInt_t)];
835 if (
n == 0 ||
n == -5) {
859 char ok[2] = {
'o',
'k' };
894 if (
length == 0)
return 0;
899 if (
n == 0 ||
n == -5) {
934 Info(
"RecvStreamerInfos",
"importing TStreamerInfo: %s, version = %d",
935 info->GetName(),
info->GetClassVersion());
940 lnk = list->FirstLink();
948 Info(
"RecvStreamerInfos",
"importing TStreamerInfo: %s, version = %d",
949 info->GetName(),
info->GetClassVersion());
986 Info(
"RecvProcessIDs",
"importing TProcessID: %s", pid->
GetTitle());
1053 if (level < 0) level = 0;
1054 if (level > 99) level = 99;
1103 if (
sproto.Contains(
"sockd")) {
1105 }
else if (
sproto.Contains(
"rootd")) {
1109 Info(
"Authenticate",
"Local protocol: %s",
sproto.Data());
1155 gROOT->GetPluginManager()->FindHandler(
"TVirtualAuth",
alib);
1156 if (!
h ||
h->LoadPlugin() != 0) {
1157 Error(
"Authenticate",
1158 "could not load properly %s authentication plugin",
alib.Data());
1165 Error(
"Authenticate",
"could not instantiate the interface class");
1169 Info(
"Authenticate",
"class for '%s' authentication loaded",
alib.Data());
1172 if (!(
auth->Authenticate(
this, host, user,
opts))) {
1173 Error(
"Authenticate",
1174 "authentication attempt failed for %s@%s", user, host.
Data());
1184 Warning(
"Authenticate",
"problem sending kROOTD_USER (%s,%s)",
u->fUser.Data(), user);
1188 Warning(
"Authenticate",
"problem sending kROOTD_USER (-1,%s)", user);
1194 if (
Recv(stat, kind) > 0) {
1205 Info(
"Authenticate",
"no authentication required remotely");
1211 Info(
"Authenticate",
"expected message type %d, received %d",
1216 Info(
"Authenticate",
"error receiving message");
1276 if (
proto.EndsWith(
"up") ||
proto.EndsWith(
"ug")) {
1280 }
else if (
proto.EndsWith(
"s") ||
proto.EndsWith(
"k") ||
1281 proto.EndsWith(
"g") ||
proto.EndsWith(
"h")) {
1288 if ((
proto.EndsWith(
"p") ||
size > 1) ||
1289 proto.BeginsWith(
"root") ) {
1291 if (
proto.EndsWith(
"p"))
1296 if (!
proto.BeginsWith(
"sock") &&
1297 !
proto.BeginsWith(
"root"))
1318 if (sock && sock->
IsValid()) {
1336 if (
eurl.Contains(
"?"))
1413 if (!user ||
strlen(user) > 0) {
1421 eurl += (port > 0 ? port : 0);
UShort_t net2host(UShort_t x)
R__EXTERN const char * gRootdErrStr[]
size_t size(const MatrixT &matrix)
retrieve the size of a square matrix
int Int_t
Signed integer 4 bytes (int)
long Long_t
Signed long integer 4 bytes (long). Size depends on architecture.
unsigned int UInt_t
Unsigned integer 4 bytes (unsigned int)
unsigned long long ULong64_t
Portable unsigned long integer 8 bytes.
const char Option_t
Option string (const char)
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 length
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 UChar_t len
Int_t gDebug
Global variable setting the debug level. Set to 0 to disable, increase it in steps of 1 to increase t...
TVirtualMutex * gSocketAuthMutex
char * Form(const char *fmt,...)
Formats a string in a circular formatting buffer.
R__EXTERN TSystem * gSystem
#define R__LOCKGUARD2(mutex)
Bool_t TestBitNumber(UInt_t bitnumber) const
void SetBitNumber(UInt_t bitnumber, Bool_t value=kTRUE)
virtual void SetOwner(Bool_t enable=kTRUE)
Set whether this collection is the owner (enable==true) of its content.
This class represents an Internet Protocol (IP) address.
const char * GetHostName() const
TObject * FindObject(const char *name) const override
Find an object in this list using its name.
void Add(TObject *obj) override
Int_t Compress()
Compress the message.
The TNamed class is the base class for all named ROOT classes.
virtual void SetTitle(const char *title="")
Set the title of the TNamed.
const char * GetTitle() const override
Returns title of object.
virtual void SetName(const char *name)
Set the name of the TNamed.
Wrapper around a TObject so it can be stored in a TList.
Collectable string class.
Mother of all ROOT objects.
R__ALWAYS_INLINE Bool_t TestBit(UInt_t f) const
virtual UInt_t GetUniqueID() const
Return the unique object id.
virtual void Warning(const char *method, const char *msgfmt,...) const
Issue warning message.
void SetBit(UInt_t f, Bool_t set)
Set or unset the user status bits as specified in f.
virtual void Error(const char *method, const char *msgfmt,...) const
Issue error message.
virtual void SetUniqueID(UInt_t uid)
Set the unique object id.
virtual void Info(const char *method, const char *msgfmt,...) const
Issue info message.
A TProcessID identifies a ROOT job in a unique way in time and space.
Int_t IncrementCount()
Increase the reference count to this object.
static TObjArray * GetPIDs()
static: returns array of TProcessIDs
virtual Int_t SetOption(ESockOptions opt, Int_t val)
Set socket options.
Int_t GetErrorCode() const
Returns error code.
TVirtualMutex * fLastUsageMtx
void SetCompressionLevel(Int_t level=ROOT::RCompressionSetting::ELevel::kUseMin)
See comments for function SetCompressionSettings.
void SendStreamerInfos(const TMessage &mess)
Check if TStreamerInfo must be sent.
void SetCompressionAlgorithm(Int_t algorithm=ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
See comments for function SetCompressionSettings.
static ULong64_t GetSocketBytesSent()
Get total number of bytes sent via all sockets.
Bool_t RecvStreamerInfos(TMessage *mess)
Receive a message containing streamer infos.
virtual Int_t Recv(TMessage *&mess)
Receive a TMessage object.
static Int_t GetClientProtocol()
Static method returning supported client protocol.
Bool_t Authenticate(const char *user)
Authenticated the socket with specified user.
TInetAddress fLocalAddress
static ULong64_t fgBytesRecv
virtual void Close(Option_t *opt="")
Close the socket.
void MarkBrokenConnection()
Close the socket and mark as due to a broken connection.
Bool_t RecvProcessIDs(TMessage *mess)
Receive a message containing process ids.
TInetAddress GetInetAddress() const
Int_t GetCompressionLevel() const
virtual Int_t RecvRaw(void *buffer, Int_t length, ESendRecvOptions opt=kDefault)
Receive a raw buffer of specified length bytes.
static ULong64_t fgBytesSent
virtual Int_t SendRaw(const void *buffer, Int_t length, ESendRecvOptions opt=kDefault)
Send a raw buffer of specified length.
void SendProcessIDs(const TMessage &mess)
Check if TProcessIDs must be sent.
static Int_t fgClientProtocol
virtual TInetAddress GetLocalInetAddress()
Return internet address of local host to which the socket is bound.
TSecContext * fSecContext
virtual Int_t Select(Int_t interest=kRead, Long_t timeout=-1)
Waits for this socket to change status.
virtual Int_t GetLocalPort()
Return the local port # to which the socket is bound.
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...
static void NetError(const char *where, Int_t error)
Print error string depending on error code.
virtual Int_t SendObject(const TObject *obj, Int_t kind=kMESS_OBJECT)
Send an object.
void SetCompressionSettings(Int_t settings=ROOT::RCompressionSetting::EDefaults::kUseCompiledDefault)
Used to specify the compression level and algorithm: settings = 100 * algorithm + level.
virtual Bool_t IsValid() const
virtual Int_t Send(const TMessage &mess)
Send a TMessage object.
virtual Bool_t IsAuthenticated() const
static ULong64_t GetSocketBytesRecv()
Get total number of bytes received via all sockets.
Describes a persistent version of a class.
const char * Data() const
void Form(const char *fmt,...)
Formats a string using a printf style format descriptor.
Bool_t Contains(const char *pat, ECaseCompare cmp=kExact) const
virtual int GetServiceByName(const char *service)
Get port # of internet service.
virtual TInetAddress GetSockName(int sock)
Get Internet Protocol (IP) address of host and port #.
static void ResetErrno()
Static function resetting system error number.
virtual char * GetServiceByPort(int port)
Get name of internet service.
virtual int SetSockOpt(int sock, int kind, int val)
Set socket option.
virtual TInetAddress GetPeerName(int sock)
Get Internet Protocol (IP) address of remote host and port #.
virtual int OpenConnection(const char *server, int port, int tcpwindowsize=-1, const char *protocol="tcp")
Open a connection to another host.
virtual int GetSockOpt(int sock, int kind, int *val)
Get socket option.
virtual int RecvRaw(int sock, void *buffer, int length, int flag)
Receive exactly length bytes into buffer.
virtual Int_t Select(TList *active, Long_t timeout)
Select on active file descriptors (called by TMonitor).
virtual TInetAddress GetHostByName(const char *server)
Get Internet Protocol (IP) address of host.
virtual int SendRaw(int sock, const void *buffer, int length, int flag)
Send exactly length bytes from buffer.
virtual void CloseConnection(int sock, Bool_t force=kFALSE)
Close socket connection.
virtual UserGroup_t * GetUserInfo(Int_t uid)
Returns all user info in the UserGroup_t structure.
This class represents a WWW compatible URL.
const char * GetProtocol() const
This class implements a mutex interface.
@ kUndefined
Undefined compression algorithm (must be kept the last of the list in case a new algorithm is added).
@ kUseMin
Compression level reserved when we are not sure what to use (1 is for the fastest compression)