81 gROOT->GetListOfSockets()->Add(
this);
100 :
TNamed(
addr.GetHostName(),
""), fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
126 gROOT->GetListOfSockets()->Add(
this);
141 :
TNamed(host,
service), fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
165 gROOT->GetListOfSockets()->Add(
this);
184 :
TNamed(
TUrl(
url).GetHost(),
""), fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
213 gROOT->GetListOfSockets()->Add(
this);
225 fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
248 gROOT->GetListOfSockets()->Add(
this);
275 gROOT->GetListOfSockets()->Add(
this);
286 fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
309 gROOT->GetListOfSockets()->Add(
this);
336 gROOT->GetListOfSockets()->Add(
this);
353 gROOT->GetListOfSockets()->Remove(
this);
459 if (str)
mess.WriteString(str);
484 if (
mess.IsReading()) {
485 Error(
"Send",
"cannot send a message used for reading");
500 if (
mess.GetCompressionLevel() > 0)
505 if (
mess.CompBuffer()) {
540 Error(
"Send",
"bad acknowledgement");
562 mess.WriteObject(obj);
610 if (
mess.fInfos &&
mess.fInfos->GetEntries()) {
622 Info(
"SendStreamerInfos",
"sending TStreamerInfo: %s, version = %d",
623 info->GetName(),
info->GetClassVersion());
633 Warning(
"SendStreamerInfos",
"problems sending TStreamerInfo's ...");
645 if (
mess.TestBitNumber(0)) {
666 Info(
"SendProcessIDs",
"sending TProcessID: %s", pid->
GetTitle());
674 Warning(
"SendProcessIDs",
"problems sending TProcessID's ...");
691 if ((
n =
Recv(str, max, kind)) <= 0) {
700 Error(
"Recv",
"got message of wrong kind (expected %d, got %d)",
731 mess->ReadString(str, max);
790 if (
n == 0 ||
n == -5) {
801 char *buf =
new char[
len+
sizeof(
UInt_t)];
803 if (
n == 0 ||
n == -5) {
828 char ok[2] = {
'o',
'k' };
864 if (
length == 0)
return 0;
869 if (
n == 0 ||
n == -5) {
905 Info(
"RecvStreamerInfos",
"importing TStreamerInfo: %s, version = %d",
906 info->GetName(),
info->GetClassVersion());
911 lnk = list->FirstLink();
919 Info(
"RecvStreamerInfos",
"importing TStreamerInfo: %s, version = %d",
920 info->GetName(),
info->GetClassVersion());
957 Info(
"RecvProcessIDs",
"importing TProcessID: %s", pid->
GetTitle());
1025 if (level < 0) level = 0;
1026 if (level > 99) level = 99;
UShort_t net2host(UShort_t x)
R__EXTERN const char * gRootdErrStr[]
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...
R__EXTERN TVirtualMutex * gROOTMutex
R__EXTERN TSystem * gSystem
#define R__LOCKGUARD(mutex)
Bool_t TestBitNumber(UInt_t bitnumber) const
void SetBitNumber(UInt_t bitnumber, Bool_t value=kTRUE)
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.
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
Describes a persistent version of a class.
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.
void SetCompressionSettings(Int_t settings=ROOT::RCompressionSetting::EDefaults::kUseCompiledDefault)
Used to specify the compression level and algorithm: settings = 100 * algorithm + level.
Int_t GetErrorCode() const
Returns error code.
Bool_t RecvStreamerInfos(TMessage *mess)
Receive a message containing streamer infos.
virtual TInetAddress GetLocalInetAddress()
Return internet address of local host to which the socket is bound.
TInetAddress fLocalAddress
void SetCompressionLevel(Int_t level=ROOT::RCompressionSetting::ELevel::kUseMin)
See comments for function SetCompressionSettings.
virtual Int_t RecvRaw(void *buffer, Int_t length, ESendRecvOptions opt=kDefault)
Receive a raw buffer of specified length bytes.
TVirtualMutex * fLastUsageMtx
virtual Int_t GetLocalPort()
Return the local port # to which the socket is bound.
static ULong64_t fgBytesRecv
Bool_t RecvProcessIDs(TMessage *mess)
Receive a message containing process ids.
virtual Bool_t IsValid() const
static void NetError(const char *where, Int_t error)
Print error string depending on error code.
void SetCompressionAlgorithm(Int_t algorithm=ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
See comments for function SetCompressionSettings.
virtual Int_t Recv(TMessage *&mess)
Receive a TMessage object.
virtual void Close(Option_t *opt="")
Close the socket.
virtual Int_t SetOption(ESockOptions opt, Int_t val)
Set socket options.
static ULong64_t fgBytesSent
Int_t GetCompressionLevel() const
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.
static ULong64_t GetSocketBytesRecv()
Get total number of bytes received via all sockets.
virtual Int_t Send(const TMessage &mess)
Send a TMessage object.
Option_t * GetOption() const override
static ULong64_t GetSocketBytesSent()
Get total number of bytes sent via all sockets.
virtual Int_t Select(Int_t interest=kRead, Long_t timeout=-1)
Waits for this socket to change status.
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.
TSecContext * fSecContext
This class represents a WWW compatible URL.
Namespace for new ROOT classes and functions.
@ 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)