Merge "redis: fix concurrent access on acquire()"
This commit is contained in:
commit
9f87cf158d
@ -88,7 +88,8 @@ class RedisLock(locking.Lock):
|
||||
acquired = self._lock.acquire(
|
||||
blocking=blocking, blocking_timeout=timeout)
|
||||
if acquired:
|
||||
self._coord._acquired_locks.add(self)
|
||||
with self._exclusive_access:
|
||||
self._coord._acquired_locks.add(self)
|
||||
return acquired
|
||||
|
||||
def release(self):
|
||||
|
Loading…
x
Reference in New Issue
Block a user