diff --git a/npm/pkg/dataplane/dataplane_linux_test.go b/npm/pkg/dataplane/dataplane_linux_test.go index e7ad11733c..9f9363ba4f 100644 --- a/npm/pkg/dataplane/dataplane_linux_test.go +++ b/npm/pkg/dataplane/dataplane_linux_test.go @@ -11,6 +11,7 @@ import ( "github.com/Azure/azure-container-networking/npm/util" testutils "github.com/Azure/azure-container-networking/test/utils" "github.com/stretchr/testify/require" + "k8s.io/klog" ) var netpolInBackgroundCfg = &Config{ @@ -81,7 +82,8 @@ func TestNetPolInBackgroundUpdatePolicy(t *testing.T) { require.NoError(t, err) defer func() { stopCh <- struct{}{} - time.Sleep(100 * time.Millisecond) + time.Sleep(1000 * time.Millisecond) + klog.Info("defer for TestNetPolInBackgroundUpdatePolicy finished") }() dp.RunPeriodicTasks() @@ -89,12 +91,12 @@ func TestNetPolInBackgroundUpdatePolicy(t *testing.T) { err = dp.AddPolicy(&testPolicyobj) require.NoError(t, err) - time.Sleep(500 * time.Millisecond) + time.Sleep(1000 * time.Millisecond) err = dp.UpdatePolicy(&updatedTestPolicyobj) require.NoError(t, err) - time.Sleep(100 * time.Millisecond) + time.Sleep(1000 * time.Millisecond) linuxPromVals{2, 1, 0, 0, 1}.assert(t) } @@ -110,14 +112,15 @@ func TestNetPolInBackgroundSkipAddAfterRemove(t *testing.T) { require.NoError(t, err) defer func() { stopCh <- struct{}{} - time.Sleep(500 * time.Millisecond) + time.Sleep(1000 * time.Millisecond) + klog.Info("defer for TestNetPolInBackgroundSkipAddAfterRemove finished") }() require.NoError(t, dp.AddPolicy(&testPolicyobj)) require.NoError(t, dp.RemovePolicy(testPolicyobj.PolicyKey)) dp.RunPeriodicTasks() - time.Sleep(100 * time.Millisecond) + time.Sleep(1000 * time.Millisecond) // nothing happens linuxPromVals{0, 0, 0, 0, 0}.assert(t) @@ -175,7 +178,7 @@ func TestNetPolInBackgroundFailureToAddFirstTime(t *testing.T) { require.NoError(t, err) defer func() { stopCh <- struct{}{} - time.Sleep(500 * time.Millisecond) + time.Sleep(1000 * time.Millisecond) }() require.NoError(t, dp.AddPolicy(&testPolicyobj))