kube-proxy: log stale services operations

Antonio Ojea · Antonio Ojea · commit 880baa9f6f04 · 2020-10-19T09:35:34.000+02:00
diff --git a/pkg/proxy/iptables/proxier.go b/pkg/proxy/iptables/proxier.go
@@ -1625,11 +1625,13 @@ func (proxier *Proxier) syncProxyRules() {
 
 	// Finish housekeeping.
 	// TODO: these could be made more consistent.
+	klog.V(4).Infof("Deleting stale services IPs: %v", staleServices.UnsortedList())
 	for _, svcIP := range staleServices.UnsortedList() {
 		if err := conntrack.ClearEntriesForIP(proxier.exec, svcIP, v1.ProtocolUDP); err != nil {
 			klog.Errorf("Failed to delete stale service IP %s connections, error: %v", svcIP, err)
 		}
 	}
+	klog.V(4).Infof("Deleting stale endpoint connections: %v", endpointUpdateResult.StaleEndpoints)
 	proxier.deleteEndpointConnections(endpointUpdateResult.StaleEndpoints)
 }
 

Original file line number	Diff line number	Diff line change
`@@ -1625,11 +1625,13 @@ func (proxier *Proxier) syncProxyRules() {`
`1625`	`1625`
`1626`	`1626`	`// Finish housekeeping.`
`1627`	`1627`	`// TODO: these could be made more consistent.`
	`1628`	`+ klog.V(4).Infof("Deleting stale services IPs: %v", staleServices.UnsortedList())`
`1628`	`1629`	`for _, svcIP := range staleServices.UnsortedList() {`
`1629`	`1630`	`if err := conntrack.ClearEntriesForIP(proxier.exec, svcIP, v1.ProtocolUDP); err != nil {`
`1630`	`1631`	`klog.Errorf("Failed to delete stale service IP %s connections, error: %v", svcIP, err)`
`1631`	`1632`	`}`
`1632`	`1633`	`}`
	`1634`	`+ klog.V(4).Infof("Deleting stale endpoint connections: %v", endpointUpdateResult.StaleEndpoints)`
`1633`	`1635`	`proxier.deleteEndpointConnections(endpointUpdateResult.StaleEndpoints)`
`1634`	`1636`	`}`
`1635`	`1637`