From 880baa9f6f040b622babfb7da7cc20726bd652a9 Mon Sep 17 00:00:00 2001
From: Antonio Ojea <aojea@redhat.com>
Date: Mon, 19 Oct 2020 09:35:34 +0200
Subject: [PATCH 1/2] kube-proxy: log stale services operations

---
 pkg/proxy/iptables/proxier.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pkg/proxy/iptables/proxier.go b/pkg/proxy/iptables/proxier.go
index 5e618e12918..3af1bc836e3 100644
--- 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)
 }
 

From e3c1777f7d1e1ad0259b43039e6ba6612232c065 Mon Sep 17 00:00:00 2001
From: Antonio Ojea <aojea@redhat.com>
Date: Mon, 19 Oct 2020 10:01:58 +0200
Subject: [PATCH 2/2] conntrack log delete operations

---
 pkg/util/conntrack/BUILD        | 1 +
 pkg/util/conntrack/conntrack.go | 3 +++
 2 files changed, 4 insertions(+)

diff --git a/pkg/util/conntrack/BUILD b/pkg/util/conntrack/BUILD
index 958fba489aa..a3d89e15ed1 100644
--- a/pkg/util/conntrack/BUILD
+++ b/pkg/util/conntrack/BUILD
@@ -7,6 +7,7 @@ go_library(
     visibility = ["//visibility:public"],
     deps = [
         "//staging/src/k8s.io/api/core/v1:go_default_library",
+        "//vendor/k8s.io/klog/v2:go_default_library",
         "//vendor/k8s.io/utils/exec:go_default_library",
         "//vendor/k8s.io/utils/net:go_default_library",
     ],
diff --git a/pkg/util/conntrack/conntrack.go b/pkg/util/conntrack/conntrack.go
index 204e05dd1e5..edec3028b04 100644
--- a/pkg/util/conntrack/conntrack.go
+++ b/pkg/util/conntrack/conntrack.go
@@ -22,6 +22,7 @@ import (
 	"strings"
 
 	v1 "k8s.io/api/core/v1"
+	"k8s.io/klog/v2"
 	"k8s.io/utils/exec"
 	utilnet "k8s.io/utils/net"
 )
@@ -62,10 +63,12 @@ func Exec(execer exec.Interface, parameters ...string) error {
 	if err != nil {
 		return fmt.Errorf("error looking for path of conntrack: %v", err)
 	}
+	klog.V(4).Infof("Clearing conntrack entries %v", parameters)
 	output, err := execer.Command(conntrackPath, parameters...).CombinedOutput()
 	if err != nil {
 		return fmt.Errorf("conntrack command returned: %q, error message: %s", string(output), err)
 	}
+	klog.V(4).Infof("Conntrack entries deleted %s", string(output))
 	return nil
 }