Code Review / ric-plt / submgr.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | review | tree
raw | inline | side by side
Fix for xApp transction release place
[ric-plt/submgr.git] / pkg / control / ut_messaging_test.go
diff --git a/pkg/control/ut_messaging_test.go b/pkg/control/ut_messaging_test.go
index dff639e..9c2874b 100644 (file)
--- a/pkg/control/ut_messaging_test.go
+++ b/pkg/control/ut_messaging_test.go
@@ -2134,6 +2134,7 @@ func TestSubReqNokAndSubDelOkWithRestartInMiddle(t *testing.T) {
        mainCtrl.SimulateRestart(t)
        xapp.Logger.Debug("mainCtrl.SimulateRestart done")
 
+       // Submgr send delete for uncompleted subscription
        delreq, delmsg := e2termConn1.RecvSubsDelReq(t)
        e2termConn1.SendSubsDelResp(t, delreq, delmsg)
 
@@ -2370,6 +2371,11 @@ func TestPostEmptyDb(t *testing.T) {
        mainCtrl.sendPostRequest(t, "localhost:8080", "/ric/v1/test/emptydb")
 }
 
+func TestGetRestSubscriptions(t *testing.T) {
+
+       mainCtrl.sendGetRequest(t, "localhost:8080", "/ric/v1/restsubscriptions")
+}
+
 //-----------------------------------------------------------------------------
 // TestRESTSubReqAndRouteNok
 //
@@ -2414,6 +2420,7 @@ func TestRESTSubReqAndRouteNok(t *testing.T) {
        })
 
        const subReqCount int = 1
+
        // Add delay for rtmgt HTTP handling so that HTTP response is received before notify on XAPP side
        waiter := rtmgrHttp.AllocNextSleep(50, false)
        newSubsId := mainCtrl.get_registry_next_subid(t)
