-
- var e2SubsId []uint32
- for i := 0; i < subReqCount; i++ {
- crereq, cremsg := e2termConn1.RecvSubsReq(t)
- xappConn1.ExpectRESTNotification(t, restSubId)
- e2termConn1.SendSubsResp(t, crereq, cremsg)
- instanceId := xappConn1.WaitRESTNotification(t, restSubId)
- xapp.Logger.Debug("TEST: REST notification received e2SubsId=%v", instanceId)
- e2SubsId = append(e2SubsId, instanceId)
- }
-
- // Del
- xappConn1.SendRESTSubsDelReq(t, &restSubId)
-
- for i := 0; i < subReqCount; i++ {
- delreq, delmsg := e2termConn1.RecvSubsDelReq(t)
- e2termConn1.SendSubsDelResp(t, delreq, delmsg)
- }
-
- // Wait that subs is cleaned
- for i := 0; i < subReqCount; i++ {
- mainCtrl.wait_subs_clean(t, e2SubsId[i], 10)
- }
- xappConn1.TestMsgChanEmpty(t)
- e2termConn1.TestMsgChanEmpty(t)
- mainCtrl.wait_registry_empty(t, 10)
-}
-
-func TestRESTTwoPolicySubReqAndSubDelOk(t *testing.T) {
-
- mainCtrl.CounterValuesToBeVeriefied(t, CountersToBeAdded{
- Counter{cRestSubReqFromXapp, 1},
- Counter{cRestSubRespToXapp, 1},
- Counter{cSubReqToE2, 2},
- Counter{cSubRespFromE2, 2},
- Counter{cRestSubNotifToXapp, 2},
- Counter{cRestSubDelReqFromXapp, 1},
- Counter{cSubDelReqToE2, 2},
- Counter{cSubDelRespFromE2, 2},
- Counter{cRestSubDelRespToXapp, 1},
- })
-
- const subReqCount int = 2
-
- // Req
- params := xappConn1.GetRESTSubsReqPolicyParams(subReqCount)
- restSubId := xappConn1.SendRESTSubsReq(t, params)
- e2SubsIds := sendAndReceiveMultipleE2SubReqs(t, subReqCount, xappConn1, e2termConn1, restSubId)