class TPServerSocket: public TServerSocket
TPServerSocket This class implements parallel server sockets. A parallel server socket waits for requests to come in over the network. It performs some operation based on that request and then possibly returns a full duplex parallel socket to the requester. The actual work is done via the TSystem class (either TUnixSystem or TWinNTSystem).
Function Members (Methods)
public:
protected:
| Bool_t | TSocket::Authenticate(const char* user) |
| virtual void | TObject::DoError(int level, const char* location, const char* fmt, va_list va) const |
| void | TObject::MakeZombie() |
| Bool_t | TSocket::RecvProcessIDs(TMessage* mess) |
| Bool_t | TSocket::RecvStreamerInfos(TMessage* mess) |
| void | TSocket::SendProcessIDs(const TMessage& mess) |
| void | TSocket::SendStreamerInfos(const TMessage& mess) |
| void | TSocket::SetDescriptor(Int_t desc) |
private:
| TPServerSocket(const TPServerSocket&) | |
| void | operator=(const TPServerSocket&) |
Data Members
public:
| enum TServerSocket::[unnamed] { | kDefaultBacklog | |
| }; | ||
| enum TSocket::EStatusBits { | kIsUnix | |
| kBrokenConn | ||
| }; | ||
| enum TSocket::EInterest { | kRead | |
| kWrite | ||
| }; | ||
| enum TSocket::EServiceType { | kSOCKD | |
| kROOTD | ||
| kPROOFD | ||
| }; | ||
| enum TObject::EStatusBits { | kCanDelete | |
| kMustCleanup | ||
| kObjInCanvas | ||
| kIsReferenced | ||
| kHasUUID | ||
| kCannotPick | ||
| kNoContextMenu | ||
| kInvalidObject | ||
| }; | ||
| enum TObject::[unnamed] { | kIsOnHeap | |
| kNotDeleted | ||
| kZombie | ||
| kBitMask | ||
| kSingleKey | ||
| kOverwrite | ||
| kWriteDelete | ||
| }; |
protected:
| TInetAddress | TSocket::fAddress | remote internet address and port # |
| TBits | TSocket::fBitsInfo | bits array to mark TStreamerInfo classes already sent |
| UInt_t | TSocket::fBytesRecv | total bytes received over this socket |
| UInt_t | TSocket::fBytesSent | total bytes sent using this socket |
| Int_t | TSocket::fCompress | Compression level and algorithm |
| TTimeStamp | TSocket::fLastUsage | Time stamp of last usage |
| TVirtualMutex* | TSocket::fLastUsageMtx | Protect last usage setting / reading |
| TInetAddress | TSocket::fLocalAddress | local internet address and port # |
| TString | TNamed::fName | object identifier |
| Int_t | TSocket::fRemoteProtocol | protocol of remote daemon |
| TSecContext* | TSocket::fSecContext | after a successful Authenticate call |
| TSocket::EServiceType | TSocket::fServType | remote service type |
| TString | TSocket::fService | name of service (matches remote port #) |
| Int_t | TSocket::fSocket | socket descriptor |
| Int_t | TSocket::fTcpWindowSize | TCP window size (default 65535); |
| TString | TNamed::fTitle | object title |
| TList* | TSocket::fUUIDs | list of TProcessIDs already sent through the socket |
| TString | TSocket::fUrl | needs this for special authentication options |
| static ULong64_t | TSocket::fgBytesRecv | total bytes received by all socket objects |
| static ULong64_t | TSocket::fgBytesSent | total bytes sent by all socket objects |
| static Int_t | TSocket::fgClientProtocol | client "protocol" version |
private:
| Int_t | fTcpWindowSize | size of tcp window (for window scaling) |
Class Charts
Function documentation
TPServerSocket(Int_t port, Bool_t reuse = kFALSE, Int_t backlog = kDefaultBacklog, Int_t tcpwindowsize = -1)
Create a parallel server socket object on a specified port. Set reuse to true to force reuse of the server socket (i.e. do not wait for the time out to pass). Using backlog one can set the desirable queue length for pending connections. Use tcpwindowsize to specify the size of the receive buffer, it has to be specified here to make sure the window scale option is set (for tcpwindowsize > 65KB and for platforms supporting window scaling). Use IsValid() to check the validity of the server socket. In case server socket is not valid use GetErrorCode() to obtain the specific error value. These values are: 0 = no error (socket is valid) -1 = low level socket() call failed -2 = low level bind() call failed -3 = low level listen() call failed Every valid server socket is added to the TROOT sockets list which will make sure that any open sockets are properly closed on program termination.
TPServerSocket(const char* service, Bool_t reuse = kFALSE, Int_t backlog = kDefaultBacklog, Int_t tcpwindowsize = -1)
Create a parallel server socket object for a named service. Set reuse to true to force reuse of the server socket (i.e. do not wait for the time out to pass). Using backlog one can set the desirable queue length for pending connections. Use tcpwindowsize to specify the size of the receive buffer, it has to be specified here to make sure the window scale option is set (for tcpwindowsize > 65KB and for platforms supporting window scaling). Use IsValid() to check the validity of the server socket. In case server socket is not valid use GetErrorCode() to obtain the specific error value. These values are: 0 = no error (socket is valid) -1 = low level socket() call failed -2 = low level bind() call failed -3 = low level listen() call failed Every valid server socket is added to the TROOT sockets list which will make sure that any open sockets are properly closed on program termination.
TSocket * Accept(UChar_t Opt = kSrvNoAuth)
Accept a connection on a parallel server socket. Returns a full-duplex parallel communication TPSocket object. If no pending connections are present on the queue and nonblocking mode has not been enabled with SetOption(kNoBlock,1) the call blocks until a connection is present. The returned socket must be deleted by the user. The socket is also added to the TROOT sockets list which will make sure that any open sockets are properly closed on program termination. In case of error 0 is returned and in case non-blocking I/O is enabled and no connections are available -1 is returned.
TPServerSocket(const TPServerSocket& )
void operator=(const TPServerSocket& )