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

conntrack log delete operations

Browse Source
This commit is contained in:
Antonio Ojea 2020-10-19 10:01:58 +02:00
parent 880baa9f6f
commit e3c1777f7d
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/util/conntrack/BUILD
View File

@ -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",
],

3
pkg/util/conntrack/conntrack.go
View File

@ -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
}