Fixed miner and logger
This commit is contained in:
parent
cd9b344506
commit
2762ec22d0
@ -96,7 +96,7 @@ func AddLogSystem(logSystem LogSystem) {
|
|||||||
mutex.Lock()
|
mutex.Lock()
|
||||||
defer mutex.Unlock()
|
defer mutex.Unlock()
|
||||||
if logSystems == nil {
|
if logSystems == nil {
|
||||||
logMessages = make(chan *logMessage)
|
logMessages = make(chan *logMessage, 10)
|
||||||
quit = make(chan bool, 1)
|
quit = make(chan bool, 1)
|
||||||
go start()
|
go start()
|
||||||
}
|
}
|
||||||
|
@ -135,10 +135,9 @@ out:
|
|||||||
|
|
||||||
func (self *Miner) Stop() {
|
func (self *Miner) Stop() {
|
||||||
logger.Infoln("Stopping...")
|
logger.Infoln("Stopping...")
|
||||||
self.quitChan <- true
|
|
||||||
|
|
||||||
close(self.powQuitChan)
|
self.quitChan <- true
|
||||||
close(self.quitChan)
|
self.powQuitChan <- ethutil.React{}
|
||||||
|
|
||||||
self.ethereum.Reactor().Post("miner:stop", self)
|
self.ethereum.Reactor().Post("miner:stop", self)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user