tornadocontrib/go-ethereum
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added channel for starting/stopping miner

Browse Source
This commit is contained in:
obscuren 2014-07-18 12:21:11 +02:00
parent 65650a5c66
commit dad29bcaa1
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
ethminer/miner.go
View File

@ -24,11 +24,11 @@ type Miner struct {
quitChan chan bool quitChan chan bool
} }
func (self Miner) GetPow() *ethchain.PoW { func (self *Miner) GetPow() ethchain.PoW {
return &self.pow return self.pow
} }
func NewDefaultMiner(coinbase []byte, ethereum ethchain.EthManager) Miner { func NewDefaultMiner(coinbase []byte, ethereum ethchain.EthManager) *Miner {
reactChan := make(chan ethutil.React, 1) // This is the channel that receives 'updates' when ever a new transaction or block comes in reactChan := make(chan ethutil.React, 1) // This is the channel that receives 'updates' when ever a new transaction or block comes in
powChan := make(chan []byte, 1) // This is the channel that receives valid sha hases for a given block powChan := make(chan []byte, 1) // This is the channel that receives valid sha hases for a given block
powQuitChan := make(chan ethutil.React, 1) // This is the channel that can exit the miner thread powQuitChan := make(chan ethutil.React, 1) // This is the channel that can exit the miner thread
@ -59,7 +59,7 @@ func NewDefaultMiner(coinbase []byte, ethereum ethchain.EthManager) Miner {
miner.txs = ethereum.TxPool().Flush() miner.txs = ethereum.TxPool().Flush()
miner.block = ethereum.BlockChain().NewBlock(miner.coinbase) miner.block = ethereum.BlockChain().NewBlock(miner.coinbase)
return miner return &miner
} }
func (miner *Miner) Start() { func (miner *Miner) Start() {
@ -67,6 +67,8 @@ func (miner *Miner) Start() {
//miner.ethereum.StateManager().Prepare(miner.block.State(), miner.block.State()) //miner.ethereum.StateManager().Prepare(miner.block.State(), miner.block.State())
go miner.listener() go miner.listener()
logger.Infoln("Started") logger.Infoln("Started")
miner.ethereum.Reactor().Post("miner:start", miner)
} }
func (miner *Miner) listener() { func (miner *Miner) listener() {
@ -137,6 +139,8 @@ func (self *Miner) Stop() {
close(self.powQuitChan) close(self.powQuitChan)
close(self.quitChan) close(self.quitChan)
self.ethereum.Reactor().Post("miner:stop", self)
} }
func (self *Miner) mineNewBlock() { func (self *Miner) mineNewBlock() {