Don't reuse cache locks between instances of class
This commit is contained in:
parent
ae4c8a0bd1
commit
6e73a1bebf
@ -761,6 +761,10 @@ class Collection(BaseCollection):
|
|||||||
"storage", "filesystem_close_lock_file")
|
"storage", "filesystem_close_lock_file")
|
||||||
cls._lock = FileBackedRwLock(lock_path, close_lock_file)
|
cls._lock = FileBackedRwLock(lock_path, close_lock_file)
|
||||||
|
|
||||||
|
# init cache lock
|
||||||
|
cls._cache_locks = {}
|
||||||
|
cls._cache_locks_lock = threading.Lock()
|
||||||
|
|
||||||
def __init__(self, path, principal=None, folder=None,
|
def __init__(self, path, principal=None, folder=None,
|
||||||
filesystem_path=None):
|
filesystem_path=None):
|
||||||
# DEPRECATED: Remove principal and folder attributes
|
# DEPRECATED: Remove principal and folder attributes
|
||||||
@ -1309,9 +1313,6 @@ class Collection(BaseCollection):
|
|||||||
pass
|
pass
|
||||||
return content
|
return content
|
||||||
|
|
||||||
_cache_locks = {}
|
|
||||||
_cache_locks_lock = threading.Lock()
|
|
||||||
|
|
||||||
@contextmanager
|
@contextmanager
|
||||||
def _acquire_cache_lock(self, ns=""):
|
def _acquire_cache_lock(self, ns=""):
|
||||||
if "/" in ns:
|
if "/" in ns:
|
||||||
|
Loading…
Reference in New Issue
Block a user