mirror/borg
1
0
Fork 0
mirror of https://github.com/borgbackup/borg.git synced 2025-01-31 11:42:05 +00:00
Code Issues Releases Wiki Activity

Fix issue with truncated file cache file

Browse source
This commit is contained in:
Jonas Borgström 2011-07-06 22:11:01 +02:00
parent f7ebd19640
commit 1711a457f7
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
darc/cache.py
View file

@ -60,7 +60,7 @@ def open(self):
self.id = self.config.get('cache', 'store_id').decode('hex')
self.tid = self.config.getint('cache', 'tid')
self.chunks = NSIndex(os.path.join(self.path, 'chunks'))
self.files = {}
self.files = None
def _read_files(self):
with open(os.path.join(self.path, 'files'), 'rb') as fd:
@ -90,9 +90,10 @@ def commit(self):
"""
if not self.txn_active:
return
with open(os.path.join(self.path, 'files'), 'wb') as fd:
for item in self.files.iteritems():
msgpack.pack(item, fd)
if self.files is not None:
with open(os.path.join(self.path, 'files'), 'wb') as fd:
for item in self.files.iteritems():
msgpack.pack(item, fd)
for id, (count, size) in self.chunks.iteritems():
if count > 1000000:
self.chunks[id] = count - 1000000, size
@ -170,7 +171,7 @@ def chunk_decref(self, id):
self.chunks[id] = (count - 1, size)
def file_known_and_unchanged(self, path_hash, st):
if not self.files:
if self.files is None:
self._read_files()
entry = self.files.get(path_hash)
if (entry and entry[3] == st.st_mtime