From: Anssi Mannila <anssi.mannila@nokia.com>
Date: Thu, 27 May 2021 07:09:06 +0000 (+0000)
Subject: Merge "Added UT cases for Del Req e2ap un/packing errors"
X-Git-Tag: 0.7.1~18
X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=commitdiff_plain;h=0bb76b8349891790788a622c69591bac5f5930d1;hp=ac8bde486e4453d613db6ae05f6839661068a4ab;p=ric-plt%2Fsubmgr.git

Merge "Added UT cases for Del Req e2ap un/packing errors"
---

diff --git a/pkg/control/ut_messaging_test.go b/pkg/control/ut_messaging_test.go
index e6d6646..5e7d5a7 100644
--- a/pkg/control/ut_messaging_test.go
+++ b/pkg/control/ut_messaging_test.go
@@ -2409,15 +2409,12 @@ func TestRESTSubReqAndRouteNok(t *testing.T) {
 	})
 
 	const subReqCount int = 1
-	const parameterSet = 1
-	const actionDefinitionPresent bool = true
-	const actionParamCount 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)
 
 	// Req
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 	xappConn1.ExpectRESTNotification(t, restSubId)
 	waiter.WaitResult(t)
@@ -2460,7 +2457,7 @@ func TestRESTSubReqAndRouteUpdateNok(t *testing.T) {
 	// xapp2 ROUTE creation shall fail with  400 from rtmgr -> submgr
 	waiter := rtmgrHttp.AllocNextEvent(false)
 	newSubsId := mainCtrl.get_registry_next_subid(t)
-	params = xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	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)
@@ -2611,14 +2608,11 @@ func TestRESTSubReqRetransmission(t *testing.T) {
 
 	// Subs Create
 	const subReqCount int = 1
-	const parameterSet = 1
-	const actionDefinitionPresent bool = true
-	const actionParamCount int = 1
 
 	// In order to force both XAPP's to create their own subscriptions, force rtmgr to block a while so that 2nd create
 	// gets into execution before the rtmgrg responds for the first one.
 	waiter := rtmgrHttp.AllocNextSleep(10, true)
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId1 := xappConn1.SendRESTSubsReq(t, params)
 	restSubId2 := xappConn2.SendRESTSubsReq(t, params)
 
@@ -2735,12 +2729,9 @@ func TestRESTSubReqDelReq(t *testing.T) {
 	})
 
 	const subReqCount int = 1
-	const parameterSet = 1
-	const actionDefinitionPresent bool = true
-	const actionParamCount int = 1
 
 	// Req
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 
 	// Del. This will fail as processing of the subscription
@@ -2783,12 +2774,12 @@ func TestRESTSubReqAndSubDelOkTwoParallel(t *testing.T) {
 	})
 
 	//Req1
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId1 := xappConn1.SendRESTSubsReq(t, params)
 	xapp.Logger.Info("Send 1st REST subscriber request for subscriberId : %v", restSubId1)
 
 	//Req2
-	params = xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	restSubId2 := xappConn2.SendRESTSubsReq(t, params)
 	xapp.Logger.Info("Send 2nd REST subscriber request for subscriberId : %v", restSubId2)
 
@@ -2835,11 +2826,11 @@ func TestRESTSameSubsDiffRan(t *testing.T) {
 		Counter{cSubDelRespToXapp, 2},
 	})
 
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
 	xapp.Logger.Info("Send 1st REST subscriber request for subscriberId : %v", restSubId1)
 
-	params = xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	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)
@@ -2873,7 +2864,7 @@ func TestRESTSubReqRetryInSubmgr(t *testing.T) {
 		Counter{cSubDelRespToXapp, 1},
 	})
 
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 
 	xapp.Logger.Info("Send REST subscriber request for subscriber : %v", restSubId)
@@ -2951,7 +2942,7 @@ func TestRESTSubReqRetryNoRespSubDelRespInSubmgr(t *testing.T) {
 		Counter{cSubDelRespFromE2, 1},
 	})
 
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 	xapp.Logger.Info("Send REST subscriber request for subscriber : %v", restSubId)
 
@@ -2986,7 +2977,7 @@ func TestREST2eTermNotRespondingToSubReq(t *testing.T) {
 		Counter{cSubDelReqTimerExpiry, 2},
 	})
 
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 	xapp.Logger.Info("Send REST subscriber request for subscriber : %v", restSubId)
 
@@ -3063,7 +3054,7 @@ func TestRESTSubReqTwoRetriesNoRespAtAllInSubmgr(t *testing.T) {
 		Counter{cSubDelReqTimerExpiry, 2},
 	})
 
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 	xapp.Logger.Info("Send REST subscriber request for subscriber : %v", restSubId)
 
@@ -3132,11 +3123,8 @@ func TestRESTSubReqSubFailRespInSubmgr(t *testing.T) {
 	})
 
 	const subReqCount int = 1
-	const parameterSet = 1
-	const actionDefinitionPresent bool = true
-	const actionParamCount int = 1
 
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 
 	crereq1, cremsg1 := e2termConn1.RecvSubsReq(t)
@@ -3410,7 +3398,7 @@ func TestRESTSubReqAndSubDelOkSameAction(t *testing.T) {
 	queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
 	// Req2
-	params = xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	params.SetMeid("RAN_NAME_1")
 
 	xapp.Subscription.SetResponseCB(xappConn2.SubscriptionRespHandler)
@@ -3497,11 +3485,11 @@ func TestRESTSubReqAndSubDelOkSameActionParallel(t *testing.T) {
 		Counter{cSubDelRespToXapp, 2},
 	})
 
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId1 := xappConn1.SendRESTSubsReq(t, params)
 	crereq1, cremsg1 := e2termConn1.RecvSubsReq(t)
 
-	params2 := xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params2 := xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	restSubId2 := xappConn2.SendRESTSubsReq(t, params2)
 
 	xappConn1.ExpectRESTNotification(t, restSubId1)
@@ -3594,18 +3582,15 @@ func TestRESTSubReqAndSubDelNoAnswerSameActionParallel(t *testing.T) {
 	})
 
 	const subReqCount int = 1
-	const parameterSet = 1
-	const actionDefinitionPresent bool = true
-	const actionParamCount int = 1
 
 	// Req1
-	params1 := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params1 := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId1 := xappConn1.SendRESTSubsReq(t, params1)
 	crereq1, _ := e2termConn1.RecvSubsReq(t)
 
 	// Req2
 	subepcnt2 := mainCtrl.get_subs_entrypoint_cnt(t, crereq1.RequestId.InstanceId)
-	params2 := xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params2 := xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	params2.SetMeid("RAN_NAME_1")
 	restSubId2 := xappConn2.SendRESTSubsReq(t, params2)
 	mainCtrl.wait_subs_entrypoint_cnt_change(t, crereq1.RequestId.InstanceId, subepcnt2, 10)
@@ -3701,18 +3686,15 @@ func TestRESTSubReqAndSubDelNokSameActionParallel(t *testing.T) {
 	})
 
 	const subReqCount int = 1
-	const parameterSet = 1
-	const actionDefinitionPresent bool = true
-	const actionParamCount int = 1
 
 	// Req1
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId1 := xappConn1.SendRESTSubsReq(t, params)
 	crereq1, cremsg1 := e2termConn1.RecvSubsReq(t)
 
 	// Req2
 	subepcnt2 := mainCtrl.get_subs_entrypoint_cnt(t, crereq1.RequestId.InstanceId)
-	params2 := xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params2 := xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	params2.SetMeid("RAN_NAME_1")
 	restSubId2 := xappConn2.SendRESTSubsReq(t, params2)
 	mainCtrl.wait_subs_entrypoint_cnt_change(t, crereq1.RequestId.InstanceId, subepcnt2, 10)
@@ -3761,11 +3743,8 @@ func TestRESTSubReqPolicyAndSubDelOk(t *testing.T) {
 	})
 
 	const subReqCount int = 1
-	const parameterSet = 1
-	const actionDefinitionPresent bool = true
-	const actionParamCount int = 1
 
-	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount, actionDefinitionPresent, policyParamCount)
+	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 	xapp.Logger.Info("Send REST Policy subscriber request for subscriberId : %v", restSubId)
 
@@ -3848,18 +3827,15 @@ func TestRESTSubReqPolicyChangeAndSubDelOk(t *testing.T) {
 	})
 
 	const subReqCount int = 1
