Merge pull request ethereum#193 from XinFinOrg/xin-250

xin-250 skip process message whenever synchronising
s1na · Oct 15, 2022 · e8e9b2e · e8e9b2e
2 parents 55d9946 + 30d7958
commit e8e9b2e
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/eth/handler.go b/eth/handler.go
@@ -849,8 +849,7 @@ func (pm *ProtocolManager) handleMsg(p *peer) error {
 			pm.lendingpool.AddRemotes(txs)
 		}
 	case msg.Code == VoteMsg:
-		// VoteMsg arrived, make sure we have a valid and fresh chain to handle them
-		if atomic.LoadUint32(&pm.acceptTxs) == 0 {
+		if pm.downloader.Synchronising() {
 			break
 		}
 
@@ -868,8 +867,7 @@ func (pm *ProtocolManager) handleMsg(p *peer) error {
 		}
 
 	case msg.Code == TimeoutMsg:
-		// TimeoutMsg arrived, make sure we have a valid and fresh chain to handle them
-		if atomic.LoadUint32(&pm.acceptTxs) == 0 {
+		if pm.downloader.Synchronising() {
 			break
 		}
 
@@ -888,8 +886,7 @@ func (pm *ProtocolManager) handleMsg(p *peer) error {
 		}
 
 	case msg.Code == SyncInfoMsg:
-		// SyncInfoMsg arrived, make sure we have a valid and fresh chain to handle them
-		if atomic.LoadUint32(&pm.acceptTxs) == 0 {
+		if pm.downloader.Synchronising() {
 			break
 		}