github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-09 03:57:41 +00:00
Code Issues Projects Releases Wiki Activity

Do not mark errorFetchingAddressFromLease, in case when the there's no address being fetched from the lease object

Browse Source
This commit is contained in:
Richa Banker 2024-09-27 16:37:46 -07:00
parent 80941e3e87
commit ac3fd5c634
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler.go
View File

@ -203,7 +203,6 @@ func (h *peerProxyHandler) findServiceableByServers(gvr schema.GroupVersionResou
apiservers.Range(func(key, value interface{}) bool { apiservers.Range(func(key, value interface{}) bool {
apiserverKey := key.(string) apiserverKey := key.(string)
if apiserverKey == localAPIServerId { if apiserverKey == localAPIServerId {
response.errorFetchingAddressFromLease = true
response.locallyServiceable = true response.locallyServiceable = true
// stop iteration // stop iteration
return false return false
@ -221,11 +220,9 @@ func (h *peerProxyHandler) findServiceableByServers(gvr schema.GroupVersionResou
if err != nil { if err != nil {
response.errorFetchingAddressFromLease = true response.errorFetchingAddressFromLease = true
klog.Errorf("invalid address found for server %s", apiserverKey) klog.Errorf("invalid address found for server %s", apiserverKey)
// continue with iteration
return true return true
} }
peerServerEndpoints = append(peerServerEndpoints, hostPort) peerServerEndpoints = append(peerServerEndpoints, hostPort)
// continue with iteration
return true return true
}) })