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/transaction_pool_test.go | |
parent | 2fe54ab233c0cd1bf09b49085477c961dcc1980f (diff) | |
download | dexon-498b24270a9c301a9251150afb7f3889c929765c.tar dexon-498b24270a9c301a9251150afb7f3889c929765c.tar.gz dexon-498b24270a9c301a9251150afb7f3889c929765c.tar.bz2 dexon-498b24270a9c301a9251150afb7f3889c929765c.tar.lz dexon-498b24270a9c301a9251150afb7f3889c929765c.tar.xz dexon-498b24270a9c301a9251150afb7f3889c929765c.tar.zst dexon-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/transaction_pool_test.go')
-rw-r--r-- | core/transaction_pool_test.go | 54 |
1 files changed, 52 insertions, 2 deletions
diff --git a/core/transaction_pool_test.go b/core/transaction_pool_test.go index b7486adb3..5a5cd866f 100644 --- a/core/transaction_pool_test.go +++ b/core/transaction_pool_test.go @@ -56,7 +56,57 @@ func TestInvalidTransactions(t *testing.T) { tx.SignECDSA(key) err = pool.Add(tx) - if err != ErrImpossibleNonce { - t.Error("expected", ErrImpossibleNonce) + if err != ErrNonce { + t.Error("expected", ErrNonce) + } +} + +func TestTransactionQueue(t *testing.T) { + pool, key := setupTxPool() + tx := transaction() + tx.SignECDSA(key) + from, _ := tx.From() + pool.currentState().AddBalance(from, big.NewInt(1)) + pool.addTx(tx) + + pool.checkQueue() + if len(pool.txs) != 1 { + t.Error("expected valid txs to be 1 is", len(pool.txs)) + } + + tx = transaction() + tx.SignECDSA(key) + from, _ = tx.From() + pool.currentState().SetNonce(from, 10) + tx.SetNonce(1) + pool.addTx(tx) + pool.checkQueue() + if _, ok := pool.txs[tx.Hash()]; ok { + t.Error("expected transaction to be in tx pool") + } + + if len(pool.queue[from]) != 0 { + t.Error("expected transaction queue to be empty. is", len(pool.queue[from])) + } + + pool, key = setupTxPool() + tx1, tx2, tx3 := transaction(), transaction(), transaction() + tx2.SetNonce(10) + tx3.SetNonce(11) + tx1.SignECDSA(key) + tx2.SignECDSA(key) + tx3.SignECDSA(key) + pool.addTx(tx1) + pool.addTx(tx2) + pool.addTx(tx3) + from, _ = tx1.From() + pool.checkQueue() + + if len(pool.txs) != 1 { + t.Error("expected tx pool to be 1 =") + } + + if len(pool.queue[from]) != 2 { + t.Error("expected transaction queue to be empty. is", len(pool.queue[from])) } } |