diff options
author | obscuren <geffobscura@gmail.com> | 2014-12-05 06:54:07 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-12-05 06:54:07 +0800 |
commit | 8dbca75d85553f2d9451ee563a919850f05ea1dd (patch) | |
tree | 31fbd960506f216eb0c0dc394b1ce7b4014210d5 /miner | |
parent | 3db9c8007086e0735695a6477c21056737519db9 (diff) | |
download | dexon-8dbca75d85553f2d9451ee563a919850f05ea1dd.tar dexon-8dbca75d85553f2d9451ee563a919850f05ea1dd.tar.gz dexon-8dbca75d85553f2d9451ee563a919850f05ea1dd.tar.bz2 dexon-8dbca75d85553f2d9451ee563a919850f05ea1dd.tar.lz dexon-8dbca75d85553f2d9451ee563a919850f05ea1dd.tar.xz dexon-8dbca75d85553f2d9451ee563a919850f05ea1dd.tar.zst dexon-8dbca75d85553f2d9451ee563a919850f05ea1dd.zip |
Skip mining on transactions that don't meet the min accepted gas price
Diffstat (limited to 'miner')
-rw-r--r-- | miner/miner.go | 22 |
1 files changed, 16 insertions, 6 deletions
diff --git a/miner/miner.go b/miner/miner.go index f9b8a9c22..c350eb1a8 100644 --- a/miner/miner.go +++ b/miner/miner.go @@ -228,23 +228,33 @@ func (self *Miner) mine() { func (self *Miner) finiliseTxs() types.Transactions { // Sort the transactions by nonce in case of odd network propagation - var txs types.Transactions + actualSize := len(self.localTxs) // See copy below + txs := make(types.Transactions, actualSize+self.eth.TxPool().Size()) state := self.eth.BlockManager().TransState() // XXX This has to change. Coinbase is, for new, same as key. key := self.eth.KeyManager() - for _, ltx := range self.localTxs { + for i, ltx := range self.localTxs { tx := types.NewTransactionMessage(ltx.To, ethutil.Big(ltx.Value), ethutil.Big(ltx.Gas), ethutil.Big(ltx.GasPrice), ltx.Data) tx.Nonce = state.GetNonce(self.Coinbase) state.SetNonce(self.Coinbase, tx.Nonce+1) tx.Sign(key.PrivateKey()) - txs = append(txs, tx) + txs[i] = tx } - txs = append(txs, self.eth.TxPool().CurrentTransactions()...) - sort.Sort(types.TxByNonce{txs}) + // Faster than append + for _, tx := range self.eth.TxPool().CurrentTransactions() { + if tx.GasPrice.Cmp(self.MinAcceptedGasPrice) >= 0 { + txs[actualSize] = tx + actualSize++ + } + } + + newTransactions := make(types.Transactions, actualSize) + copy(newTransactions, txs[:actualSize]) + sort.Sort(types.TxByNonce{newTransactions}) - return txs + return newTransactions } |