mirror/borg
1
0
Fork 0
mirror of https://github.com/borgbackup/borg.git synced 2024-12-26 01:37:20 +00:00
Code Issues Releases Wiki Activity

cache: adjust AdHocCache API (test_create_no_cache_sync)

Browse source
This commit is contained in:
Marian Beermann 2017-07-30 21:50:57 +02:00
parent 03dea8c78b
commit c5a154985f
1 changed files with 5 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/borg/cache.py
View file

@ -976,7 +976,7 @@ def memorize_file(self, path_hash, st, ids):
def add_chunk(self, id, chunk, stats, overwrite=False, wait=True):
assert not overwrite, 'AdHocCache does not permit overwrites — trying to use it for recreate?'
if not self._txn_active:
self._begin_txn()
self.begin_txn()
size = len(chunk)
refcount = self.seen_chunk(id, size)
if refcount:
@ -990,7 +990,7 @@ def add_chunk(self, id, chunk, stats, overwrite=False, wait=True):
def seen_chunk(self, id, size=None):
if not self._txn_active:
self._begin_txn()
self.begin_txn()
entry = self.chunks.get(id, ChunkIndexEntry(0, None, None))
if entry.refcount and size and not entry.size:
# The LocalCache has existing size information and uses *size* to make an effort at detecting collisions.
@ -1001,7 +1001,7 @@ def seen_chunk(self, id, size=None):
def chunk_incref(self, id, stats, size=None):
if not self._txn_active:
self._begin_txn()
self.begin_txn()
count, _size, csize = self.chunks.incref(id)
# When _size is 0 and size is not given, then this chunk has not been locally visited yet (seen_chunk with
# size or add_chunk); we can't add references to those (size=0 is invalid) and generally don't try to.
@ -1012,7 +1012,7 @@ def chunk_incref(self, id, stats, size=None):
def chunk_decref(self, id, stats, wait=True):
if not self._txn_active:
self._begin_txn()
self.begin_txn()
count, size, csize = self.chunks.decref(id)
if count == 0:
del self.chunks[id]
@ -1031,9 +1031,7 @@ def rollback(self):
self._txn_active = False
del self.chunks
# Private API
def _begin_txn(self):
def begin_txn(self):
self._txn_active = True
# Explicitly set the initial hash table capacity to avoid performance issues
# due to hash table "resonance".