X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fut_ctrl_submgr_test.go;fp=pkg%2Fcontrol%2Fut_ctrl_submgr_test.go;h=1563a00dd4190c5c24f12a8019a90d143476f45c;hb=316b8d22ae977d8063e6277e5c057279b35a95c2;hp=dadf42fb7f34b830a0f95af3519f27bfd8173694;hpb=e60d7b6dc1c2244ef9f885d03984d2bd238a49e0;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/ut_ctrl_submgr_test.go b/pkg/control/ut_ctrl_submgr_test.go index dadf42f..1563a00 100644 --- a/pkg/control/ut_ctrl_submgr_test.go +++ b/pkg/control/ut_ctrl_submgr_test.go @@ -83,15 +83,14 @@ func (mc *testingSubmgrControl) SimulateRestart(t *testing.T) { mainCtrl.c.restDuplicateCtrl.Init() // Read subIds and subscriptions from database - go mainCtrl.c.ReadE2Subscriptions() // This needs to be run in own go routine when called from here <<--- improve this + mainCtrl.c.ReadE2Subscriptions() mc.TestLog(t, "mainCtrl.c.registry.register:") - /* - for subId, subs := range mainCtrl.c.registry.register { - mc.TestLog(t, " subId=%v", subId) - mc.TestLog(t, " subs.SubRespRcvd=%v", subs.SubRespRcvd) - mc.TestLog(t, " subs=%v\n", subs) - } - */ + for subId, subs := range mainCtrl.c.registry.register { + mc.TestLog(t, " subId=%v", subId) + mc.TestLog(t, " subs.SubRespRcvd=%v", subs.SubRespRcvd) + mc.TestLog(t, " subs=%v\n", subs) + } + // Read REST subIds and REST subscriptions from database mainCtrl.c.ReadRESTSubscriptions() mc.TestLog(t, "mainCtrl.c.registry.restSubscriptions:") @@ -99,7 +98,6 @@ func (mc *testingSubmgrControl) SimulateRestart(t *testing.T) { mc.TestLog(t, " restSubId=%v", restSubId) mc.TestLog(t, " restSubs=%v\n", restSubs) } - //go mainCtrl.c.HandleUncompletedSubscriptions(mainCtrl.c.registry.register) // This needs to be run in own go routine when called from here } func (mc *testingSubmgrControl) MakeTransactionNil(t *testing.T, subId uint32) { @@ -123,7 +121,7 @@ func (mc *testingSubmgrControl) removeExistingSubscriptions(t *testing.T) { mainCtrl.c.registry.Initialize() } -func PringSubscriptionQueryResult(resp models.SubscriptionList) { +func PrintSubscriptionQueryResult(resp models.SubscriptionList) { for _, item := range resp { fmt.Printf("item.SubscriptionID=%v\n", item.SubscriptionID) fmt.Printf("item.Meid=%v\n", item.Meid)