mirror of https://github.com/poanetwork/quorum.git
only process messages for istanbul
This commit is contained in:
parent
f0f472404f
commit
30f506208c
|
@ -94,14 +94,12 @@ func (sb *backend) HandleMsg(addr common.Address, msg p2p.Msg) (bool, error) {
|
|||
if msg.Code == 0x07 && sb.core.IsProposer() { // eth.NewBlockMsg: import cycle
|
||||
// this case is to safeguard the race of similar block which gets propagated from other node while this node is proposing
|
||||
|
||||
_, hash, err := sb.decode(msg)
|
||||
if err != nil {
|
||||
return true, errDecodeFailed
|
||||
}
|
||||
if _, hash, err := sb.decode(msg); err == nil {
|
||||
if _, ok := sb.knownMessages.Get(hash); ok {
|
||||
return true, nil
|
||||
}
|
||||
}
|
||||
}
|
||||
return false, nil
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue