ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2024-12-20 05:28:04 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Add ignore pending argument to _periodic_full_scan

Browse Source
This commit is contained in:
David Stainton 2015-12-18 02:44:56 +02:00 committed by Brian Warner
parent cf462d8b1f
commit 96b846f762
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -242,7 +242,7 @@ class Uploader(QueueMixin):
for relpath_u in all_relpaths:
self._add_pending(relpath_u)
self._periodic_full_scan()
self._periodic_full_scan(ignore_pending=True)
self._extend_queue_and_keep_going(self._pending)
def _extend_queue_and_keep_going(self, relpaths_u):
@ -256,10 +256,13 @@ class Uploader(QueueMixin):
else:
self._clock.callLater(0, self._turn_deque)
def _periodic_full_scan(self):
def _periodic_full_scan(self, ignore_pending=False):
self.periodic_callid = self._clock.callLater(self._periodic_full_scan_duration, self._periodic_full_scan)
if len(self._pending) == 0:
if ignore_pending:
self._full_scan()
else:
if len(self._pending) == 0:
self._full_scan()
def _full_scan(self):
print "FULL SCAN"