From a980ea337bcd74dca34938246c5b29292cdc2a68 Mon Sep 17 00:00:00 2001 From: Brian Warner Date: Tue, 1 Dec 2009 17:54:38 -0500 Subject: [PATCH] remove MutableFileNode.download(), prefer download_best_version() instead --- src/allmydata/mutable/filenode.py | 15 --------------- src/allmydata/test/common.py | 18 ++---------------- 2 files changed, 2 insertions(+), 31 deletions(-) diff --git a/src/allmydata/mutable/filenode.py b/src/allmydata/mutable/filenode.py index 4e531b96..f8e12b5f 100644 --- a/src/allmydata/mutable/filenode.py +++ b/src/allmydata/mutable/filenode.py @@ -278,21 +278,6 @@ class MutableFileNode: ################################# # IMutableFileNode - # allow the use of IDownloadTarget - def download(self, target): - # fake it. TODO: make this cleaner. - d = self.download_best_version() - def _done(data): - target.open(len(data)) - target.write(data) - target.close() - return target.finish() - d.addCallback(_done) - return d - - - # new API - def download_best_version(self): return self._do_serialized(self._download_best_version) def _download_best_version(self): diff --git a/src/allmydata/test/common.py b/src/allmydata/test/common.py index 7113cceb..ef2f6795 100644 --- a/src/allmydata/test/common.py +++ b/src/allmydata/test/common.py @@ -270,6 +270,8 @@ class FakeMutableFileNode: return d def download_best_version(self): + if self.storage_index not in self.all_contents: + return defer.fail(NotEnoughSharesError(None, 0, 3)) return defer.succeed(self.all_contents[self.storage_index]) def overwrite(self, new_contents): if len(new_contents) > self.MUTABLE_SIZELIMIT: @@ -288,22 +290,6 @@ class FakeMutableFileNode: self.all_contents[self.storage_index] = modifier(old_contents, None, True) return None - def download(self, target): - if self.storage_index not in self.all_contents: - f = failure.Failure(NotEnoughSharesError(None, 0, 3)) - target.fail(f) - return defer.fail(f) - data = self.all_contents[self.storage_index] - target.open(len(data)) - target.write(data) - target.close() - return defer.maybeDeferred(target.finish) - def download_to_data(self): - if self.storage_index not in self.all_contents: - return defer.fail(NotEnoughSharesError(None, 0, 3)) - data = self.all_contents[self.storage_index] - return defer.succeed(data) - def make_mutable_file_cap(): return uri.WriteableSSKFileURI(writekey=os.urandom(16), fingerprint=os.urandom(32)) -- 2.45.2