From 047f2bc1af17bc173ebe0e7c7f55e4741bc2b131 Mon Sep 17 00:00:00 2001 From: Robert Hensing Date: Sun, 20 Apr 2025 22:42:12 +0200 Subject: [PATCH] refactor: Extract RETRY_TIME constants in filetransfer --- src/libstore/filetransfer.cc | 5 ++++- src/libstore/include/nix/store/filetransfer.hh | 4 +++- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/src/libstore/filetransfer.cc b/src/libstore/filetransfer.cc index 5a298a658..8fc4f14f2 100644 --- a/src/libstore/filetransfer.cc +++ b/src/libstore/filetransfer.cc @@ -33,6 +33,9 @@ using namespace std::string_literals; namespace nix { +const unsigned int RETRY_TIME_MS_DEFAULT = 250; +const unsigned int RETRY_TIME_MS_TOO_MANY_REQUESTS = 60000; + FileTransferSettings fileTransferSettings; static GlobalConfig::Register rFileTransferSettings(&fileTransferSettings); @@ -453,7 +456,7 @@ struct curlFileTransfer : public FileTransfer err = Forbidden; } else if (httpStatus == 429) { // 429 means too many requests, so we retry (with a substantially longer delay) - retryTimeMs = 60000; + retryTimeMs = RETRY_TIME_MS_TOO_MANY_REQUESTS; } else if (httpStatus >= 400 && httpStatus < 500 && httpStatus != 408) { // Most 4xx errors are client errors and are probably not worth retrying: // * 408 means the server timed out waiting for us, so we try again diff --git a/src/libstore/include/nix/store/filetransfer.hh b/src/libstore/include/nix/store/filetransfer.hh index f9b1f620f..10c3ec7ef 100644 --- a/src/libstore/include/nix/store/filetransfer.hh +++ b/src/libstore/include/nix/store/filetransfer.hh @@ -58,6 +58,8 @@ struct FileTransferSettings : Config extern FileTransferSettings fileTransferSettings; +extern const unsigned int RETRY_TIME_MS_DEFAULT; + struct FileTransferRequest { std::string uri; @@ -67,7 +69,7 @@ struct FileTransferRequest bool head = false; bool post = false; size_t tries = fileTransferSettings.tries; - unsigned int baseRetryTimeMs = 250; + unsigned int baseRetryTimeMs = RETRY_TIME_MS_DEFAULT; ActivityId parentAct; bool decompress = true; std::optional data;