Show More
@@ -341,6 +341,9 b' def get_mutex_lock(client, lock_key, loc' | |||
|
341 | 341 | return self.lock.acquire(wait) |
|
342 | 342 | except redis_lock.AlreadyAcquired: |
|
343 | 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 | 348 | def release(self): |
|
346 | 349 | try: |
General Comments 0
You need to be logged in to leave comments.
Login now