From 13d9d9446ba0035f54fd33159b3559b8c418b603 Mon Sep 17 00:00:00 2001
From: Jonas Bostoen <jonas.bostoen@hotmail.com>
Date: Fri, 19 Jan 2024 14:34:53 +0100
Subject: [PATCH] fix(socket): limit exp backoff to 16 retries

---
 msg-socket/src/req/socket.rs | 2 +-
 msg-socket/src/sub/driver.rs | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/msg-socket/src/req/socket.rs b/msg-socket/src/req/socket.rs
index f845577..308983d 100644
--- a/msg-socket/src/req/socket.rs
+++ b/msg-socket/src/req/socket.rs
@@ -71,7 +71,7 @@ where
 
         tracing::info!("Connecting to {}", endpoint);
 
-        let mut backoff = ExponentialBackoff::new(Duration::from_millis(20), 256);
+        let mut backoff = ExponentialBackoff::new(Duration::from_millis(20), 16);
 
         let mut stream = loop {
             if let Some(duration) = backoff.next().await {
diff --git a/msg-socket/src/sub/driver.rs b/msg-socket/src/sub/driver.rs
index bbe2cc3..fb03dd2 100644
--- a/msg-socket/src/sub/driver.rs
+++ b/msg-socket/src/sub/driver.rs
@@ -114,7 +114,7 @@ where
             addr,
             PublisherState::Inactive {
                 addr,
-                backoff: ExponentialBackoff::new(Duration::from_millis(10), 256),
+                backoff: ExponentialBackoff::new(Duration::from_millis(10), 16),
             },
         );
     }