@@ -2425,7 +2432,7 @@ func TestRESTSubReqAndRouteNok(t *testing.T) {
        waiter.WaitResult(t)
 
        e2SubsId := xappConn1.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("TEST: REST notification received e2SubsId=%v", e2SubsId)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", e2SubsId)
 
        // Del
        xappConn1.SendRESTSubsDelReq(t, &restSubId)
@@ -2467,7 +2474,7 @@ func TestRESTSubReqAndRouteUpdateNok(t *testing.T) {
        params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
        params.SetMeid("RAN_NAME_1")
        restSubId2 := xappConn2.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for second subscriber : %v", restSubId2)
+       xapp.Logger.Debug("Send REST subscriber request for second subscriber : %v", restSubId2)
        xappConn2.ExpectRESTNotificationNok(t, restSubId2, "allFail")
        waiter.WaitResult(t)
        // e2SubsId2 := xappConn2.WaitRESTNotification(t, restSubId2) - TOD: missing delete
@@ -2630,7 +2637,7 @@ func TestRESTSubReqRetransmission(t *testing.T) {
        e2termConn1.SendSubsResp(t, crereq, cremsg)
 
        e2SubsIdA := <-xappConn1.ListedRESTNotifications
-       xapp.Logger.Info("TEST: 1.st XAPP notification received e2SubsId=%v", e2SubsIdA)
+       xapp.Logger.Debug("TEST: 1.st XAPP notification received e2SubsId=%v", e2SubsIdA)
 
        // Del1
        xappConn1.SendRESTSubsDelReq(t, &restSubId1)
@@ -3319,12 +3326,12 @@ func TestRESTSubReqAndSubDelOkTwoParallel(t *testing.T) {
        //Req1
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
        restSubId1 := xappConn1.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send 1st REST subscriber request for subscriberId : %v", restSubId1)
+       xapp.Logger.Debug("Send 1st REST subscriber request for subscriberId : %v", restSubId1)
 
        //Req2
        params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
        restSubId2 := xappConn2.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send 2nd REST subscriber request for subscriberId : %v", restSubId2)
+       xapp.Logger.Debug("Send 2nd REST subscriber request for subscriberId : %v", restSubId2)
 
        crereq1, cremsg1 := e2termConn1.RecvSubsReq(t)
        crereq2, cremsg2 := e2termConn1.RecvSubsReq(t)
@@ -3338,9 +3345,9 @@ func TestRESTSubReqAndSubDelOkTwoParallel(t *testing.T) {
        e2termConn1.SendSubsResp(t, crereq2, cremsg2)
 
        e2SubsIdA := <-xappConn1.ListedRESTNotifications
-       xapp.Logger.Info("TEST: 1.st XAPP notification received e2SubsId=%v", e2SubsIdA)
+       xapp.Logger.Debug("TEST: 1.st XAPP notification received e2SubsId=%v", e2SubsIdA)
        e2SubsIdB := <-xappConn1.ListedRESTNotifications
-       xapp.Logger.Info("TEST: 2.nd XAPP notification received e2SubsId=%v", e2SubsIdB)
+       xapp.Logger.Debug("TEST: 2.nd XAPP notification received e2SubsId=%v", e2SubsIdB)
 
        //Del1
        deleteSubscription(t, xappConn1, e2termConn1, &restSubId1)
@@ -3372,12 +3379,12 @@ func TestRESTSameSubsDiffRan(t *testing.T) {
 
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
        restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
-       xapp.Logger.Info("Send 1st REST subscriber request for subscriberId : %v", restSubId1)
+       xapp.Logger.Debug("Send 1st REST subscriber request for subscriberId : %v", restSubId1)
 
        params = xappConn1.GetRESTSubsReqReportParams(subReqCount)
        params.SetMeid("RAN_NAME_2")
        restSubId2, e2SubsId2 := createSubscription(t, xappConn1, e2termConn1, params)
-       xapp.Logger.Info("Send 2nd REST subscriber request for subscriberId : %v", restSubId2)
+       xapp.Logger.Debug("Send 2nd REST subscriber request for subscriberId : %v", restSubId2)
 
        //Del1
        deleteSubscription(t, xappConn1, e2termConn1, &restSubId1)
@@ -3412,11 +3419,11 @@ func TestRESTSubReqRetryInSubmgr(t *testing.T) {
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
        restSubId := xappConn1.SendRESTSubsReq(t, params)
 
-       xapp.Logger.Info("Send REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Send REST subscriber request for subscriber : %v", restSubId)
 
        // Catch the first message and ignore it
        crereq, cremsg := e2termConn1.RecvSubsReq(t)
-       xapp.Logger.Info("Ignore REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Ignore REST subscriber request for subscriber : %v", restSubId)
 
        // The second request is being handled normally
        crereq, cremsg = e2termConn1.RecvSubsReq(t)
@@ -3491,13 +3498,13 @@ func TestRESTSubReqRetryNoRespSubDelRespInSubmgr(t *testing.T) {
 
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
        restSubId := xappConn1.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Send REST subscriber request for subscriber : %v", restSubId)
 
        e2termConn1.RecvSubsReq(t)
-       xapp.Logger.Info("Ignore 1st REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Ignore 1st REST subscriber request for subscriber : %v", restSubId)
 
        e2termConn1.RecvSubsReq(t)
-       xapp.Logger.Info("Ignore 2nd REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Ignore 2nd REST subscriber request for subscriber : %v", restSubId)
 
        delreq, delmsg := e2termConn1.RecvSubsDelReq(t)
        xappConn1.ExpectRESTNotificationNok(t, restSubId, "allFail")
@@ -3526,20 +3533,20 @@ func TestREST2eTermNotRespondingToSubReq(t *testing.T) {
 
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
        restSubId := xappConn1.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Send REST subscriber request for subscriber : %v", restSubId)
 
        e2termConn1.RecvSubsReq(t)
-       xapp.Logger.Info("Ignore 1st REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Ignore 1st REST subscriber request for subscriber : %v", restSubId)
 
        e2termConn1.RecvSubsReq(t)
-       xapp.Logger.Info("Ignore 2nd REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Ignore 2nd REST subscriber request for subscriber : %v", restSubId)
 
        e2termConn1.RecvSubsDelReq(t)
-       xapp.Logger.Info("Ignore 1st INTERNAL delete request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Ignore 1st INTERNAL delete request for subscriber : %v", restSubId)
 
        xappConn1.ExpectRESTNotificationNok(t, restSubId, "allFail")
        e2termConn1.RecvSubsDelReq(t)
-       xapp.Logger.Info("Ignore 2nd INTERNAL delete request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Ignore 2nd INTERNAL delete request for subscriber : %v", restSubId)
 
        e2SubsId := xappConn1.WaitRESTNotification(t, restSubId)
 
@@ -3604,20 +3611,20 @@ func TestRESTSubReqTwoRetriesNoRespAtAllInSubmgr(t *testing.T) {
 
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
        restSubId := xappConn1.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Send REST subscriber request for subscriber : %v", restSubId)
 
        e2termConn1.RecvSubsReq(t)
-       xapp.Logger.Info("Ignore 1st REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Ignore 1st REST subscriber request for subscriber : %v", restSubId)
 
        e2termConn1.RecvSubsReq(t)
-       xapp.Logger.Info("Ignore 2nd REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Ignore 2nd REST subscriber request for subscriber : %v", restSubId)
 
        e2termConn1.RecvSubsDelReq(t)
-       xapp.Logger.Info("Ignore 1st INTERNAL delete request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Ignore 1st INTERNAL delete request for subscriber : %v", restSubId)
 
        xappConn1.ExpectRESTNotificationNok(t, restSubId, "allFail")
        e2termConn1.RecvSubsDelReq(t)
-       xapp.Logger.Info("Ignore 2nd INTERNAL delete request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Ignore 2nd INTERNAL delete request for subscriber : %v", restSubId)
 
        e2SubsId := xappConn1.WaitRESTNotification(t, restSubId)
 
@@ -3672,8 +3679,12 @@ func TestRESTSubReqSubFailRespInSubmgr(t *testing.T) {
        })
 
        const subReqCount int = 1
+       const e2Timeout int64 = 2
+       const e2RetryCount int64 = 1
+       const routingNeeded bool = true
 
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
+       params.SetSubscriptionDirectives(e2Timeout, e2RetryCount, routingNeeded)
        restSubId := xappConn1.SendRESTSubsReq(t, params)
 
        crereq1, cremsg1 := e2termConn1.RecvSubsReq(t)
@@ -3685,7 +3696,7 @@ func TestRESTSubReqSubFailRespInSubmgr(t *testing.T) {
        xappConn1.ExpectRESTNotificationNok(t, restSubId, "allFail")
        e2termConn1.SendSubsDelResp(t, delreq1, delmsg1)
        e2SubsId := xappConn1.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("TEST: REST notification received e2SubsId=%v", e2SubsId)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", e2SubsId)
 
        // REST subscription sill there to be deleted
        xappConn1.SendRESTSubsDelReq(t, &restSubId)
@@ -3959,9 +3970,9 @@ func TestRESTSubReqAndSubDelOkSameAction(t *testing.T) {
        waiter := rtmgrHttp.AllocNextSleep(10, true)
        restSubId2 := xappConn2.SendRESTSubsReq(t, params)
        waiter.WaitResult(t)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId2)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId2)
        e2SubsId2 := xappConn2.WaitAnyRESTNotification(t)
-       xapp.Logger.Info("REST notification received e2SubsId=%v", e2SubsId2)
+       xapp.Logger.Debug("REST notification received e2SubsId=%v", e2SubsId2)
 
        queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560", "localhost:13660"})
 
@@ -4159,9 +4170,9 @@ func TestRESTSubReqAndSubDelNoAnswerSameActionParallel(t *testing.T) {
        e2termConn1.SendSubsDelResp(t, delreq1, delmsg1)
 
        e2SubsIdA := <-xappConn1.ListedRESTNotifications
-       xapp.Logger.Info("TEST: 1.st XAPP notification received e2SubsId=%v", e2SubsIdA)
+       xapp.Logger.Debug("TEST: 1.st XAPP notification received e2SubsId=%v", e2SubsIdA)
        e2SubsIdB := <-xappConn1.ListedRESTNotifications
-       xapp.Logger.Info("TEST: 2.nd XAPP notification received e2SubsId=%v", e2SubsIdB)
+       xapp.Logger.Debug("TEST: 2.nd XAPP notification received e2SubsId=%v", e2SubsIdB)
 
        // Del1
        xappConn1.SendRESTSubsDelReq(t, &restSubId1)
@@ -4266,9 +4277,9 @@ func TestRESTSubReqAndSubDelNokSameActionParallel(t *testing.T) {
        e2termConn1.SendSubsDelResp(t, delreq, delmsg)
 
        e2SubsIdA := <-xappConn1.ListedRESTNotifications
-       xapp.Logger.Info("TEST: 1.st XAPP notification received e2SubsId=%v", e2SubsIdA)
+       xapp.Logger.Debug("TEST: 1.st XAPP notification received e2SubsId=%v", e2SubsIdA)
        e2SubsIdB := <-xappConn1.ListedRESTNotifications
-       xapp.Logger.Info("TEST: 2.nd XAPP notification received e2SubsId=%v", e2SubsIdB)
+       xapp.Logger.Debug("TEST: 2.nd XAPP notification received e2SubsId=%v", e2SubsIdB)
 
        // Del1
        xappConn1.SendRESTSubsDelReq(t, &restSubId1)
@@ -4299,17 +4310,15 @@ func TestRESTSubReqPolicyAndSubDelOk(t *testing.T) {
                Counter{cRestSubDelRespToXapp, 1},
        })
 
-       const subReqCount int = 1
-
        params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
        restSubId := xappConn1.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST Policy subscriber request for subscriberId : %v", restSubId)
+       xapp.Logger.Debug("Send REST Policy subscriber request for subscriberId : %v", restSubId)
 
        crereq1, cremsg1 := e2termConn1.RecvSubsReq(t)
        xappConn1.ExpectRESTNotification(t, restSubId)
        e2termConn1.SendSubsResp(t, crereq1, cremsg1)
        e2SubsId := xappConn1.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("REST notification received e2SubsId=%v", e2SubsId)
+       xapp.Logger.Debug("REST notification received e2SubsId=%v", e2SubsId)
 
        xappConn1.SendRESTSubsDelReq(t, &restSubId)
        delreq, delmsg := e2termConn1.RecvSubsDelReq(t)
@@ -4385,15 +4394,20 @@ func TestRESTSubReqPolicyChangeAndSubDelOk(t *testing.T) {
        })
 
        const subReqCount int = 1
+       const e2Timeout int64 = 1
+       const e2RetryCount int64 = 0
+       const routingNeeded bool = true
 
        // Req
        params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
+       params.SetSubscriptionDirectives(e2Timeout, e2RetryCount, routingNeeded)
        restSubId, e2SubsId := createSubscription(t, xappConn1, e2termConn1, params)
 
        // Policy change
-       // GetRESTSubsReqPolicyParams sets some coutners on tc side.
+       // GetRESTSubsReqPolicyParams sets some counters on tc side.
 
        params = xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
+       params.SetSubscriptionDirectives(e2Timeout, e2RetryCount, routingNeeded)
        params.SetSubscriptionID(&restSubId)
        params.SetTimeToWait("w200ms")
        restSubId, e2SubsId = createSubscription(t, xappConn1, e2termConn1, params)
@@ -4434,7 +4448,7 @@ func TestRESTSubReqPolicyChangeAndSubDelOk(t *testing.T) {
 //     | RESTSubReq      |              |
 //     |---------------->|              |
 //     |                 |              |
-//     |         RESTSubUpdateFail      |
+//     |         RESTSubUpdateFail(400 Bad request)
 //     |                 |              |
 //     | RESTSubDelReq   |              |
 //     |---------------->|              |
@@ -4465,17 +4479,14 @@ func TestRESTSubReqPolicyChangeNOk(t *testing.T) {
                Counter{cRestSubDelRespToXapp, 1},
        })
 
-       const subReqCount int = 1
-
        // Req
        params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
        restSubId, e2SubsId := createSubscription(t, xappConn1, e2termConn1, params)
 
        // Policy change
-
        params = xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
 
-       restSubIdUpd := strings.ToUpper(restSubId)
+       restSubIdUpd := strings.ToUpper(restSubId) // This makes RESTSubReq to fail
        params.SetSubscriptionID(&restSubIdUpd)
        params.SetTimeToWait("w200ms")
 
@@ -4569,13 +4580,13 @@ func TestRESTSubReqAndSubDelOkTwoE2termParallel(t *testing.T) {
        xappConn1.ExpectRESTNotification(t, restSubId1)
        e2termConn1.SendSubsResp(t, crereq1, cremsg1)
        e2SubsId1 := xappConn1.WaitRESTNotification(t, restSubId1)
-       xapp.Logger.Info("TEST: REST notification received e2SubsId1=%v", e2SubsId1)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId1=%v", e2SubsId1)
 
        // Resp2
        xappConn2.ExpectRESTNotification(t, restSubId2)
        e2termConn2.SendSubsResp(t, crereq2, cremsg2)
        e2SubsId2 := xappConn2.WaitRESTNotification(t, restSubId2)
-       xapp.Logger.Info("TEST: REST notification received e2SubsId2=%v", e2SubsId2)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId2=%v", e2SubsId2)
 
        // Delete1
        xappConn1.SendRESTSubsDelReq(t, &restSubId1)
@@ -4621,7 +4632,7 @@ func TestRESTSubReqAndSubDelOkTwoE2termParallel(t *testing.T) {
 func TestRESTSubReqAsn1EncodeFail(t *testing.T) {
        CaseBegin("TestRESTSubReqAsn1EncodeFail")
 
-       xapp.Logger.Info("Xapp-frame, v0.8.1 sufficient REST API validation")
+       xapp.Logger.Debug("Xapp-frame, v0.8.1 sufficient REST API validation")
 
 }
 
@@ -4745,7 +4756,7 @@ func TestRESTSubReqNokAndSubDelOkWithRestartInMiddle(t *testing.T) {
        //Req
        mainCtrl.SetResetTestFlag(t, true) // subs.DoNotWaitSubResp will be set TRUE for the subscription
        restSubId := xappConn1.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Send REST subscriber request for subscriber : %v", restSubId)
 
        e2termConn1.RecvSubsReq(t)
 
@@ -4826,17 +4837,13 @@ func TestRESTSubReqAndSubDelOkWithRestartInMiddle(t *testing.T) {
 
        // Create subscription
        restSubId, e2SubsId := createSubscription(t, xappConn1, e2termConn1, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriber : %v", restSubId)
+       xapp.Logger.Debug("Send REST subscriber request for subscriber : %v", restSubId)
 
        // Check subscription
        queryXappSubscription(t, int64(e2SubsId), "RAN_NAME_1", []string{"localhost:13560"})
 
-       // When SDL support for the REST Interface is added
-       // the submgr restart statement below should be removed
-       // from the comment.
-
-       //      mainCtrl.SimulateRestart(t)
-       //      xapp.Logger.Debug("mainCtrl.SimulateRestart done")
+       mainCtrl.SimulateRestart(t)
+       xapp.Logger.Debug("mainCtrl.SimulateRestart done")
 
        // Check subscription
        queryXappSubscription(t, int64(e2SubsId), "RAN_NAME_1", []string{"localhost:13560"})
@@ -4929,7 +4936,7 @@ func TestRESTSubReqAndSubDelOkSameActionWithRestartsInMiddle(t *testing.T) {
 
        // Create subscription 1
        restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriber 1 : %v", restSubId1)
+       xapp.Logger.Debug("Send REST subscriber request for subscriber 1 : %v", restSubId1)
 
        // Create subscription 2 with same action
        params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
@@ -4937,30 +4944,22 @@ func TestRESTSubReqAndSubDelOkSameActionWithRestartsInMiddle(t *testing.T) {
        xapp.Subscription.SetResponseCB(xappConn2.SubscriptionRespHandler)
        xappConn2.ExpectAnyNotification(t)
        restSubId2 := xappConn2.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId2)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId2)
        e2SubsId2 := xappConn2.WaitAnyRESTNotification(t)
-       xapp.Logger.Info("REST notification received e2SubsId=%v", e2SubsId2)
+       xapp.Logger.Debug("REST notification received e2SubsId=%v", e2SubsId2)
 
        queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560", "localhost:13660"})
 
-       // When SDL support for the REST Interface is added
-       // the submgr restart statement below should be removed
-       // from the comment.
-
-       //      mainCtrl.SimulateRestart(t)
-       //      xapp.Logger.Debug("mainCtrl.SimulateRestart done")
+       mainCtrl.SimulateRestart(t)
+       xapp.Logger.Debug("mainCtrl.SimulateRestart done")
 
        // Delete subscription 1, and wait until it has removed the first endpoint
        subepcnt := mainCtrl.get_subs_entrypoint_cnt(t, e2SubsId1)
        xappConn1.SendRESTSubsDelReq(t, &restSubId1)
        mainCtrl.wait_subs_entrypoint_cnt_change(t, e2SubsId1, subepcnt, 10)
 
-       // When SDL support for the REST Interface is added
-       // the submgr restart statement below should be removed
-       // from the comment.
-
-       //      mainCtrl.SimulateRestart(t)
-       //      xapp.Logger.Debug("mainCtrl.SimulateRestart done")
+       mainCtrl.SimulateRestart(t)
+       xapp.Logger.Debug("mainCtrl.SimulateRestart done")
        queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13660"})
 
        // Delete subscription 2
@@ -5019,13 +5018,13 @@ func TestRESTSubReqAndSubDelOkSameActionWithRestartsInMiddle(t *testing.T) {
 
 func TestRESTReportSubReqAndSubDelOk(t *testing.T) {
        CaseBegin("TestRESTReportSubReqAndSubDelOk")
-       subReqCount := 1
+       const subReqCount int = 1
        testIndex := 1
        RESTReportSubReqAndSubDelOk(t, subReqCount, testIndex)
 }
 
 func RESTReportSubReqAndSubDelOk(t *testing.T, subReqCount int, testIndex int) {
-       xapp.Logger.Info("TEST: TestRESTReportSubReqAndSubDelOk with testIndex %v", testIndex)
+       xapp.Logger.Debug("TEST: TestRESTReportSubReqAndSubDelOk with testIndex %v", testIndex)
 
        // Req
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
@@ -5038,7 +5037,7 @@ func RESTReportSubReqAndSubDelOk(t *testing.T, subReqCount int, testIndex int) {
 
                e2termConn1.SendSubsResp(t, crereq, cremsg)
                instanceId := xappConn1.WaitRESTNotification(t, restSubId)
-               xapp.Logger.Info("TEST: REST notification received e2SubsId=%v", instanceId)
+               xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", instanceId)
                e2SubsId = append(e2SubsId, instanceId)
                resp, _ := xapp.Subscription.QuerySubscriptions()
                assert.Equal(t, resp[i].SubscriptionID, (int64)(instanceId))
@@ -5079,13 +5078,11 @@ func TestRESTPolicySubReqAndSubDelOk(t *testing.T) {
 }
 */
 func RESTPolicySubReqAndSubDelOk(t *testing.T, subReqCount int, testIndex int) {
-       xapp.Logger.Info("TEST: TestRESTPolicySubReqAndSubDelOk with testIndex %v", testIndex)
+       xapp.Logger.Debug("TEST: TestRESTPolicySubReqAndSubDelOk with testIndex %v", testIndex)
 
        // Req
        params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
        restSubId := xappConn1.SendRESTSubsReq(t, params)
-       //params := xappConn1.GetRESTSubsReqPolicyParams1(subReqCount)
-       //restSubId := xappConn1.SendRESTPolicySubsReq(t, params)
 
        var e2SubsId []uint32
        for i := 0; i < subReqCount; i++ {
@@ -5093,7 +5090,7 @@ func RESTPolicySubReqAndSubDelOk(t *testing.T, subReqCount int, testIndex int) {
                xappConn1.ExpectRESTNotification(t, restSubId)
                e2termConn1.SendSubsResp(t, crereq, cremsg)
                instanceId := xappConn1.WaitRESTNotification(t, restSubId)
-               xapp.Logger.Info("TEST: REST notification received e2SubsId=%v", instanceId)
+               xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", instanceId)
                e2SubsId = append(e2SubsId, instanceId)
        }
 
@@ -5116,8 +5113,6 @@ func RESTPolicySubReqAndSubDelOk(t *testing.T, subReqCount int, testIndex int) {
 
 func TestRESTTwoPolicySubReqAndSubDelOk(t *testing.T) {
 
-       subReqCount := 2
-
        mainCtrl.CounterValuesToBeVeriefied(t, CountersToBeAdded{
                Counter{cRestSubReqFromXapp, 1},
                Counter{cRestSubRespToXapp, 1},
@@ -5130,6 +5125,8 @@ func TestRESTTwoPolicySubReqAndSubDelOk(t *testing.T) {
                Counter{cRestSubDelRespToXapp, 1},
        })
 
+       const subReqCount int = 2
+
        // Req
        params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
        restSubId := xappConn1.SendRESTSubsReq(t, params)
@@ -5149,8 +5146,6 @@ func TestRESTTwoPolicySubReqAndSubDelOk(t *testing.T) {
 }
 func TestRESTPolicySubReqAndSubDelOkFullAmount(t *testing.T) {
 
-       subReqCount := 19
-
        mainCtrl.CounterValuesToBeVeriefied(t, CountersToBeAdded{
                Counter{cRestSubReqFromXapp, 1},
                Counter{cRestSubRespToXapp, 1},
@@ -5163,6 +5158,7 @@ func TestRESTPolicySubReqAndSubDelOkFullAmount(t *testing.T) {
                Counter{cRestSubDelRespToXapp, 1},
        })
 
+       const subReqCount int = 19
        // Req
        params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
        restSubId := xappConn1.SendRESTSubsReq(t, params)
@@ -5179,6 +5175,7 @@ func TestRESTPolicySubReqAndSubDelOkFullAmount(t *testing.T) {
 
        mainCtrl.VerifyCounterValues(t)
 }
+
 func TestRESTTwoReportSubReqAndSubDelOk(t *testing.T) {
 
        subReqCount := 2
@@ -5301,7 +5298,7 @@ func TestRESTSubReqReportSameActionDiffEventTriggerDefinitionLen(t *testing.T) {
 
        //Subs Create
        restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId1)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId1)
 
        queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
@@ -5312,7 +5309,7 @@ func TestRESTSubReqReportSameActionDiffEventTriggerDefinitionLen(t *testing.T) {
        params.SetSubEventTriggerDefinition(eventTriggerDefinition)
 
        restSubId2 := xappConn2.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId2)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId2)
        crereq, cremsg := e2termConn1.RecvSubsReq(t)
        xappConn2.ExpectRESTNotification(t, restSubId2)
        e2termConn1.SendSubsResp(t, crereq, cremsg)
@@ -5348,7 +5345,7 @@ func TestRESTSubReqReportSameActionDiffActionListLen(t *testing.T) {
 
        //Subs Create
        restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId1)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId1)
 
        queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
@@ -5364,7 +5361,7 @@ func TestRESTSubReqReportSameActionDiffActionListLen(t *testing.T) {
        params.AppendActionToActionToBeSetupList(actionId, actionType, actionDefinition, subsequestActionType, timeToWait)
 
        restSubId2 := xappConn2.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId2)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId2)
        crereq, cremsg := e2termConn1.RecvSubsReq(t)
        xappConn2.ExpectRESTNotification(t, restSubId2)
        e2termConn1.SendSubsResp(t, crereq, cremsg)
@@ -5400,7 +5397,7 @@ func TestRESTSubReqReportSameActionDiffActionID(t *testing.T) {
 
        //Subs Create
        restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId1)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId1)
 
        queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
@@ -5410,7 +5407,7 @@ func TestRESTSubReqReportSameActionDiffActionID(t *testing.T) {
        params.SetSubActionIDs(int64(2))
 
        restSubId2 := xappConn2.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId2)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId2)
        crereq, cremsg := e2termConn1.RecvSubsReq(t)
        xappConn2.ExpectRESTNotification(t, restSubId2)
        e2termConn1.SendSubsResp(t, crereq, cremsg)
@@ -5441,21 +5438,27 @@ func TestRESTSubReqDiffActionType(t *testing.T) {
                Counter{cRestSubDelRespToXapp, 2},
        })
 
+       const e2Timeout int64 = 2
+       const e2RetryCount int64 = 2
+       const routingNeeded bool = true
+
        // Req1
        params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
+       params.SetSubscriptionDirectives(e2Timeout, e2RetryCount, routingNeeded)
 
        //Subs Create
        restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId1)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId1)
 
        queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
        // Req2
        params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
+       params.SetSubscriptionDirectives(e2Timeout, e2RetryCount, routingNeeded)
        params.SetMeid("RAN_NAME_1")
 
        restSubId2 := xappConn2.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId2)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId2)
        crereq, cremsg := e2termConn1.RecvSubsReq(t)
        xappConn2.ExpectRESTNotification(t, restSubId2)
        e2termConn1.SendSubsResp(t, crereq, cremsg)
@@ -5486,21 +5489,27 @@ func TestRESTSubReqPolicyAndSubDelOkSameAction(t *testing.T) {
                Counter{cRestSubDelRespToXapp, 2},
        })
 
+       const e2Timeout int64 = 2
+       const e2RetryCount int64 = 2
+       const routingNeeded bool = true
+
        // Req1
        params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
+       params.SetSubscriptionDirectives(e2Timeout, e2RetryCount, routingNeeded)
 
        //Subs Create
        restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId1)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId1)
 
        queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
        // Req2
        params = xappConn2.GetRESTSubsReqPolicyParams(subReqCount)
+       params.SetSubscriptionDirectives(e2Timeout, e2RetryCount, routingNeeded)
        params.SetMeid("RAN_NAME_1")
 
        restSubId2 := xappConn2.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId2)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId2)
        crereq, cremsg := e2termConn1.RecvSubsReq(t)
        xappConn2.ExpectRESTNotification(t, restSubId2)
        e2termConn1.SendSubsResp(t, crereq, cremsg)
@@ -5536,7 +5545,7 @@ func TestRESTSubReqReportSameActionDiffActionDefinitionLen(t *testing.T) {
 
        //Subs Create
        restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId1)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId1)
 
        queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
@@ -5547,7 +5556,7 @@ func TestRESTSubReqReportSameActionDiffActionDefinitionLen(t *testing.T) {
        params.SetSubActionDefinition(actionDefinition)
 
        restSubId2 := xappConn2.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId2)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId2)
        crereq, cremsg := e2termConn1.RecvSubsReq(t)
        xappConn2.ExpectRESTNotification(t, restSubId2)
        e2termConn1.SendSubsResp(t, crereq, cremsg)
@@ -5583,7 +5592,7 @@ func TestRESTSubReqReportSameActionDiffActionDefinitionContents(t *testing.T) {
 
        //Subs Create
        restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId1)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId1)
 
        queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
@@ -5594,7 +5603,7 @@ func TestRESTSubReqReportSameActionDiffActionDefinitionContents(t *testing.T) {
        params.SetSubActionDefinition(actionDefinition)
 
        restSubId2 := xappConn2.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId2)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId2)
        crereq, cremsg := e2termConn1.RecvSubsReq(t)
        xappConn2.ExpectRESTNotification(t, restSubId2)
        e2termConn1.SendSubsResp(t, crereq, cremsg)
@@ -5630,7 +5639,7 @@ func TestRESTSubReqReportSameActionDiffSubsAction(t *testing.T) {
 
        //Subs Create
        restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId1)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId1)
 
        queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
@@ -5639,7 +5648,7 @@ func TestRESTSubReqReportSameActionDiffSubsAction(t *testing.T) {
        params.SetMeid("RAN_NAME_1")
        params.SetTimeToWait("w200ms")
        restSubId2 := xappConn2.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId2)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId2)
        crereq, cremsg := e2termConn1.RecvSubsReq(t)
        xappConn2.ExpectRESTNotification(t, restSubId2)
        e2termConn1.SendSubsResp(t, crereq, cremsg)
@@ -5691,8 +5700,8 @@ func TestRESTSubReqReportSameActionDiffSubsAction(t *testing.T) {
 //-----------------------------------------------------------------------------
 
 func TestRESTUnpackSubscriptionResponseDecodeFail(t *testing.T) {
-       xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionResponseDecodeFail")
-       subReqCount := 1
+       xapp.Logger.Debug("TEST: TestRESTUnpackSubscriptionResponseDecodeFail")
+       const subReqCount int = 1
 
        // Req
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
@@ -5716,7 +5725,7 @@ func TestRESTUnpackSubscriptionResponseDecodeFail(t *testing.T) {
        e2termConn1.SendSubsDelResp(t, delreq, delmsg)
 
        instanceId := xappConn1.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("TEST: REST notification received e2SubsId=%v", instanceId)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", instanceId)
 
        // Wait that subs is cleaned
        mainCtrl.wait_subs_clean(t, crereq.RequestId.InstanceId, 10)
@@ -5762,8 +5771,8 @@ func TestRESTUnpackSubscriptionResponseDecodeFail(t *testing.T) {
 //-----------------------------------------------------------------------------
 
 func TestRESTUnpackSubscriptionResponseUnknownInstanceId(t *testing.T) {
-       xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionResponseUnknownInstanceId")
-       subReqCount := 1
+       xapp.Logger.Debug("TEST: TestRESTUnpackSubscriptionResponseUnknownInstanceId")
+       const subReqCount int = 1
 
        // Req
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
@@ -5790,7 +5799,7 @@ func TestRESTUnpackSubscriptionResponseUnknownInstanceId(t *testing.T) {
        e2termConn1.SendSubsDelResp(t, delreq, delmsg)
 
        instanceId := xappConn1.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("TEST: REST notification received e2SubsId=%v", instanceId)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", instanceId)
 
        // Wait that subs is cleaned
        mainCtrl.wait_subs_clean(t, orgInstanceId, 10)
@@ -5841,8 +5850,8 @@ func TestRESTUnpackSubscriptionResponseUnknownInstanceId(t *testing.T) {
 //
 //-----------------------------------------------------------------------------
 func TestRESTUnpackSubscriptionResponseNoTransaction(t *testing.T) {
-       xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionResponseNoTransaction")
-       subReqCount := 1
+       xapp.Logger.Debug("TEST: TestRESTUnpackSubscriptionResponseNoTransaction")
+       const subReqCount int = 1
 
        // Req
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
@@ -5872,7 +5881,7 @@ func TestRESTUnpackSubscriptionResponseNoTransaction(t *testing.T) {
        e2termConn1.SendSubsDelResp(t, delreq, delmsg)
 
        instanceId := xappConn1.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("TEST: REST notification received e2SubsId=%v", instanceId)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", instanceId)
 
        // Wait that subs is cleaned
        mainCtrl.wait_subs_clean(t, crereq.RequestId.InstanceId, 10)
@@ -5918,8 +5927,8 @@ func TestRESTUnpackSubscriptionResponseNoTransaction(t *testing.T) {
 //
 //-----------------------------------------------------------------------------
 func TestRESTUnpackSubscriptionFailureDecodeFail(t *testing.T) {
-       xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionFailureDecodeFail")
-       subReqCount := 1
+       xapp.Logger.Debug("TEST: TestRESTUnpackSubscriptionFailureDecodeFail")
+       const subReqCount int = 1
 
        // Req
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
@@ -5944,7 +5953,7 @@ func TestRESTUnpackSubscriptionFailureDecodeFail(t *testing.T) {
        e2termConn1.SendSubsDelResp(t, delreq, delmsg)
 
        instanceId := xappConn1.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("TEST: REST notification received e2SubsId=%v", instanceId)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", instanceId)
 
        // Wait that subs is cleaned
        mainCtrl.wait_subs_clean(t, crereq.RequestId.InstanceId, 10)
@@ -5989,8 +5998,8 @@ func TestRESTUnpackSubscriptionFailureDecodeFail(t *testing.T) {
 //
 //-----------------------------------------------------------------------------
 func TestRESTUnpackSubscriptionFailureUnknownInstanceId(t *testing.T) {
-       xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionFailureUnknownInstanceId")
-       subReqCount := 1
+       xapp.Logger.Debug("TEST: TestRESTUnpackSubscriptionFailureUnknownInstanceId")
+       const subReqCount int = 1
 
        // Req
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
@@ -6016,7 +6025,7 @@ func TestRESTUnpackSubscriptionFailureUnknownInstanceId(t *testing.T) {
        e2termConn1.SendSubsDelResp(t, delreq, delmsg)
 
        instanceId := xappConn1.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("TEST: REST notification received e2SubsId=%v", instanceId)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", instanceId)
 
        // Wait that subs is cleaned
        mainCtrl.wait_subs_clean(t, crereq.RequestId.InstanceId, 10)
@@ -6061,8 +6070,8 @@ func TestRESTUnpackSubscriptionFailureUnknownInstanceId(t *testing.T) {
 //
 //-----------------------------------------------------------------------------
 func TestRESTUnpackSubscriptionFailureNoTransaction(t *testing.T) {
-       xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionFailureNoTransaction")
-       subReqCount := 1
+       xapp.Logger.Debug("TEST: TestRESTUnpackSubscriptionFailureNoTransaction")
+       const subReqCount int = 1
 
        // Req
        params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
@@ -6093,7 +6102,7 @@ func TestRESTUnpackSubscriptionFailureNoTransaction(t *testing.T) {
        e2termConn1.SendSubsDelResp(t, delreq, delmsg)
 
        instanceId := xappConn1.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("TEST: REST notification received e2SubsId=%v", instanceId)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", instanceId)
 
        // Wait that subs is cleaned
        mainCtrl.wait_subs_clean(t, crereq.RequestId.InstanceId, 10)
@@ -6135,7 +6144,7 @@ func TestRESTUnpackSubscriptionFailureNoTransaction(t *testing.T) {
 //
 //-----------------------------------------------------------------------------
 func TestRESTUnpackSubscriptionDeleteResponseDecodeFail(t *testing.T) {
-       xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionDeleteResponseDecodeFail")
+       xapp.Logger.Debug("TEST: TestRESTUnpackSubscriptionDeleteResponseDecodeFail")
 
        // Req
        var params *teststube2ap.RESTSubsReqParams = nil
@@ -6195,7 +6204,7 @@ func TestRESTUnpackSubscriptionDeleteResponseDecodeFail(t *testing.T) {
 //
 //-----------------------------------------------------------------------------
 func TestRESTUnpackSubscriptionDeleteResponseUnknownInstanceId(t *testing.T) {
-       xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionDeleteResponseUnknownInstanceId")
+       xapp.Logger.Debug("TEST: TestRESTUnpackSubscriptionDeleteResponseUnknownInstanceId")
 
        // Req
        var params *teststube2ap.RESTSubsReqParams = nil
@@ -6256,7 +6265,7 @@ func TestRESTUnpackSubscriptionDeleteResponseUnknownInstanceId(t *testing.T) {
 //
 //-----------------------------------------------------------------------------
 func TestRESTUnpackSubscriptionDeleteResponseNoTransaction(t *testing.T) {
-       xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionDeleteResponseNoTransaction")
+       xapp.Logger.Debug("TEST: TestRESTUnpackSubscriptionDeleteResponseNoTransaction")
 
        // Req
        var params *teststube2ap.RESTSubsReqParams = nil
@@ -6318,7 +6327,7 @@ func TestRESTUnpackSubscriptionDeleteResponseNoTransaction(t *testing.T) {
 //
 //-----------------------------------------------------------------------------
 func TestRESTUnpackSubscriptionDeleteFailureDecodeFail(t *testing.T) {
-       xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionDeleteFailureDecodeFail")
+       xapp.Logger.Debug("TEST: TestRESTUnpackSubscriptionDeleteFailureDecodeFail")
 
        // Req
        var params *teststube2ap.RESTSubsReqParams = nil
@@ -6378,7 +6387,7 @@ func TestRESTUnpackSubscriptionDeleteFailureDecodeFail(t *testing.T) {
 //
 //-----------------------------------------------------------------------------
 func TestRESTUnpackSubscriptionDeleteailureUnknownInstanceId(t *testing.T) {
-       xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionDeleteailureUnknownInstanceId")
+       xapp.Logger.Debug("TEST: TestRESTUnpackSubscriptionDeleteailureUnknownInstanceId")
 
        // Req
        var params *teststube2ap.RESTSubsReqParams = nil
@@ -6439,7 +6448,7 @@ func TestRESTUnpackSubscriptionDeleteailureUnknownInstanceId(t *testing.T) {
 //
 //-----------------------------------------------------------------------------
 func TestRESTUnpackSubscriptionDeleteFailureNoTransaction(t *testing.T) {
-       xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionDeleteFailureNoTransaction")
+       xapp.Logger.Debug("TEST: TestRESTUnpackSubscriptionDeleteFailureNoTransaction")
 
        // Req
        var params *teststube2ap.RESTSubsReqParams = nil
@@ -6505,12 +6514,10 @@ func TestRESTSubReqFailAsn1PackSubReqError(t *testing.T) {
        mainCtrl.CounterValuesToBeVeriefied(t, CountersToBeAdded{
                Counter{cRestSubReqFromXapp, 1},
                Counter{cRestSubRespToXapp, 1},
-               Counter{cSubDelReqToE2, 1},
-               Counter{cSubDelFailFromE2, 1},
                Counter{cRestSubFailNotifToXapp, 1},
        })
 
-       subReqCount := 1
+       const subReqCount int = 1
 
        var params *teststube2ap.RESTSubsReqParams = nil
        params = xappConn1.GetRESTSubsReqReportParams(subReqCount)
@@ -6518,17 +6525,13 @@ func TestRESTSubReqFailAsn1PackSubReqError(t *testing.T) {
 
        // Req
        restSubId := xappConn1.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId)
 
        // E2t: Receive SubsDelReq
-       delreq, delmsg := e2termConn1.RecvSubsDelReq(t)
        xappConn1.ExpectRESTNotificationNok(t, restSubId, "allFail")
 
-       // Subscription does not exist in in E2 Node.
-       e2termConn1.SendSubsDelFail(t, delreq, delmsg)
-
        e2SubsId := xappConn1.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("TEST: REST notification received e2SubsId=%v", e2SubsId)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", e2SubsId)
 
        e2ap_wrapper.AllowE2apToProcess(e2ap_wrapper.SUB_REQ, true)
        // Wait that subs is cleaned
@@ -6536,6 +6539,183 @@ func TestRESTSubReqFailAsn1PackSubReqError(t *testing.T) {
        mainCtrl.VerifyCounterValues(t)
 }
 
+func TestRESTSubReqPolicyUpdateTimeoutAndSubDelOkSameAction(t *testing.T) {
+       CaseBegin("TestRESTSubReqPolicyUpdateTimeoutAndSubDelOkSameAction")
+
+       mainCtrl.CounterValuesToBeVeriefied(t, CountersToBeAdded{
+               Counter{cRestSubReqFromXapp, 2},
+               Counter{cRestSubRespToXapp, 2},
+               Counter{cSubReqToE2, 2},
+               Counter{cSubRespFromE2, 1},
+               Counter{cRestSubNotifToXapp, 1},
+               Counter{cRestSubFailNotifToXapp, 1},
+               Counter{cRestSubDelReqFromXapp, 1},
+               Counter{cSubDelReqToE2, 1},
+               Counter{cSubDelRespFromE2, 1},
+               Counter{cRestSubDelRespToXapp, 1},
+       })
+
+       const e2Timeout int64 = 1
+       const e2RetryCount int64 = 0
+       const routingNeeded bool = false
+
+       // Req1
+       params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
+       params.SetSubscriptionDirectives(e2Timeout, e2RetryCount, routingNeeded)
+
+       // Subs Create
+       restSubId := xappConn1.SendRESTSubsReq(t, params)
+       xapp.Logger.Debug("Send REST subscribe request for subscriberId : %v", restSubId)
+
+       crereq1, cremsg1 := e2termConn1.RecvSubsReq(t)
+       xappConn1.ExpectRESTNotification(t, restSubId)
+       e2termConn1.SendSubsResp(t, crereq1, cremsg1)
+       e2SubsId := xappConn1.WaitRESTNotification(t, restSubId)
+       xapp.Logger.Debug("REST notification received e2SubsId=%v", e2SubsId)
+
+       // Policy change
+       params = xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
+       params.SetSubscriptionDirectives(e2Timeout, e2RetryCount, routingNeeded)
+       params.SetSubscriptionID(&restSubId)
+       params.SetTimeToWait("w200ms")
+       restSubId = xappConn1.SendRESTSubsReq(t, params)
+       xapp.Logger.Debug("Send REST subscribe request for subscriberId : %v", restSubId)
+
+       crereq1, cremsg1 = e2termConn1.RecvSubsReq(t)
+       xappConn1.ExpectRESTNotification(t, restSubId)
+       // SubsResp is missing, e2SubsId will be 0
+       zeroE2SubsId := xappConn1.WaitRESTNotification(t, restSubId)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", zeroE2SubsId)
+
+       // Del
+       xappConn1.SendRESTSubsDelReq(t, &restSubId)
+       delreq, delmsg := e2termConn1.RecvSubsDelReq(t)
+       e2termConn1.SendSubsDelResp(t, delreq, delmsg)
+
+       waitSubsCleanup(t, e2SubsId, 10)
+
+       mainCtrl.VerifyCounterValues(t)
+}
+
+//-----------------------------------------------------------------------------
+// TestPolicyUpdateRESTSubReqAndSubDelOkWithRestartInMiddle
+//
+//   stub                             stub
+// +-------+        +---------+    +---------+
+// | xapp  |        | submgr  |    | e2term  |
+// +-------+        +---------+    +---------+
+//     |                 |              |
+//     | RESTSubReq      |              |
+//     |---------------->|              |
+//     |                 |              |
+//     |     RESTSubResp |              |
+//     |<----------------|              |
+//     |                 | SubReq       |
+//     |                 |------------->|
+//     |                 |              |
+//     |                 |      SubResp |
+//     |                 |<-------------|
+//     |                 |              |
+//     |       RESTNotif |              |
+//     |<----------------|              |
+//     |                 |              |
+//     | RESTSubReq      |              |
+//     |---------------->|              |
+//     |                 |              |
+//     |     RESTSubResp |              |
+//     |<----------------|              |
+//     |                 | SubReq       |
+//     |                 |------------->|
+//     |                                |
+//     |           Submgr restart       |
+//     |                 |              |
+//     | RESTSubDelReq   |              |
+//     |---------------->|              |
+//     |                 |              |
+//     |                 | SubDelReq    |
+//     |                 |------------->|
+//     |                 |              |
+//     |                 |   SubDelResp |
+//     |                 |<-------------|
+//     |                 |              |
+//     |  RESTSubDelResp |              |
+//     |<----------------|              |
+//
+//-----------------------------------------------------------------------------
+
+func TestPolicyUpdateRESTSubReqAndSubDelOkWithRestartInMiddle(t *testing.T) {
+       CaseBegin("TestPolicyUpdateRESTSubReqAndSubDelOkWithRestartInMiddle")
+
+       mainCtrl.CounterValuesToBeVeriefied(t, CountersToBeAdded{
+               Counter{cRestSubReqFromXapp, 2},
+               Counter{cRestSubRespToXapp, 2},
+               Counter{cSubReqToE2, 2},
+               Counter{cSubRespFromE2, 1},
+               Counter{cRestSubNotifToXapp, 1},
+               Counter{cRestSubNotifToXapp, 1},
+               Counter{cRestSubDelReqFromXapp, 1},
+               Counter{cSubDelReqToE2, 1},
+               Counter{cRestSubDelRespToXapp, 1},
+       })
+
+       // Remove possible existing subscription
+       mainCtrl.removeExistingSubscriptions(t)
+
+       const e2Timeout int64 = 1
+       const e2RetryCount int64 = 0
+       const routingNeeded bool = false
+
+       // Req1
+       params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
+       params.SetSubscriptionDirectives(e2Timeout, e2RetryCount, routingNeeded)
+       // Create subscription
+       restSubId := xappConn1.SendRESTSubsReq(t, params)
+       xapp.Logger.Debug("Send REST subscribe request for subscriberId : %v", restSubId)
+
+       crereq1, cremsg1 := e2termConn1.RecvSubsReq(t)
+       xappConn1.ExpectRESTNotification(t, restSubId)
+       e2termConn1.SendSubsResp(t, crereq1, cremsg1)
+       e2SubsId := xappConn1.WaitRESTNotification(t, restSubId)
+       xapp.Logger.Debug("REST notification received e2SubsId=%v", e2SubsId)
+
+       // Check subscription
+       queryXappSubscription(t, int64(e2SubsId), "RAN_NAME_1", []string{"localhost:13560"})
+
+       // Policy change
+       params = xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
+       params.SetSubscriptionDirectives(e2Timeout, e2RetryCount, routingNeeded)
+       params.SetSubscriptionID(&restSubId)
+       params.SetTimeToWait("w200ms")
+       mainCtrl.SetResetTestFlag(t, true) // subs.DoNotWaitSubResp will be set TRUE for the subscription
+       restSubId = xappConn1.SendRESTSubsReq(t, params)
+       xapp.Logger.Debug("Send REST subscribe request for subscriberId : %v", restSubId)
+
+       crereq1, cremsg1 = e2termConn1.RecvSubsReq(t)
+       mainCtrl.SetResetTestFlag(t, false)
+
+       // SubsResp is missing due to submgr restart
+
+       mainCtrl.SimulateRestart(t)
+       xapp.Logger.Debug("mainCtrl.SimulateRestart done")
+
+       // Check subscription
+       queryXappSubscription(t, int64(e2SubsId), "RAN_NAME_1", []string{"localhost:13560"})
+
+       xapp.Logger.Debug("Here 1")
+       //<-time.After(3 * time.Second)
+       xapp.Logger.Debug("Here 2")
+
+       // Delete subscription
+       xappConn1.SendRESTSubsDelReq(t, &restSubId)
+       delreq, delmsg := e2termConn1.RecvSubsDelReq(t)
+       e2termConn1.SendSubsDelResp(t, delreq, delmsg)
+
+       //Wait that subs is cleaned
+       waitSubsCleanup(t, e2SubsId, 10)
+
+       mainCtrl.VerifyCounterValues(t)
+}
+
 ////////////////////////////////////////////////////////////////////////////////////
 //   Services for UT cases
 ////////////////////////////////////////////////////////////////////////////////////
@@ -6547,13 +6727,13 @@ func createSubscription(t *testing.T, fromXappConn *teststube2ap.E2Stub, toE2ter
                params = fromXappConn.GetRESTSubsReqReportParams(subReqCount)
        }
        restSubId := fromXappConn.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId)
 
        crereq1, cremsg1 := toE2termConn.RecvSubsReq(t)
        fromXappConn.ExpectRESTNotification(t, restSubId)
        toE2termConn.SendSubsResp(t, crereq1, cremsg1)
        e2SubsId := fromXappConn.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("REST notification received e2SubsId=%v", e2SubsId)
+       xapp.Logger.Debug("REST notification received e2SubsId=%v", e2SubsId)
 
        return restSubId, e2SubsId
 }
@@ -6567,23 +6747,24 @@ func createXapp2MergedSubscription(t *testing.T, meid string) (string, uint32) {
        xapp.Subscription.SetResponseCB(xappConn2.SubscriptionRespHandler)
        restSubId := xappConn2.SendRESTSubsReq(t, params)
        xappConn2.ExpectRESTNotification(t, restSubId)
-       xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId)
+       xapp.Logger.Debug("Send REST subscriber request for subscriberId : %v", restSubId)
        e2SubsId := xappConn2.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("REST notification received e2SubsId=%v", e2SubsId)
+       xapp.Logger.Debug("REST notification received e2SubsId=%v", e2SubsId)
 
        return restSubId, e2SubsId
 }
 
 func createXapp1PolicySubscription(t *testing.T) (string, uint32) {
+
        params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
        restSubId := xappConn1.SendRESTSubsReq(t, params)
-       xapp.Logger.Info("Send REST Policy subscriber request for subscriberId : %v", restSubId)
+       xapp.Logger.Debug("Send REST Policy subscriber request for subscriberId : %v", restSubId)
 
        crereq1, cremsg1 := e2termConn1.RecvSubsReq(t)
        xappConn1.ExpectRESTNotification(t, restSubId)
        e2termConn1.SendSubsResp(t, crereq1, cremsg1)
        e2SubsId := xappConn1.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("REST notification received e2SubsId=%v", e2SubsId)
+       xapp.Logger.Debug("REST notification received e2SubsId=%v", e2SubsId)
 
        return restSubId, e2SubsId
 }
@@ -6601,7 +6782,7 @@ func createXapp1ReportSubscriptionE2Fail(t *testing.T) (string, uint32) {
        xappConn1.ExpectRESTNotification(t, restSubId)
        e2termConn1.SendSubsDelResp(t, delreq1, delmsg1)
        e2SubsId := xappConn1.WaitRESTNotification(t, restSubId)
-       xapp.Logger.Info("TEST: REST notification received e2SubsId=%v", e2SubsId)
+       xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", e2SubsId)
 
        return restSubId, e2SubsId
 }
@@ -6646,14 +6827,14 @@ func sendAndReceiveMultipleE2SubReqs(t *testing.T, count int, fromXappConn *test
        var e2SubsId []uint32
 
        for i := 0; i < count; i++ {
-               xapp.Logger.Info("TEST: %d ===================================== BEGIN CRE ============================================", i+1)
+               xapp.Logger.Debug("TEST: %d ===================================== BEGIN CRE ============================================", i+1)
                crereq, cremsg := toE2termConn.RecvSubsReq(t)
                fromXappConn.ExpectRESTNotification(t, restSubId)
                toE2termConn.SendSubsResp(t, crereq, cremsg)
                instanceId := fromXappConn.WaitRESTNotification(t, restSubId)
                e2SubsId = append(e2SubsId, instanceId)
-               xapp.Logger.Info("TEST: %v", e2SubsId)
-               xapp.Logger.Info("TEST: %d ===================================== END CRE ============================================", i+1)
+               xapp.Logger.Debug("TEST: %v", e2SubsId)
+               xapp.Logger.Debug("TEST: %d ===================================== END CRE ============================================", i+1)
                <-time.After(100 * time.Millisecond)
        }
        return e2SubsId
@@ -6662,11 +6843,11 @@ func sendAndReceiveMultipleE2SubReqs(t *testing.T, count int, fromXappConn *test
 func sendAndReceiveMultipleE2DelReqs(t *testing.T, e2SubsIds []uint32, toE2termConn *teststube2ap.E2Stub) {
 
        for i := 0; i < len(e2SubsIds); i++ {
-               xapp.Logger.Info("TEST: %d ===================================== BEGIN DEL ============================================", i+1)
+               xapp.Logger.Debug("TEST: %d ===================================== BEGIN DEL ============================================", i+1)
                delreq, delmsg := toE2termConn.RecvSubsDelReq(t)
                toE2termConn.SendSubsDelResp(t, delreq, delmsg)
                <-time.After(1 * time.Second)
-               xapp.Logger.Info("TEST: %d ===================================== END DEL ============================================", i+1)
+               xapp.Logger.Debug("TEST: %d ===================================== END DEL ============================================", i+1)
                <-time.After(100 * time.Millisecond)
        }
 
(near-realtime) RIC Platform Subscription Manager