summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2018-03-07 18:05:59 -0800
committerDana Powers <dana.powers@rd.io>2018-03-07 18:05:59 -0800
commitd40a440a79626eb678cc12b5893d8be769b2c04d (patch)
tree25c3a53e56792b41c76079e068cfaa2232ded80c
parent33577d8d1e5fe201adc61b4c1661396c729ae0c0 (diff)
downloadkafka-python-d40a440a79626eb678cc12b5893d8be769b2c04d.tar.gz
Test BrokerConnection.connection_delay()
-rw-r--r--test/test_conn.py9
1 files changed, 9 insertions, 0 deletions
diff --git a/test/test_conn.py b/test/test_conn.py
index 5698519..f35cebe 100644
--- a/test/test_conn.py
+++ b/test/test_conn.py
@@ -72,6 +72,15 @@ def test_blacked_out(conn):
assert conn.blacked_out() is True
+def test_connection_delay(conn):
+ conn.last_attempt = time.time()
+ assert round(conn.connection_delay()) == round(conn.config['reconnect_backoff_ms'])
+ conn.state = ConnectionStates.CONNECTING
+ assert conn.connection_delay() == 0
+ conn.state = ConnectionStates.CONNECTED
+ assert conn.connection_delay() == float('inf')
+
+
def test_connected(conn):
assert conn.connected() is False
conn.state = ConnectionStates.CONNECTED