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 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");