X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fut_ctrl_submgr_test.go;fp=pkg%2Fcontrol%2Fut_ctrl_submgr_test.go;h=4e2c471e3ea28260776de1a12dd4497c9a6b0d18;hb=e5fdcd295671f86f1cbda6e5571c6f2075796af4;hp=31eed311916ff7026d46587440e8d784cf228c19;hpb=d5c027e9d52c5a1f43304a71cdf84b4c1ccf8024;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/ut_ctrl_submgr_test.go b/pkg/control/ut_ctrl_submgr_test.go index 31eed31..4e2c471 100644 --- a/pkg/control/ut_ctrl_submgr_test.go +++ b/pkg/control/ut_ctrl_submgr_test.go @@ -298,7 +298,7 @@ func (mc *testingSubmgrControl) VerifyAllClean(t *testing.T) { } } <-time.After(time.Millisecond * 100) - mc.TestLog(t, "VerifyAllClean delay plus 100ms") + xapp.Logger.Debug("VerifyAllClean delay plus 100ms") } assert.Equal(t, 0, len(mainCtrl.c.registry.register)) @@ -313,6 +313,15 @@ func (mc *testingSubmgrControl) VerifyAllClean(t *testing.T) { verifyE2KeyCount(t, 0) } +func (mc *testingSubmgrControl) WaitOngoingRequestMapEmpty() { + for i := 0; i < 100; i++ { + if len(mainCtrl.c.restDuplicateCtrl.ongoingRequestMap) != 0 { + <-time.After(time.Millisecond * 100) + xapp.Logger.Debug("WaitOngoingRequestMapEmpty delay plus 100ms") + } + } +} + func (mc *testingSubmgrControl) GetMetrics(t *testing.T) (string, error) { req, err := http.NewRequest("GET", "http://localhost:8080/ric/v1/metrics", nil) if err != nil {