| /thrift-3.4.0/lib/cpp/test/ |
| D | TSocketInterruptTest.cpp | 67 clientSock.close(); in BOOST_AUTO_TEST_CASE()
68 accepted->close(); in BOOST_AUTO_TEST_CASE()
69 sock1.close(); in BOOST_AUTO_TEST_CASE()
88 clientSock.close(); in BOOST_AUTO_TEST_CASE()
90 accepted->close(); in BOOST_AUTO_TEST_CASE()
91 sock1.close(); in BOOST_AUTO_TEST_CASE()
98 sock1.close(); in BOOST_AUTO_TEST_CASE()
119 clientSock.close(); in BOOST_AUTO_TEST_CASE()
120 accepted->close(); in BOOST_AUTO_TEST_CASE()
121 sock1.close(); in BOOST_AUTO_TEST_CASE()
[all …]
|
| D | TSSLSocketInterruptTest.cpp | 155 clientSock->close(); in BOOST_AUTO_TEST_CASE()
156 accepted->close(); in BOOST_AUTO_TEST_CASE()
157 sock1.close(); in BOOST_AUTO_TEST_CASE()
176 accepted->close(); in BOOST_AUTO_TEST_CASE()
177 clientSock->close(); in BOOST_AUTO_TEST_CASE()
178 sock1.close(); in BOOST_AUTO_TEST_CASE()
202 accepted->close(); in BOOST_AUTO_TEST_CASE()
203 clientSock->close(); in BOOST_AUTO_TEST_CASE()
204 sock1.close(); in BOOST_AUTO_TEST_CASE()
212 sock1.close(); in BOOST_AUTO_TEST_CASE()
[all …]
|
| D | TServerSocketTest.cpp | 43 accepted->close(); in BOOST_AUTO_TEST_CASE()
44 sock1.close(); in BOOST_AUTO_TEST_CASE()
49 sock2.close(); in BOOST_AUTO_TEST_CASE()
64 sock1.close(); in BOOST_AUTO_TEST_CASE()
|
| /thrift-3.4.0/lib/cpp/src/thrift/transport/ |
| D | TNonblockingServerSocket.cpp | 151 close(); in ~TNonblockingServerSocket()
229 close(); in isOpen()
245 close(); in isOpen()
260 close(); in isOpen()
272 close(); in isOpen()
280 close(); in isOpen()
290 close(); in isOpen()
302 close(); in isOpen()
311 close(); in isOpen()
332 close(); in isOpen()
[all …]
|
| D | TServerSocket.cpp | 183 close(); in ~TServerSocket()
272 close(); in isOpen()
288 close(); in isOpen()
303 close(); in isOpen()
315 close(); in isOpen()
323 close(); in isOpen()
335 close(); in isOpen()
343 close(); in isOpen()
362 close(); in isOpen()
374 close(); in isOpen()
[all …]
|
| /thrift-3.4.0/lib/d/src/thrift/server/ |
| D | simple.d | 99 scope(failure) client.close();
102 scope(failure) inputTransport.close();
105 scope(failure) outputTransport.close();
156 inputTransport.close();
161 outputTransport.close();
166 client.close();
173 serverTransport_.close();
|
| D | threaded.d | 103 scope(failure) client.close();
106 scope(failure) inputTransport.close();
109 scope(failure) outputTransport.close();
132 serverTransport_.close();
189 inputProtocol_.transport.close(); in run()
194 outputProtocol_.transport.close(); in run()
199 client_.close(); in run()
|
| D | taskpool.d | 133 scope(failure) client.close();
136 scope(failure) inputTransport.close();
139 scope(failure) outputTransport.close();
165 serverTransport_.close();
284 inputProtocol.transport.close(); in worker()
289 outputProtocol.transport.close(); in worker()
294 client.close(); in worker()
|
| /thrift-3.4.0/lib/erl/src/ |
| D | thrift_memory_buffer.erl | 27 -export([read/2, write/2, flush/1, close/1]).
46 close(State) -> thrift_membuffer_transport:close(State). function
|
| D | thrift_base64_transport.erl | 28 -export([write/2, read/2, flush/1, close/1]).
57 close(This0) -> function
59 {NewWrapped, ok} = thrift_transport:close(Wrapped),
|
| D | thrift_socket_transport.erl | 27 -export([read/2, read_exact/2, write/2, flush/1, close/1]).
85 gen_tcp:close(Socket),
96 gen_tcp:close(Socket),
114 gen_tcp:close(State#t_socket.socket),
125 gen_tcp:close(Socket),
135 close(State = #t_socket{socket = Socket}) -> function
136 {State, gen_tcp:close(Socket)}.
|
| /thrift-3.4.0/lib/py/test/ |
| D | thrift_transport.py | 37 buf.close()
43 buf.close()
56 buffer_w.close()
66 buffer_r.close()
|
| D | test_socket.py | 50 acc.client.close() # this also blocks until the other thread is done
51 acc.close()
54 sock.close()
|
| D | thrift_TZlibTransport.py | 57 zlib_trans.close()
63 zlib_trans.close()
83 zlib_trans.close()
89 zlib_trans.close()
|
| /thrift-3.4.0/lib/erl/test/ |
| D | test_thrift_socket_transport.erl | 59 meck:expect(gen_tcp, close, fun(_) -> ok end)
112 meck:expect(gen_tcp, close, fun(_) -> ok end)
189 close(Transport) -> thrift_socket_transport:close(Transport). function
195 meck:expect(gen_tcp, close, fun(_) -> ok end)
201 close({t_socket, a_fake_socket, 60000, []})
|
| /thrift-3.4.0/lib/swift/Sources/ |
| D | TSocketTransport.swift | 43 static let close = Glibc.close variable
47 static let close = Darwin.close variable
178 close()
212 public func close() { in close() function
214 _ = Sys.close(socketDescriptor) in close()
|
| D | TFramedTransport.swift | 58 try close() in read()
64 try close() in read()
110 public func close() throws { in close() function
111 try transport.close() in close()
|
| /thrift-3.4.0/lib/lua/ |
| D | TServer.lua | 121 itrans:close()
122 otrans:close()
125 function TServer:close()
126 self.serverTransport:close()
143 self:close()
|
| /thrift-3.4.0/lib/py/src/transport/ |
| D | TTransport.py | 52 def close(self): member in TTransportBase
117 def close(self): member in TServerTransportBase
157 def close(self): member in TBufferedTransport
158 return self.__trans.close()
228 def close(self): member in TMemoryBuffer
229 self._buffer.close()
275 def close(self): member in TFramedTransport
276 return self.__trans.close()
332 def close(self): member in TFileObjectTransport
333 self.fileobj.close()
[all …]
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/server/ |
| D | TSaslNonblockingServer.java | 144 close(); in run()
167 connection.close(); in acceptNewConnection()
187 private void close() { in close() method in TSaslNonblockingServer.AcceptorThread
189 serverTransport.close(); in close()
191 acceptSelector.close(); in close()
222 close(); in run()
297 connection.close(); in handleIncomingConnections()
302 private synchronized void close() { in close() method in TSaslNonblockingServer.NetworkThread
309 incomingConnection.close(); in close()
316 ioSelector.close(); in close()
[all …]
|
| /thrift-3.4.0/lib/cpp/src/thrift/server/ |
| D | TNonblockingServer.cpp | 238 void close();
296 close(); in forceClose()
358 connection_->close(); in run()
442 close(); in workSocket()
451 close(); in workSocket()
475 close(); in workSocket()
498 close(); in workSocket()
511 close(); in workSocket()
536 close(); in workSocket()
556 close(); in workSocket()
[all …]
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/ |
| D | TServerSocket.java | 93 close(); in TServerSocket()
129 public void close() { in close() method in TServerSocket
132 serverSocket_.close(); in close()
143 close(); in interrupt()
|
| D | TSocket.java | 74 close(); in TSocket()
230 close(); in open()
236 public void close() { in close() method in TSocket
238 super.close(); in close()
243 socket_.close(); in close()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/ |
| D | TNonblockingMultiFetchClient.java | 172 multiFetch.close(); in fetch()
238 s.close(); in run()
316 sChannel.close(); in run()
331 sChannel.close(); in run()
345 sChannel.close(); in run()
360 public void close() { in close() method in TNonblockingMultiFetchClient.MultiFetch
365 sChannel.close(); in close()
367 selector.close(); in close()
|
| /thrift-3.4.0/lib/php/lib/Server/ |
| D | TForkingServer.php | 90 @$transport->close();
108 @$transport->close();
122 $this->transport_->close();
|
