bk.syncPeer = peer
if err := bk.fastBlockSync(checkPoint); err != nil {
log.WithFields(log.Fields{"module": logModule, "err": err}).Warning("fail on fastBlockSync")
- bk.peers.ErrorHandler(peer.ID(), security.LevelMsgIllegal, err)
+ bk.peers.ProcessIllegal(peer.ID(), security.LevelMsgIllegal, err.Error())
return false
}
return true
if err := bk.regularBlockSync(targetHeight); err != nil {
log.WithFields(log.Fields{"module": logModule, "err": err}).Warning("fail on regularBlockSync")
- bk.peers.ErrorHandler(peer.ID(), security.LevelMsgIllegal, err)
+ bk.peers.ProcessIllegal(peer.ID(), security.LevelMsgIllegal, err.Error())
return false
}
return true
return nil
}
-func (ps *peerSet) ErrorHandler(peerID string, level byte, err error) {
- if errors.Root(err) == ErrPeerMisbehave {
- ps.ProcessIllegal(peerID, level, err.Error())
- } else {
- ps.removePeer(peerID)
- }
-}
-
// Peer retrieves the registered peer with the given id.
func (ps *peerSet) getPeer(id string) *peer {
ps.mtx.RLock()