diff options
| author | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-03-25 15:09:38 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-03-25 15:09:38 +0500 |
| commit | ddd3945c26e6fe505697434d5d2d1cba909c8e29 (patch) | |
| tree | 50b27834b5a567886b4639ac1cce9ecc13b6aedb /weed/server/raft_server.go | |
| parent | c1450bf9fe59d304e94a7dee8051d8c02670edc4 (diff) | |
| download | seaweedfs-ddd3945c26e6fe505697434d5d2d1cba909c8e29.tar.xz seaweedfs-ddd3945c26e6fe505697434d5d2d1cba909c8e29.zip | |
fix remove deleted peers of raft server
https://github.com/chrislusf/seaweedfs/issues/2804
Diffstat (limited to 'weed/server/raft_server.go')
| -rw-r--r-- | weed/server/raft_server.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/server/raft_server.go b/weed/server/raft_server.go index 16afb5c7d..f22b7c45d 100644 --- a/weed/server/raft_server.go +++ b/weed/server/raft_server.go @@ -119,17 +119,17 @@ func NewRaftServer(option *RaftServerOption) (*RaftServer, error) { exists := false var existingPeer pb.ServerAddress for _, peer := range s.peers { - if peer.ToGrpcAddress() == existsPeerName { + if peer.String() == existsPeerName { exists, existingPeer = true, peer break } } - if exists { + if !exists { if err := s.raftServer.RemovePeer(existsPeerName); err != nil { glog.V(0).Infoln(err) return nil, err } else { - glog.V(0).Infof("removing old peer %s", existingPeer) + glog.V(0).Infof("removing old peer: %s", existingPeer) } } } |