fix a race condition.

auxesis · Nov 1, 2013 · 9ef4b61 · 9ef4b61
1 parent 559e7ed
commit 9ef4b61
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/coordinator/coordinator_test.go b/src/coordinator/coordinator_test.go
@@ -28,7 +28,7 @@ type CoordinatorSuite struct{}
 var _ = Suite(&CoordinatorSuite{})
 
 func init() {
-	runtime.GOMAXPROCS(runtime.NumCPU())
+	runtime.GOMAXPROCS(runtime.NumCPU() * 2)
 }
 
 const (

diff --git a/src/coordinator/raft_server.go b/src/coordinator/raft_server.go
@@ -232,11 +232,11 @@ func (s *RaftServer) ListenAndServe(potentialLeaders []string, retryUntilJoin bo
 }
 
 func (s *RaftServer) Serve(l net.Listener, potentialLeaders []string, retryUntilJoin bool) error {
-	go s.startRaft(potentialLeaders, retryUntilJoin)
-
 	s.port = l.Addr().(*net.TCPAddr).Port
 	s.listener = l
 
+	go s.startRaft(potentialLeaders, retryUntilJoin)
+
 	log.Println("Initializing Raft HTTP server")
 
 	// Initialize and start HTTP server.