Merge pull request #344 from treviza153/bugfix/CheckingLock

Adding get cached info validation

docker-compose.yml

@@ -56,8 +56,8 @@ services:
         image: globocom/networkapi:latest
         restart: always
         ports:
-            - "127.0.0.1:8000:8000"
-            - "127.0.0.1:8001:8001"
+            - "8000:8000"
+            - "8001:8001"
         env_file:
             - scripts/docker/netapi.env
         volumes:

networkapi/distributedlock/__init__.py

@@ -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()

networkapi/distributedlock/memcachedlock.py

@@ -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

networkapi/util/geral.py

@@ -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: