10 examples of 'python socket close' in Python

69
def test_close(self):
70
    import socket, httplib, gc
71
72
    # calling .close() on urllib2's response objects should close the
73
    # underlying socket
74
75
    # delve deep into response to fetch socket._socketobject
76
    response = urllib2.urlopen("http://www.python.org/")
77
    abused_fileobject = response.fp
78
    self.assert_(abused_fileobject.__class__ is socket._fileobject)
79
    httpresponse = abused_fileobject._sock
80
    self.assert_(httpresponse.__class__ is httplib.HTTPResponse)
81
    fileobject = httpresponse.fp
82
    self.assert_(fileobject.__class__ is socket._fileobject)
83
84
    self.assert_(not fileobject.closed)
85
    response.close()
86
    self.assert_(fileobject.closed)

256
@idiokit.stream
257
def close(self):
258
    yield timer.sleep(0.0)
259
260
    with socket.wrapped_socket_errors():
261
        self._ssl.close()

63
def close(self):
64
	SocketStream.close(self)
65
	if self.tun:
66
		self.tun.close()

126
def close(self):
127
    utp.UTP_Close(self.utp_socket)

92
def close(self):
93
    """Return this instance's socket to the connection pool.
94
    """
95
    if not self.__closed:
96
        self.__closed = True
97
        self.pool.return_socket(self.sock)
98
        self.sock, self.pool = None, None

177
def _decref_socketios(self):
178
    if self._io_refs > 0:
179
        self._io_refs -= 1
180
    if self._closed:
181
        self.close()

13
@abstractmethod
14
async def close(self) -> None:
15
    raise NotImplementedError()

123
def close_socket(self):
124
    return self.modem.close_socket()

25
def test_recv_closed(self):
26
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
27
    sock.connect(('localhost', self.server.server_port))
28
    receiver = gevent.spawn(sock.recv, 25)
29
    try:
30
        gevent.sleep(0.001)
31
        sock.close()
32
        receiver.join(timeout=0.1)
33
        assert receiver.ready(), receiver
34
        self.assertEqual(receiver.value, None)
35
        assert isinstance(receiver.exception, socket.error)
36
        self.assertEqual(receiver.exception.errno, socket.EBADF)
37
    finally:
38
        receiver.kill()

128
def test_server_socket_close():
129
    server_socket = TServerSocket(host="localhost", port=12345)
130
    server_socket.listen()
131
132
    client_socket = TSocket(host="localhost", port=12345, socket_timeout=100)
133
    client_socket.open()
134
135
    conn = server_socket.accept()
136
    server_socket.close()
137
138
    client_socket.write(b"Hello world")
139
    with pytest.raises(socket.timeout):
140
        client_socket.read(1024)
141
142
    conn.close()
143
    server_socket.close()