From 128abd6b96a214bc56f097c6e3c5c36218d57738 Mon Sep 17 00:00:00 2001 From: Anton Evangelatov Date: Thu, 9 May 2019 16:32:27 +0200 Subject: [PATCH] swarm/network: measure addPeer and deletePeer to know if Kad rearranged --- swarm/network/stream/stream.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/swarm/network/stream/stream.go b/swarm/network/stream/stream.go index 99235af66a..9cdf5c04b4 100644 --- a/swarm/network/stream/stream.go +++ b/swarm/network/stream/stream.go @@ -309,6 +309,7 @@ func (r *Registry) getPeer(peerId enode.ID) *Peer { func (r *Registry) setPeer(peer *Peer) { r.peersMu.Lock() r.peers[peer.ID()] = peer + metrics.GetOrRegisterCounter("registry.setpeer", nil).Inc(1) metrics.GetOrRegisterGauge("registry.peers", nil).Update(int64(len(r.peers))) r.peersMu.Unlock() } @@ -316,6 +317,7 @@ func (r *Registry) setPeer(peer *Peer) { func (r *Registry) deletePeer(peer *Peer) { r.peersMu.Lock() delete(r.peers, peer.ID()) + metrics.GetOrRegisterCounter("registry.deletepeer", nil).Inc(1) metrics.GetOrRegisterGauge("registry.peers", nil).Update(int64(len(r.peers))) r.peersMu.Unlock() }