mirror of https://github.com/ethereum/go-ethereum
obscuren
10 years ago
commit
00fca40939
@ -0,0 +1,73 @@ |
||||
package miner |
||||
|
||||
import ( |
||||
"github.com/ethereum/go-ethereum/core/types" |
||||
"github.com/ethereum/go-ethereum/pow" |
||||
) |
||||
|
||||
type CpuMiner struct { |
||||
c chan *types.Block |
||||
quit chan struct{} |
||||
quitCurrentOp chan struct{} |
||||
returnCh chan<- Work |
||||
|
||||
index int |
||||
pow pow.PoW |
||||
} |
||||
|
||||
func NewCpuMiner(index int, pow pow.PoW) *CpuMiner { |
||||
miner := &CpuMiner{ |
||||
c: make(chan *types.Block, 1), |
||||
quit: make(chan struct{}), |
||||
quitCurrentOp: make(chan struct{}, 1), |
||||
pow: pow, |
||||
index: index, |
||||
} |
||||
go miner.update() |
||||
|
||||
return miner |
||||
} |
||||
|
||||
func (self *CpuMiner) Work() chan<- *types.Block { return self.c } |
||||
func (self *CpuMiner) Pow() pow.PoW { return self.pow } |
||||
func (self *CpuMiner) SetNonceCh(ch chan<- Work) { self.returnCh = ch } |
||||
|
||||
func (self *CpuMiner) Stop() { |
||||
close(self.quit) |
||||
close(self.quitCurrentOp) |
||||
} |
||||
|
||||
func (self *CpuMiner) update() { |
||||
out: |
||||
for { |
||||
select { |
||||
case block := <-self.c: |
||||
// make sure it's open
|
||||
self.quitCurrentOp <- struct{}{} |
||||
|
||||
go self.mine(block) |
||||
case <-self.quit: |
||||
break out |
||||
} |
||||
} |
||||
|
||||
done: |
||||
// Empty channel
|
||||
for { |
||||
select { |
||||
case <-self.c: |
||||
default: |
||||
close(self.c) |
||||
|
||||
break done |
||||
} |
||||
} |
||||
} |
||||
|
||||
func (self *CpuMiner) mine(block *types.Block) { |
||||
minerlogger.Infof("(re)started agent[%d]. mining...\n", self.index) |
||||
nonce := self.pow.Search(block, self.quitCurrentOp) |
||||
if nonce != nil { |
||||
self.returnCh <- Work{block.Number().Uint64(), nonce} |
||||
} |
||||
} |
||||
@ -1,263 +1,61 @@ |
||||
/* |
||||
This file is part of go-ethereum |
||||
|
||||
go-ethereum is free software: you can redistribute it and/or modify |
||||
it under the terms of the GNU Lesser General Public License as published by |
||||
the Free Software Foundation, either version 3 of the License, or |
||||
(at your option) any later version. |
||||
|
||||
go-ethereum is distributed in the hope that it will be useful, |
||||
but WITHOUT ANY WARRANTY; without even the implied warranty of |
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
||||
GNU General Public License for more details. |
||||
|
||||
You should have received a copy of the GNU Lesser General Public License |
||||
along with go-ethereum. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/ |
||||
/** |
||||
* @authors |
||||
* Jeffrey Wilcke <i@jev.io> |
||||
* @date 2014 |
||||
* |
||||
*/ |
||||
|
||||
package miner |
||||
|
||||
import ( |
||||
"math/big" |
||||
"sort" |
||||
|
||||
"github.com/ethereum/go-ethereum/eth" |
||||
"github.com/ethereum/go-ethereum/ethutil" |
||||
"github.com/ethereum/go-ethereum/pow" |
||||
"github.com/ethereum/go-ethereum/pow/ezp" |
||||
"github.com/ethereum/go-ethereum/state" |
||||
|
||||
"github.com/ethereum/go-ethereum/core" |
||||
"github.com/ethereum/go-ethereum/core/types" |
||||
"github.com/ethereum/go-ethereum/event" |
||||
"github.com/ethereum/go-ethereum/logger" |
||||
"github.com/ethereum/go-ethereum/pow/ezp" |
||||
) |
||||
|
||||
type LocalTx struct { |
||||
To []byte `json:"to"` |
||||
Data []byte `json:"data"` |
||||
Gas string `json:"gas"` |
||||
GasPrice string `json:"gasPrice"` |
||||
Value string `json:"value"` |
||||
} |
||||
|
||||
func (self *LocalTx) Sign(key []byte) *types.Transaction { |
||||
return nil |
||||
} |
||||
|
||||
var minerlogger = logger.NewLogger("MINER") |
||||
|
||||
type Miner struct { |
||||
eth *eth.Ethereum |
||||
events event.Subscription |
||||
|
||||
uncles []*types.Header |
||||
localTxs map[int]*LocalTx |
||||
localTxId int |
||||
|
||||
pow pow.PoW |
||||
quitCh chan struct{} |
||||
powQuitCh chan struct{} |
||||
|
||||
Coinbase []byte |
||||
|
||||
mining bool |
||||
worker *worker |
||||
|
||||
MinAcceptedGasPrice *big.Int |
||||
Extra string |
||||
} |
||||
|
||||
func New(coinbase []byte, eth *eth.Ethereum) *Miner { |
||||
return &Miner{ |
||||
eth: eth, |
||||
powQuitCh: make(chan struct{}), |
||||
pow: ezp.New(), |
||||
mining: false, |
||||
localTxs: make(map[int]*LocalTx), |
||||
MinAcceptedGasPrice: big.NewInt(10000000000000), |
||||
Coinbase: coinbase, |
||||
} |
||||
coinbase []byte |
||||
mining bool |
||||
} |
||||
|
||||
func (self *Miner) GetPow() pow.PoW { |
||||
return self.pow |
||||
func New(coinbase []byte, eth *eth.Ethereum) *Miner { |
||||
miner := &Miner{ |
||||
coinbase: coinbase, |
||||
worker: newWorker(coinbase, eth), |
||||
} |
||||
|
||||
func (self *Miner) AddLocalTx(tx *LocalTx) int { |
||||
minerlogger.Infof("Added local tx (%x %v / %v)\n", tx.To[0:4], tx.GasPrice, tx.Value) |
||||
|
||||
self.localTxId++ |
||||
self.localTxs[self.localTxId] = tx |
||||
self.eth.EventMux().Post(tx) |
||||
|
||||
return self.localTxId |
||||
for i := 0; i < 4; i++ { |
||||
miner.worker.register(NewCpuMiner(i, ezp.New())) |
||||
} |
||||
|
||||
func (self *Miner) RemoveLocalTx(id int) { |
||||
if tx := self.localTxs[id]; tx != nil { |
||||
minerlogger.Infof("Removed local tx (%x %v / %v)\n", tx.To[0:4], tx.GasPrice, tx.Value) |
||||
return miner |
||||
} |
||||
self.eth.EventMux().Post(&LocalTx{}) |
||||
|
||||
delete(self.localTxs, id) |
||||
func (self *Miner) Mining() bool { |
||||
return self.mining |
||||
} |
||||
|
||||
func (self *Miner) Start() { |
||||
if self.mining { |
||||
return |
||||
} |
||||
|
||||
minerlogger.Infoln("Starting mining operations") |
||||
self.mining = true |
||||
self.quitCh = make(chan struct{}) |
||||
self.powQuitCh = make(chan struct{}) |
||||
|
||||
mux := self.eth.EventMux() |
||||
self.events = mux.Subscribe(core.NewBlockEvent{}, core.TxPreEvent{}, &LocalTx{}) |
||||
self.worker.start() |
||||
|
||||
go self.update() |
||||
go self.mine() |
||||
self.worker.commitNewWork() |
||||
} |
||||
|
||||
func (self *Miner) Stop() { |
||||
if !self.mining { |
||||
return |
||||
} |
||||
|
||||
self.mining = false |
||||
|
||||
minerlogger.Infoln("Stopping mining operations") |
||||
|
||||
self.events.Unsubscribe() |
||||
|
||||
close(self.quitCh) |
||||
close(self.powQuitCh) |
||||
self.worker.stop() |
||||
} |
||||
|
||||
func (self *Miner) Mining() bool { |
||||
return self.mining |
||||
func (self *Miner) HashRate() int64 { |
||||
var tot int64 |
||||
for _, agent := range self.worker.agents { |
||||
tot += agent.Pow().GetHashrate() |
||||
} |
||||
|
||||
func (self *Miner) update() { |
||||
out: |
||||
for { |
||||
select { |
||||
case event := <-self.events.Chan(): |
||||
switch event := event.(type) { |
||||
case core.NewBlockEvent: |
||||
block := event.Block |
||||
if self.eth.ChainManager().HasBlock(block.Hash()) { |
||||
self.reset() |
||||
self.eth.TxPool().RemoveSet(block.Transactions()) |
||||
go self.mine() |
||||
} else if true { |
||||
// do uncle stuff
|
||||
} |
||||
case core.TxPreEvent, *LocalTx: |
||||
self.reset() |
||||
go self.mine() |
||||
} |
||||
case <-self.quitCh: |
||||
break out |
||||
} |
||||
} |
||||
} |
||||
|
||||
func (self *Miner) reset() { |
||||
close(self.powQuitCh) |
||||
self.powQuitCh = make(chan struct{}) |
||||
} |
||||
|
||||
func (self *Miner) mine() { |
||||
var ( |
||||
blockProcessor = self.eth.BlockProcessor() |
||||
chainMan = self.eth.ChainManager() |
||||
block = chainMan.NewBlock(self.Coinbase) |
||||
state = state.New(block.Root(), self.eth.Db()) |
||||
) |
||||
block.Header().Extra = self.Extra |
||||
|
||||
// Apply uncles
|
||||
block.SetUncles(self.uncles) |
||||
|
||||
parent := chainMan.GetBlock(block.ParentHash()) |
||||
coinbase := state.GetOrNewStateObject(block.Coinbase()) |
||||
coinbase.SetGasPool(core.CalcGasLimit(parent, block)) |
||||
|
||||
transactions := self.finiliseTxs() |
||||
|
||||
// Accumulate all valid transactions and apply them to the new state
|
||||
// Error may be ignored. It's not important during mining
|
||||
receipts, txs, _, erroneous, err := blockProcessor.ApplyTransactions(coinbase, state, block, transactions, true) |
||||
if err != nil { |
||||
minerlogger.Debugln(err) |
||||
} |
||||
self.eth.TxPool().RemoveSet(erroneous) |
||||
|
||||
block.SetTransactions(txs) |
||||
block.SetReceipts(receipts) |
||||
|
||||
// Accumulate the rewards included for this block
|
||||
blockProcessor.AccumulateRewards(state, block, parent) |
||||
|
||||
state.Update(ethutil.Big0) |
||||
block.SetRoot(state.Root()) |
||||
|
||||
minerlogger.Infof("Mining on block. Includes %v transactions", len(transactions)) |
||||
|
||||
// Find a valid nonce
|
||||
nonce := self.pow.Search(block, self.powQuitCh) |
||||
if nonce != nil { |
||||
block.Header().Nonce = nonce |
||||
err := chainMan.InsertChain(types.Blocks{block}) |
||||
if err != nil { |
||||
minerlogger.Infoln(err) |
||||
} else { |
||||
self.eth.EventMux().Post(core.NewMinedBlockEvent{block}) |
||||
|
||||
minerlogger.Infof("🔨 Mined block %x\n", block.Hash()) |
||||
minerlogger.Infoln(block) |
||||
} |
||||
|
||||
go self.mine() |
||||
} |
||||
} |
||||
|
||||
func (self *Miner) finiliseTxs() types.Transactions { |
||||
// Sort the transactions by nonce in case of odd network propagation
|
||||
actualSize := len(self.localTxs) // See copy below
|
||||
txs := make(types.Transactions, actualSize+self.eth.TxPool().Size()) |
||||
|
||||
state := self.eth.ChainManager().TransState() |
||||
// XXX This has to change. Coinbase is, for new, same as key.
|
||||
key := self.eth.KeyManager() |
||||
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.SetNonce(state.GetNonce(self.Coinbase)) |
||||
state.SetNonce(self.Coinbase, tx.Nonce()+1) |
||||
|
||||
tx.Sign(key.PrivateKey()) |
||||
|
||||
txs[i] = tx |
||||
} |
||||
|
||||
// Faster than append
|
||||
for _, tx := range self.eth.TxPool().GetTransactions() { |
||||
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 newTransactions |
||||
return tot |
||||
} |
||||
|
||||
Loading…
Reference in new issue