From b7c99788e46a4e3c0e25f38742dfac67b72a7b9d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Timo=20K=C3=B6sters?= <timo@koesters.xyz>
Date: Thu, 23 Feb 2023 11:49:35 +0100
Subject: [PATCH] All the logs

---
 src/service/rooms/event_handler/mod.rs | 4 +++-
 src/service/sending/mod.rs             | 4 +++-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/service/rooms/event_handler/mod.rs b/src/service/rooms/event_handler/mod.rs
index e3502e65..da40e6f3 100644
--- a/src/service/rooms/event_handler/mod.rs
+++ b/src/service/rooms/event_handler/mod.rs
@@ -1513,7 +1513,7 @@ impl Service {
             }
         }
 
-        info!("Asking individual servers for signing keys");
+        info!("Asking individual servers for signing keys: {servers:?}");
         let mut futures: FuturesUnordered<_> = servers
             .into_keys()
             .map(|server| async move {
@@ -1528,6 +1528,7 @@ impl Service {
             .collect();
 
         while let Some(result) = futures.next().await {
+            info!("Received new result");
             if let (Ok(get_keys_response), origin) = result {
                 if let Ok(key) = get_keys_response.server_key.deserialize() {
                     let result: BTreeMap<_, _> = services()
@@ -1542,6 +1543,7 @@ impl Service {
                         .insert(origin.to_string(), result);
                 }
             }
+            info!("Done handling result");
         }
 
         info!("Search for signing keys done");
diff --git a/src/service/sending/mod.rs b/src/service/sending/mod.rs
index e0e2f549..b0d9b4b1 100644
--- a/src/service/sending/mod.rs
+++ b/src/service/sending/mod.rs
@@ -40,7 +40,7 @@ use tokio::{
     select,
     sync::{mpsc, Mutex, Semaphore},
 };
-use tracing::{error, warn};
+use tracing::{error, info, warn};
 
 #[derive(Clone, Debug, PartialEq, Eq, Hash)]
 pub enum OutgoingKind {
@@ -683,7 +683,9 @@ impl Service {
     where
         T: Debug,
     {
+        info!("Waiting for permit");
         let permit = self.maximum_requests.acquire().await;
+        info!("Got permit");
         let response = tokio::time::timeout(
             Duration::from_secs(2 * 60),
             server_server::send_request(destination, request),