56 :
TNamed(addr.GetHostName(), service), fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
83 gROOT->GetListOfSockets()->Add(
this);
102 :
TNamed(addr.GetHostName(),
""), fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
130 gROOT->GetListOfSockets()->Add(
this);
145 :
TNamed(host, service), fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
171 gROOT->GetListOfSockets()->Add(
this);
190 :
TNamed(
TUrl(url).GetHost(),
""), fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
221 gROOT->GetListOfSockets()->Add(
this);
233 fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
256 gROOT->GetListOfSockets()->Add(
this);
283 gROOT->GetListOfSockets()->Add(
this);
294 fCompress(
ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
317 gROOT->GetListOfSockets()->Add(
this);
344 gROOT->GetListOfSockets()->Add(
this);
361 gROOT->GetListOfSockets()->Remove(
this);
432 if ((nsent =
Send(mess)) < 0)
451 if ((nsent =
Send(mess)) < 0)
470 if ((nsent =
Send(mess)) < 0)
473 return nsent -
sizeof(
Int_t);
493 Error(
"Send",
"cannot send a message used for reading");
511 char *mbuf = mess.
Buffer();
547 if (strncmp(buf,
"ok", 2)) {
548 Error(
"Send",
"bad acknowledgement");
557 return nsent -
sizeof(
UInt_t);
574 if ((nsent =
Send(mess)) < 0)
628 minilist =
new TList();
630 Info(
"SendStreamerInfos",
"sending TStreamerInfo: %s, version = %d",
640 if (
Send(messinfo) < 0)
641 Warning(
"SendStreamerInfos",
"problems sending TStreamerInfo's ...");
658 for (
Int_t ipid = 0; ipid < npids; ipid++) {
672 minilist =
new TList();
674 Info(
"SendProcessIDs",
"sending TProcessID: %s", pid->
GetTitle());
681 if (
Send(messpid) < 0)
682 Warning(
"SendProcessIDs",
"problems sending TProcessID's ...");
699 if ((
n =
Recv(str, max, kind)) <= 0) {
708 Error(
"Recv",
"got message of wrong kind (expected %d, got %d)",
728 if ((
n =
Recv(mess)) <= 0) {
761 if ((
n =
Recv(mess)) <= 0) {
798 if (
n == 0 ||
n == -5) {
809 char *buf =
new char[len+
sizeof(
UInt_t)];
811 if (
n == 0 ||
n == -5) {
836 char ok[2] = {
'o',
'k' };
872 if (length == 0)
return 0;
877 if (
n == 0 ||
n == -5) {
909 Bool_t isstl = element && strcmp(
"This",element->
GetName())==0;
913 Info(
"RecvStreamerInfos",
"importing TStreamerInfo: %s, version = %d",
923 Bool_t isstl = element && strcmp(
"This",element->
GetName())==0;
927 Info(
"RecvStreamerInfos",
"importing TStreamerInfo: %s, version = %d",
954 TIter nextpid(pidslist);
965 Info(
"RecvProcessIDs",
"importing TProcessID: %s", pid->
GetTitle());
1033 if (level < 0) level = 0;
1034 if (level > 99) level = 99;
UShort_t net2host(UShort_t x)
R__EXTERN const char * gRootdErrStr[]
unsigned long long ULong64_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)
TObject * ReadObject(const TClass *cl) override
Read object from I/O buffer.
void WriteString(const char *s) override
Write string to I/O buffer.
char * ReadString(char *s, Int_t max) override
Read string from I/O buffer.
void WriteObject(const TObject *obj, Bool_t cacheReuse=kTRUE) override
Write object to I/O buffer.
virtual Int_t GetEntries() const
This class represents an Internet Protocol (IP) address.
const char * GetHostName() const
virtual void Add(TObject *obj)
virtual TObject * FindObject(const char *name) const
Find an object in this list using its name.
virtual TObjLink * FirstLink() const
virtual void Clear(Option_t *option="")
Remove all objects from the list.
void SetLength() const
Set the message length at the beginning of the message buffer.
Bool_t TestBitNumber(UInt_t bitnumber) const
char * CompBuffer() const
Int_t Compress()
Compress the message.
Int_t GetCompressionLevel() const
void SetWhat(UInt_t what)
Using this method one can change the message type a-posteriori In case you OR "what" with kMESS_ACK,...
The TNamed class is the base class for all named ROOT classes.
virtual void SetTitle(const char *title="")
Set the title of the TNamed.
virtual void SetName(const char *name)
Set the name of the TNamed.
virtual const char * GetTitle() const
Returns title of object.
virtual const char * GetName() const
Returns name of object.
Int_t IndexOf(const TObject *obj) const
Int_t GetEntries() const
Return the number of objects in array (i.e.
TObject * UncheckedAt(Int_t i) const
TObject * At(Int_t idx) const
Wrapper around a TObject so it can be stored in a TList.
TObject * GetObject() const
Collectable string class.
Mother of all ROOT objects.
virtual const char * GetName() const
Returns name of object.
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
Describe Streamer information for one class version.
TObjArray * GetElements() const
void BuildCheck(TFile *file=0, Bool_t load=kTRUE)
Check if built and consistent with the class dictionary.
Int_t GetClassVersion() 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.
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.
Option_t * GetOption() const
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.
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.
tbb::task_arena is an alias of tbb::interface7::task_arena, which doesn't allow to forward declare tb...
@ 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)