From f10579d3b5901d70dec60b2502a2c9abfcdc9303 Mon Sep 17 00:00:00 2001 From: Tobias Grieger Date: Tue, 6 Sep 2022 10:08:43 +0200 Subject: [PATCH] TestLeaderAcknowledgeCommit This needed to call `(*raft).advance` so that the leader would self-ack the entries. Signed-off-by: Tobias Grieger --- raft/raft_paper_test.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/raft/raft_paper_test.go b/raft/raft_paper_test.go index afa1f96c4..54b38b438 100644 --- a/raft/raft_paper_test.go +++ b/raft/raft_paper_test.go @@ -496,8 +496,10 @@ func TestLeaderAcknowledgeCommit(t *testing.T) { li := r.raftLog.lastIndex() r.Step(pb.Message{From: 1, To: 1, Type: pb.MsgProp, Entries: []pb.Entry{{Data: []byte("some data")}}}) - tt.nonLeaderAcceptors[1] = true // leader always has the entry - for _, m := range r.readMessages() { + rd := newReady(r, &SoftState{}, pb.HardState{}) + s.Append(rd.Entries) + r.advance(rd) // simulate having appended entry on leader + for _, m := range rd.Messages { if tt.nonLeaderAcceptors[m.To] { r.Step(acceptAndReply(m)) }