Add bad peer count (prysmaticlabs#4537)

* Add bad peer count * Merge branch 'master' into badpeercount * Merge branch 'master' into badpeercount * Merge branch 'master' into badpeercount * Merge branch 'master' into badpeercount
cryptomental · Feb 24, 2020 · 841e122 · 841e122
1 parent 2a3b3ea
commit 841e122
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/beacon-chain/p2p/monitoring.go b/beacon-chain/p2p/monitoring.go
@@ -27,4 +27,5 @@ func (s *Service) updateMetrics() {
 	p2pPeerCount.WithLabelValues("Disconnected").Set(float64(len(s.peers.Disconnected())))
 	p2pPeerCount.WithLabelValues("Connecting").Set(float64(len(s.peers.Connecting())))
 	p2pPeerCount.WithLabelValues("Disconnecting").Set(float64(len(s.peers.Disconnecting())))
+	p2pPeerCount.WithLabelValues("Bad").Set(float64(len(s.peers.Bad())))
 }
diff --git a/beacon-chain/p2p/peers/status.go b/beacon-chain/p2p/peers/status.go
@@ -294,6 +294,19 @@ func (p *Status) Inactive() []peer.ID {
 	return peers
 }
 
+// Bad returns the peers that are bad.
+func (p *Status) Bad() []peer.ID {
+	p.lock.RLock()
+	defer p.lock.RUnlock()
+	peers := make([]peer.ID, 0)
+	for pid, status := range p.status {
+		if status.badResponses >= p.maxBadResponses {
+			peers = append(peers, pid)
+		}
+	}
+	return peers
+}
+
 // All returns all the peers regardless of state.
 func (p *Status) All() []peer.ID {
 	p.lock.RLock()