diff options
author | Péter Szilágyi <peterke@gmail.com> | 2017-04-07 22:22:06 +0800 |
---|---|---|
committer | Péter Szilágyi <peterke@gmail.com> | 2017-04-07 22:22:06 +0800 |
commit | b801be99d47ba09121a3e7d14aa028f828525b61 (patch) | |
tree | ffa8ffe28b6e7539cfd9baa6aa0b3c48522b91fc /eth/api.go | |
parent | cc13d576f07fb6803e09fb42880591a67b8b0ef6 (diff) | |
download | go-tangerine-b801be99d47ba09121a3e7d14aa028f828525b61.tar go-tangerine-b801be99d47ba09121a3e7d14aa028f828525b61.tar.gz go-tangerine-b801be99d47ba09121a3e7d14aa028f828525b61.tar.bz2 go-tangerine-b801be99d47ba09121a3e7d14aa028f828525b61.tar.lz go-tangerine-b801be99d47ba09121a3e7d14aa028f828525b61.tar.xz go-tangerine-b801be99d47ba09121a3e7d14aa028f828525b61.tar.zst go-tangerine-b801be99d47ba09121a3e7d14aa028f828525b61.zip |
consensus, eth: don't CPU mine by default during remote mining
Diffstat (limited to 'eth/api.go')
-rw-r--r-- | eth/api.go | 27 |
1 files changed, 17 insertions, 10 deletions
diff --git a/eth/api.go b/eth/api.go index 041ccd397..947070515 100644 --- a/eth/api.go +++ b/eth/api.go @@ -139,16 +139,17 @@ func NewPrivateMinerAPI(e *Ethereum) *PrivateMinerAPI { // threads allowed to use. func (api *PrivateMinerAPI) Start(threads *int) error { // Set the number of threads if the seal engine supports it - if threads != nil { - type threaded interface { - SetThreads(threads int) - } - if th, ok := api.e.engine.(threaded); ok { - log.Info("Updated mining threads", "threads", *threads) - th.SetThreads(*threads) - } else { - log.Warn("Current seal engine isn't threaded") - } + if threads == nil { + threads = new(int) + } else if *threads == 0 { + *threads = -1 // Disable the miner from within + } + type threaded interface { + SetThreads(threads int) + } + if th, ok := api.e.engine.(threaded); ok { + log.Info("Updated mining threads", "threads", *threads) + th.SetThreads(*threads) } // Start the miner and return if !api.e.IsMining() { @@ -159,6 +160,12 @@ func (api *PrivateMinerAPI) Start(threads *int) error { // Stop the miner func (api *PrivateMinerAPI) Stop() bool { + type threaded interface { + SetThreads(threads int) + } + if th, ok := api.e.engine.(threaded); ok { + th.SetThreads(-1) + } api.e.StopMining() return true } |