github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-27 05:27:21 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #2191 from thockin/udpsvc

Browse Source 
UDP services need UDP portals
This commit is contained in:
Daniel Smith 2014-11-06 12:19:31 -08:00
commit 42b0131d47
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/proxy/proxier.go
View File

@ -482,7 +482,7 @@ func (proxier *Proxier) OnUpdate(services []api.Service) {
} }
func (proxier *Proxier) openPortal(service string, info *serviceInfo) error { func (proxier *Proxier) openPortal(service string, info *serviceInfo) error {
args := iptablesPortalArgs(info.portalIP, info.portalPort, proxier.listenAddress, info.proxyPort, service) args := iptablesPortalArgs(info.portalIP, info.portalPort, info.protocol, proxier.listenAddress, info.proxyPort, service)
existed, err := proxier.iptables.EnsureRule(iptables.TableNAT, iptablesProxyChain, args...) existed, err := proxier.iptables.EnsureRule(iptables.TableNAT, iptablesProxyChain, args...)
if err != nil { if err != nil {
glog.Errorf("Failed to install iptables %s rule for service %q", iptablesProxyChain, service) glog.Errorf("Failed to install iptables %s rule for service %q", iptablesProxyChain, service)
@ -495,7 +495,7 @@ func (proxier *Proxier) openPortal(service string, info *serviceInfo) error {
} }
func (proxier *Proxier) closePortal(service string, info *serviceInfo) error { func (proxier *Proxier) closePortal(service string, info *serviceInfo) error {
args := iptablesPortalArgs(info.portalIP, info.portalPort, proxier.listenAddress, info.proxyPort, service) args := iptablesPortalArgs(info.portalIP, info.portalPort, info.protocol, proxier.listenAddress, info.proxyPort, service)
if err := proxier.iptables.DeleteRule(iptables.TableNAT, iptablesProxyChain, args...); err != nil { if err := proxier.iptables.DeleteRule(iptables.TableNAT, iptablesProxyChain, args...); err != nil {
glog.Errorf("Failed to delete iptables %s rule for service %q", iptablesProxyChain, service) glog.Errorf("Failed to delete iptables %s rule for service %q", iptablesProxyChain, service)
return err return err
@ -533,11 +533,11 @@ var zeroIP = net.ParseIP("0.0.0.0")
var localhostIP = net.ParseIP("127.0.0.1") var localhostIP = net.ParseIP("127.0.0.1")
// Build a slice of iptables args for a portal rule. // Build a slice of iptables args for a portal rule.
func iptablesPortalArgs(destIP net.IP, destPort int, proxyIP net.IP, proxyPort int, service string) []string { func iptablesPortalArgs(destIP net.IP, destPort int, protocol api.Protocol, proxyIP net.IP, proxyPort int, service string) []string {
args := []string{ args := []string{
"-m", "comment", "-m", "comment",
"--comment", service, "--comment", service,
"-p", "tcp", "-p", strings.ToLower(string(protocol)),
"-d", destIP.String(), "-d", destIP.String(),
"--dport", fmt.Sprintf("%d", destPort), "--dport", fmt.Sprintf("%d", destPort),
} }