diff options
author | joseph <joseph.altmaier@gmail.com> | 2017-03-01 15:47:14 -0800 |
---|---|---|
committer | joseph <joseph.altmaier@gmail.com> | 2017-03-01 15:47:14 -0800 |
commit | fa47be45c1f8787ce48fea135563f2579e92ce4e (patch) | |
tree | f62d508cb9fe0501b86a8dc0b5cadb11edd4ef47 | |
parent | b77d8dee99b1ed396cdfa89cec76cbd11d9212c1 (diff) | |
download | kazoo-fa47be45c1f8787ce48fea135563f2579e92ce4e.tar.gz |
Always call _safe_close() on KazooClient.stop() so we don't leak worker threads
-rw-r--r-- | kazoo/client.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/kazoo/client.py b/kazoo/client.py index 99d8bb7..2e760f3 100644 --- a/kazoo/client.py +++ b/kazoo/client.py @@ -595,8 +595,10 @@ class KazooClient(object): self._stopped.set() self._queue.append((CloseInstance, None)) - self._connection._write_sock.send(b'\0') - self._safe_close() + try: + self._connection._write_sock.send(b'\0') + finally: + self._safe_close() def restart(self): """Stop and restart the Zookeeper session.""" |