forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-24 21:56:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Poll-based mining

Browse source
This commit is contained in:
Luke Williams 2016-06-22 15:06:00 +10:00
parent 5b0255f05d
commit c399152a07
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
miner/miner.go
View file

@ -57,6 +57,7 @@ type Miner struct {
func New(eth core.Backend, config *core.ChainConfig, mux *event.TypeMux, pow pow.PoW) *Miner { func New(eth core.Backend, config *core.ChainConfig, mux *event.TypeMux, pow pow.PoW) *Miner {
miner := &Miner{eth: eth, mux: mux, pow: pow, worker: newWorker(config, common.Address{}, eth), canStart: 1} miner := &Miner{eth: eth, mux: mux, pow: pow, worker: newWorker(config, common.Address{}, eth), canStart: 1}
go miner.update() go miner.update()
go miner.runLoop()
return miner return miner
} }
@ -105,13 +106,13 @@ func (m *Miner) SetGasPrice(price *big.Int) {
func (self *Miner) Start(coinbase common.Address, threads int) { func (self *Miner) Start(coinbase common.Address, threads int) {
self.sub = self.mux.Subscribe(core.TxPreEvent{}, core.NewBlockEvent{}, core.NewMinedBlockEvent{}) self.sub = self.mux.Subscribe(core.TxPreEvent{}, core.NewBlockEvent{}, core.NewMinedBlockEvent{})
//go self.filterLoop(coinbase, threads) //go self.filterLoop(coinbase, threads)
go self.runLoop(coinbase, threads) self.actuallyStart(coinbase, threads)
} }
func (self *Miner) runLoop(coinbase common.Address, threads int) { func (self *Miner) runLoop() {
for true { for true {
if len(self.worker.txQueue) == 0 { if len(self.worker.current.txs) == 0 {
if self.Mining() { if self.Mining() {
glog.V(logger.Info).Infoln("Nothing to do. The miner sleeps.") glog.V(logger.Info).Infoln("Nothing to do. The miner sleeps.")
self.Stop() self.Stop()
@ -119,10 +120,10 @@ func (self *Miner) runLoop(coinbase common.Address, threads int) {
} else { } else {
if self.Mining() == false { if self.Mining() == false {
glog.V(logger.Info).Infoln("A transaction awaits! Waking up miner.") glog.V(logger.Info).Infoln("A transaction awaits! Waking up miner.")
self.Start(coinbase, threads) self.Start(self.coinbase, self.threads)
} }
time.Sleep(3000 * time.Millisecond)
} }
time.Sleep(3000 * time.Millisecond)
} }
} }