Skip to content

K
k3s
Commit 4ca62e4f authored by Jia Xin's avatar Jia Xin
Browse files
Options

Restore *filter table for ipvs

Resolve: #68194
parent dd2a1e5d
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 0 deletions
pkg/proxy/ipvs/proxier.go
View file @ 4ca62e4f
...@@ -697,6 +697,8 @@ func (proxier *Proxier) syncProxyRules() { ...@@ -697,6 +697,8 @@ func (proxier *Proxier) syncProxyRules() {
// This is to avoid memory reallocations and thus improve performance. // This is to avoid memory reallocations and thus improve performance.
proxier.natChains.Reset() proxier.natChains.Reset()
proxier.natRules.Reset() proxier.natRules.Reset()
proxier.filterChains.Reset()
proxier.filterRules.Reset()
// Write table headers. // Write table headers.
writeLine(proxier.filterChains, "*filter") writeLine(proxier.filterChains, "*filter")
...@@ -1131,6 +1133,8 @@ func (proxier *Proxier) syncProxyRules() { ...@@ -1131,6 +1133,8 @@ func (proxier *Proxier) syncProxyRules() {
proxier.iptablesData.Reset() proxier.iptablesData.Reset()
proxier.iptablesData.Write(proxier.natChains.Bytes()) proxier.iptablesData.Write(proxier.natChains.Bytes())
proxier.iptablesData.Write(proxier.natRules.Bytes()) proxier.iptablesData.Write(proxier.natRules.Bytes())
proxier.iptablesData.Write(proxier.filterChains.Bytes())
proxier.iptablesData.Write(proxier.filterRules.Bytes())
glog.V(5).Infof("Restoring iptables rules: %s", proxier.iptablesData.Bytes()) glog.V(5).Infof("Restoring iptables rules: %s", proxier.iptablesData.Bytes())
err = proxier.iptables.RestoreAll(proxier.iptablesData.Bytes(), utiliptables.NoFlushTables, utiliptables.RestoreCounters) err = proxier.iptables.RestoreAll(proxier.iptablesData.Bytes(), utiliptables.NoFlushTables, utiliptables.RestoreCounters)
......
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