status-im
/
nim-eth
mirror of https://github.com/status-im/nim-eth.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

use new nim-metrics API

This commit is contained in:
Ștefan Talpalaru 2019-07-16 12:56:36 +02:00 committed by zah
parent 14ae046354
commit 620573f63c
3 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
eth/common/utils.nim
View File

@ -10,5 +10,5 @@ proc parseAddress*(hexString: string): EthAddress =
proc `$`*(a: EthAddress): string = proc `$`*(a: EthAddress): string =
a.toHex() a.toHex()
var peerGauge* = newGauge("connected_peers", "number of peers in the pool") newPublicGauge(connected_peers, "number of peers in the pool")

3
eth/p2p/peer_pool.nim
View File

@ -110,8 +110,7 @@ proc getRandomBootnode(p: PeerPool): Option[Node] =
proc addPeer*(pool: PeerPool, peer: Peer) {.gcsafe.} = proc addPeer*(pool: PeerPool, peer: Peer) {.gcsafe.} =
doAssert(peer.remote notin pool.connectedNodes) doAssert(peer.remote notin pool.connectedNodes)
pool.connectedNodes[peer.remote] = peer pool.connectedNodes[peer.remote] = peer
{.gcsafe.}: connected_peers.inc()
peerGauge.inc()
for o in pool.observers.values: for o in pool.observers.values:
if not o.onPeerConnected.isNil: if not o.onPeerConnected.isNil:
if o.protocol.isNil or peer.supports(o.protocol): if o.protocol.isNil or peer.supports(o.protocol):

3
eth/p2p/rlpx.nim
View File

@ -795,8 +795,7 @@ proc removePeer(network: EthereumNode, peer: Peer) =
# between which side disconnects first. # between which side disconnects first.
if network.peerPool != nil and not peer.remote.isNil and peer.remote in network.peerPool.connectedNodes: if network.peerPool != nil and not peer.remote.isNil and peer.remote in network.peerPool.connectedNodes:
network.peerPool.connectedNodes.del(peer.remote) network.peerPool.connectedNodes.del(peer.remote)
{.gcsafe.}: connected_peers.dec()
peerGauge.dec()
# Note: we need to do this check as disconnect (and thus removePeer) # Note: we need to do this check as disconnect (and thus removePeer)
# currently can get called before the dispatcher is initialized. # currently can get called before the dispatcher is initialized.