From: Nutomic <me@nutomic.com>
Date: Tue, 22 Mar 2022 18:40:40 +0000 (+0000)
Subject: Adjust retry interval for sending activities (#2141)
X-Git-Url: http://these/git/%24%7BgetStaticDir%28%29%7D/styles/%7Bsrc%7D?a=commitdiff_plain;h=a10bf7d4104ea433156a6c17a72dda8c0ea9673e;p=lemmy.git

Adjust retry interval for sending activities (#2141)
---

diff --git a/crates/apub_lib/src/activity_queue.rs b/crates/apub_lib/src/activity_queue.rs
index ca8645cb..a94229ff 100644
--- a/crates/apub_lib/src/activity_queue.rs
+++ b/crates/apub_lib/src/activity_queue.rs
@@ -72,8 +72,19 @@ impl ActixJob for SendActivityTask {
   type Future = Pin<Box<dyn Future<Output = Result<(), Error>>>>;
   const NAME: &'static str = "SendActivityTask";
 
+  /// With these params, retries are made at the following intervals:
+  ///          3s
+  ///          9s
+  ///         27s
+  ///      1m 21s
+  ///      4m  3s
+  ///     12m  9s
+  ///     36m 27s
+  ///  1h 49m 21s
+  ///  5h 28m  3s
+  /// 16h 24m  9s
   const MAX_RETRIES: MaxRetries = MaxRetries::Count(10);
-  const BACKOFF: Backoff = Backoff::Exponential(2);
+  const BACKOFF: Backoff = Backoff::Exponential(3);
 
   fn run(self, state: Self::State) -> Self::Future {
     Box::pin(async move { do_send(self, &state.client).await })