fix: remove deleted peers if resumeState = true

This commit is contained in:
Устюжанин Антон Александрович
2020-10-04 21:56:17 +05:00
parent b3dd0ba446
commit 702b1cb876
2 changed files with 26 additions and 5 deletions

View File

@@ -104,7 +104,24 @@ func NewRaftServer(grpcDialOption grpc.DialOption, peers []string, serverAddr, d
if err := s.raftServer.AddPeer(peer, pb.ServerToGrpcAddress(peer)); err != nil {
return nil, err
}
}
// Remove deleted peers
if raftResumeState {
for existsPeerName, _ := range s.raftServer.Peers() {
exists := false
for _, peer := range s.peers {
if peer == existsPeerName {
exists = true
}
}
if !exists {
if err := s.raftServer.RemovePeer(existsPeerName); err != nil {
glog.V(0).Infoln(err)
return nil, err
}
}
}
}
s.GrpcServer = raft.NewGrpcServer(s.raftServer)