Teach uploader's _scan to use the deque
authorDavid Stainton <dstainton415@gmail.com>
Tue, 15 Dec 2015 16:16:22 +0000 (18:16 +0200)
committerDaira Hopwood <daira@jacaranda.org>
Mon, 21 Dec 2015 22:24:34 +0000 (22:24 +0000)
src/allmydata/frontends/magic_folder.py

index 2b10d3163a173cab0544e5d49935d54cf21d2b6d..06cebf290259d49551b2c35d0bc7d8804a76aa63 100644 (file)
@@ -237,16 +237,10 @@ class Uploader(QueueMixin):
         return self._full_scan()
 
     def _full_scan(self):
+        print "FULL SCAN"
         self._pending = self._db.get_all_relpaths()
         self._log("all_files %r" % (self._pending))
         d = self._scan(u"")
-        def _add_pending(ign):
-            # This adds all of the files that were in the db but not already processed
-            # (normally because they have been deleted on disk).
-            self._log("adding %r" % (self._pending))
-            self._deque.extend(self._pending)
-        d.addCallback(_add_pending)
-        d.addCallback(lambda ign: self._turn_deque())
         return d
 
     def _scan(self, reldir_u):
@@ -271,13 +265,11 @@ class Uploader(QueueMixin):
                     return None
 
                 self._pending.add(relpath_u)
-                return relpath_u
             d.addCallback(_add_pending)
-            # This call to _process doesn't go through the deque, and probably should.
-            d.addCallback(self._process)
-            d.addBoth(self._call_hook, 'processed')
-            d.addErrback(log.err)
-
+        def _add_pending(ign):
+            self._log("adding %r" % (self._pending))
+            self._deque.extend(self._pending)
+        d.addCallback(_add_pending)
         return d
 
     def is_pending(self, relpath_u):