diff options
author | Mark <markya0616@gmail.com> | 2017-09-08 05:22:27 +0800 |
---|---|---|
committer | Felix Lange <fjl@users.noreply.github.com> | 2017-09-08 05:22:27 +0800 |
commit | c1740e454015e61e8207cdeb34c48eee3adbb4d3 (patch) | |
tree | cf9ac38c8a8ff8ad3aec9d542e1f2c6632122511 /core/types/transaction.go | |
parent | e3db1236de65619d26e87eb7c886e565fcc2eafc (diff) | |
download | go-tangerine-c1740e454015e61e8207cdeb34c48eee3adbb4d3.tar go-tangerine-c1740e454015e61e8207cdeb34c48eee3adbb4d3.tar.gz go-tangerine-c1740e454015e61e8207cdeb34c48eee3adbb4d3.tar.bz2 go-tangerine-c1740e454015e61e8207cdeb34c48eee3adbb4d3.tar.lz go-tangerine-c1740e454015e61e8207cdeb34c48eee3adbb4d3.tar.xz go-tangerine-c1740e454015e61e8207cdeb34c48eee3adbb4d3.tar.zst go-tangerine-c1740e454015e61e8207cdeb34c48eee3adbb4d3.zip |
core/types, miner: avoid tx sender miscaching (#14773)
Diffstat (limited to 'core/types/transaction.go')
-rw-r--r-- | core/types/transaction.go | 22 |
1 files changed, 12 insertions, 10 deletions
diff --git a/core/types/transaction.go b/core/types/transaction.go index 947fc85d6..7f54860fc 100644 --- a/core/types/transaction.go +++ b/core/types/transaction.go @@ -381,28 +381,32 @@ func (s *TxByPrice) Pop() interface{} { // transactions in a profit-maximising sorted order, while supporting removing // entire batches of transactions for non-executable accounts. type TransactionsByPriceAndNonce struct { - txs map[common.Address]Transactions // Per account nonce-sorted list of transactions - heads TxByPrice // Next transaction for each unique account (price heap) + txs map[common.Address]Transactions // Per account nonce-sorted list of transactions + heads TxByPrice // Next transaction for each unique account (price heap) + signer Signer // Signer for the set of transactions } // NewTransactionsByPriceAndNonce creates a transaction set that can retrieve // price sorted transactions in a nonce-honouring way. // // Note, the input map is reowned so the caller should not interact any more with -// if after providng it to the constructor. -func NewTransactionsByPriceAndNonce(txs map[common.Address]Transactions) *TransactionsByPriceAndNonce { +// if after providing it to the constructor. +func NewTransactionsByPriceAndNonce(signer Signer, txs map[common.Address]Transactions) *TransactionsByPriceAndNonce { // Initialize a price based heap with the head transactions heads := make(TxByPrice, 0, len(txs)) - for acc, accTxs := range txs { + for _, accTxs := range txs { heads = append(heads, accTxs[0]) + // Ensure the sender address is from the signer + acc, _ := Sender(signer, accTxs[0]) txs[acc] = accTxs[1:] } heap.Init(&heads) // Assemble and return the transaction set return &TransactionsByPriceAndNonce{ - txs: txs, - heads: heads, + txs: txs, + heads: heads, + signer: signer, } } @@ -416,9 +420,7 @@ func (t *TransactionsByPriceAndNonce) Peek() *Transaction { // Shift replaces the current best head with the next one from the same account. func (t *TransactionsByPriceAndNonce) Shift() { - signer := deriveSigner(t.heads[0].data.V) - // derive signer but don't cache. - acc, _ := Sender(signer, t.heads[0]) // we only sort valid txs so this cannot fail + acc, _ := Sender(t.signer, t.heads[0]) if txs, ok := t.txs[acc]; ok && len(txs) > 0 { t.heads[0], t.txs[acc] = txs[0], txs[1:] heap.Fix(&t.heads, 0) |