From bbc704834bf15798e4bce3e75e3baaebd38a8765 Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Tue, 26 Sep 2017 02:07:53 -0300 Subject: [feature] retry during upload + proper wait Added retry to upload and modified retry implementation to comply with discussed spec. According to it, we should wait between retries, something like 1s, 10s, .. up to 1 minute. -- Resolves: #8822 --- tests/server/test_blobs_server.py | 23 +++++++++++++++++++++++ 1 file changed, 23 insertions(+) (limited to 'tests') diff --git a/tests/server/test_blobs_server.py b/tests/server/test_blobs_server.py index f27fa985..e3bc761d 100644 --- a/tests/server/test_blobs_server.py +++ b/tests/server/test_blobs_server.py @@ -255,6 +255,29 @@ class BlobServerTestCase(unittest.TestCase): self.assertIsNotNone(result) self.assertEquals(result[0].getvalue(), "X") + @defer.inlineCallbacks + @pytest.mark.usefixtures("method_tmpdir") + def test_send_missing_retry(self): + manager = BlobManager(self.tempdir, self.uri, self.secret, + self.secret, uuid4().hex) + self.addCleanup(manager.close) + blob_id = 'remote_only_blob_id' + yield manager.local.put(blob_id, BytesIO("X"), size=1) + yield self.port.stopListening() + + def sleep(x): + d = defer.Deferred() + reactor.callLater(x, d.callback, None) + return d + d = manager.send_missing() + yield sleep(1) + self.port = reactor.listenTCP( + self.host.port, self.site, interface='127.0.0.1') + yield d + result = yield manager._download_and_decrypt(blob_id) + self.assertIsNotNone(result) + self.assertEquals(result[0].getvalue(), "X") + @defer.inlineCallbacks @pytest.mark.usefixtures("method_tmpdir") def test_sync_fetch_missing(self): -- cgit v1.2.3