Skip to content

Commit

Permalink
test with 1000 seconds
Browse files Browse the repository at this point in the history
  • Loading branch information
rayaisaiah committed Mar 7, 2025
1 parent b416f07 commit f92231b
Showing 1 changed file with 9 additions and 6 deletions.
15 changes: 9 additions & 6 deletions npm/pkg/dataplane/dataplane_linux_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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{
Expand Down Expand Up @@ -81,20 +82,21 @@ 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()

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)
}
Expand All @@ -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)
Expand Down Expand Up @@ -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))
Expand Down

0 comments on commit f92231b

Please sign in to comment.