diff --git a/eth/protocols/eth/handler.go b/eth/protocols/eth/handler.go index ec2036c339..88a2201e76 100644 --- a/eth/protocols/eth/handler.go +++ b/eth/protocols/eth/handler.go @@ -259,6 +259,7 @@ func handleMessage(backend Backend, peer *Peer) error { if handler := handlers[msg.Code]; handler != nil { err := handler(backend, msg, peer) log.Info("***** Message handling failed", "err", err) + return err } return fmt.Errorf("%w: %v", errInvalidMsgCode, msg.Code)