conntrack log delete operations

chenjianfei2017 · Oct 19, 2020 · e3c1777 · e3c1777
1 parent 880baa9
commit e3c1777
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git 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
@@ -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
 }