Logo ROOT   6.16/01
Reference Guide
TPSocket.cxx
Go to the documentation of this file.
1// @(#)root/net:$Id$
2// Author: Fons Rademakers 22/1/2001
3
4/*************************************************************************
5 * Copyright (C) 1995-2001, 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//////////////////////////////////////////////////////////////////////////
13// //
14// TPSocket //
15// //
16// This class implements parallel client sockets. A parallel socket is //
17// an endpoint for communication between two machines. It is parallel //
18// because several TSockets are open at the same time to the same //
19// destination. This especially speeds up communication over Big Fat //
20// Pipes (i.e. high bandwidth, high latency WAN connections). //
21// //
22//////////////////////////////////////////////////////////////////////////
23
24#include "TPSocket.h"
25#include "TUrl.h"
26#include "TServerSocket.h"
27#include "TMonitor.h"
28#include "TSystem.h"
29#include "TMessage.h"
30#include "Bytes.h"
31#include "TROOT.h"
32#include "TError.h"
33#include "TVirtualMutex.h"
34
36
37////////////////////////////////////////////////////////////////////////////////
38/// Create a parallel socket. Connect to the named service at address addr.
39/// Use tcpwindowsize to specify the size of the receive buffer, it has
40/// to be specified here to make sure the window scale option is set (for
41/// tcpwindowsize > 65KB and for platforms supporting window scaling).
42/// Returns when connection has been accepted by remote side. Use IsValid()
43/// to check the validity of the socket. Every socket is added to the TROOT
44/// sockets list which will make sure that any open sockets are properly
45/// closed on program termination.
46
47TPSocket::TPSocket(TInetAddress addr, const char *service, Int_t size,
48 Int_t tcpwindowsize) : TSocket(addr, service)
49{
50 fSize = size;
51 Init(tcpwindowsize);
52}
53
54////////////////////////////////////////////////////////////////////////////////
55/// Create a parallel socket. Connect to the specified port # at address addr.
56/// Use tcpwindowsize to specify the size of the receive buffer, it has
57/// to be specified here to make sure the window scale option is set (for
58/// tcpwindowsize > 65KB and for platforms supporting window scaling).
59/// Returns when connection has been accepted by remote side. Use IsValid()
60/// to check the validity of the socket. Every socket is added to the TROOT
61/// sockets list which will make sure that any open sockets are properly
62/// closed on program termination.
63
65 Int_t tcpwindowsize) : TSocket(addr, port)
66{
67 fSize = size;
68 Init(tcpwindowsize);
69}
70
71////////////////////////////////////////////////////////////////////////////////
72/// Create a parallel socket. Connect to named service on the remote host.
73/// Use tcpwindowsize to specify the size of the receive buffer, it has
74/// to be specified here to make sure the window scale option is set (for
75/// tcpwindowsize > 65KB and for platforms supporting window scaling).
76/// Returns when connection has been accepted by remote side. Use IsValid()
77/// to check the validity of the socket. Every socket is added to the TROOT
78/// sockets list which will make sure that any open sockets are properly
79/// closed on program termination.
80
81TPSocket::TPSocket(const char *host, const char *service, Int_t size,
82 Int_t tcpwindowsize) : TSocket(host, service)
83{
84 fSize = size;
85 Init(tcpwindowsize);
86}
87
88////////////////////////////////////////////////////////////////////////////////
89/// Create a parallel socket. Connect to specified port # on the remote host.
90/// Use tcpwindowsize to specify the size of the receive buffer, it has
91/// to be specified here to make sure the window scale option is set (for
92/// tcpwindowsize > 65KB and for platforms supporting window scaling).
93/// Returns when connection has been accepted by remote side. Use IsValid()
94/// to check the validity of the socket. Every socket is added to the TROOT
95/// sockets list which will make sure that any open sockets are properly
96/// closed on program termination.
97
98TPSocket::TPSocket(const char *host, Int_t port, Int_t size,
99 Int_t tcpwindowsize)
100 : TSocket(host, port, (Int_t)(size > 1 ? -1 : tcpwindowsize))
101{
102 // To avoid uninitialization problems when Init is not called ...
103 fSockets = 0;
104 fWriteMonitor = 0;
105 fReadMonitor = 0;
106 fWriteBytesLeft = 0;
107 fReadBytesLeft = 0;
108 fWritePtr = 0;
109 fReadPtr = 0;
110
111 // set to the real value only at end (except for old servers)
112 fSize = 1;
113
114 // to control the flow
115 Bool_t valid = TSocket::IsValid();
116
117 // check if we are called from CreateAuthSocket()
118 Bool_t authreq = kFALSE;
119 char *pauth = (char *)strstr(host, "?A");
120 if (pauth) {
121 authreq = kTRUE;
122 }
123
124 // perhaps we can use fServType here ... to be checked
125 Bool_t rootdSrv = (strstr(host,"rootd")) ? kTRUE : kFALSE;
126
127 // try authentication , if required
128 if (authreq) {
129 if (valid) {
130 if (!Authenticate(TUrl(host).GetUser())) {
131 if (rootdSrv && (fRemoteProtocol > 0 && fRemoteProtocol < 10)) {
132 // We failed because we are talking to an old
133 // server: we need to re-open the connection
134 // and communicate the size first
135 Int_t tcpw = (size > 1 ? -1 : tcpwindowsize);
136 TSocket *ns = new TSocket(host, port, tcpw);
137 if (ns->IsValid()) {
139 gROOT->GetListOfSockets()->Remove(ns);
140 fSocket = ns->GetDescriptor();
141 fSize = size;
142 Init(tcpwindowsize);
143 }
144 if ((valid = IsValid())) {
145 if (!Authenticate(TUrl(host).GetUser())) {
147 valid = kFALSE;
148 }
149 }
150 } else {
152 valid = kFALSE;
153 }
154 }
155 }
156 // reset url to the original state
157 *pauth = '\0';
158 SetUrl(host);
159 }
160
161 // open the sockets ...
162 if (!rootdSrv || fRemoteProtocol > 9) {
163 if (valid) {
164 fSize = size;
165 Init(tcpwindowsize);
166 }
167 }
168}
169
170////////////////////////////////////////////////////////////////////////////////
171/// Create a parallel socket on a connection already opened via
172/// TSocket sock.
173/// This constructor is provided to optimize TNetFile opening when
174/// instatiated via a call to TXNetFile.
175/// Returns when connection has been accepted by remote side. Use IsValid()
176/// to check the validity of the socket. Every socket is added to the TROOT
177/// sockets list which will make sure that any open sockets are properly
178/// closed on program termination.
179
180TPSocket::TPSocket(const char *host, Int_t port, Int_t size, TSocket *sock)
181{
182 // To avoid uninitialization problems when Init is not called ...
183 fSockets = 0;
184 fWriteMonitor = 0;
185 fReadMonitor = 0;
186 fWriteBytesLeft = 0;
187 fReadBytesLeft = 0;
188 fWritePtr = 0;
189 fReadPtr = 0;
190
191 // set to the real value only at end (except for old servers)
192 fSize = 1;
193
194 // We need a opened connection
195 if (!sock) return;
196
197 // Now import existing socket info
198 fSocket = sock->GetDescriptor();
199 fService = sock->GetService();
200 fAddress = sock->GetInetAddress();
202 fBytesSent = sock->GetBytesSent();
203 fBytesRecv = sock->GetBytesRecv();
205 fSecContext = sock->GetSecContext();
209
210 // to control the flow
211 Bool_t valid = sock->IsValid();
212
213 // check if we are called from CreateAuthSocket()
214 Bool_t authreq = kFALSE;
215 char *pauth = (char *)strstr(host, "?A");
216 if (pauth) {
217 authreq = kTRUE;
218 }
219
220 // perhaps we can use fServType here ... to be checked
221 Bool_t rootdSrv = (strstr(host,"rootd")) ? kTRUE : kFALSE;
222
223 // try authentication , if required
224 if (authreq) {
225 if (valid) {
226 if (!Authenticate(TUrl(host).GetUser())) {
227 if (rootdSrv && (fRemoteProtocol > 0 && fRemoteProtocol < 10)) {
228 // We failed because we are talking to an old
229 // server: we need to re-open the connection
230 // and communicate the size first
231 Int_t tcpw = (size > 1 ? -1 : fTcpWindowSize);
232 TSocket *ns = new TSocket(host, port, tcpw);
233 if (ns->IsValid()) {
235 gROOT->GetListOfSockets()->Remove(ns);
236 fSocket = ns->GetDescriptor();
237 fSize = size;
239 }
240 if ((valid = IsValid())) {
241 if (!Authenticate(TUrl(host).GetUser())) {
243 valid = kFALSE;
244 }
245 }
246 } else {
248 valid = kFALSE;
249 }
250 }
251 }
252 // reset url to the original state
253 *pauth = '\0';
254 SetUrl(host);
255 }
256
257 // open the sockets ...
258 if (!rootdSrv || fRemoteProtocol > 9) {
259 if (valid) {
260 fSize = size;
261 Init(fTcpWindowSize, sock);
262 }
263 }
264
265 // Add to the list if everything OK
266 if (IsValid()) {
268 gROOT->GetListOfSockets()->Add(this);
269 }
270}
271
272////////////////////////////////////////////////////////////////////////////////
273/// Create a parallel socket. This ctor is called by TPServerSocket.
274
276{
277 fSockets = pSockets;
278 fSize = size;
279
280 // set descriptor if simple socket (needed when created
281 // by TPServerSocket)
282 if (fSize <= 1)
284
285 // set socket options (no blocking and no delay)
287 if (fSize > 1)
289
294 fWritePtr = new char*[fSize];
295 fReadPtr = new char*[fSize];
296
297 for (int i = 0; i < fSize; i++) {
300 }
303
304 SetName(fSockets[0]->GetName());
307
308 {
310 gROOT->GetListOfSockets()->Add(this);
311 }
312}
313
314////////////////////////////////////////////////////////////////////////////////
315/// Cleanup the parallel socket.
316
318{
319 Close();
320
321 delete fWriteMonitor;
322 delete fReadMonitor;
323 delete [] fWriteBytesLeft;
324 delete [] fReadBytesLeft;
325 delete [] fWritePtr;
326 delete [] fReadPtr;
327}
328
329////////////////////////////////////////////////////////////////////////////////
330/// Close a parallel socket. If option is "force", calls shutdown(id,2) to
331/// shut down the connection. This will close the connection also
332/// for the parent of this process. Also called via the dtor (without
333/// option "force", call explicitly Close("force") if this is desired).
334
336{
337
338 if (!IsValid()) {
339 // if closing happens too early (e.g. timeout) the underlying
340 // socket may still be open
341 TSocket::Close(option);
342 return;
343 }
344
345 if (fSize <= 1) {
346 TSocket::Close(option);
347 } else {
348 for (int i = 0; i < fSize; i++) {
349 fSockets[i]->Close(option);
350 delete fSockets[i];
351 }
352 }
353 delete [] fSockets;
354 fSockets = 0;
355
356 {
358 gROOT->GetListOfSockets()->Remove(this);
359 }
360}
361
362////////////////////////////////////////////////////////////////////////////////
363/// Create a parallel socket to the specified host.
364
365void TPSocket::Init(Int_t tcpwindowsize, TSocket *sock)
366{
367 fSockets = 0;
368 fWriteMonitor = 0;
369 fReadMonitor = 0;
370 fWriteBytesLeft = 0;
371 fReadBytesLeft = 0;
372 fWritePtr = 0;
373 fReadPtr = 0;
374
375 if ((sock && !sock->IsValid()) || !TSocket::IsValid())
376 return;
377
378 Int_t i = 0;
379
380 if (fSize <= 1) {
381 // check if single mode
382 fSize = 1;
383
384 // set socket options (no delay)
385 if (sock)
386 sock->SetOption(kNoDelay, 1);
387 else
389
390 // if yes, communicate this to server
391 // (size = 0 for backward compatibility)
392 if (sock) {
393 if (sock->Send((Int_t)0, (Int_t)0) < 0)
394 Warning("Init", "%p: problems sending (0,0)", sock);
395 } else {
396 if (TSocket::Send((Int_t)0, (Int_t)0) < 0)
397 Warning("Init", "problems sending (0,0)");
398 }
399
400 // needs to fill additional private members
401 fSockets = new TSocket*[1];
402 fSockets[0]= (TSocket *)this;
403
404 } else {
405
406 // create server that will be used to accept the parallel sockets from
407 // the remote host, use port=0 to scan for a free port
408 TServerSocket ss(0, kFALSE, fSize, tcpwindowsize);
409
410 // send the local port number of the just created server socket and the
411 // number of desired parallel sockets
412 if (sock) {
413 if (sock->Send(ss.GetLocalPort(), fSize) < 0)
414 Warning("Init", "%p: problems sending size", sock);
415 } else {
416 if (TSocket::Send(ss.GetLocalPort(), fSize) < 0)
417 Warning("Init", "problems sending size");
418 }
419
420 fSockets = new TSocket*[fSize];
421
422 // establish fSize parallel socket connections between client and server
423 for (i = 0; i < fSize; i++) {
424 fSockets[i] = ss.Accept();
426 gROOT->GetListOfSockets()->Remove(fSockets[i]);
427 }
428
429 // set socket options (no blocking and no delay)
432
433 // close original socket
434 if (sock)
435 sock->Close();
436 else
438 fSocket = -1;
439 }
440
445 fWritePtr = new char*[fSize];
446 fReadPtr = new char*[fSize];
447
448 for (i = 0; i < fSize; i++) {
451 }
454}
455
456////////////////////////////////////////////////////////////////////////////////
457/// Return internet address of local host to which the socket is bound.
458/// In case of error TInetAddress::IsValid() returns kFALSE.
459
461{
462 if (fSize<= 1)
464
465 if (IsValid()) {
466 if (fLocalAddress.GetPort() == -1)
468 return fLocalAddress;
469 }
470 return TInetAddress();
471}
472
473////////////////////////////////////////////////////////////////////////////////
474/// Return socket descriptor
475
477{
478 if (fSize <= 1)
479 return TSocket::GetDescriptor();
480
481 return fSockets ? fSockets[0]->GetDescriptor() : -1;
482
483}
484
485////////////////////////////////////////////////////////////////////////////////
486/// Send a TMessage object. Returns the number of bytes in the TMessage
487/// that were sent and -1 in case of error. In case the TMessage::What
488/// has been or'ed with kMESS_ACK, the call will only return after having
489/// received an acknowledgement, making the sending process synchronous.
490/// Returns -4 in case of kNoBlock and errno == EWOULDBLOCK.
491
493{
494 if (!fSockets || fSize <= 1)
495 return TSocket::Send(mess); // only the case when called via Init()
496
497 if (!IsValid()) {
498 return -1;
499 }
500
501 if (mess.IsReading()) {
502 Error("Send", "cannot send a message used for reading");
503 return -1;
504 }
505
506 // send streamer infos in case schema evolution is enabled in the TMessage
507 SendStreamerInfos(mess);
508
509 // send the process id's so TRefs work
510 SendProcessIDs(mess);
511
512 mess.SetLength(); //write length in first word of buffer
513
514 if (GetCompressionLevel() > 0 && mess.GetCompressionLevel() == 0)
515 const_cast<TMessage&>(mess).SetCompressionSettings(fCompress);
516
517 if (mess.GetCompressionLevel() > 0)
518 const_cast<TMessage&>(mess).Compress();
519
520 char *mbuf = mess.Buffer();
521 Int_t mlen = mess.Length();
522 if (mess.CompBuffer()) {
523 mbuf = mess.CompBuffer();
524 mlen = mess.CompLength();
525 }
526
527 Int_t nsent, ulen = (Int_t) sizeof(UInt_t);
528 // send length
529 if ((nsent = SendRaw(mbuf, ulen, kDefault)) <= 0)
530 return nsent;
531
532 // send buffer (this might go in parallel)
533 if ((nsent = SendRaw(mbuf+ulen, mlen-ulen, kDefault)) <= 0)
534 return nsent;
535
536 // if acknowledgement is desired, wait for it
537 if (mess.What() & kMESS_ACK) {
538 char buf[2];
539 if (RecvRaw(buf, sizeof(buf), kDefault) < 0)
540 return -1;
541 if (strncmp(buf, "ok", 2)) {
542 Error("Send", "bad acknowledgement");
543 return -1;
544 }
545 }
546
547 return nsent; //length - length header
548}
549
550////////////////////////////////////////////////////////////////////////////////
551/// Send a raw buffer of specified length. Returns the number of bytes
552/// send and -1 in case of error.
553
554Int_t TPSocket::SendRaw(const void *buffer, Int_t length, ESendRecvOptions opt)
555{
556 if (fSize == 1)
557 return TSocket::SendRaw(buffer,length,opt);
558
559 if (!fSockets) return -1;
560
561 // if data buffer size < 4K use only one socket
562 Int_t i, nsocks = fSize, len = length;
563 if (len < 4096)
564 nsocks = 1;
565
567 if (nsocks == 1)
568 sendopt = kDefault;
569
570 if (opt != kDefault) {
571 nsocks = 1;
572 sendopt = opt;
573 }
574
575 if (nsocks == 1)
577 else
579
580 // setup pointer appropriately for transferring data equally on the
581 // parallel sockets
582 for (i = 0; i < nsocks; i++) {
583 fWriteBytesLeft[i] = len/nsocks;
584 fWritePtr[i] = (char *)buffer + (i*fWriteBytesLeft[i]);
586 }
587 fWriteBytesLeft[nsocks-1] += len%nsocks;
588
589 // send the data on the parallel sockets
590 while (len > 0) {
592 for (int is = 0; is < nsocks; is++) {
593 if (s == fSockets[is]) {
594 if (fWriteBytesLeft[is] > 0) {
595 Int_t nsent;
596again:
598 if ((nsent = fSockets[is]->SendRaw(fWritePtr[is],
599 fWriteBytesLeft[is],
600 sendopt)) <= 0) {
601 if (nsent == -4) {
602 // got EAGAIN/EWOULDBLOCK error, keep trying...
603 goto again;
604 }
606 if (nsent == -5) {
607 // connection reset by peer or broken ...
609 Close();
610 }
611 return -1;
612 }
613 if (opt == kDontBlock) {
615 return nsent;
616 }
617 fWriteBytesLeft[is] -= nsent;
618 fWritePtr[is] += nsent;
619 len -= nsent;
620 }
621 }
622 }
623 }
625
626 return length;
627}
628
629////////////////////////////////////////////////////////////////////////////////
630/// Receive a TMessage object. The user must delete the TMessage object.
631/// Returns length of message in bytes (can be 0 if other side of connection
632/// is closed) or -1 in case of error or -4 in case a non-blocking socket would
633/// block (i.e. there is nothing to be read). In those case mess == 0.
634
636{
637 if (fSize <= 1)
638 return TSocket::Recv(mess);
639
640 if (!IsValid()) {
641 mess = 0;
642 return -1;
643 }
644
645oncemore:
646 Int_t n;
647 UInt_t len;
648 if ((n = RecvRaw(&len, sizeof(UInt_t), kDefault)) <= 0) {
649 mess = 0;
650 return n;
651 }
652 len = net2host(len); //from network to host byte order
653
654 char *buf = new char[len+sizeof(UInt_t)];
655 if ((n = RecvRaw(buf+sizeof(UInt_t), len, kDefault)) <= 0) {
656 delete [] buf;
657 mess = 0;
658 return n;
659 }
660
661 mess = new TMessage(buf, len+sizeof(UInt_t));
662
663 // receive any streamer infos
664 if (RecvStreamerInfos(mess))
665 goto oncemore;
666
667 // receive any process ids
668 if (RecvProcessIDs(mess))
669 goto oncemore;
670
671 if (mess->What() & kMESS_ACK) {
672 char ok[2] = { 'o', 'k' };
673 if (SendRaw(ok, sizeof(ok), kDefault) < 0) {
674 delete mess;
675 mess = 0;
676 return -1;
677 }
678 mess->SetWhat(mess->What() & ~kMESS_ACK);
679 }
680
681 return n;
682}
683
684////////////////////////////////////////////////////////////////////////////////
685/// Send a raw buffer of specified length. Returns the number of bytes
686/// sent or -1 in case of error.
687
689{
690 if (fSize <= 1)
691 return TSocket::RecvRaw(buffer,length,opt);
692
693 if (!fSockets) return -1;
694
695 // if data buffer size < 4K use only one socket
696 Int_t i, nsocks = fSize, len = length;
697 if (len < 4096)
698 nsocks = 1;
699
701 if (nsocks == 1)
702 recvopt = kDefault;
703
704 if (opt != kDefault) {
705 nsocks = 1;
706 recvopt = opt;
707 }
708
709 if (nsocks == 1)
711 else
713
714 // setup pointer appropriately for transferring data equally on the
715 // parallel sockets
716 for (i = 0; i < nsocks; i++) {
717 fReadBytesLeft[i] = len/nsocks;
718 fReadPtr[i] = (char *)buffer + (i*fReadBytesLeft[i]);
720 }
721 fReadBytesLeft[nsocks-1] += len%nsocks;
722
723 // start receiving data on all sockets. Receive data as and when
724 // they are available on a socket by by using select.
725 // Exit the loop as soon as all data has been received.
726 while (len > 0) {
728 for (int is = 0; is < nsocks; is++) {
729 if (s == fSockets[is]) {
730 if (fReadBytesLeft[is] > 0) {
731 Int_t nrecv;
733 if ((nrecv = fSockets[is]->RecvRaw(fReadPtr[is],
734 fReadBytesLeft[is],
735 recvopt)) <= 0) {
737 if (nrecv == -5) {
738 // connection reset by peer or broken ...
740 Close();
741 }
742 return -1;
743 }
744 if (opt == kDontBlock) {
746 return nrecv;
747 }
748 fReadBytesLeft[is] -= nrecv;
749 fReadPtr[is] += nrecv;
750 len -= nrecv;
751 }
752 }
753 }
754 }
756
757 return length;
758}
759
760////////////////////////////////////////////////////////////////////////////////
761/// Set socket options.
762
764{
765 if (fSize <= 1)
766 return TSocket::SetOption(opt,val);
767
768 Int_t ret = 0;
769 for (int i = 0; i < fSize; i++)
770 ret = fSockets[i]->SetOption(opt, val);
771 return ret;
772}
773
774////////////////////////////////////////////////////////////////////////////////
775/// Get socket options. Returns -1 in case of error.
776
778{
779 if (fSize <= 1)
780 return TSocket::GetOption(opt,val);
781
782 Int_t ret = 0;
783 for (int i = 0; i < fSize; i++)
784 ret = fSockets[i]->GetOption(opt, val);
785 return ret;
786}
787
788////////////////////////////////////////////////////////////////////////////////
789/// Returns error code. Meaning depends on context where it is called.
790/// If no error condition returns 0 else a value < 0.
791
793{
794 if (fSize <= 1)
795 return TSocket::GetErrorCode();
796
797 return fSockets[0] ? fSockets[0]->GetErrorCode() : 0;
798}
UShort_t net2host(UShort_t x)
Definition: Bytes.h:577
@ kMESS_ACK
Definition: MessageTypes.h:29
int Int_t
Definition: RtypesCore.h:41
unsigned int UInt_t
Definition: RtypesCore.h:42
const Bool_t kFALSE
Definition: RtypesCore.h:88
bool Bool_t
Definition: RtypesCore.h:59
const Bool_t kTRUE
Definition: RtypesCore.h:87
const char Option_t
Definition: RtypesCore.h:62
#define ClassImp(name)
Definition: Rtypes.h:363
R__EXTERN TVirtualMutex * gROOTMutex
Definition: TROOT.h:57
#define gROOT
Definition: TROOT.h:410
ESockOptions
Definition: TSocket.h:37
@ kNoBlock
Definition: TSocket.h:44
@ kNoDelay
Definition: TSocket.h:43
ESendRecvOptions
Definition: TSocket.h:50
@ kDontBlock
Definition: TSocket.h:54
@ kDefault
Definition: TSocket.h:51
R__EXTERN TSystem * gSystem
Definition: TSystem.h:540
#define R__LOCKGUARD(mutex)
Bool_t IsReading() const
Definition: TBuffer.h:83
Int_t Length() const
Definition: TBuffer.h:96
char * Buffer() const
Definition: TBuffer.h:93
This class represents an Internet Protocol (IP) address.
Definition: TInetAddress.h:36
Int_t GetPort() const
Definition: TInetAddress.h:73
UInt_t What() const
Definition: TMessage.h:75
void SetLength() const
Set the message length at the beginning of the message buffer.
Definition: TMessage.cxx:201
char * CompBuffer() const
Definition: TMessage.h:89
Int_t Compress()
Compress the message.
Definition: TMessage.cxx:302
Int_t GetCompressionLevel() const
Definition: TMessage.h:106
Int_t CompLength() const
Definition: TMessage.h:90
void SetWhat(UInt_t what)
Using this method one can change the message type a-posteriory.
Definition: TMessage.cxx:221
@ kWrite
Definition: TMonitor.h:54
@ kRead
Definition: TMonitor.h:54
TSocket * Select()
Return pointer to socket for which an event is waiting.
Definition: TMonitor.cxx:322
virtual void Activate(TSocket *sock)
Activate a de-activated socket.
Definition: TMonitor.cxx:250
virtual void Add(TSocket *sock, Int_t interest=kRead)
Add socket to the monitor's active list.
Definition: TMonitor.cxx:168
virtual void DeActivateAll()
De-activate all activated sockets.
Definition: TMonitor.cxx:302
virtual void SetTitle(const char *title="")
Set the title of the TNamed.
Definition: TNamed.cxx:164
virtual void SetName(const char *name)
Set the name of the TNamed.
Definition: TNamed.cxx:140
virtual const char * GetTitle() const
Returns title of object.
Definition: TNamed.h:48
virtual const char * GetName() const
Returns name of object.
Definition: TNamed.h:47
virtual void Warning(const char *method, const char *msgfmt,...) const
Issue warning message.
Definition: TObject.cxx:866
void SetBit(UInt_t f, Bool_t set)
Set or unset the user status bits as specified in f.
Definition: TObject.cxx:694
virtual void Error(const char *method, const char *msgfmt,...) const
Issue error message.
Definition: TObject.cxx:880
void ResetBit(UInt_t f)
Definition: TObject.h:171
Int_t SetOption(ESockOptions opt, Int_t val)
Set socket options.
Definition: TPSocket.cxx:763
Int_t GetDescriptor() const
Return socket descriptor.
Definition: TPSocket.cxx:476
Int_t RecvRaw(void *buffer, Int_t length, ESendRecvOptions opt)
Send a raw buffer of specified length.
Definition: TPSocket.cxx:688
TPSocket(TSocket *pSockets[], Int_t size)
Create a parallel socket. This ctor is called by TPServerSocket.
Definition: TPSocket.cxx:275
void Close(Option_t *opt="")
Close a parallel socket.
Definition: TPSocket.cxx:335
Int_t fSize
Definition: TPSocket.h:41
Int_t SendRaw(const void *buffer, Int_t length, ESendRecvOptions opt)
Send a raw buffer of specified length.
Definition: TPSocket.cxx:554
char ** fReadPtr
Definition: TPSocket.h:45
TMonitor * fWriteMonitor
Definition: TPSocket.h:39
Int_t Send(const TMessage &mess)
Send a TMessage object.
Definition: TPSocket.cxx:492
Int_t Recv(TMessage *&mess)
Receive a TMessage object.
Definition: TPSocket.cxx:635
virtual ~TPSocket()
Cleanup the parallel socket.
Definition: TPSocket.cxx:317
TMonitor * fReadMonitor
Definition: TPSocket.h:40
Int_t GetErrorCode() const
Returns error code.
Definition: TPSocket.cxx:792
char ** fWritePtr
Definition: TPSocket.h:44
Option_t * GetOption() const
Definition: TPSocket.h:51
Int_t * fWriteBytesLeft
Definition: TPSocket.h:42
void Init(Int_t tcpwindowsize, TSocket *sock=0)
Create a parallel socket to the specified host.
Definition: TPSocket.cxx:365
Int_t * fReadBytesLeft
Definition: TPSocket.h:43
TInetAddress GetLocalInetAddress()
Return internet address of local host to which the socket is bound.
Definition: TPSocket.cxx:460
Bool_t IsValid() const
Definition: TPSocket.h:79
TSocket ** fSockets
Definition: TPSocket.h:38
virtual Int_t GetLocalPort()
Get port # to which server socket is bound. In case of error returns -1.
virtual TSocket * Accept(UChar_t Opt=0)
Accept a connection on a server socket.
TInetAddress fAddress
Definition: TSocket.h:79
Option_t * GetOption() const
Definition: TSocket.h:118
Int_t fCompress
Definition: TSocket.h:82
virtual Int_t SetOption(ESockOptions opt, Int_t val)
Set socket options.
Definition: TSocket.cxx:1012
Int_t fSocket
Definition: TSocket.h:89
Int_t GetErrorCode() const
Returns error code.
Definition: TSocket.cxx:1034
UInt_t GetBytesRecv() const
Definition: TSocket.h:140
void SendStreamerInfos(const TMessage &mess)
Check if TStreamerInfo must be sent.
Definition: TSocket.cxx:649
const char * GetService() const
Definition: TSocket.h:136
TSocket()
Definition: TSocket.h:103
TString fService
Definition: TSocket.h:87
Bool_t RecvStreamerInfos(TMessage *mess)
Receive a message containing streamer infos.
Definition: TSocket.cxx:927
virtual Int_t Recv(TMessage *&mess)
Receive a TMessage object.
Definition: TSocket.cxx:817
Int_t GetRemoteProtocol() const
Definition: TSocket.h:146
UInt_t GetBytesSent() const
Definition: TSocket.h:139
Bool_t Authenticate(const char *user)
Authenticated the socket with specified user.
Definition: TSocket.cxx:1105
TInetAddress fLocalAddress
Definition: TSocket.h:83
Int_t GetTcpWindowSize() const
Definition: TSocket.h:148
@ kBrokenConn
Definition: TSocket.h:69
virtual void Close(Option_t *opt="")
Close the socket.
Definition: TSocket.cxx:389
Bool_t RecvProcessIDs(TMessage *mess)
Receive a message containing process ids.
Definition: TSocket.cxx:974
void SetUrl(const char *url)
Definition: TSocket.h:175
TInetAddress GetInetAddress() const
Definition: TSocket.h:133
Int_t GetCompressionLevel() const
Definition: TSocket.h:201
virtual Int_t RecvRaw(void *buffer, Int_t length, ESendRecvOptions opt=kDefault)
Receive a raw buffer of specified length bytes.
Definition: TSocket.cxx:897
TSecContext * GetSecContext() const
Definition: TSocket.h:147
virtual Int_t SendRaw(const void *buffer, Int_t length, ESendRecvOptions opt=kDefault)
Send a raw buffer of specified length.
Definition: TSocket.cxx:620
void SendProcessIDs(const TMessage &mess)
Check if TProcessIDs must be sent.
Definition: TSocket.cxx:684
virtual TInetAddress GetLocalInetAddress()
Return internet address of local host to which the socket is bound.
Definition: TSocket.cxx:409
TSecContext * fSecContext
Definition: TSocket.h:85
Int_t fTcpWindowSize
Definition: TSocket.h:90
EServiceType
Definition: TSocket.h:72
virtual Int_t GetDescriptor() const
Definition: TSocket.h:132
Int_t GetCompressionSettings() const
Definition: TSocket.h:207
Int_t GetServType() const
Definition: TSocket.h:137
void SetCompressionSettings(Int_t settings=ROOT::RCompressionSetting::EDefaults::kUseGeneralPurpose)
Used to specify the compression level and algorithm: settings = 100 * algorithm + level.
Definition: TSocket.cxx:1097
EServiceType fServType
Definition: TSocket.h:88
UInt_t fBytesSent
Definition: TSocket.h:81
Int_t fRemoteProtocol
Definition: TSocket.h:84
UInt_t fBytesRecv
Definition: TSocket.h:80
virtual Bool_t IsValid() const
Definition: TSocket.h:152
virtual Int_t Send(const TMessage &mess)
Send a TMessage object.
Definition: TSocket.cxx:522
virtual TInetAddress GetSockName(int sock)
Get Internet Protocol (IP) address of host and port #.
Definition: TSystem.cxx:2352
virtual void CloseConnection(int sock, Bool_t force=kFALSE)
Close socket connection.
Definition: TSystem.cxx:2433
This class represents a WWW compatible URL.
Definition: TUrl.h:35
const Int_t n
Definition: legend1.C:16
static constexpr double s
static constexpr double ns