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=dadf42fb7f34b830a0f95af3519f27bfd8173694;hb=93a5f9e27a6803adce055811c222632bfd69d11c;hp=4e2c471e3ea28260776de1a12dd4497c9a6b0d18;hpb=b43c8445740c9a5ac5535a2b065b403c3608b5dc;p=ric-plt%2Fsubmgr.git

diff --git a/pkg/control/ut_ctrl_submgr_test.go b/pkg/control/ut_ctrl_submgr_test.go
index 4e2c471..dadf42f 100644
--- a/pkg/control/ut_ctrl_submgr_test.go
+++ b/pkg/control/ut_ctrl_submgr_test.go
@@ -297,8 +297,8 @@ func (mc *testingSubmgrControl) VerifyAllClean(t *testing.T) {
 				break
 			}
 		}
+		xapp.Logger.Debug("VerifyAllClean. Adding 100ms more delay to complete")
 		<-time.After(time.Millisecond * 100)
-		xapp.Logger.Debug("VerifyAllClean delay plus 100ms")
 	}
 
 	assert.Equal(t, 0, len(mainCtrl.c.registry.register))
@@ -317,7 +317,17 @@ 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")
+			xapp.Logger.Debug("WaitOngoingRequestMapEmpty. Adding 100ms more delay to complete")
+		}
+	}
+}
+
+func (mc *testingSubmgrControl) WaitRESTSubscriptionDelete(restSubsId string) {
+	for i := 0; i < 100; i++ {
+		restSubscription, _ := mainCtrl.c.registry.GetRESTSubscription(restSubsId, false)
+		if restSubscription != nil {
+			xapp.Logger.Debug("WaitRESTSubscriptionDelete. Adding 100ms more delay to complete")
+			<-time.After(time.Millisecond * 100)
 		}
 	}
 }