swarm: fix peers_total metric
License: MIT Signed-off-by: Lars Gierth <larsg@systemli.org>
Lars Gierth committed
Jul 1, 2015 at 21:59 UTC
9c30b85180855c2cf9acf677d9eb7c5c408b9a9e
2 files changed
+4
-4
p2p/net/swarm/swarm.go
+2
-2
@@ -289,11 +289,11 @@ func (n *ps2netNotifee) ClosedStream(s *ps.Stream) {
289
type metricsNotifiee Swarm
290
291
func (nn *metricsNotifiee) Connected(n inet.Network, v inet.Conn) {
292
- peersTotalGauge(n.LocalPeer()).Inc()
292
+ peersTotalGauge(n.LocalPeer()).Set(float64(len(n.Conns())))
293
}
294
295
func (nn *metricsNotifiee) Disconnected(n inet.Network, v inet.Conn) {
296
- peersTotalGauge(n.LocalPeer()).Dec()
296
+ peersTotalGauge(n.LocalPeer()).Set(float64(len(n.Conns())))
297
}
298
299
func (nn *metricsNotifiee) OpenedStream(n inet.Network, v inet.Stream) {}
p2p/net/swarm/swarm_net.go
+2
-2
@@ -58,12 +58,12 @@ func (n *Network) LocalPeer() peer.ID {
58
return n.Swarm().LocalPeer()
59
}
60
61
-// Peers returns the connected peers
61
+// Peers returns the known peer IDs from the Peerstore
62
func (n *Network) Peers() []peer.ID {
63
return n.Swarm().Peers()
64
}
65
66
-// Peers returns the connected peers
66
+// Peers returns the Peerstore, which tracks known peers
67
func (n *Network) Peerstore() peer.Peerstore {
68
return n.Swarm().peers
69
}