aboutsummaryrefslogtreecommitdiffstats
path: root/miner
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-12-05 06:54:07 +0800
committerobscuren <geffobscura@gmail.com>2014-12-05 06:54:07 +0800
commit8dbca75d85553f2d9451ee563a919850f05ea1dd (patch)
tree31fbd960506f216eb0c0dc394b1ce7b4014210d5 /miner
parent3db9c8007086e0735695a6477c21056737519db9 (diff)
downloaddexon-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.go22
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
}