forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-19 18:32:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

p2p: use the metered variable in the condition

Browse source
This commit is contained in:
Kurkó Mihály 2018-09-19 12:25:49 +03:00
parent 269e16945c
commit fe18aa2400
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
p2p/metrics.go
View file

@ -93,7 +93,7 @@ type meteredConn struct {
connected time.Time // Connection time of the peer connected time.Time // Connection time of the peer
ip net.IP // IP address of the peer ip net.IP // IP address of the peer
id string // NodeID of the peer id string // NodeID of the peer
metered bool // Used when the connection is closed to check if the peer was metered metered bool // Checks if the peer is metered
ingressMeter metrics.Meter // Meter for the read bytes of the peer ingressMeter metrics.Meter // Meter for the read bytes of the peer
egressMeter metrics.Meter // Meter for the written bytes of the peer egressMeter metrics.Meter // Meter for the written bytes of the peer
@ -132,7 +132,7 @@ func (c *meteredConn) Read(b []byte) (n int, err error) {
n, err = c.Conn.Read(b) n, err = c.Conn.Read(b)
ingressTrafficMeter.Mark(int64(n)) ingressTrafficMeter.Mark(int64(n))
c.lock.RLock() c.lock.RLock()
if c.ingressMeter != nil { if c.metered {
c.ingressMeter.Mark(int64(n)) c.ingressMeter.Mark(int64(n))
} }
c.lock.RUnlock() c.lock.RUnlock()
@ -145,7 +145,7 @@ func (c *meteredConn) Write(b []byte) (n int, err error) {
n, err = c.Conn.Write(b) n, err = c.Conn.Write(b)
egressTrafficMeter.Mark(int64(n)) egressTrafficMeter.Mark(int64(n))
c.lock.RLock() c.lock.RLock()
if c.egressMeter != nil { if c.metered {
c.egressMeter.Mark(int64(n)) c.egressMeter.Mark(int64(n))
} }
c.lock.RUnlock() c.lock.RUnlock()