check for nil raftState
parent
114b20ec5c
commit
2379a0a406
|
@ -427,15 +427,16 @@ func (s *Store) checkRaftState() error {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Store) changeState(state raftState) error {
|
func (s *Store) changeState(state raftState) error {
|
||||||
if err := s.raftState.close(); err != nil {
|
if s.raftState != nil {
|
||||||
return err
|
if err := s.raftState.close(); err != nil {
|
||||||
}
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
// Clear out any persistent state
|
// Clear out any persistent state
|
||||||
if err := s.raftState.remove(); err != nil {
|
if err := s.raftState.remove(); err != nil {
|
||||||
return err
|
return err
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
s.raftState = state
|
s.raftState = state
|
||||||
|
|
||||||
if err := s.raftState.open(); err != nil {
|
if err := s.raftState.open(); err != nil {
|
||||||
|
|
Loading…
Reference in New Issue