From: David Stainton Date: Thu, 17 Dec 2015 23:17:01 +0000 (+0200) Subject: Naive periodic full scan X-Git-Url: https://git.rkrishnan.org/(%5B%5E?a=commitdiff_plain;h=dabce4b1906c6e0ab58bfc0ac5e18363c4a9cb49;p=tahoe-lafs%2Ftahoe-lafs.git Naive periodic full scan --- diff --git a/src/allmydata/frontends/magic_folder.py b/src/allmydata/frontends/magic_folder.py index f3da04c6..87655951 100644 --- a/src/allmydata/frontends/magic_folder.py +++ b/src/allmydata/frontends/magic_folder.py @@ -194,6 +194,8 @@ class Uploader(QueueMixin): self._notifier = self._inotify.INotify() self._pending = set() # of unicode relpaths + self._periodic_full_scan_duration = 10 * 60 # perform a full scan every 10 minutes + if hasattr(self._notifier, 'set_pending_delay'): self._notifier.set_pending_delay(pending_delay) @@ -222,6 +224,7 @@ class Uploader(QueueMixin): self._log("stop") self._notifier.stopReading() self._count('dirs_monitored', -1) + self.periodic_callid.cancel() if hasattr(self._notifier, 'wait_until_stopped'): d = self._notifier.wait_until_stopped() else: @@ -239,7 +242,7 @@ class Uploader(QueueMixin): for relpath_u in all_relpaths: self._add_pending(relpath_u) - self._full_scan() + self._periodic_full_scan() self._extend_queue_and_keep_going(self._pending) def _extend_queue_and_keep_going(self, relpaths_u): @@ -253,6 +256,10 @@ class Uploader(QueueMixin): else: self._clock.callLater(0, self._turn_deque) + def _periodic_full_scan(self): + self.periodic_callid = self._clock.callLater(self._periodic_full_scan_duration, self._periodic_full_scan) + self._full_scan() + def _full_scan(self): print "FULL SCAN" self._log("_pending %r" % (self._pending))