From 0b9ca727d33736a96c43f716157d925b49247091 Mon Sep 17 00:00:00 2001 From: AntiochP <30642645+antiochp@users.noreply.github.com> Date: Wed, 6 Dec 2017 09:28:11 -0500 Subject: [PATCH] add logging in monitor_peers for healthy/banned/defunct counts (#436) --- grin/src/seed.rs | 25 ++++++++++++++++++++++++- 1 file changed, 24 insertions(+), 1 deletion(-) diff --git a/grin/src/seed.rs b/grin/src/seed.rs index b60467af..f216c1fb 100644 --- a/grin/src/seed.rs +++ b/grin/src/seed.rs @@ -88,12 +88,35 @@ impl Seeder { .for_each(move |_| { debug!( LOGGER, - "monitoring peers ({} / {} / {})", + "monitoring_peers: {} / {} / {}", p2p_server.most_work_peers().len(), p2p_server.connected_peers().len(), p2p_server.all_peers().len(), ); + let all_peers = p2p_server.all_peers(); + let healthy_count = all_peers + .iter() + .filter(|x| x.flags == p2p::State::Healthy) + .count(); + let banned_count = all_peers + .iter() + .filter(|x| x.flags == p2p::State::Banned) + .count(); + let defunct_count = all_peers + .iter() + .filter(|x| x.flags == p2p::State::Defunct) + .count(); + + debug!( + LOGGER, + "monitoring_peers: all - {}, healthy - {}, banned - {}, defunct - {}", + all_peers.len(), + healthy_count, + banned_count, + defunct_count, + ); + // maintenance step first, clean up p2p server peers let _ = p2p_server.clean_peers();