dolysis/conduwuit
3
0
Fork 0
mirror of https://github.com/girlbossceo/conduwuit.git synced 2024-11-30 22:43:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

All the logs

Browse source
This commit is contained in:
Timo Kösters 2023-02-23 11:49:35 +01:00
parent 2316d89048
commit b7c99788e4
No known key found for this signature in database
GPG key ID: 0B25E636FBA7E4CB
2 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/service/rooms/event_handler/mod.rs
View file

@ -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 let mut futures: FuturesUnordered<_> = servers
.into_keys() .into_keys()
.map(|server| async move { .map(|server| async move {
@ -1528,6 +1528,7 @@ impl Service {
.collect(); .collect();
while let Some(result) = futures.next().await { while let Some(result) = futures.next().await {
info!("Received new result");
if let (Ok(get_keys_response), origin) = result { if let (Ok(get_keys_response), origin) = result {
if let Ok(key) = get_keys_response.server_key.deserialize() { if let Ok(key) = get_keys_response.server_key.deserialize() {
let result: BTreeMap<_, _> = services() let result: BTreeMap<_, _> = services()
@ -1542,6 +1543,7 @@ impl Service {
.insert(origin.to_string(), result); .insert(origin.to_string(), result);
} }
} }
info!("Done handling result");
} }
info!("Search for signing keys done"); info!("Search for signing keys done");

4
src/service/sending/mod.rs
View file

@ -40,7 +40,7 @@ use tokio::{
select, select,
sync::{mpsc, Mutex, Semaphore}, sync::{mpsc, Mutex, Semaphore},
}; };
use tracing::{error, warn}; use tracing::{error, info, warn};
#[derive(Clone, Debug, PartialEq, Eq, Hash)] #[derive(Clone, Debug, PartialEq, Eq, Hash)]
pub enum OutgoingKind { pub enum OutgoingKind {
@ -683,7 +683,9 @@ impl Service {
where where
T: Debug, T: Debug,
{ {
info!("Waiting for permit");
let permit = self.maximum_requests.acquire().await; let permit = self.maximum_requests.acquire().await;
info!("Got permit");
let response = tokio::time::timeout( let response = tokio::time::timeout(
Duration::from_secs(2 * 60), Duration::from_secs(2 * 60),
server_server::send_request(destination, request), server_server::send_request(destination, request),