Skip to content

Commit

Permalink
fixed improperly migrated logs
Browse files Browse the repository at this point in the history
  • Loading branch information
shiva1333 committed Oct 19, 2021
1 parent 23d7007 commit 9df7989
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions pkg/proxy/ipvs/proxier.go
Expand Up @@ -1098,7 +1098,7 @@ func (proxier *Proxier) syncProxyRules() {
if hasNodePort {
nodeAddrSet, err := utilproxy.GetNodeAddresses(proxier.nodePortAddresses, proxier.networkInterfacer)
if err != nil {
klog.ErrorS(err, "Failed to get node ip address matching nodeport cidr")
klog.ErrorS(err, "Failed to get node IP address matching nodeport cidr")
} else {
nodeAddresses = nodeAddrSet.List()
for _, address := range nodeAddresses {
Expand Down Expand Up @@ -1216,10 +1216,10 @@ func (proxier *Proxier) syncProxyRules() {
internalNodeLocal = true
}
if err := proxier.syncEndpoint(svcName, internalNodeLocal, serv); err != nil {
klog.ErrorS(err, "Failed to sync endpoint for service", "service", serv)
klog.ErrorS(err, "Failed to sync endpoint for service", "service", svcName, "virtualServer", serv)
}
} else {
klog.ErrorS(err, "Failed to sync service", "service", serv)
klog.ErrorS(err, "Failed to sync service", "service", svcName, "virtualServer", serv)
}

// Capture externalIPs.
Expand Down Expand Up @@ -1298,10 +1298,10 @@ func (proxier *Proxier) syncProxyRules() {
activeBindAddrs[serv.Address.String()] = true

if err := proxier.syncEndpoint(svcName, svcInfo.NodeLocalExternal(), serv); err != nil {
klog.ErrorS(err, "Failed to sync endpoint for service", "service", serv)
klog.ErrorS(err, "Failed to sync endpoint for service", "service", svcName, "virtualServer", serv)
}
} else {
klog.ErrorS(err, "Failed to sync service", "service", serv)
klog.ErrorS(err, "Failed to sync service", "service", svcName, "virtualServer", serv)
}
}

Expand Down

0 comments on commit 9df7989

Please sign in to comment.