From: Brian Warner Date: Thu, 31 Jan 2008 02:03:19 +0000 (-0700) Subject: remove upload.upload_(data,filename,filehandle) convenience functions X-Git-Url: https://git.rkrishnan.org/%5B/%5D%20/uri/frontends/FTP-and-SFTP.rst?a=commitdiff_plain;h=909d8480714fdbe04c0a1ffa06a6e12a6bd3bb89;p=tahoe-lafs%2Ftahoe-lafs.git remove upload.upload_(data,filename,filehandle) convenience functions --- diff --git a/src/allmydata/control.py b/src/allmydata/control.py index 2fc3afc3..2428948b 100644 --- a/src/allmydata/control.py +++ b/src/allmydata/control.py @@ -44,7 +44,8 @@ class ControlServer(Referenceable, service.Service, testutil.PollMixin): def remote_upload_from_file_to_uri(self, filename): uploader = self.parent.getServiceNamed("uploader") - d = uploader.upload_filename(filename) + u = upload.FileName(filename) + d = uploader.upload(u) return d def remote_download_from_uri_to_file(self, uri, filename): diff --git a/src/allmydata/test/test_helper.py b/src/allmydata/test/test_helper.py index cf766ac7..6fa96585 100644 --- a/src/allmydata/test/test_helper.py +++ b/src/allmydata/test/test_helper.py @@ -53,6 +53,10 @@ def flush_but_dont_ignore(res): d.addCallback(_done) return d +def upload_data(uploader, data): + u = upload.Data(data) + return uploader.upload(u) + class AssistedUpload(unittest.TestCase): def setUp(self): self.s = FakeClient() @@ -94,7 +98,7 @@ class AssistedUpload(unittest.TestCase): assert u._helper DATA = "I need help\n" * 1000 - return u.upload_data(DATA) + return upload_data(u, DATA) d.addCallback(_ready) def _uploaded(uri): assert "CHK" in uri @@ -137,7 +141,7 @@ class AssistedUpload(unittest.TestCase): def _ready(res): assert u._helper - return u.upload_data(DATA) + return upload_data(u, DATA) d.addCallback(_ready) def _uploaded(uri): assert "CHK" in uri @@ -168,7 +172,7 @@ class AssistedUpload(unittest.TestCase): assert u._helper DATA = "I need help\n" * 1000 - return u.upload_data(DATA) + return upload_data(u, DATA) d.addCallback(_ready) def _uploaded(uri): assert "CHK" in uri diff --git a/src/allmydata/test/test_upload.py b/src/allmydata/test/test_upload.py index 52d84863..c402d08a 100644 --- a/src/allmydata/test/test_upload.py +++ b/src/allmydata/test/test_upload.py @@ -181,6 +181,16 @@ SIZE_ZERO = 0 SIZE_SMALL = 16 SIZE_LARGE = len(DATA) +def upload_data(uploader, data): + u = upload.Data(data) + return uploader.upload(u) +def upload_filename(uploader, filename): + u = upload.FileName(filename) + return uploader.upload(u) +def upload_filehandle(uploader, fh): + u = upload.FileHandle(fh) + return uploader.upload(u) + class GoodServer(unittest.TestCase): def setUp(self): self.node = FakeClient(mode="good") @@ -215,19 +225,19 @@ class GoodServer(unittest.TestCase): def test_data_zero(self): data = self.get_data(SIZE_ZERO) - d = self.u.upload_data(data) + d = upload_data(self.u, data) d.addCallback(self._check_small, SIZE_ZERO) return d def test_data_small(self): data = self.get_data(SIZE_SMALL) - d = self.u.upload_data(data) + d = upload_data(self.u, data) d.addCallback(self._check_small, SIZE_SMALL) return d def test_data_large(self): data = self.get_data(SIZE_LARGE) - d = self.u.upload_data(data) + d = upload_data(self.u, data) d.addCallback(self._check_large, SIZE_LARGE) return d @@ -236,25 +246,25 @@ class GoodServer(unittest.TestCase): segsize = int(SIZE_LARGE / 2.5) # we want 3 segments, since that's not a power of two self.set_encoding_parameters(25, 75, 100, segsize) - d = self.u.upload_data(data) + d = upload_data(self.u, data) d.addCallback(self._check_large, SIZE_LARGE) return d def test_filehandle_zero(self): data = self.get_data(SIZE_ZERO) - d = self.u.upload_filehandle(StringIO(data)) + d = upload_filehandle(self.u, StringIO(data)) d.addCallback(self._check_small, SIZE_ZERO) return d def test_filehandle_small(self): data = self.get_data(SIZE_SMALL) - d = self.u.upload_filehandle(StringIO(data)) + d = upload_filehandle(self.u, StringIO(data)) d.addCallback(self._check_small, SIZE_SMALL) return d def test_filehandle_large(self): data = self.get_data(SIZE_LARGE) - d = self.u.upload_filehandle(StringIO(data)) + d = upload_filehandle(self.u, StringIO(data)) d.addCallback(self._check_large, SIZE_LARGE) return d @@ -264,7 +274,7 @@ class GoodServer(unittest.TestCase): data = self.get_data(SIZE_ZERO) f.write(data) f.close() - d = self.u.upload_filename(fn) + d = upload_filename(self.u, fn) d.addCallback(self._check_small, SIZE_ZERO) return d @@ -274,7 +284,7 @@ class GoodServer(unittest.TestCase): data = self.get_data(SIZE_SMALL) f.write(data) f.close() - d = self.u.upload_filename(fn) + d = upload_filename(self.u, fn) d.addCallback(self._check_small, SIZE_SMALL) return d @@ -284,7 +294,7 @@ class GoodServer(unittest.TestCase): data = self.get_data(SIZE_LARGE) f.write(data) f.close() - d = self.u.upload_filename(fn) + d = upload_filename(self.u, fn) d.addCallback(self._check_large, SIZE_LARGE) return d @@ -300,7 +310,7 @@ class FullServer(unittest.TestCase): def test_data_large(self): data = DATA - d = self.u.upload_data(data) + d = upload_data(self.u, data) d.addBoth(self._should_fail) return d @@ -339,7 +349,7 @@ class PeerSelection(unittest.TestCase): self.make_client() data = self.get_data(SIZE_LARGE) self.set_encoding_parameters(25, 30, 50) - d = self.u.upload_data(data) + d = upload_data(self.u, data) d.addCallback(self._check_large, SIZE_LARGE) def _check(res): for p in self.node.last_peers: @@ -356,7 +366,7 @@ class PeerSelection(unittest.TestCase): self.make_client() data = self.get_data(SIZE_LARGE) self.set_encoding_parameters(50, 75, 100) - d = self.u.upload_data(data) + d = upload_data(self.u, data) d.addCallback(self._check_large, SIZE_LARGE) def _check(res): for p in self.node.last_peers: @@ -373,7 +383,7 @@ class PeerSelection(unittest.TestCase): self.make_client() data = self.get_data(SIZE_LARGE) self.set_encoding_parameters(24, 41, 51) - d = self.u.upload_data(data) + d = upload_data(self.u, data) d.addCallback(self._check_large, SIZE_LARGE) def _check(res): got_one = [] @@ -400,7 +410,7 @@ class PeerSelection(unittest.TestCase): self.make_client() data = self.get_data(SIZE_LARGE) self.set_encoding_parameters(100, 150, 200) - d = self.u.upload_data(data) + d = upload_data(self.u, data) d.addCallback(self._check_large, SIZE_LARGE) def _check(res): for p in self.node.last_peers: @@ -417,7 +427,7 @@ class PeerSelection(unittest.TestCase): self.make_client(3) data = self.get_data(SIZE_LARGE) self.set_encoding_parameters(3, 5, 10) - d = self.u.upload_data(data) + d = upload_data(self.u, data) d.addCallback(self._check_large, SIZE_LARGE) def _check(res): counts = {} diff --git a/src/allmydata/upload.py b/src/allmydata/upload.py index 9837f62a..7a9d0b34 100644 --- a/src/allmydata/upload.py +++ b/src/allmydata/upload.py @@ -973,11 +973,3 @@ class Uploader(service.MultiService): return res d.addBoth(_done) return d - - # utility functions - def upload_data(self, data, contenthashkey=True): - return self.upload(Data(data, contenthashkey=contenthashkey)) - def upload_filename(self, filename, contenthashkey=True): - return self.upload(FileName(filename, contenthashkey=contenthashkey)) - def upload_filehandle(self, filehandle, contenthashkey=True): - return self.upload(FileHandle(filehandle, contenthashkey=contenthashkey))