commit
4e97305df0
|
@ -243,7 +243,7 @@ func (n *node) run(r *raft) {
|
||||||
|
|
||||||
lead := None
|
lead := None
|
||||||
prevSoftSt := r.softState()
|
prevSoftSt := r.softState()
|
||||||
prevHardSt := r.HardState
|
prevHardSt := emptyState
|
||||||
|
|
||||||
for {
|
for {
|
||||||
if advancec != nil {
|
if advancec != nil {
|
||||||
|
|
|
@ -362,7 +362,7 @@ func TestNodeRestart(t *testing.T) {
|
||||||
st := raftpb.HardState{Term: 1, Commit: 1}
|
st := raftpb.HardState{Term: 1, Commit: 1}
|
||||||
|
|
||||||
want := Ready{
|
want := Ready{
|
||||||
HardState: emptyState,
|
HardState: st,
|
||||||
// commit up to index commit index in st
|
// commit up to index commit index in st
|
||||||
CommittedEntries: entries[:st.Commit],
|
CommittedEntries: entries[:st.Commit],
|
||||||
}
|
}
|
||||||
|
@ -405,7 +405,7 @@ func TestNodeRestartFromSnapshot(t *testing.T) {
|
||||||
st := raftpb.HardState{Term: 1, Commit: 3}
|
st := raftpb.HardState{Term: 1, Commit: 3}
|
||||||
|
|
||||||
want := Ready{
|
want := Ready{
|
||||||
HardState: emptyState,
|
HardState: st,
|
||||||
// commit up to index commit index in st
|
// commit up to index commit index in st
|
||||||
CommittedEntries: entries,
|
CommittedEntries: entries,
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue