X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fut_messaging_test.go;h=5d57832bbe0418c22e4453b50b14d91b10b07dc2;hb=e530286062bdc07625e54433bd64530ae7ae2118;hp=de2458a09d9579327b54c7bb335d773584ed9721;hpb=9bcb0a4620d71671f758dce029cb2e3da9ab9dbe;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/ut_messaging_test.go b/pkg/control/ut_messaging_test.go index de2458a..5d57832 100644 --- a/pkg/control/ut_messaging_test.go +++ b/pkg/control/ut_messaging_test.go @@ -1214,10 +1214,8 @@ func TestSubReqPolicyAndSubDelOk(t *testing.T) { deltrans := xappConn1.SendSubsDelReq(t, nil, e2SubsId) delreq, delmsg := e2termConn.RecvSubsDelReq(t) - waiter := rtmgrHttp.AllocNextEvent(true) e2termConn.SendSubsDelResp(t, delreq, delmsg) xappConn1.RecvSubsDelResp(t, deltrans) - waiter.WaitResult(t) //Wait that subs is cleaned mainCtrl.wait_subs_clean(t, e2SubsId, 10) @@ -1277,12 +1275,10 @@ func TestSubReqPolicyAndSubDelOk(t *testing.T) { func TestSubReqPolicyChangeAndSubDelOk(t *testing.T) { CaseBegin("TestSubReqAndSubDelOk") - waiter := rtmgrHttp.AllocNextEvent(true) rparams1 := &teststube2ap.E2StubSubsReqParams{} rparams1.Init() rparams1.Req.ActionSetups[0].ActionType = e2ap.E2AP_ActionTypePolicy cretrans := xappConn1.SendSubsReq(t, rparams1, nil) - waiter.WaitResult(t) crereq, cremsg := e2termConn.RecvSubsReq(t) e2termConn.SendSubsResp(t, crereq, cremsg) @@ -1299,10 +1295,8 @@ func TestSubReqPolicyChangeAndSubDelOk(t *testing.T) { deltrans := xappConn1.SendSubsDelReq(t, nil, e2SubsId) delreq, delmsg := e2termConn.RecvSubsDelReq(t) - waiter = rtmgrHttp.AllocNextEvent(true) e2termConn.SendSubsDelResp(t, delreq, delmsg) xappConn1.RecvSubsDelResp(t, deltrans) - waiter.WaitResult(t) //Wait that subs is cleaned mainCtrl.wait_subs_clean(t, e2SubsId, 10)