summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2017-02-24 09:53:44 -0800
committerGitHub <noreply@github.com>2017-02-24 09:53:44 -0800
commitbcb4009b935fb74e3ca71206466c68ad74bc7b3c (patch)
tree66d6cfd1147ed95e92d6623828e92fb46b77957b
parent8fde79dbb5a3793b1a9ebd10e032d5f3dd535645 (diff)
downloadkafka-python-bcb4009b935fb74e3ca71206466c68ad74bc7b3c.tar.gz
Drop bad disconnect test -- just use the mocked-socket test (#982)
-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()