diff --git a/raft/node.go b/raft/node.go index 177b6d5fb..5e983e86d 100644 --- a/raft/node.go +++ b/raft/node.go @@ -233,7 +233,7 @@ func (n *node) run(r *raft) { lead := None prevSoftSt := r.softState() - prevHardSt := r.HardState + prevHardSt := emptyState for { if advancec != nil { diff --git a/raft/node_test.go b/raft/node_test.go index 4da225396..518759eae 100644 --- a/raft/node_test.go +++ b/raft/node_test.go @@ -354,7 +354,7 @@ func TestNodeRestart(t *testing.T) { st := raftpb.HardState{Term: 1, Commit: 1} want := Ready{ - HardState: emptyState, + HardState: st, // commit up to index commit index in st CommittedEntries: entries[:st.Commit], } @@ -389,7 +389,7 @@ func TestNodeRestartFromSnapshot(t *testing.T) { st := raftpb.HardState{Term: 1, Commit: 3} want := Ready{ - HardState: emptyState, + HardState: st, // commit up to index commit index in st CommittedEntries: entries, }