-	const parameterSet = 1
-	const actionDefinitionPresent bool = true
-	const policyParamCount int = 1
 
 	// Req
-	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount, actionDefinitionPresent, policyParamCount)
+	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
 	restSubId, e2SubsId := createSubscription(t, xappConn1, e2termConn1, params)
 
 	// Policy change
 	instanceId := int64(e2SubsId)
 	// GetRESTSubsReqPolicyParams sets some coutners on tc side.
-	params = xappConn1.GetRESTSubsReqPolicyParams(subReqCount, actionDefinitionPresent, policyParamCount)
+	params = xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
 	params.SubsReqParams.SubscriptionDetails[0].InstanceID = &instanceId
 	params.SetTimeToWait("w200ms")
 	restSubId, e2SubsId = createSubscription(t, xappConn1, e2termConn1, params)
@@ -3932,17 +3908,14 @@ func TestRESTSubReqAndSubDelOkTwoE2termParallel(t *testing.T) {
 	})
 
 	const subReqCount int = 1
-	const parameterSet = 1
-	const actionDefinitionPresent bool = true
-	const actionParamCount int = 1
 
 	// Req1
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId1 := xappConn1.SendRESTSubsReq(t, params)
 	crereq1, cremsg1 := e2termConn1.RecvSubsReq(t)
 
 	// Req2
-	params = xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	params.SetMeid("RAN_NAME_11")
 	// Here we use xappConn2 to simulate sending second request from same xapp as doing it from xappConn1
 	// would not work as notification would not be received
@@ -4060,11 +4033,8 @@ func TestRESTSubReqInsertAndSubDelOk(t *testing.T) {
 	})
 
 	const subReqCount int = 1
-	const parameterSet int = 1
-	const actionDefinitionPresent bool = true
-	const actionParamCount int = 1
 
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	params.SetSubActionTypes("insert")
 
 	// Req
@@ -4121,14 +4091,11 @@ func TestRESTSubReqNokAndSubDelOkWithRestartInMiddle(t *testing.T) {
 	})
 
 	const subReqCount int = 1
-	const parameterSet = 1
-	const actionDefinitionPresent bool = true
-	const actionParamCount int = 1
 
 	// Remove possible existing subscription
 	mainCtrl.removeExistingSubscriptions(t)
 
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 
 	//Req
 	mainCtrl.SetResetTestFlag(t, true) // subs.DoNotWaitSubResp will be set TRUE for the subscription
