fix(socket): limit exp backoff to 16 retries

chainbound · Jan 19, 2024 · 13d9d94 · 13d9d94
1 parent c5bfee6
commit 13d9d94
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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),
  },
  );
  }