diff options
| author | chrislu <chris.lu@gmail.com> | 2022-03-26 10:24:05 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-03-26 10:24:05 -0700 |
| commit | fba1cfc2d6ef741164047e3c1af73843ee6bc2b7 (patch) | |
| tree | 39727b739ed537ef4eff13358c365ff2e8de58c0 /weed/server/raft_server.go | |
| parent | a3411dd9da8361a1d2e49e935e94a2ce2ad78a51 (diff) | |
| download | seaweedfs-fba1cfc2d6ef741164047e3c1af73843ee6bc2b7.tar.xz seaweedfs-fba1cfc2d6ef741164047e3c1af73843ee6bc2b7.zip | |
simplify a bit
Diffstat (limited to 'weed/server/raft_server.go')
| -rw-r--r-- | weed/server/raft_server.go | 10 |
1 files changed, 1 insertions, 9 deletions
diff --git a/weed/server/raft_server.go b/weed/server/raft_server.go index 09141ab0d..5f27a3a0e 100644 --- a/weed/server/raft_server.go +++ b/weed/server/raft_server.go @@ -118,15 +118,7 @@ func NewRaftServer(option *RaftServerOption) (*RaftServer, error) { // Remove deleted peers for existsPeerName := range s.raftServer.Peers() { - exists := false - var existingPeer pb.ServerAddress - for name, peer := range s.peers { - if name == existsPeerName { - exists, existingPeer = true, peer - break - } - } - if !exists { + if existingPeer, found := s.peers[existsPeerName]; !found { if err := s.raftServer.RemovePeer(existsPeerName); err != nil { glog.V(0).Infoln(err) return nil, err |