From d383cbb668bae0e5bb34b9b7a654deaed891bbc8 Mon Sep 17 00:00:00 2001 From: David Stainton Date: Tue, 21 Apr 2015 18:48:14 +0100 Subject: [PATCH] wip - confirming that the db persistence doesn't work --- src/allmydata/frontends/drop_upload.py | 21 ++++++++++++++++++--- src/allmydata/test/test_drop_upload.py | 5 +++-- 2 files changed, 21 insertions(+), 5 deletions(-) diff --git a/src/allmydata/frontends/drop_upload.py b/src/allmydata/frontends/drop_upload.py index d6e9e608..1d338758 100644 --- a/src/allmydata/frontends/drop_upload.py +++ b/src/allmydata/frontends/drop_upload.py @@ -123,9 +123,10 @@ class DropUploader(service.MultiService): if must_upload: self._append_to_deque(childpath) elif isfile: - print "isfile" + print "isfile %s" % (childpath,) must_upload = self._check_db_file(childpath) if must_upload: + print "must_upload" self._append_to_deque(childpath) else: self.warn("WARNING: cannot backup special file %s" % quote_local_unicode_path(childpath)) @@ -205,8 +206,8 @@ class DropUploader(service.MultiService): if sys.platform != "win32": name = name.decode(get_filesystem_encoding()) # XXX - #dirname = path.decode(get_filesystem_encoding()) - dirname = path + dirname = path.decode(get_filesystem_encoding()) + #dirname = path return self._parent.create_subdirectory(name) @@ -225,6 +226,20 @@ class DropUploader(service.MultiService): return None elif os.path.isfile(path): d.addCallback(_add_file) + def add_db_entry(val): + filecap = val.get_uri() + print "filename %s filecap %s" % (path, filecap) + s = os.stat(path) + self._db.did_upload_file(filecap, path.decode('UTF-8'), s.st_mtime, s.st_ctime, s.st_size) + + #r = self._db.check_file(path.decode('UTF-8')) + #was_uploaded = r.was_uploaded() + #if was_uploaded: + # print "was_uploaded true" + #else: + # print "was_uploaded false" + + d.addCallback(add_db_entry) self._stats_provider.count('drop_upload.files_uploaded', 1) return None else: diff --git a/src/allmydata/test/test_drop_upload.py b/src/allmydata/test/test_drop_upload.py index f1688882..825f515c 100644 --- a/src/allmydata/test/test_drop_upload.py +++ b/src/allmydata/test/test_drop_upload.py @@ -157,12 +157,13 @@ class DropUploadTestMixin(GridTestMixin, ShouldFailMixin, ReallyEqualMixin, NonA d.addCallback(lambda ign: self.failUnlessReallyEqual(self._get_count('drop_upload.objects_queued'), 0)) d.addCallback(self._cleanup) d.addCallback(lambda ign: self.client.removeService(self.uploader)) - + def msg(val): + print "stopped and removed uploader service." + d.addCallback(msg) d.addCallback(self._made_upload_dir) d.addCallback(lambda ign: self.failUnlessReallyEqual(self._get_count('drop_upload.objects_queued'), 0)) d.addCallback(lambda ign: self.failUnlessReallyEqual(self._get_count('drop_upload.objects_uploaded'), 1)) d.addBoth(self._cleanup) - return d def _test(self): -- 2.45.2