tahoe-lafs/tahoe-lafs
tahoe-lafs
/
tahoe-lafs
2
0
Fork 0
Code Issues Pull Requests 23 Packages Projects Releases 1 Wiki Activity

only keep history for items that are processed

This commit is contained in:
meejah 2018-01-15 18:10:02 -07:00
parent bcdd15394b
commit 8ac63cf5bd
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/allmydata/frontends/magic_folder.py
View File

@ -432,8 +432,11 @@ class QueueMixin(HookMixin):
self._log(" processing '%r'" % (item,)) self._log(" processing '%r'" % (item,))
proc = yield self._process(item) proc = yield self._process(item)
self._log(" done: %r" % proc) self._log(" done: %r" % proc)
if not proc:
self._process_history.remove(item)
except Exception as e: except Exception as e:
log.err("processing '%r' failed: %s" % (item, e)) log.err("processing '%r' failed: %s" % (item, e))
item.set_status('failed', self._clock.seconds())
proc = Failure() proc = Failure()
self._call_hook(proc, 'processed') self._call_hook(proc, 'processed')
@ -668,6 +671,10 @@ class Uploader(QueueMixin):
self._call_hook(path, 'inotify') self._call_hook(path, 'inotify')
def _process(self, item): def _process(self, item):
"""
process a single QueuedItem. If this returns False, the item is
removed from _process_history
"""
# Uploader # Uploader
relpath_u = item.relpath_u relpath_u = item.relpath_u
self._log("_process(%r)" % (relpath_u,)) self._log("_process(%r)" % (relpath_u,))