diff options
Diffstat (limited to 'miner/worker.go')
| -rw-r--r-- | miner/worker.go | 35 |
1 files changed, 34 insertions, 1 deletions
diff --git a/miner/worker.go b/miner/worker.go index 269219ba0..535ce5144 100644 --- a/miner/worker.go +++ b/miner/worker.go @@ -457,9 +457,42 @@ func (self *worker) commitNewWork() { self.makeCurrent(parent, header) work := self.current - // commit transactions for this run. + /* //approach 1 transactions := self.eth.TxPool().GetTransactions() sort.Sort(types.TxByNonce{transactions}) + */ + + //approach 2 + transactions := self.eth.TxPool().GetTransactions() + sort.Sort(types.TxByPriceAndNonce{transactions}) + + /* // approach 3 + // commit transactions for this run. + txPerOwner := make(map[common.Address]types.Transactions) + // Sort transactions by owner + for _, tx := range self.eth.TxPool().GetTransactions() { + from, _ := tx.From() // we can ignore the sender error + txPerOwner[from] = append(txPerOwner[from], tx) + } + var ( + singleTxOwner types.Transactions + multiTxOwner types.Transactions + ) + // Categorise transactions by + // 1. 1 owner tx per block + // 2. multi txs owner per block + for _, txs := range txPerOwner { + if len(txs) == 1 { + singleTxOwner = append(singleTxOwner, txs[0]) + } else { + multiTxOwner = append(multiTxOwner, txs...) + } + } + sort.Sort(types.TxByPrice{singleTxOwner}) + sort.Sort(types.TxByNonce{multiTxOwner}) + transactions := append(singleTxOwner, multiTxOwner...) + */ + work.coinbase.SetGasLimit(header.GasLimit) work.commitTransactions(transactions, self.gasPrice, self.proc) self.eth.TxPool().RemoveTransactions(work.lowGasTxs) |