diff --git a/eth/peer.go b/eth/peer.go index 953aca17b9..8908803e0e 100644 --- a/eth/peer.go +++ b/eth/peer.go @@ -207,9 +207,6 @@ func (p *peer) SendTransactions(txs types.Transactions) error { func (p *peer) AsyncSendTransactions(txs []*types.Transaction) { select { case p.queuedTxs <- txs: - for _, tx := range txs { - p.knownTxs.Add(tx.Hash()) - } default: p.Log().Debug("Dropping transaction propagation", "count", len(txs)) } @@ -235,7 +232,6 @@ func (p *peer) SendNewBlockHashes(hashes []common.Hash, numbers []uint64) error func (p *peer) AsyncSendNewBlockHash(block *types.Block) { select { case p.queuedAnns <- block: - p.knownBlocks.Add(block.Hash()) default: p.Log().Debug("Dropping block announcement", "number", block.NumberU64(), "hash", block.Hash()) } @@ -252,7 +248,6 @@ func (p *peer) SendNewBlock(block *types.Block, td *big.Int) error { func (p *peer) AsyncSendNewBlock(block *types.Block, td *big.Int) { select { case p.queuedProps <- &propEvent{block: block, td: td}: - p.knownBlocks.Add(block.Hash()) default: p.Log().Debug("Dropping block propagation", "number", block.NumberU64(), "hash", block.Hash()) }