+
+ all_relpaths = self._db.get_all_relpaths()
+ self._log("all relpaths: %r" % (all_relpaths,))
+
+ for relpath_u in all_relpaths:
+ self._add_pending(relpath_u)
+
+ self._full_scan()
+ self._extend_queue_and_keep_going(self._pending)
+
+ def _extend_queue_and_keep_going(self, relpaths_u):
+ self._log("queueing %r" % (relpaths_u,))
+ self._deque.extend(relpaths_u)
+ self._count('objects_queued', len(relpaths_u))
+
+ if self.is_ready:
+ if self._immediate: # for tests
+ self._turn_deque()
+ else:
+ self._clock.callLater(0, self._turn_deque)