From 5caf532e5c8ff2232c29f3940ceeaed088f1a9a6 Mon Sep 17 00:00:00 2001
From: Felix Ableitner <me@nutomic.com>
Date: Thu, 23 May 2024 16:57:35 +0200
Subject: [PATCH] fmt

---
 crates/federate/src/lib.rs    | 3 ++-
 crates/federate/src/stats.rs  | 6 ++++--
 crates/federate/src/worker.rs | 3 ++-
 3 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/crates/federate/src/lib.rs b/crates/federate/src/lib.rs
index 2151c0eed..6355d40f2 100644
--- a/crates/federate/src/lib.rs
+++ b/crates/federate/src/lib.rs
@@ -138,7 +138,8 @@ impl SendManager {
       self.workers.len(),
       WORKER_EXIT_TIMEOUT
     );
-    // the cancel futures need to be awaited concurrently for the shutdown processes to be triggered concurrently
+    // the cancel futures need to be awaited concurrently for the shutdown processes to be triggered
+    // concurrently
     futures::future::join_all(
       self
         .workers
diff --git a/crates/federate/src/stats.rs b/crates/federate/src/stats.rs
index f6d21b666..a813684b3 100644
--- a/crates/federate/src/stats.rs
+++ b/crates/federate/src/stats.rs
@@ -9,7 +9,8 @@ use std::{collections::HashMap, time::Duration};
 use tokio::{sync::mpsc::UnboundedReceiver, time::interval};
 use tracing::{debug, error, info};
 
-/// every 60s, print the state for every instance. exits if the receiver is done (all senders dropped)
+/// every 60s, print the state for every instance. exits if the receiver is done (all senders
+/// dropped)
 pub(crate) async fn receive_print_stats(
   pool: ActualDbPool,
   mut receiver: UnboundedReceiver<(String, FederationQueueState)>,
@@ -39,7 +40,8 @@ async fn print_stats(pool: &mut DbPool<'_>, stats: &HashMap<String, FederationQu
     error!("could not get last id");
     return;
   };
-  // it's expected that the values are a bit out of date, everything < SAVE_STATE_EVERY should be considered up to date
+  // it's expected that the values are a bit out of date, everything < SAVE_STATE_EVERY should be
+  // considered up to date
   info!("Federation state as of {}:", Local::now().to_rfc3339());
   // todo: more stats (act/sec, avg http req duration)
   let mut ok_count = 0;
diff --git a/crates/federate/src/worker.rs b/crates/federate/src/worker.rs
index 215eef48a..384cbb890 100644
--- a/crates/federate/src/worker.rs
+++ b/crates/federate/src/worker.rs
@@ -107,7 +107,8 @@ impl InstanceWorker {
     worker.loop_until_stopped().await
   }
   /// loop fetch new activities from db and send them to the inboxes of the given instances
-  /// this worker only returns if (a) there is an internal error or (b) the cancellation token is cancelled (graceful exit)
+  /// this worker only returns if (a) there is an internal error or (b) the cancellation token is
+  /// cancelled (graceful exit)
   pub(crate) async fn loop_until_stopped(&mut self) -> Result<(), anyhow::Error> {
     debug!("Starting federation worker for {}", self.instance.domain);
     let save_state_every = chrono::Duration::from_std(SAVE_STATE_EVERY_TIME).expect("not negative");