summaryrefslogtreecommitdiff
path: root/test
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2017-02-09 15:28:01 -0800
committerDana Powers <dana.powers@gmail.com>2017-02-09 15:28:01 -0800
commitbd6ecef5b480c31721dec47c529b3c30206e3f9c (patch)
tree66d6cfd1147ed95e92d6623828e92fb46b77957b /test
parent8fde79dbb5a3793b1a9ebd10e032d5f3dd535645 (diff)
downloadkafka-python-remove_bad_test.tar.gz
Drop bad disconnect test -- just use the mocked-socket testremove_bad_test
Diffstat (limited to 'test')
-rw-r--r--test/test_conn.py28
1 files changed, 1 insertions, 27 deletions
diff --git a/test/test_conn.py b/test/test_conn.py
index c3e40c0..248ab88 100644
--- a/test/test_conn.py
+++ b/test/test_conn.py
@@ -166,33 +166,7 @@ def test_can_send_more(conn):
assert conn.can_send_more() is False
-def test_recv_disconnected():
- sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
- sock.bind(('127.0.0.1', 0))
- port = sock.getsockname()[1]
- sock.listen(5)
-
- conn = BrokerConnection('127.0.0.1', port, socket.AF_INET)
- timeout = time.time() + 1
- while time.time() < timeout:
- conn.connect()
- if conn.connected():
- break
- else:
- assert False, 'Connection attempt to local socket timed-out ?'
-
- conn.send(MetadataRequest[0]([]))
-
- # Disconnect server socket
- sock.close()
-
- # Attempt to receive should mark connection as disconnected
- assert conn.connected()
- conn.recv()
- assert conn.disconnected()
-
-
-def test_recv_disconnected_too(_socket, conn):
+def test_recv_disconnected(_socket, conn):
conn.connect()
assert conn.connected()