diff options
author | obscuren <geffobscura@gmail.com> | 2015-03-04 03:13:11 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2015-03-04 03:13:11 +0800 |
commit | 8e995b97ccc92098f5744dd7fc3d8e7e111ca09c (patch) | |
tree | 90e1ab7694f43608798ab770026b0debfed605d6 | |
parent | 40ff3cac3943ee672d818776fdd8235fc6684dca (diff) | |
download | dexon-8e995b97ccc92098f5744dd7fc3d8e7e111ca09c.tar.gz dexon-8e995b97ccc92098f5744dd7fc3d8e7e111ca09c.tar.zst dexon-8e995b97ccc92098f5744dd7fc3d8e7e111ca09c.zip |
Fixes and debug added
-rw-r--r-- | cmd/ethereum/main.go | 4 | ||||
-rw-r--r-- | miner/agent.go | 7 | ||||
-rw-r--r-- | miner/miner.go | 1 | ||||
-rw-r--r-- | miner/worker.go | 2 |
4 files changed, 8 insertions, 6 deletions
diff --git a/cmd/ethereum/main.go b/cmd/ethereum/main.go index 9d78b6282..f79f948d1 100644 --- a/cmd/ethereum/main.go +++ b/cmd/ethereum/main.go @@ -114,10 +114,6 @@ func main() { return } - if StartMining { - ethereum.Miner().Start() - } - if len(ImportChain) > 0 { start := time.Now() err := utils.ImportChain(ethereum, ImportChain) diff --git a/miner/agent.go b/miner/agent.go index 5b2bfdb06..6c21d8015 100644 --- a/miner/agent.go +++ b/miner/agent.go @@ -42,11 +42,16 @@ func (self *CpuMiner) Start() { } func (self *CpuMiner) update() { + justStarted := true out: for { select { case block := <-self.c: - self.quitCurrentOp <- struct{}{} + if justStarted { + justStarted = true + } else { + self.quitCurrentOp <- struct{}{} + } go self.mine(block) case <-self.quit: diff --git a/miner/miner.go b/miner/miner.go index b60422a3a..b95c65859 100644 --- a/miner/miner.go +++ b/miner/miner.go @@ -29,6 +29,7 @@ func New(coinbase []byte, eth core.Backend, pow pow.PoW, minerThreads int) *Mine pow: pow, } + minerThreads = 1 for i := 0; i < minerThreads; i++ { miner.worker.register(NewCpuMiner(i, miner.pow)) } diff --git a/miner/worker.go b/miner/worker.go index 774ef9a7e..012353fa1 100644 --- a/miner/worker.go +++ b/miner/worker.go @@ -151,10 +151,10 @@ func (self *worker) wait() { self.current.block.Header().Nonce = work.Nonce self.current.block.Header().MixDigest = work.MixDigest self.current.block.Header().SeedHash = work.SeedHash - fmt.Println(self.current.block) if err := self.chain.InsertChain(types.Blocks{self.current.block}); err == nil { self.mux.Post(core.NewMinedBlockEvent{self.current.block}) + fmt.Println("GOOD BLOCK", self.current.block) } else { self.commitNewWork() } |