| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/ |
| D | TServerSocket.java | 36 private ServerSocket serverSocket_ = null; field in TServerSocket
82 this.serverSocket_ = args.serverSocket; in TServerSocket()
87 serverSocket_ = new ServerSocket(); in TServerSocket()
89 serverSocket_.setReuseAddress(true); in TServerSocket()
91 serverSocket_.bind(args.bindAddr, args.backlog); in TServerSocket()
101 if (serverSocket_ != null) { in listen()
103 serverSocket_.setSoTimeout(0); in listen()
112 if (serverSocket_ == null) { in accept()
117 result = serverSocket_.accept(); in accept()
130 if (serverSocket_ != null) { in close()
[all …]
|
| D | TNonblockingServerSocket.java | 44 private ServerSocket serverSocket_ = null; field in TNonblockingServerSocket
101 serverSocket_ = serverSocketChannel.socket(); in TNonblockingServerSocket()
103 serverSocket_.setReuseAddress(true); in TNonblockingServerSocket()
105 serverSocket_.bind(args.bindAddr, args.backlog); in TNonblockingServerSocket()
107 serverSocket_ = null; in TNonblockingServerSocket()
115 if (serverSocket_ != null) { in listen()
117 serverSocket_.setSoTimeout(0); in listen()
126 if (serverSocket_ == null) { in accept()
156 if (serverSocket_ != null) { in close()
158 serverSocket_.close(); in close()
[all …]
|
| /thrift-3.4.0/lib/cpp/src/thrift/transport/ |
| D | TNonblockingServerSocket.cpp | 91 serverSocket_(THRIFT_INVALID_SOCKET), in TNonblockingServerSocket()
106 serverSocket_(THRIFT_INVALID_SOCKET), in TNonblockingServerSocket()
122 serverSocket_(THRIFT_INVALID_SOCKET), in TNonblockingServerSocket()
138 serverSocket_(THRIFT_INVALID_SOCKET), in TNonblockingServerSocket()
155 if (serverSocket_ == THRIFT_INVALID_SOCKET) in isOpen()
218 if (-1 == setsockopt(serverSocket_, in isOpen()
238 if (-1 == setsockopt(serverSocket_, in isOpen()
253 if (-1 == setsockopt(serverSocket_, in isOpen()
269 if (-1 == setsockopt(serverSocket_, SOL_SOCKET, SO_LINGER, cast_sockopt(&ling), sizeof(ling))) { in isOpen()
277 …if (-1 == setsockopt(serverSocket_, SOL_SOCKET, SO_KEEPALIVE, const_cast_sockopt(&one), sizeof(one… in isOpen()
[all …]
|
| D | TServerSocket.cpp | 107 serverSocket_(THRIFT_INVALID_SOCKET), in TServerSocket()
126 serverSocket_(THRIFT_INVALID_SOCKET), in TServerSocket()
146 serverSocket_(THRIFT_INVALID_SOCKET), in TServerSocket()
166 serverSocket_(THRIFT_INVALID_SOCKET), in TServerSocket()
187 if (serverSocket_ == THRIFT_INVALID_SOCKET) in isOpen()
261 if (-1 == setsockopt(serverSocket_, in isOpen()
281 if (-1 == setsockopt(serverSocket_, in isOpen()
296 if (-1 == setsockopt(serverSocket_, in isOpen()
312 if (-1 == setsockopt(serverSocket_, SOL_SOCKET, SO_LINGER, cast_sockopt(&ling), sizeof(ling))) { in isOpen()
320 if (-1 == setsockopt(serverSocket_, SOL_SOCKET, SO_NOSIGPIPE, &one, sizeof(one))) { in isOpen()
[all …]
|
| D | TNonblockingServerSocket.h | 102 THRIFT_SOCKET getSocketFD() override { return serverSocket_; } in getSocketFD()
128 THRIFT_SOCKET serverSocket_; variable
|
| D | TServerSocket.h | 128 THRIFT_SOCKET getSocketFD() override { return serverSocket_; } in getSocketFD()
156 THRIFT_SOCKET serverSocket_; variable
|
| /thrift-3.4.0/lib/d/src/thrift/server/transport/ |
| D | socket.d | 108 serverSocket_ = makeSocketAndListen(port_, ACCEPT_BACKLOG, retryLimit_, in listen()
115 serverSocket_.shutdown(SocketShutdown.BOTH); in close()
116 serverSocket_.close(); in close()
117 serverSocket_ = null; in close()
121 return serverSocket_ !is null; in isListening()
141 socketSet_.add(serverSocket_);
170 if (socketSet_.isSet(serverSocket_)) {
177 auto client = createTSocket(serverSocket_.accept());
205 Socket serverSocket_; variable
|
| /thrift-3.4.0/lib/cpp/src/thrift/server/ |
| D | TNonblockingServer.cpp | 965 assert(fd == serverSocket_); in handleEvent()
1027 serverSocket_ = serverTransport_->getSocketFD(); in createAndListenOnSocket()
1097 if (serverSocket_ == THRIFT_INVALID_SOCKET) in registerEvents()
1110 THRIFT_SOCKET listenFd = (id == 0 ? serverSocket_ : THRIFT_INVALID_SOCKET); in registerEvents()
|
| D | TNonblockingServer.h | 156 THRIFT_SOCKET serverSocket_; variable
278 serverSocket_ = THRIFT_INVALID_SOCKET; in init()
|
