diff options
author | Dana Powers <dana.powers@gmail.com> | 2017-02-09 15:28:01 -0800 |
---|---|---|
committer | Dana Powers <dana.powers@gmail.com> | 2017-02-09 15:28:01 -0800 |
commit | bd6ecef5b480c31721dec47c529b3c30206e3f9c (patch) | |
tree | 66d6cfd1147ed95e92d6623828e92fb46b77957b | |
parent | 8fde79dbb5a3793b1a9ebd10e032d5f3dd535645 (diff) | |
download | kafka-python-remove_bad_test.tar.gz |
Drop bad disconnect test -- just use the mocked-socket testremove_bad_test
-rw-r--r-- | test/test_conn.py | 28 |
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() |