diff options
author | obscuren <geffobscura@gmail.com> | 2015-03-01 06:09:49 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2015-03-01 06:09:49 +0800 |
commit | 65cad14f9b27db396d036f47814d4843d947ac43 (patch) | |
tree | 89395b2035f38d9dd851c0d50a064387469355eb /miner/worker.go | |
parent | fdf939a6f9b5360d76415c7118969d92af2774f9 (diff) | |
download | go-tangerine-65cad14f9b27db396d036f47814d4843d947ac43.tar.gz go-tangerine-65cad14f9b27db396d036f47814d4843d947ac43.tar.zst go-tangerine-65cad14f9b27db396d036f47814d4843d947ac43.zip |
Report debug hash rate
Diffstat (limited to 'miner/worker.go')
-rw-r--r-- | miner/worker.go | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/miner/worker.go b/miner/worker.go index 4f0909302..afce68c35 100644 --- a/miner/worker.go +++ b/miner/worker.go @@ -5,6 +5,7 @@ import ( "math/big" "sort" "sync" + "time" "github.com/ethereum/go-ethereum/core" "github.com/ethereum/go-ethereum/core/types" @@ -111,6 +112,8 @@ func (self *worker) register(agent Agent) { func (self *worker) update() { events := self.mux.Subscribe(core.ChainEvent{}, core.NewMinedBlockEvent{}) + timer := time.NewTicker(2 * time.Second) + out: for { select { @@ -129,6 +132,8 @@ out: agent.Stop() } break out + case <-timer.C: + minerlogger.Debugln("Hash rate:", self.HashRate(), "Khash") } } @@ -244,3 +249,12 @@ func (self *worker) commitTransaction(tx *types.Transaction) error { return nil } + +func (self *worker) HashRate() int64 { + var tot int64 + for _, agent := range self.agents { + tot += agent.Pow().GetHashrate() + } + + return tot +} |