github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-15 14:14:39 +00:00
Code Issues Projects Releases Wiki Activity

Check for node IP

Browse Source
This commit is contained in:
ksubrmnn
2019-07-02 14:16:23 -07:00
parent 03291ca467
commit 378fcc809a
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/proxy/winkernel/proxier.go
View File

@@ -1076,6 +1076,7 @@ func (proxier *Proxier) syncProxyRules() {
klog.V(4).Infof("====Applying Policy for %s====", svcName) klog.V(4).Infof("====Applying Policy for %s====", svcName)
// Create Remote endpoints for every endpoint, corresponding to the service // Create Remote endpoints for every endpoint, corresponding to the service
containsPublicIP := false containsPublicIP := false
containsNodeIP := false
for _, ep := range proxier.endpointsMap[svcName] { for _, ep := range proxier.endpointsMap[svcName] {
var newHnsEndpoint *endpointsInfo var newHnsEndpoint *endpointsInfo
@@ -1126,13 +1127,15 @@ func (proxier *Proxier) syncProxyRules() {
} }
if ep.ip == rs.providerAddress { if ep.ip == rs.providerAddress {
providerAddress = rs.providerAddress providerAddress = rs.providerAddress
containsNodeIP = true
} }
} }
if len(providerAddress) == 0 { if len(providerAddress) == 0 {
klog.Errorf("Could not find provider address for %s", ep.ip) klog.Infof("Could not find provider address for %s. Assuming it is a public IP", ep.ip)
providerAddress = proxier.nodeIP.String() providerAddress = proxier.nodeIP.String()
containsPublicIP = true containsPublicIP = true
} }
hnsEndpoint := &endpointsInfo{ hnsEndpoint := &endpointsInfo{
ip: ep.ip, ip: ep.ip,
isLocal: false, isLocal: false,
@@ -1186,7 +1189,7 @@ func (proxier *Proxier) syncProxyRules() {
klog.V(4).Infof("Trying to Apply Policies for service %s", spew.Sdump(svcInfo)) klog.V(4).Infof("Trying to Apply Policies for service %s", spew.Sdump(svcInfo))
var hnsLoadBalancer *loadBalancerInfo var hnsLoadBalancer *loadBalancerInfo
var sourceVip = proxier.sourceVip var sourceVip = proxier.sourceVip
if containsPublicIP { if containsPublicIP || containsNodeIP {
sourceVip = proxier.nodeIP.String() sourceVip = proxier.nodeIP.String()
} }
hnsLoadBalancer, err := hns.getLoadBalancer( hnsLoadBalancer, err := hns.getLoadBalancer(