sleep before connection

ecmwf · Oct 31, 2024 · 0d61134 · 0d61134
1 parent f8652cb
commit 0d61134
Showing 1 changed file with 15 additions and 0 deletions.
diff --git a/src/fdb5/remote/client/ClientConnectionRouter.cc b/src/fdb5/remote/client/ClientConnectionRouter.cc
@@ -1,5 +1,9 @@
 #include "fdb5/remote/client/ClientConnectionRouter.h"
 
+#include <chrono>
+#include <random>
+#include <thread>
+
 namespace{
 
 class ConnectionError : public eckit::Exception {
@@ -37,6 +41,17 @@ ClientConnection& ClientConnectionRouter::connection(const eckit::net::Endpoint&
         return *(it->second);
     } else {
         ClientConnection* clientConnection = new ClientConnection{endpoint, defaultEndpoint};
+
+        static int fdbConnectMaxSleep = eckit::Resource<int>("fdbConnectMaxSleep", 0);
+
+        if (fdbConnectMaxSleep) {
+            std::random_device rd;
+            std::mt19937 mt(rd());
+            std::uniform_int_distribution<int> dist(0, fdbConnectMaxSleep);
+
+            std::this_thread::sleep_for(std::chrono::milliseconds(dist(rd)));
+        }
+
         if (clientConnection->connect()) {
             auto it = (connections_.emplace(endpoint, std::unique_ptr<ClientConnection>(clientConnection))).first;
             return *(it->second);