mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-19 03:10:48 +00:00
eth/protocols: use errors.Is instead of errors.Unwrap
This commit is contained in:
parent
d09ece6b6e
commit
b988cb65ea
1 changed files with 6 additions and 12 deletions
|
|
@ -191,22 +191,16 @@ func markError(p *Peer, err error) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
m := meters.get(p.Inbound())
|
m := meters.get(p.Inbound())
|
||||||
|
switch {
|
||||||
base := errors.Unwrap(err)
|
case errors.Is(err, errNetworkIDMismatch):
|
||||||
if base == nil {
|
|
||||||
base = err
|
|
||||||
}
|
|
||||||
|
|
||||||
switch base {
|
|
||||||
case errNetworkIDMismatch:
|
|
||||||
m.networkIDMismatch.Mark(1)
|
m.networkIDMismatch.Mark(1)
|
||||||
case errProtocolVersionMismatch:
|
case errors.Is(err, errProtocolVersionMismatch):
|
||||||
m.protocolVersionMismatch.Mark(1)
|
m.protocolVersionMismatch.Mark(1)
|
||||||
case errGenesisMismatch:
|
case errors.Is(err, errGenesisMismatch):
|
||||||
m.genesisMismatch.Mark(1)
|
m.genesisMismatch.Mark(1)
|
||||||
case errForkIDRejected:
|
case errors.Is(err, errForkIDRejected):
|
||||||
m.forkidRejected.Mark(1)
|
m.forkidRejected.Mark(1)
|
||||||
case p2p.DiscReadTimeout:
|
case errors.Is(err, p2p.DiscReadTimeout):
|
||||||
m.timeoutError.Mark(1)
|
m.timeoutError.Mark(1)
|
||||||
default:
|
default:
|
||||||
m.peerError.Mark(1)
|
m.peerError.Mark(1)
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue