raft: init stateMachine in New

raft/cluster_test.go

@@ -95,7 +95,6 @@ func buildCluster(size int) (nt *network, nodes []*Node) {
 	Dictate(nodes[0]).Next()
 	for i := 1; i < size; i++ {
 		nt.send(nodes[0].newConfMessage(configAdd, &Config{NodeId: i}))
-		nodes[i].Start()
 		for j := 0; j < i; j++ {
 			nodes[j].Next()
 		}

raft/node.go

@@ -39,29 +39,22 @@ func New(addr int, heartbeat, election tick) *Node {
 		heartbeat: heartbeat,
 		election:  election,
 		addr:      addr,
+		sm:        newStateMachine(addr, []int{addr}),
 	}
 
 	return n
 }
 
-// Propose asynchronously proposes data be applied to the underlying state machine.
-func (n *Node) Propose(data []byte) {
-	m := Message{Type: msgProp, Entries: []Entry{{Data: data}}}
-	n.Step(m)
-}
-
 func Dictate(n *Node) *Node {
-	n.sm = newStateMachine(n.addr, []int{n.addr})
 	n.Step(Message{Type: msgHup})
 	n.Step(n.newConfMessage(configAdd, &Config{NodeId: n.addr}))
 	return n
 }
 
-func (n *Node) Start() {
-	if n.sm != nil {
-		panic("node is started")
-	}
-	n.sm = newStateMachine(n.addr, nil)
+// Propose asynchronously proposes data be applied to the underlying state machine.
+func (n *Node) Propose(data []byte) {
+	m := Message{Type: msgProp, Entries: []Entry{{Data: data}}}
+	n.Step(m)
 }
 
 func (n *Node) Add(addr int) {