sablink/entropy
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[entropy.db.sqlite] do not clear the cache if locks are already acquired

Browse Source
This commit is contained in:
Fabio Erculiani
2013-12-26 16:08:16 +01:00
parent 603c96fc05
commit 11e6d596b8
1 changed files with 20 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/entropy/db/sqlite.py
+20 -12
View File
@@ -563,11 +563,13 @@ class EntropySQLiteRepository(EntropySQLRepository):
if lock.directed():
return lock
already_acquired = lock.is_already_acquired()
lock.acquire_shared()
# in-RAM cached data may have become stale
if not self._is_memory():
self.clearCache()
if not already_acquired:
# in-RAM cached data may have become stale
if not self._is_memory():
self.clearCache()
return lock
@@ -579,11 +581,13 @@ class EntropySQLiteRepository(EntropySQLRepository):
if lock.directed():
return lock
already_acquired = lock.is_already_acquired()
acquired = lock.try_acquire_shared()
if acquired:
# in-RAM cached data may have become stale
if not self._is_memory():
self.clearCache()
if not already_acquired:
# in-RAM cached data may have become stale
if not self._is_memory():
self.clearCache()
return lock
else:
return None
@@ -596,11 +600,13 @@ class EntropySQLiteRepository(EntropySQLRepository):
if lock.directed():
return lock
already_acquired = lock.is_already_acquired()
lock.acquire_exclusive()
# in-RAM cached data may have become stale
if not self._is_memory():
self.clearCache()
if not already_acquired:
# in-RAM cached data may have become stale
if not self._is_memory():
self.clearCache()
return lock
def try_acquire_exclusive(self):
@@ -611,11 +617,13 @@ class EntropySQLiteRepository(EntropySQLRepository):
if lock.directed():
return lock
already_acquired = lock.is_already_acquired()
acquired = lock.try_acquire_exclusive()
if acquired:
# in-RAM cached data may have become stale
if not self._is_memory():
self.clearCache()
if not already_acquired:
# in-RAM cached data may have become stale
if not self._is_memory():
self.clearCache()
return lock
def _release_reslock(self, lock, mode):