uqbar-dao/nectar
1
1
Fork 0
mirror of https://github.com/uqbar-dao/nectar.git synced 2025-01-05 00:10:23 +03:00
Code Issues Packages Projects Releases Wiki Activity

net: fix for silly async block

Browse Source
This commit is contained in:
dr-frmr 2023-11-06 12:04:13 -05:00
parent 866f690bd3
commit 2b91a6c21c
No known key found for this signature in database
1 changed files with 9 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/net/mod.rs
View File

@ -882,24 +882,20 @@ async fn handle_local_message(
}
Ok("diagnostics") => {
printout.push_str(&format!("our Identity: {:#?}\r\n", our));
printout.push_str(&format!(
"we have connections with peers: {:#?}\r\n",
peers.keys()
));
printout.push_str(&format!(
"we are routing for: {:#?}\r\n",
peers
.iter()
.filter(|(_, peer)| peer.blocking_read().routing_for)
.map(|(id, _)| id)
.collect::<Vec<&NodeId>>()
));
printout.push_str(&format!("we have connections with peers:\r\n"));
for peer in peers.values() {
let read = peer.read().await;
printout.push_str(&format!(
"{}, routing_for={}\r\n",
read.identity.name,
read.routing_for,
));
}
printout.push_str(&format!("we have {} entries in the PKI\r\n", pki.len()));
printout.push_str(&format!(
"we have {} open peer connections\r\n",
peer_connections.len()
));
if pending_passthroughs.is_some() {
printout.push_str(&format!(
"we have {} pending passthrough connections\r\n",