forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-18 02:40:45 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

xin-201 skip message while synchronize (#100)

Browse source
This commit is contained in:
Liam 2022-06-19 10:59:23 +02:00 committed by GitHub
parent ac5096d692
commit 2d25b89610
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 15 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
eth/handler.go
View file

@ -847,6 +847,11 @@ func (pm *ProtocolManager) handleMsg(p *peer) error {
pm.lendingpool.AddRemotes(txs) pm.lendingpool.AddRemotes(txs)
} }
case msg.Code == VoteMsg: case msg.Code == VoteMsg:
// VoteMsg arrived, make sure we have a valid and fresh chain to handle them
if atomic.LoadUint32(&pm.acceptTxs) == 0 {
break
}
var vote types.Vote var vote types.Vote
if err := msg.Decode(&vote); err != nil { if err := msg.Decode(&vote); err != nil {
return errResp(ErrDecode, "msg %v: %v", msg, err) return errResp(ErrDecode, "msg %v: %v", msg, err)
@ -864,6 +869,11 @@ func (pm *ProtocolManager) handleMsg(p *peer) error {
} }
case msg.Code == TimeoutMsg: case msg.Code == TimeoutMsg:
// TimeoutMsg arrived, make sure we have a valid and fresh chain to handle them
if atomic.LoadUint32(&pm.acceptTxs) == 0 {
break
}
var timeout types.Timeout var timeout types.Timeout
if err := msg.Decode(&timeout); err != nil { if err := msg.Decode(&timeout); err != nil {
return errResp(ErrDecode, "msg %v: %v", msg, err) return errResp(ErrDecode, "msg %v: %v", msg, err)
@ -883,6 +893,11 @@ func (pm *ProtocolManager) handleMsg(p *peer) error {
} }
case msg.Code == SyncInfoMsg: case msg.Code == SyncInfoMsg:
// SyncInfoMsg arrived, make sure we have a valid and fresh chain to handle them
if atomic.LoadUint32(&pm.acceptTxs) == 0 {
break
}
var syncInfo types.SyncInfo var syncInfo types.SyncInfo
if err := msg.Decode(&syncInfo); err != nil { if err := msg.Decode(&syncInfo); err != nil {
return errResp(ErrDecode, "msg %v: %v", msg, err) return errResp(ErrDecode, "msg %v: %v", msg, err)