@@ -4316,7 +4283,7 @@ func TestRESTSubReqAndSubDelOkSameActionWithRestartsInMiddle(t *testing.T) {
 	xapp.Logger.Info("Send REST subscriber request for subscriber 1 : %v", restSubId1)
 
 	// Create subscription 2 with same action
-	params = xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	params.SetMeid("RAN_NAME_1")
 	xapp.Subscription.SetResponseCB(xappConn2.SubscriptionRespHandler)
 	xappConn2.WaitRESTNotificationForAnySubscriptionId(t)
@@ -4403,18 +4370,15 @@ func TestRESTSubReqAndSubDelOkSameActionWithRestartsInMiddle(t *testing.T) {
 func TestRESTReportSubReqAndSubDelOk(t *testing.T) {
 	CaseBegin("TestRESTReportSubReqAndSubDelOk")
 	subReqCount := 1
-	parameterSet := 1 // E2SM-gNB-X2
-	actionDefinitionPresent := true
-	actionParamCount := 1
 	testIndex := 1
-	RESTReportSubReqAndSubDelOk(t, subReqCount, parameterSet, actionDefinitionPresent, actionParamCount, testIndex)
+	RESTReportSubReqAndSubDelOk(t, subReqCount, testIndex)
 }
 
-func RESTReportSubReqAndSubDelOk(t *testing.T, subReqCount int, parameterSet int, actionDefinitionPresent bool, actionParamCount int, testIndex int) {
-	xapp.Logger.Info("TEST: TestRESTReportSubReqAndSubDelOk with parameter set %v", testIndex)
+func RESTReportSubReqAndSubDelOk(t *testing.T, subReqCount int, testIndex int) {
+	xapp.Logger.Info("TEST: TestRESTReportSubReqAndSubDelOk with testIndex %v", testIndex)
 
 	// Req
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 
 	var e2SubsId []uint32
@@ -4456,25 +4420,21 @@ func TestRESTPolicySubReqAndSubDelOk(t *testing.T) {
 	CaseBegin("TestRESTPolicySubReqAndSubDelOk")
 
 	subReqCount := 2
-	actionDefinitionPresent := true
-	policyParamCount := 1
 	testIndex := 1
-	RESTPolicySubReqAndSubDelOk(t, subReqCount, actionDefinitionPresent, policyParamCount, testIndex)
+	RESTPolicySubReqAndSubDelOk(t, subReqCount, testIndex)
 
 	subReqCount = 19
-	actionDefinitionPresent = false
-	policyParamCount = 0
 	testIndex = 2
-	RESTPolicySubReqAndSubDelOk(t, subReqCount, actionDefinitionPresent, policyParamCount, testIndex)
+	RESTPolicySubReqAndSubDelOk(t, subReqCount, testIndex)
 }
 */
-func RESTPolicySubReqAndSubDelOk(t *testing.T, subReqCount int, actionDefinitionPresent bool, policyParamCount int, testIndex int) {
-	xapp.Logger.Info("TEST: TestRESTPolicySubReqAndSubDelOk with parameter set %v", testIndex)
+func RESTPolicySubReqAndSubDelOk(t *testing.T, subReqCount int, testIndex int) {
+	xapp.Logger.Info("TEST: TestRESTPolicySubReqAndSubDelOk with testIndex %v", testIndex)
 
 	// Req
-	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount, actionDefinitionPresent, policyParamCount)
+	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
-	//params := xappConn1.GetRESTSubsReqPolicyParams1(subReqCount, actionDefinitionPresent, policyParamCount)
+	//params := xappConn1.GetRESTSubsReqPolicyParams1(subReqCount)
 	//restSubId := xappConn1.SendRESTPolicySubsReq(t, params)
 
 	var e2SubsId []uint32
@@ -4520,7 +4480,7 @@ func TestRESTTwoPolicySubReqAndSubDelOk(t *testing.T) {
 	})
 
 	// Req
-	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount, actionDefinitionPresent, policyParamCount)
+	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 	e2SubsIds := sendAndReceiveMultipleE2SubReqs(t, subReqCount, xappConn1, e2termConn1, restSubId)
 
@@ -4552,7 +4512,7 @@ func TestRESTPolicySubReqAndSubDelOkFullAmount(t *testing.T) {
 	})
 
 	// Req
-	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount, actionDefinitionPresent, policyParamCount)
+	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 	e2SubsIds := sendAndReceiveMultipleE2SubReqs(t, subReqCount, xappConn1, e2termConn1, restSubId)
 
@@ -4570,9 +4530,6 @@ func TestRESTPolicySubReqAndSubDelOkFullAmount(t *testing.T) {
 func TestRESTTwoReportSubReqAndSubDelOk(t *testing.T) {
 
 	subReqCount := 2
-	parameterSet := 1
-	actionDefinitionPresent := true
-	actionParamCount := 1
 
 	mainCtrl.CounterValuesToBeVeriefied(t, CountersToBeAdded{
 		Counter{cSubReqFromXapp, 1},
@@ -4586,7 +4543,7 @@ func TestRESTTwoReportSubReqAndSubDelOk(t *testing.T) {
 	})
 
 	// Req
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 	e2SubsIds := sendAndReceiveMultipleE2SubReqs(t, subReqCount, xappConn1, e2termConn1, restSubId)
 
@@ -4606,9 +4563,6 @@ func TestRESTTwoReportSubReqAndSubDelOk(t *testing.T) {
 func TestRESTTwoReportSubReqAndSubDelOkNoActParams(t *testing.T) {
 
 	subReqCount := 2
-	parameterSet := 1
-	actionDefinitionPresent := false
-	actionParamCount := 0
 
 	mainCtrl.CounterValuesToBeVeriefied(t, CountersToBeAdded{
 		Counter{cSubReqFromXapp, 1},
@@ -4622,7 +4576,7 @@ func TestRESTTwoReportSubReqAndSubDelOkNoActParams(t *testing.T) {
 	})
 
 	// Req
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 	e2SubsIds := sendAndReceiveMultipleE2SubReqs(t, subReqCount, xappConn1, e2termConn1, restSubId)
 
@@ -4642,9 +4596,6 @@ func TestRESTTwoReportSubReqAndSubDelOkNoActParams(t *testing.T) {
 func TestRESTFullAmountReportSubReqAndSubDelOk(t *testing.T) {
 
 	subReqCount := 19
-	parameterSet := 1
-	actionDefinitionPresent := false
-	actionParamCount := 0
 
 	mainCtrl.CounterValuesToBeVeriefied(t, CountersToBeAdded{
 		Counter{cSubReqFromXapp, 1},
@@ -4658,7 +4609,7 @@ func TestRESTFullAmountReportSubReqAndSubDelOk(t *testing.T) {
 	})
 
 	// Req
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 	e2SubsIds := sendAndReceiveMultipleE2SubReqs(t, subReqCount, xappConn1, e2termConn1, restSubId)
 
@@ -4699,7 +4650,7 @@ func TestRESTSubReqReportSameActionDiffEventTriggerDefinitionLen(t *testing.T) {
 	queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
 	// Req2
-	params = xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	params.SetMeid("RAN_NAME_1")
 	eventTriggerDefinition := "1234"
 	params.SetSubEventTriggerDefinition(eventTriggerDefinition)
@@ -4745,7 +4696,7 @@ func TestRESTSubReqReportSameActionDiffActionListLen(t *testing.T) {
 	queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
 	// Req2
-	params = xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	params.SetMeid("RAN_NAME_1")
 
 	actionId := int64(1)
@@ -4796,7 +4747,7 @@ func TestRESTSubReqReportSameActionDiffActionID(t *testing.T) {
 	queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
 	// Req2
-	params = xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	params.SetMeid("RAN_NAME_1")
 	params.SetSubActionIDs(int64(2))
 
@@ -4832,7 +4783,7 @@ func TestRESTSubReqDiffActionType(t *testing.T) {
 	})
 
 	// Req1
-	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount, actionDefinitionPresent, policyParamCount)
+	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
 
 	//Subs Create
 	restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
@@ -4841,7 +4792,7 @@ func TestRESTSubReqDiffActionType(t *testing.T) {
 	queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
 	// Req2
-	params = xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	params.SetMeid("RAN_NAME_1")
 
 	restSubId2 := xappConn2.SendRESTSubsReq(t, params)
@@ -4876,7 +4827,7 @@ func TestRESTSubReqPolicyAndSubDelOkSameAction(t *testing.T) {
 	})
 
 	// Req1
-	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount, actionDefinitionPresent, policyParamCount)
+	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
 
 	//Subs Create
 	restSubId1, e2SubsId1 := createSubscription(t, xappConn1, e2termConn1, params)
@@ -4885,7 +4836,7 @@ func TestRESTSubReqPolicyAndSubDelOkSameAction(t *testing.T) {
 	queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
 	// Req2
-	params = xappConn2.GetRESTSubsReqPolicyParams(subReqCount, actionDefinitionPresent, policyParamCount)
+	params = xappConn2.GetRESTSubsReqPolicyParams(subReqCount)
 	params.SetMeid("RAN_NAME_1")
 
 	restSubId2 := xappConn2.SendRESTSubsReq(t, params)
@@ -4929,7 +4880,7 @@ func TestRESTSubReqReportSameActionDiffActionDefinitionLen(t *testing.T) {
 	queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
 	// Req2
-	params = xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	params.SetMeid("RAN_NAME_1")
 	actionDefinition := "5678"
 	params.SetSubActionDefinition(actionDefinition)
@@ -4975,7 +4926,7 @@ func TestRESTSubReqReportSameActionDiffActionDefinitionContents(t *testing.T) {
 	queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
 	// Req2
-	params = xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	params.SetMeid("RAN_NAME_1")
 	actionDefinition := "56782"
 	params.SetSubActionDefinition(actionDefinition)
@@ -5021,7 +4972,7 @@ func TestRESTSubReqReportSameActionDiffSubsAction(t *testing.T) {
 	queryXappSubscription(t, int64(e2SubsId1), "RAN_NAME_1", []string{"localhost:13560"})
 
 	// Req2
-	params = xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params = xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	params.SetMeid("RAN_NAME_1")
 	params.SetTimeToWait("w200ms")
 	restSubId2 := xappConn2.SendRESTSubsReq(t, params)
@@ -5078,12 +5029,9 @@ func TestRESTSubReqReportSameActionDiffSubsAction(t *testing.T) {
 func TestRESTUnpackSubscriptionResponseDecodeFail(t *testing.T) {
 	xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionResponseDecodeFail")
 	subReqCount := 1
-	parameterSet := 1 // E2SM-gNB-X2
-	actionDefinitionPresent := true
-	actionParamCount := 1
 
 	// Req
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 
 	crereq, cremsg := e2termConn1.RecvSubsReq(t)
@@ -5151,12 +5099,9 @@ func TestRESTUnpackSubscriptionResponseDecodeFail(t *testing.T) {
 func TestRESTUnpackSubscriptionResponseUnknownInstanceId(t *testing.T) {
 	xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionResponseUnknownInstanceId")
 	subReqCount := 1
-	parameterSet := 1 // E2SM-gNB-X2
-	actionDefinitionPresent := true
-	actionParamCount := 1
 
 	// Req
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 
 	crereq, cremsg := e2termConn1.RecvSubsReq(t)
@@ -5233,12 +5178,9 @@ func TestRESTUnpackSubscriptionResponseUnknownInstanceId(t *testing.T) {
 func TestRESTUnpackSubscriptionResponseNoTransaction(t *testing.T) {
 	xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionResponseNoTransaction")
 	subReqCount := 1
-	parameterSet := 1 // E2SM-gNB-X2
-	actionDefinitionPresent := true
-	actionParamCount := 1
 
 	// Req
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 
 	crereq, cremsg := e2termConn1.RecvSubsReq(t)
@@ -5313,12 +5255,9 @@ func TestRESTUnpackSubscriptionResponseNoTransaction(t *testing.T) {
 func TestRESTUnpackSubscriptionFailureDecodeFail(t *testing.T) {
 	xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionFailureDecodeFail")
 	subReqCount := 1
-	parameterSet := 1 // E2SM-gNB-X2
-	actionDefinitionPresent := true
-	actionParamCount := 1
 
 	// Req
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 
 	crereq, cremsg := e2termConn1.RecvSubsReq(t)
@@ -5387,12 +5326,9 @@ func TestRESTUnpackSubscriptionFailureDecodeFail(t *testing.T) {
 func TestRESTUnpackSubscriptionFailureUnknownInstanceId(t *testing.T) {
 	xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionFailureUnknownInstanceId")
 	subReqCount := 1
-	parameterSet := 1 // E2SM-gNB-X2
-	actionDefinitionPresent := true
-	actionParamCount := 1
 
 	// Req
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 
 	crereq, cremsg := e2termConn1.RecvSubsReq(t)
@@ -5462,12 +5398,9 @@ func TestRESTUnpackSubscriptionFailureUnknownInstanceId(t *testing.T) {
 func TestRESTUnpackSubscriptionFailureNoTransaction(t *testing.T) {
 	xapp.Logger.Info("TEST: TestRESTUnpackSubscriptionFailureNoTransaction")
 	subReqCount := 1
-	parameterSet := 1 // E2SM-gNB-X2
-	actionDefinitionPresent := true
-	actionParamCount := 1
 
 	// Req
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 
 	crereq, cremsg := e2termConn1.RecvSubsReq(t)
@@ -5872,19 +5805,80 @@ func TestRESTUnpackSubscriptionDeleteFailureNoTransaction(t *testing.T) {
 	mainCtrl.wait_registry_empty(t, 10)
 }
 
+//-----------------------------------------------------------------------------
+// TestRESTSubReqFailAsn1PackSubReqError
+//
+//   stub                             stub
+// +-------+        +---------+    +---------+
+// | xapp  |        | submgr  |    | e2term  |
+// +-------+        +---------+    +---------+
+//     |                 |              |
+//     | RESTSubReq      |              |
+//     |---------------->|              |
+//     |                 |              |
+//     |     RESTSubResp |              |
+//     |<----------------|              |
+//     |                 |              |
+//     |        ASN.1 encode fails      |
+//     |                 |              |
+//     |                 | SubDelReq    |
+//     |                 |------------->|
+//     |                 |              |
+//     |                 |  SubDelFail  |
+//     |                 |<-------------|
+//     |                 |              |
+//     |       RESTNotif |              |
+//     |       unsuccess |              |
+//     |<----------------|              |
+//     |                 |              |
+//     |            [SUBS DELETE]       |
+//     |                 |              |
+//
+//-----------------------------------------------------------------------------
+func TestRESTSubReqFailAsn1PackSubReqError(t *testing.T) {
+
+	mainCtrl.CounterValuesToBeVeriefied(t, CountersToBeAdded{
+		Counter{cSubReqFromXapp, 1},
+		Counter{cSubDelReqToE2, 1},
+		Counter{cSubDelFailFromE2, 1},
+		Counter{cSubRespToXapp, 1},
+	})
+
+	subReqCount := 1
+
+	var params *teststube2ap.RESTSubsReqParams = nil
+	params = xappConn1.GetRESTSubsReqReportParams(subReqCount)
+	e2ap_wrapper.AllowE2apToProcess(e2ap_wrapper.SUB_REQ, false)
+
+	// Req
+	restSubId := xappConn1.SendRESTSubsReq(t, params)
+	xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId)
+
+	// E2t: Receive SubsDelReq
+	delreq, delmsg := e2termConn1.RecvSubsDelReq(t)
+	xappConn1.ExpectRESTNotification(t, restSubId)
+
+	// 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)
+
+	e2ap_wrapper.AllowE2apToProcess(e2ap_wrapper.SUB_REQ, true)
+	// Wait that subs is cleaned
+	waitSubsCleanup(t, e2SubsId, 10)
+	mainCtrl.VerifyCounterValues(t)
+}
+
 ////////////////////////////////////////////////////////////////////////////////////
 //   Services for UT cases
 ////////////////////////////////////////////////////////////////////////////////////
 const subReqCount int = 1
-const parameterSet = 1
-const actionDefinitionPresent bool = true
-const actionParamCount int = 1
-const policyParamCount int = 1
 const host string = "localhost"
 
 func createSubscription(t *testing.T, fromXappConn *teststube2ap.E2Stub, toE2termConn *teststube2ap.E2Stub, params *teststube2ap.RESTSubsReqParams) (string, uint32) {
 	if params == nil {
-		params = fromXappConn.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+		params = fromXappConn.GetRESTSubsReqReportParams(subReqCount)
 	}
 	restSubId := fromXappConn.SendRESTSubsReq(t, params)
 	xapp.Logger.Info("Send REST subscriber request for subscriberId : %v", restSubId)
@@ -5900,7 +5894,7 @@ func createSubscription(t *testing.T, fromXappConn *teststube2ap.E2Stub, toE2ter
 
 func createXapp2MergedSubscription(t *testing.T, meid string) (string, uint32) {
 
-	params := xappConn2.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn2.GetRESTSubsReqReportParams(subReqCount)
 	if meid != "" {
 		params.SetMeid(meid)
 	}
@@ -5915,7 +5909,7 @@ func createXapp2MergedSubscription(t *testing.T, meid string) (string, uint32) {
 }
 
 func createXapp1PolicySubscription(t *testing.T) (string, uint32) {
-	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount, actionDefinitionPresent, policyParamCount)
+	params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 	xapp.Logger.Info("Send REST Policy subscriber request for subscriberId : %v", restSubId)
 
@@ -5929,7 +5923,7 @@ func createXapp1PolicySubscription(t *testing.T) (string, uint32) {
 }
 
 func createXapp1ReportSubscriptionE2Fail(t *testing.T) (string, uint32) {
-	params := xappConn1.GetRESTSubsReqReportParams(subReqCount, parameterSet, actionDefinitionPresent, actionParamCount)
+	params := xappConn1.GetRESTSubsReqReportParams(subReqCount)
 	restSubId := xappConn1.SendRESTSubsReq(t, params)
 
 	crereq1, cremsg1 := e2termConn1.RecvSubsReq(t)
diff --git a/pkg/teststube2ap/stubE2.go b/pkg/teststube2ap/stubE2.go
index 5d28d3b..ec3010a 100644
--- a/pkg/teststube2ap/stubE2.go
+++ b/pkg/teststube2ap/stubE2.go
@@ -824,27 +824,10 @@ func (tc *E2Stub) SendRESTSubsReq(t *testing.T, params *RESTSubsReqParams) strin
 //-----------------------------------------------------------------------------
 //
 //-----------------------------------------------------------------------------
-func (tc *E2Stub) GetRESTSubsReqReportParams(subReqCount int, parameterSet int, actionDefinitionPresent bool, actionParamCount int) *RESTSubsReqParams {
+func (tc *E2Stub) GetRESTSubsReqReportParams(subReqCount int) *RESTSubsReqParams {
 
 	reportParams := RESTSubsReqParams{}
-	if parameterSet == 1 {
-		reportParams.GetRESTSubsReqReportParams1(subReqCount, actionDefinitionPresent, actionParamCount, &tc.clientEndpoint, &tc.meid)
-	} else if parameterSet == 2 {
-
-	} else {
-		tc.Error("Invalid parameterSet=%v", parameterSet)
-	}
-	tc.requestCount = subReqCount
-	return &reportParams
-}
-
-//-----------------------------------------------------------------------------
-//
-//-----------------------------------------------------------------------------
-func (tc *E2Stub) GetRESTSubsReqReportParams1(subReqCount int, actionDefinitionPresent bool, actionParamCount int) *RESTSubsReqParams {
-
-	reportParams := RESTSubsReqParams{}
-	reportParams.GetRESTSubsReqReportParams1(subReqCount, actionDefinitionPresent, actionParamCount, &tc.clientEndpoint, &tc.meid)
+	reportParams.GetRESTSubsReqReportParams(subReqCount, &tc.clientEndpoint, &tc.meid)
 	tc.requestCount = subReqCount
 	return &reportParams
 }
@@ -856,7 +839,7 @@ type RESTSubsReqParams struct {
 	SubsReqParams clientmodel.SubscriptionParams
 }
 
-func (p *RESTSubsReqParams) GetRESTSubsReqReportParams1(subReqCount int, actionDefinitionPresent bool, actionParamCount int, clientEndpoint *clientmodel.SubscriptionParamsClientEndpoint, meid *string) {
+func (p *RESTSubsReqParams) GetRESTSubsReqReportParams(subReqCount int, clientEndpoint *clientmodel.SubscriptionParamsClientEndpoint, meid *string) {
 
 	// E2SM-gNB-X2
 	p.SubsReqParams.ClientEndpoint = clientEndpoint
@@ -1041,10 +1024,10 @@ func (tc *E2Stub) SendRESTSubsDelReq(t *testing.T, subscriptionID *string) {
 //-----------------------------------------------------------------------------
 //
 //-----------------------------------------------------------------------------
-func (tc *E2Stub) GetRESTSubsReqPolicyParams(subReqCount int, actionDefinitionPresent bool, policyParamCount int) *RESTSubsReqParams {
+func (tc *E2Stub) GetRESTSubsReqPolicyParams(subReqCount int) *RESTSubsReqParams {
 
 	policyParams := RESTSubsReqParams{}
-	policyParams.GetRESTSubsReqPolicyParams(subReqCount, actionDefinitionPresent, policyParamCount, &tc.clientEndpoint, &tc.meid)
+	policyParams.GetRESTSubsReqPolicyParams(subReqCount, &tc.clientEndpoint, &tc.meid)
 	tc.requestCount = subReqCount
 	return &policyParams
 }
@@ -1052,7 +1035,7 @@ func (tc *E2Stub) GetRESTSubsReqPolicyParams(subReqCount int, actionDefinitionPr
 //-----------------------------------------------------------------------------
 //
 //-----------------------------------------------------------------------------
-func (p *RESTSubsReqParams) GetRESTSubsReqPolicyParams(subReqCount int, actionDefinitionPresent bool, policyParamCount int, clientEndpoint *clientmodel.SubscriptionParamsClientEndpoint, meid *string) {
+func (p *RESTSubsReqParams) GetRESTSubsReqPolicyParams(subReqCount int, clientEndpoint *clientmodel.SubscriptionParamsClientEndpoint, meid *string) {
 
 	p.SubsReqParams.ClientEndpoint = clientEndpoint
 	p.SubsReqParams.Meid = meid