mirrors/kube-router
1
0
Fork 0
mirror of https://github.com/cloudnativelabs/kube-router.git synced 2025-10-11 18:01:05 +02:00
Code Issues Packages Projects Releases Wiki Activity

closes https://github.com/cloudnativelabs/kube-router/issues/413 (#457)

Browse Source
This commit is contained in:
Joakim Karlsson 2018-06-04 13:52:46 +02:00 committed by Murali Reddy
parent 6887ce716e
commit 0809548716
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
pkg/controllers/proxy/network_services_controller.go
View File

@ -241,6 +241,18 @@ func (nsc *NetworkServicesController) Run(healthChan chan<- *healthcheck.Control
return errors.New("Failed to do sysctl net.ipv4.vs.conntrack=1 due to: %s" + err.Error()) return errors.New("Failed to do sysctl net.ipv4.vs.conntrack=1 due to: %s" + err.Error())
} }
// LVS failover not working with UDP packets https://access.redhat.com/solutions/58653
err = ensureIpvsExpireNodestConn()
if err != nil {
return errors.New("Failed to do sysctl net.ipv4.vs.expire_nodest_conn=1 due to: %s" + err.Error())
}
// LVS failover not working with UDP packets https://access.redhat.com/solutions/58653
err = ensureIpvsQuiescentTemplate()
if err != nil {
return errors.New("Failed to do sysctl net.ipv4.vs.expire_quiescent_template=1 due to: %s" + err.Error())
}
// loop forever unitl notified to stop on stopCh // loop forever unitl notified to stop on stopCh
for { for {
select { select {
@ -1335,6 +1347,14 @@ func ensureIpvsConntrack() error {
return ioutil.WriteFile("/proc/sys/net/ipv4/vs/conntrack", []byte(strconv.Itoa(1)), 0640) return ioutil.WriteFile("/proc/sys/net/ipv4/vs/conntrack", []byte(strconv.Itoa(1)), 0640)
} }
func ensureIpvsExpireNodestConn() error {
return ioutil.WriteFile("/proc/sys/net/ipv4/vs/expire_nodest_conn", []byte(strconv.Itoa(1)), 0640)
}
func ensureIpvsQuiescentTemplate() error {
return ioutil.WriteFile("/proc/sys/net/ipv4/vs/expire_quiescent_template", []byte(strconv.Itoa(1)), 0640)
}
func deleteMasqueradeIptablesRule() error { func deleteMasqueradeIptablesRule() error {
iptablesCmdHandler, err := iptables.New() iptablesCmdHandler, err := iptables.New()
if err != nil { if err != nil {