distributed/talent-plan-tinykv
1
0
Fork 0
mirror of https://github.com/talent-plan/tinykv.git synced 2025-03-15 20:31:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix invalid term in 3a (#246)

Browse Source 
Co-authored-by: NingLin-P <linningde25@gmail.com>
This commit is contained in:
Rapiz 2021-02-02 11:49:46 +08:00 committed by GitHub
parent 2f698ab6e3
commit 04065cadd6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
raft/raft_test.go
View File

@ -1195,6 +1195,7 @@ func TestCommitAfterRemoveNode3A(t *testing.T) {
MsgType: pb.MessageType_MsgAppendResponse,
From: 2,
Index: ccIndex,
Term: r.Term,
})
ents := nextEnts(r, s)
if len(ents) != 2 {
@ -1309,7 +1310,7 @@ func TestLeaderTransferAfterSnapshot3A(t *testing.T) {
// Transfer leadership to 3 when node 3 is lack of snapshot.
nt.send(pb.Message{From: 3, To: 1, MsgType: pb.MessageType_MsgTransferLeader})
// Send pb.MessageType_MsgHeartbeatResponse to leader to trigger a snapshot for node 3.
nt.send(pb.Message{From: 3, To: 1, MsgType: pb.MessageType_MsgHeartbeatResponse})
nt.send(pb.Message{From: 3, To: 1, MsgType: pb.MessageType_MsgHeartbeatResponse, Term: lead.Term})
checkLeaderTransferState(t, lead, StateFollower, 3)
}
@ -1408,10 +1409,10 @@ func checkLeaderTransferState(t *testing.T, r *Raft, state StateType, lead uint6
// transitioned to StateLeader)
func TestTransferNonMember3A(t *testing.T) {
r := newTestRaft(1, []uint64{2, 3, 4}, 5, 1, NewMemoryStorage())
r.Step(pb.Message{From: 2, To: 1, MsgType: pb.MessageType_MsgTimeoutNow})
r.Step(pb.Message{From: 2, To: 1, MsgType: pb.MessageType_MsgTimeoutNow, Term: r.Term})
r.Step(pb.Message{From: 2, To: 1, MsgType: pb.MessageType_MsgRequestVoteResponse})
r.Step(pb.Message{From: 3, To: 1, MsgType: pb.MessageType_MsgRequestVoteResponse})
r.Step(pb.Message{From: 2, To: 1, MsgType: pb.MessageType_MsgRequestVoteResponse, Term: r.Term})
r.Step(pb.Message{From: 3, To: 1, MsgType: pb.MessageType_MsgRequestVoteResponse, Term: r.Term})
if r.State != StateFollower {
t.Fatalf("state is %s, want StateFollower", r.State)
}