From e3a08875f6435b1674e62bd1d923941ec2092b69 Mon Sep 17 00:00:00 2001
From: obscuren <geffobscura@gmail.com>
Date: Sat, 9 May 2015 12:32:36 +0200
Subject: miner: start/stop mutex locked. Closes #887

---
 miner/worker.go | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/miner/worker.go b/miner/worker.go
index 7adf298ed..22493c235 100644
--- a/miner/worker.go
+++ b/miner/worker.go
@@ -125,6 +125,9 @@ func (self *worker) pendingBlock() *types.Block {
 }
 
 func (self *worker) start() {
+	self.mu.Lock()
+	defer self.mu.Unlock()
+
 	// spin up agents
 	for _, agent := range self.agents {
 		agent.Start()
@@ -134,6 +137,9 @@ func (self *worker) start() {
 }
 
 func (self *worker) stop() {
+	self.mu.Lock()
+	defer self.mu.Unlock()
+
 	if atomic.LoadInt32(&self.mining) == 1 {
 		// stop all agents
 		for _, agent := range self.agents {
@@ -146,6 +152,9 @@ func (self *worker) stop() {
 }
 
 func (self *worker) register(agent Agent) {
+	self.mu.Lock()
+	defer self.mu.Unlock()
+
 	self.agents = append(self.agents, agent)
 	agent.SetReturnCh(self.recv)
 }
-- 
cgit