| /thrift-3.4.0/.github/ |
| D | stale.yml | 6 # Number of days of inactivity before an Issue or Pull Request with the stale label is closed.
7 # Set to false to disable. If disabled, issues still need to be closed manually, but will remain ma…
30 recent activity. It will be closed in 7 days if no further activity occurs.
40 This issue has been automatically closed due to inactivity.
54 # recent activity. It will be closed if no further activity occurs. Thank you
|
| /thrift-3.4.0/lib/rb/spec/ |
| D | unix_socket_spec.rb | 29 @handle = double("Handle", :closed? => false)
75 it "should close the handle when closed" do
76 handle = double("UNIXServer", :closed? => false)
84 it "should delete the socket when closed" do
85 handle = double("UNIXServer", :closed? => false)
97 it "should return true for closed? when appropriate" do
98 handle = double("UNIXServer", :closed? => false)
108 allow(handle).to receive(:closed?).and_return(true)
|
| D | server_socket_spec.rb | 54 it "should close the handle when closed" do
55 handle = double("TCPServer", :closed? => false)
66 it "should return true for closed? when appropriate" do
67 handle = double("TCPServer", :closed? => false)
76 allow(handle).to receive(:closed?).and_return(true)
|
| D | socket_spec_shared.rb | 58 it "should declare itself as closed when it has an error" do
66 it "should raise an error when the stream is closed" do
68 allow(@handle).to receive(:closed?).and_return(true)
70 expect { @socket.write("fail") }.to raise_error(IOError, "closed stream")
71 expect { @socket.read(10) }.to raise_error(IOError, "closed stream")
|
| D | base_transport_spec.rb | 353 @input = double("Input", :closed? => false)
354 @output = double("Output", :closed? => false)
366 allow(@input).to receive(:closed?).and_return(true)
368 allow(@input).to receive(:closed?).and_return(false)
369 allow(@output).to receive(:closed?).and_return(true)
371 allow(@input).to receive(:closed?).and_return(true)
382 it "should close both input and output when closed" do
|
| D | ssl_socket_spec.rb | 29 @simple_socket_handle = double("Handle", :closed? => false)
34 …(double("SSLHandle", :connect_nonblock => true, :post_connection_check => true), :closed? => false)
|
| /thrift-3.4.0/lib/go/thrift/ |
| D | simple_server.go | 42 // server stop to avoid hanging too long to wait for all client connections to be closed gracefully.
48 // for all the client connections to be closed gracefully.
57 closed int32 member
189 closed := atomic.LoadInt32(&p.closed)
190 if closed != 0 {
191 return closed, nil
224 closed, err := p.innerAccept()
228 if closed != 0 {
249 if atomic.LoadInt32(&p.closed) != 0 {
252 atomic.StoreInt32(&p.closed, 1)
[all …]
|
| D | iostream_transport.go | 33 closed bool member
98 return !p.closed
101 // implicitly opened on creation, can't be reopened once closed
103 if !p.closed {
112 if p.closed {
113 return NewTTransportException(NOT_OPEN, "StreamTransport already closed.")
115 p.closed = true
|
| D | socket_conn.go | 33 closed int32 member
70 return sc != nil && sc.Conn != nil && atomic.LoadInt32(&sc.closed) == 0
90 // that the connection is already closed, we need to
119 // Already closed
122 atomic.StoreInt32(&sc.closed, 1)
|
| /thrift-3.4.0/lib/rb/lib/thrift/transport/ |
| D | unix_server_socket.rb | 47 @handle.close unless @handle.closed?
54 def closed?
55 @handle.nil? or @handle.closed?
|
| D | server_socket.rb | 53 @handle.close unless @handle.nil? or @handle.closed?
57 def closed?
58 @handle.nil? or @handle.closed?
|
| D | socket.rb | 61 !@handle.nil? and !@handle.closed?
65 raise IOError, "closed stream" unless open?
97 raise IOError, "closed stream" unless open?
122 @handle.close unless @handle.closed?
133 @handle.close unless @handle.nil? or @handle.closed?
|
| D | io_stream_transport.rb | 33 def open?; not @input.closed? or not @output.closed? end
|
| D | base_server_transport.rb | 33 def closed?
|
| /thrift-3.4.0/lib/go/ |
| D | README.md | 111 closed the connection). When implementing Go Thrift server, you can take
139 …e/thrift/lib/go/thrift#TSimpleServer.Stop) will wait for all client connections to be closed after
154 will wait for all the client connections to be closed gracefully with
156 connections to be closed gracefully util thrift.ServerStopTimeout is
157 reached, and client connections that are not closed after thrift.ServerStopTimeout
158 will be closed abruptly which may cause some client errors.
|
| /thrift-3.4.0/lib/dart/lib/src/browser/ |
| D | t_web_socket.dart | 64 _socket == null || _socket.readyState == WebSocket.CLOSED;
115 .add(StateError('Socket was closed with pending requests'));
119 _onStateController.add(TSocketState.CLOSED);
|
| /thrift-3.4.0/lib/py/src/server/ |
| D | TNonblockingServer.py | 70 CLOSED = 4 variable
117 CLOSED --- socket was closed and connection should be deleted.
192 CLOSED if request throws unexpected exception.
224 """Returns True if connection is closed."""
225 return self.status == CLOSED
233 self.status = CLOSED
|
| /thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/transport/ |
| D | ReadCountingTransport.java | 50 throw new TTransportException(TTransportException.NOT_OPEN, "Transport is closed"); in read()
59 throw new TTransportException(TTransportException.NOT_OPEN, "Transport is closed"); in write()
|
| /thrift-3.4.0/lib/lua/src/ |
| D | usocket.c | 160 return CLOSED; in socket_accept()
194 return CLOSED; in socket_connect()
212 return CLOSED; in socket_send()
232 return CLOSED; in socket_recv()
244 // Connection has been closed by peer in socket_recv()
246 return CLOSED; in socket_recv()
280 } else if (err == CLOSED) { \
|
| D | socket.h | 36 CLOSED = -2, enumerator
41 static const char * CLOSED_MSG = "Connection Closed";
|
| /thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/server/ |
| D | TestThreadPoolServer.java | 56 // TODO: The socket is actually closed (timeout) but the client code in testStopServerWithOpenClient()
58 assertTrue(client.isOpen(), "Client should be closed after server shutdown"); in testStopServerWithOpenClient()
|
| /thrift-3.4.0/lib/d/src/thrift/internal/ |
| D | socket.d | 27 // FreeBSD and OS X return -1 and set ECONNRESET if socket was closed by
61 * is logically in closed state now.
|
| /thrift-3.4.0/lib/erl/test/ |
| D | test_disklog.erl | 49 io:format("Client closed~n"),
88 io:format("Client closed~n"),
|
| /thrift-3.4.0/lib/erl/src/ |
| D | thrift_buffered_transport.erl | 84 {Closed, Result} = thrift_transport:close(Wrapped),
85 {State#t_buffered{wrapped = Closed}, Result}.
|
| /thrift-3.4.0/lib/d/src/thrift/transport/ |
| D | base.d | 35 * If a transport is closed, it can be opened by calling open(), and vice
39 * the related functions do not necessarily fail when called for a closed
42 * been closed (possibly because the connection was abruptly closed), but
|
