aboutsummaryrefslogtreecommitdiffstats
path: root/eth/api.go
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2017-04-07 22:22:06 +0800
committerPéter Szilágyi <peterke@gmail.com>2017-04-07 22:22:06 +0800
commitb801be99d47ba09121a3e7d14aa028f828525b61 (patch)
treeffa8ffe28b6e7539cfd9baa6aa0b3c48522b91fc /eth/api.go
parentcc13d576f07fb6803e09fb42880591a67b8b0ef6 (diff)
downloadgo-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.go27
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
}