Skip to content
This repository has been archived by the owner on Jul 16, 2024. It is now read-only.

Commit

Permalink
Merge pull request #396 from ahrtr/remove_member_20240427
Browse files Browse the repository at this point in the history
Fix the issue that an incorrect member may be removed
  • Loading branch information
k8s-ci-robot committed Apr 29, 2024
2 parents 39cfe40 + 31f8e5f commit 3442565
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions etcd-manager/pkg/controller/etcdclusterstate.go
Original file line number Diff line number Diff line change
Expand Up @@ -144,21 +144,21 @@ func (s *etcdClusterState) etcdAddMember(ctx context.Context, nodeInfo *protoetc
return nil, fmt.Errorf("unable to reach any cluster member, when trying to add new member %q", nodeInfo.PeerUrls)
}

func (s *etcdClusterState) etcdRemoveMember(ctx context.Context, member *etcdclient.EtcdProcessMember) error {
func (s *etcdClusterState) etcdRemoveMember(ctx context.Context, nodeInfo *etcdclient.EtcdProcessMember) error {
for id, member := range s.members {
etcdClient, err := s.newEtcdClient(member)
if err != nil {
klog.Warningf("unable to build client for member %s: %v", member.Name, err)
continue
}

err = etcdClient.RemoveMember(ctx, member)
err = etcdClient.RemoveMember(ctx, nodeInfo)
etcdclient.LoggedClose(etcdClient)
if err != nil {
klog.Warningf("Remove member call failed on %s: %v", id, err)
continue
}
return nil
}
return fmt.Errorf("unable to reach any cluster member, when trying to remove member %s", member)
return fmt.Errorf("unable to reach any cluster member, when trying to remove member %s", nodeInfo)
}

0 comments on commit 3442565

Please sign in to comment.