Procházet zdrojové kódy

Merge pull request #1968 from xiang90/fix_raft_test

raft: flush the commit to fix a race in test
Xiang Li před 11 roky
rodič
revize
f78bf987c8
1 změnil soubory, kde provedl 3 přidání a 1 odebrání
  1. 3 1
      raft/raft_test.go

+ 3 - 1
raft/raft_test.go

@@ -451,8 +451,10 @@ func TestCandidateConcede(t *testing.T) {
 	tt.send(pb.Message{From: 3, To: 3, Type: pb.MsgBeat})
 	tt.send(pb.Message{From: 3, To: 3, Type: pb.MsgBeat})
 
 
 	data := []byte("force follower")
 	data := []byte("force follower")
-	// send a proposal to 2 to flush out a MsgApp to 0
+	// send a proposal to 3 to flush out a MsgApp to 1
 	tt.send(pb.Message{From: 3, To: 3, Type: pb.MsgProp, Entries: []pb.Entry{{Data: data}}})
 	tt.send(pb.Message{From: 3, To: 3, Type: pb.MsgProp, Entries: []pb.Entry{{Data: data}}})
+	// send heartbeat; flush out commit
+	tt.send(pb.Message{From: 3, To: 3, Type: pb.MsgBeat})
 
 
 	a := tt.peers[1].(*raft)
 	a := tt.peers[1].(*raft)
 	if g := a.state; g != StateFollower {
 	if g := a.state; g != StateFollower {