Skip to content

Commit

Permalink
adding get cached info validation
Browse files Browse the repository at this point in the history
  • Loading branch information
Carlos Júnior committed Aug 18, 2021
1 parent 9ca8ba7 commit 8684564
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 0 deletions.
3 changes: 3 additions & 0 deletions networkapi/distributedlock/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -117,3 +117,6 @@ def __enter__(self):
def __exit__(self, type, value, traceback):
_debug('releasing lock %s' % self.key)
self.lock.release()

def get_cached_data(self):
return self.lock.get_cached_data()
5 changes: 5 additions & 0 deletions networkapi/distributedlock/memcachedlock.py
Original file line number Diff line number Diff line change
Expand Up @@ -69,3 +69,8 @@ def release(self):
else:
log.warning(
"I've no lock to release. Increase TIMEOUT of lock operations")

def get_cached_data(self):
value = self.client.get(self.key)

return value if value else None
3 changes: 3 additions & 0 deletions networkapi/util/geral.py
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,9 @@ def create_lock_with_blocking(locks_name):
for lock_name in locks_name:
try:
lock = distributedlock(lock_name, blocking=False)
if lock.get_cached_data():
log.info('Get cached lock data for {}. Disabling it and creating a new lock'.format(lock_name))
lock.__exit__('', '', '')
lock.__enter__()
locks_list.append(lock)
except LockNotAcquiredError:
Expand Down

0 comments on commit 8684564

Please sign in to comment.