diff options
| author | Mehdi Abaakouk <mehdi.abaakouk@enovance.com> | 2014-10-06 10:45:08 +0200 |
|---|---|---|
| committer | Mehdi Abaakouk <sileht@sileht.net> | 2014-10-06 10:45:10 +0200 |
| commit | 8932510009d4ee80db7b36bc1db6f08e3547543e (patch) | |
| tree | 6bd66c464eebdf8ed4b268bf708bdd926ac6eb84 | |
| parent | d00413cdfa02749e8e5d7ee83ac957ecc74cb1be (diff) | |
| download | tooz-8932510009d4ee80db7b36bc1db6f08e3547543e.tar.gz | |
ipc: Fix acquire lock loop logic
Really restart the loop, when ExistentialError occurs.
Change-Id: I01de25fc4a1ef5681e2878d1215251cea1dd9f33
| -rw-r--r-- | tooz/drivers/ipc.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tooz/drivers/ipc.py b/tooz/drivers/ipc.py index c89bdf8..207c843 100644 --- a/tooz/drivers/ipc.py +++ b/tooz/drivers/ipc.py @@ -87,14 +87,14 @@ class IPCLock(locking.Lock): except sysv_ipc.ExistentialError: # Semaphore has been deleted in the mean time, retry from # the beginning! - pass + continue try: self._lock.acquire(timeout=timeout) except sysv_ipc.BusyError: return False except sysv_ipc.ExistentialError: # Likely the lock has been deleted in the meantime, retry - pass + continue else: return True |