Show More
@@ -341,6 +341,9 b' def get_mutex_lock(client, lock_key, loc' | |||||
341 | return self.lock.acquire(wait) |
|
341 | return self.lock.acquire(wait) | |
342 | except redis_lock.AlreadyAcquired: |
|
342 | except redis_lock.AlreadyAcquired: | |
343 | return False |
|
343 | return False | |
|
344 | except redis_lock.AlreadyStarted: | |||
|
345 | # refresh thread exists, but it also means we acquired the lock | |||
|
346 | return True | |||
344 |
|
347 | |||
345 | def release(self): |
|
348 | def release(self): | |
346 | try: |
|
349 | try: |
General Comments 0
You need to be logged in to leave comments.
Login now