]> git.rkrishnan.org Git - tahoe-lafs/tahoe-lafs.git/commitdiff
Attempt to fix test_persistence
authorDavid Stainton <dstainton415@gmail.com>
Mon, 31 Aug 2015 21:38:55 +0000 (23:38 +0200)
committerDaira Hopwood <daira@jacaranda.org>
Wed, 30 Sep 2015 15:45:26 +0000 (16:45 +0100)
broken WIP, startup path was broken

src/allmydata/frontends/magic_folder.py
src/allmydata/test/test_magic_folder.py

index c6a00511561d9da8627bb661903be674437afe81..2557fb73b1009f720c2ef87b88716eef325e9a7c 100644 (file)
@@ -395,6 +395,11 @@ class Downloader(QueueMixin):
         self._download_scan_batch = {} # path -> [(filenode, metadata)]
 
     def start_scanning(self):
+        print "start_scanning----\n"
+        all_files = self._db.get_all_files()
+        print "---------------------"
+        print "all files in magic folder db: %s\n" % all_files
+        print "---------------------"
         d = self._scan_remote_collective()
         self._turn_deque()
         return d
index 39ecb8a39e36950c4f33097d56c9ce57fcb6d2d5..6b2154eb57b043453f4abe91d993b762933412f5 100644 (file)
@@ -209,25 +209,31 @@ class MagicFolderTestMixin(MagicFolderTestMixin, ShouldFailMixin, ReallyEqualMix
         d.addCallback(lambda ign: self.failUnlessReallyEqual(self._get_count('uploader.objects_queued'), 0))
 
         def restart(ignore):
-            #print "restart"
+            print "restart"
             tahoe_config_file = os.path.join(self.get_clientdir(), "tahoe.cfg")
             tahoe_config = fileutil.read(tahoe_config_file)
             d3 = defer.succeed(None)
             def write_config(client_node_dir):
-                #print "write_config"
+                print "write_config"
                 fileutil.write(os.path.join(client_node_dir, "tahoe.cfg"), tahoe_config)
             def setup_stats(result):
-                #print "setup_stats"
+                print "setup_stats"
                 self.client = None
                 self.set_up_grid(client_config_hooks={0: write_config})
                 self.client = self.g.clients[0]
                 self.stats_provider = self.client.stats_provider
                 self.magicfolder = self.client.getServiceNamed("magic-folder")
 
-            d3.addBoth(self.cleanup)
+                #dbfile = abspath_expanduser_unicode(u"magicfolderdb.sqlite", base=self.basedir)
+                #self.magicfolder = MagicFolder(self.client, self.upload_dircap, self.collective_dircap, self.local_dir,
+                #                               dbfile, inotify=self.inotify, pending_delay=0.2)
+                self.magicfolder.setServiceParent(self.client)
+                self.magicfolder.ready()
+
+            #d3.addBoth(self.cleanup)
             d3.addCallback(setup_stats)
-            #d3.addCallback(self._create_magicfolder)
             return d3
+        d.addBoth(self.cleanup)
         d.addCallback(restart)
         d.addCallback(lambda ign: self.failUnlessReallyEqual(self._get_count('uploader.objects_succeeded'), 0))
         d.addCallback(lambda ign: self.failUnlessReallyEqual(self._get_count('uploader.objects_queued'), 0))