From d218b77942d230e4b39674f135fb3332f96235ac Mon Sep 17 00:00:00 2001 From: Devdutt Shenoi Date: Tue, 10 Oct 2023 08:16:41 +0530 Subject: [PATCH 1/2] fix: continuous retry till timeout --- uplink/src/collector/downloader.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/uplink/src/collector/downloader.rs b/uplink/src/collector/downloader.rs index 27d73f1ba..4e43decc8 100644 --- a/uplink/src/collector/downloader.rs +++ b/uplink/src/collector/downloader.rs @@ -186,7 +186,7 @@ impl FileDownloader { // Retry mechanism tries atleast 3 times before returning a download error async fn retry_thrice(&mut self, url: &str, mut download: DownloadState) -> Result<(), Error> { let mut req = self.client.get(url).send(); - for _ in 0..3 { + loop { let resp = req.await?.error_for_status()?; match self.download(resp, &mut download).await { Ok(_) => break, From b6e282d52604305361dd49b287d087c435aac427 Mon Sep 17 00:00:00 2001 From: Devdutt Shenoi Date: Tue, 10 Oct 2023 21:52:03 +0530 Subject: [PATCH 2/2] fix: retry download after 1s sleep --- uplink/src/collector/downloader.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/uplink/src/collector/downloader.rs b/uplink/src/collector/downloader.rs index 4e43decc8..238c9f247 100644 --- a/uplink/src/collector/downloader.rs +++ b/uplink/src/collector/downloader.rs @@ -193,7 +193,7 @@ impl FileDownloader { Err(Error::Reqwest(e)) => error!("Download failed: {e}"), Err(e) => return Err(e), } - tokio::time::sleep(Duration::from_secs(30)).await; + tokio::time::sleep(Duration::from_secs(1)).await; let range = download.retry_range(); warn!("Retrying download; Continuing to download file from: {range}");