Proper new block

10 years ago · bd7aca76e1
parent 4de3ad1712
commit bd7aca76e1
1 changed files with 9 additions and 1 deletions
--- a/peer.go
+++ b/peer.go
@ -539,7 +539,15 @@ func (p *Peer) HandleInbound() {
 						p.lastBlockReceived = time.Now()
 					}
 				case ethwire.MsgNewBlockTy:
-					p.ethereum.blockPool.AddNew(ethchain.NewBlockFromRlpValue(msg.Data), p)
+					var (
+						blockPool = p.ethereum.blockPool
+						block     = ethchain.NewBlockFromRlpValue(msg.Data.Get(0))
+						td        = msg.Data.Get(1).BigInt()
+					)
+
+					if td.Cmp(blockPool.td) > 0 {
+						p.ethereum.blockPool.AddNew(block, p)
+					}
 				}

 			}