Skip to content

K
k3s
Commit 8b16d66b authored by m1093782566's avatar m1093782566
Browse files
Options

add some comment message

parent ac1cd3dc
Hide whitespace changes
Inline Side-by-side
Showing with 6 additions and 2 deletions
pkg/proxy/iptables/proxier.go
View file @ 8b16d66b
...@@ -962,7 +962,7 @@ func (proxier *Proxier) syncProxyRules() { ...@@ -962,7 +962,7 @@ func (proxier *Proxier) syncProxyRules() {
// (because the socket might open but it would never work). // (because the socket might open but it would never work).
addresses, err := utilproxy.GetNodeAddresses(proxier.nodePortAddresses, proxier.networkInterfacer) addresses, err := utilproxy.GetNodeAddresses(proxier.nodePortAddresses, proxier.networkInterfacer)
if err != nil { if err != nil {
glog.Errorf("Failed to get node ip address matching nodeport cidr") glog.Errorf("Failed to get node ip address matching nodeport cidr: %v", err)
continue continue
} }
...@@ -976,6 +976,7 @@ func (proxier *Proxier) syncProxyRules() { ...@@ -976,6 +976,7 @@ func (proxier *Proxier) syncProxyRules() {
Protocol: protocol, Protocol: protocol,
} }
lps = append(lps, lp) lps = append(lps, lp)
// If we encounter a zero CIDR, then there is no point in processing the rest of the addresses.
break break
} }
lp := utilproxy.LocalPort{ lp := utilproxy.LocalPort{
...@@ -987,6 +988,7 @@ func (proxier *Proxier) syncProxyRules() { ...@@ -987,6 +988,7 @@ func (proxier *Proxier) syncProxyRules() {
lps = append(lps, lp) lps = append(lps, lp)
} }
// For ports on node IPs, open the actual port and hold it.
for _, lp := range lps { for _, lp := range lps {
if proxier.portsMap[lp] != nil { if proxier.portsMap[lp] != nil {
glog.V(4).Infof("Port %s was open before and is still needed", lp.String()) glog.V(4).Infof("Port %s was open before and is still needed", lp.String())
......
pkg/proxy/ipvs/proxier.go
View file @ 8b16d66b
...@@ -987,7 +987,7 @@ func (proxier *Proxier) syncProxyRules() { ...@@ -987,7 +987,7 @@ func (proxier *Proxier) syncProxyRules() {
if svcInfo.NodePort != 0 { if svcInfo.NodePort != 0 {
addresses, err := utilproxy.GetNodeAddresses(proxier.nodePortAddresses, proxier.networkInterfacer) addresses, err := utilproxy.GetNodeAddresses(proxier.nodePortAddresses, proxier.networkInterfacer)
if err != nil { if err != nil {
glog.Errorf("Failed to get node ip address matching nodeport cidr") glog.Errorf("Failed to get node ip address matching nodeport cidr: %v", err)
continue continue
} }
...@@ -1001,6 +1001,7 @@ func (proxier *Proxier) syncProxyRules() { ...@@ -1001,6 +1001,7 @@ func (proxier *Proxier) syncProxyRules() {
Protocol: protocol, Protocol: protocol,
} }
lps = append(lps, lp) lps = append(lps, lp)
// If we encounter a zero CIDR, then there is no point in processing the rest of the addresses.
break break
} }
lp := utilproxy.LocalPort{ lp := utilproxy.LocalPort{
...@@ -1012,6 +1013,7 @@ func (proxier *Proxier) syncProxyRules() { ...@@ -1012,6 +1013,7 @@ func (proxier *Proxier) syncProxyRules() {
lps = append(lps, lp) lps = append(lps, lp)
} }
// For ports on node IPs, open the actual port and hold it.
for _, lp := range lps { for _, lp := range lps {
if proxier.portsMap[lp] != nil { if proxier.portsMap[lp] != nil {
glog.V(4).Infof("Port %s was open before and is still needed", lp.String()) glog.V(4).Infof("Port %s was open before and is still needed", lp.String())
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment