diff options
| author | obscuren <geffobscura@gmail.com> | 2015-04-22 04:01:04 +0800 |
|---|---|---|
| committer | obscuren <geffobscura@gmail.com> | 2015-04-23 17:50:11 +0800 |
| commit | 498b24270a9c301a9251150afb7f3889c929765c (patch) | |
| tree | a7bf2d902fef5a0558363a84b0903fec07ed5b7b /core/block_processor.go | |
| parent | 2fe54ab233c0cd1bf09b49085477c961dcc1980f (diff) | |
| download | go-tangerine-498b24270a9c301a9251150afb7f3889c929765c.tar go-tangerine-498b24270a9c301a9251150afb7f3889c929765c.tar.gz go-tangerine-498b24270a9c301a9251150afb7f3889c929765c.tar.bz2 go-tangerine-498b24270a9c301a9251150afb7f3889c929765c.tar.lz go-tangerine-498b24270a9c301a9251150afb7f3889c929765c.tar.xz go-tangerine-498b24270a9c301a9251150afb7f3889c929765c.tar.zst go-tangerine-498b24270a9c301a9251150afb7f3889c929765c.zip | |
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
Diffstat (limited to 'core/block_processor.go')
| -rw-r--r-- | core/block_processor.go | 2 |
1 files changed, 1 insertions, 1 deletions
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() { |