github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 03:41:45 +00:00
Code Issues Projects Releases Wiki Activity

test(iptables): deflake TestRestoreAllGrabOldLock

Browse Source 
Signed-off-by: knight42 <anonymousknight96@gmail.com>
This commit is contained in:
knight42 2020-09-05 00:17:04 +08:00
parent 3cdfdfccc9
commit f6f0f7922a
No known key found for this signature in database
GPG Key ID: 1040B69865E7D86C
1 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
pkg/util/iptables/iptables_test.go
View File

@ -26,9 +26,11 @@ import (
"reflect"
"strings"
"testing"
"time"
"k8s.io/apimachinery/pkg/util/sets"
utilversion "k8s.io/apimachinery/pkg/util/version"
"k8s.io/apimachinery/pkg/util/wait"
"k8s.io/utils/exec"
fakeexec "k8s.io/utils/exec/testing"
)
@ -1109,11 +1111,23 @@ func TestRestoreAllGrabOldLock(t *testing.T) {
runner := newInternal(&fexec, ProtocolIPv4, TestLockfilePath)
defer os.Remove(TestLockfilePath)
// Grab the abstract @xtables socket
runLock, err := net.ListenUnix("unix", &net.UnixAddr{Name: "@xtables", Net: "unix"})
var runLock *net.UnixListener
// Grab the abstract @xtables socket, will retry if the socket exists
err := wait.PollImmediate(time.Second, wait.ForeverTestTimeout, func() (done bool, err error) {
runLock, err = net.ListenUnix("unix", &net.UnixAddr{Name: "@xtables", Net: "unix"})
if err != nil {
t.Logf("Failed to lock @xtables: %v, will retry.", err)
return false, nil
}
return true, nil
})
if err != nil {
t.Fatalf("expected to lock @xtables, got %v", err)
t.Fatal("Timed out locking @xtables")
}
if runLock == nil {
t.Fatal("Unexpected nil runLock")
}
defer runLock.Close()
err = runner.RestoreAll([]byte{}, NoFlushTables, RestoreCounters)