From 498b24270a9c301a9251150afb7f3889c929765c Mon Sep 17 00:00:00 2001 From: obscuren Date: Tue, 21 Apr 2015 22:01:04 +0200 Subject: core: implemented a queued approach processing transactions Implemented a new transaction queue. Transactions with a holes in their nonce sequence are also not propagated over the network. N: 0,1,2,5,6,7 = propagate 0..2 -- 5..N is kept in the tx pool --- core/block_processor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'core/block_processor.go') diff --git a/core/block_processor.go b/core/block_processor.go index f33f0d433..af47069ad 100644 --- a/core/block_processor.go +++ b/core/block_processor.go @@ -258,7 +258,7 @@ func (sm *BlockProcessor) processWithParent(block, parent *types.Block) (logs st state.Sync() // Remove transactions from the pool - sm.txpool.RemoveSet(block.Transactions()) + sm.txpool.RemoveTransactions(block.Transactions()) // This puts transactions in a extra db for rpc for i, tx := range block.Transactions() { -- cgit v1.2.3