fix deadlock in nonblocking semaphore acquiring, do inner lock release for every lock acquiring attempt

1 files changed, 3 insertions, 3 deletions

diff --git a/kazoo/recipe/lock.py b/kazoo/recipe/lock.py
index d351539..59cd146 100644
--- a/kazoo/recipe/lock.py
+++ b/kazoo/recipe/lock.py
@@ -472,10 +472,10 @@ class Semaphore(object):
         w = _Watch(duration=timeout)
         w.start()
         lock = self.client.Lock(self.lock_path, self.data)
-        gotten = lock.acquire(blocking=blocking, timeout=w.leftover())
-        if not gotten:
-            return False
         try:
+            gotten = lock.acquire(blocking=blocking, timeout=w.leftover())
+            if not gotten:
+                return False
             while True:
                 self.wake_event.clear()