diff --git a/substrate/client/network/src/litep2p/discovery.rs b/substrate/client/network/src/litep2p/discovery.rs index ef0de981929ef9ce20db9af01a5e58c4a0146b03..6ff05e6af327a275d4377df9b987ccbefcb35da4 100644 --- a/substrate/client/network/src/litep2p/discovery.rs +++ b/substrate/client/network/src/litep2p/discovery.rs @@ -145,6 +145,9 @@ pub enum DiscoveryEvent { /// Record. record: Record, }, + + /// Started a random Kademlia query. + RandomKademliaStarted, } /// Discovery. @@ -456,6 +459,7 @@ impl Stream for Discovery { match this.kademlia_handle.try_find_node(peer) { Ok(query_id) => { this.find_node_query_id = Some(query_id); + return Poll::Ready(Some(DiscoveryEvent::RandomKademliaStarted)) }, Err(()) => { this.duration_to_next_find_query = cmp::min( diff --git a/substrate/client/network/src/litep2p/mod.rs b/substrate/client/network/src/litep2p/mod.rs index 329eb68997bb6dbff8b649a1b44bb4cc884e20d1..824f62082cac7c593f74bac21cd66b1bf4fef11c 100644 --- a/substrate/client/network/src/litep2p/mod.rs +++ b/substrate/client/network/src/litep2p/mod.rs @@ -929,6 +929,12 @@ impl<B: BlockT + 'static, H: ExHashT> NetworkBackend<B, H> for Litep2pNetworkBac expires, ) )); + }, + + Some(DiscoveryEvent::RandomKademliaStarted) => { + if let Some(metrics) = self.metrics.as_ref() { + metrics.kademlia_random_queries_total.inc(); + } } }, event = self.litep2p.next_event() => match event {