diff --git a/node-daemon/pvcd/Daemon.py b/node-daemon/pvcd/Daemon.py index 9a57fb6b..5354f4ba 100644 --- a/node-daemon/pvcd/Daemon.py +++ b/node-daemon/pvcd/Daemon.py @@ -468,13 +468,18 @@ def zk_listener(state): logger.out('Connection to Zookeeper lost; retrying', state='w') while True: + time.sleep(0.5) + _zk_conn = kazoo.client.KazooClient(hosts=config['coordinators']) try: _zk_conn.start() - zk_conn = _zk_conn - break except: - time.sleep(1) + del _zk_conn + continue + + zk_conn = _zk_conn + break + zk_conn.add_listener(zk_listener) ###############################################################################