/* ================================================================================== Copyright (c) 2019 AT&T Intellectual Property. Copyright (c) 2019 Nokia Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. ================================================================================== */ package control import ( "os" "testing" "time" "gerrit.o-ran-sc.org/r/ric-plt/submgr/pkg/teststub" "gerrit.o-ran-sc.org/r/ric-plt/submgr/pkg/teststubdummy" "gerrit.o-ran-sc.org/r/ric-plt/submgr/pkg/teststube2ap" "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" ) //----------------------------------------------------------------------------- // //----------------------------------------------------------------------------- func CaseBegin(desc string) *teststub.TestWrapper { tent := teststub.NewTestWrapper(desc) tent.Debug(desc) return tent } //----------------------------------------------------------------------------- // //----------------------------------------------------------------------------- const teststubPortSeed int = 55555 //----------------------------------------------------------------------------- // //----------------------------------------------------------------------------- var xappConn1 *teststube2ap.E2Stub var xappConn2 *teststube2ap.E2Stub var e2termConn1 *teststube2ap.E2Stub var e2termConn2 *teststube2ap.E2Stub var rtmgrHttp *testingHttpRtmgrStub var mainCtrl *testingSubmgrControl var dummystub *teststubdummy.RmrDummyStub func ut_test_init() func() { tent := CaseBegin("ut_test_init") //--------------------------------- // //--------------------------------- rtmgrHttp = createNewHttpRtmgrStub("RTMGRSTUB", "8989") go rtmgrHttp.run() //--------------------------------- // //--------------------------------- // //Cfg creation won't work like this as xapp-frame reads it during init. // /* cfgstr:=`{ "local": { "host": ":8080" }, "logger": { "level": 4 }, "rmr": { "protPort": "tcp:14560", "maxSize": 4096, "numWorkers": 1, "txMessages": ["RIC_SUB_REQ", "RIC_SUB_DEL_REQ"], "rxMessages": ["RIC_SUB_RESP", "RIC_SUB_FAILURE", "RIC_SUB_DEL_RESP", "RIC_SUB_DEL_FAILURE", "RIC_INDICATION"] }, "db": { "host": "localhost", "port": 6379, "namespaces": ["sdl", "rnib"] }, "rtmgr" : { "HostAddr" : "localhost", "port" : "8989", "baseUrl" : "/" } ` cfgfilename,_ := testCreateTmpFile(cfgstr) defer os.Remove(cfgfilename) os.Setenv("CFG_FILE", cfgfilename) */ tent.Debug("Using cfg file %s", os.Getenv("CFG_FILE")) //--------------------------------- // Static routetable for rmr // // NOTE: Routing table is configured so, that responses // are duplicated to xapp1 and xapp2 instances. // If XID is not matching xapp stub will just // drop message. (Messages 12011, 12012, 12021, 12022) // // NOTE2: teststubPortSeed message type is for stub rmr connectivity probing // // NOTE3: Ports per entity: // // Entity // ------------------- mainsrc := teststub.RmrSrcId{xapp.RmrEndpoint{"localhost", 14560}} xapp1src := teststub.RmrSrcId{xapp.RmrEndpoint{"localhost", 13560}} xapp2src := teststub.RmrSrcId{xapp.RmrEndpoint{"localhost", 13660}} e2term1src := teststub.RmrSrcId{xapp.RmrEndpoint{"localhost", 15560}} e2term2src := teststub.RmrSrcId{xapp.RmrEndpoint{"localhost", 15660}} dummysrc := teststub.RmrSrcId{xapp.RmrEndpoint{"localhost", 16560}} //--------------------------------- rt := &teststub.RmrRouteTable{} rt.AddRoute(12010, "", -1, mainsrc.String()) rt.AddRoute(12010, mainsrc.String(), -1, "%meid") rt.AddRoute(12011, e2term1src.String(), -1, mainsrc.String()) rt.AddRoute(12012, e2term1src.String(), -1, mainsrc.String()) rt.AddRoute(12011, e2term2src.String(), -1, mainsrc.String()) rt.AddRoute(12012, e2term2src.String(), -1, mainsrc.String()) rt.AddRoute(12011, mainsrc.String(), -1, xapp2src.String()+";"+xapp1src.String()) rt.AddRoute(12012, mainsrc.String(), -1, xapp2src.String()+";"+xapp1src.String()) rt.AddRoute(12020, "", -1, mainsrc.String()) rt.AddRoute(12020, mainsrc.String(), -1, "%meid") rt.AddRoute(12021, e2term1src.String(), -1, mainsrc.String()) rt.AddRoute(12022, e2term1src.String(), -1, mainsrc.String()) rt.AddRoute(12021, e2term2src.String(), -1, mainsrc.String()) rt.AddRoute(12022, e2term2src.String(), -1, mainsrc.String()) rt.AddRoute(12021, mainsrc.String(), -1, xapp2src.String()+";"+xapp1src.String()) rt.AddRoute(12022, mainsrc.String(), -1, xapp2src.String()+";"+xapp1src.String()) rt.AddRoute(teststubPortSeed, "", -1, xapp2src.String()+";"+xapp1src.String()+";"+e2term1src.String()+";"+e2term2src.String()+";"+dummysrc.String()) rt.AddMeid(e2term1src.String(), []string{"RAN_NAME_1", "RAN_NAME_2"}) rt.AddMeid(e2term2src.String(), []string{"RAN_NAME_11", "RAN_NAME_12"}) rt.Enable() tent.Debug("rttable[%s]", rt.Table()) //--------------------------------- // //--------------------------------- tent.Debug("### submgr ctrl run ###") mainCtrl = createSubmgrControl(mainsrc, teststub.RmrRtgSvc{}) // // Tweak to get around with fact that alarm package alternates RMR_SEED_RT environment variable // //xapp-frame inits alarms when readycb is coming from xapps rmr //alarm will make new rmr instance and overrides RMR_SEED_RT and RMR_RTG_SVC //env variables. Re-create rt info. for i := 0; i < int(10)*2; i++ { if os.Getenv("RMR_SEED_RT") == rt.FileName() { tent.Debug("Waiting that alarm alternates RMR_SEED_RT=%s", os.Getenv("RMR_SEED_RT")) time.Sleep(500 * time.Millisecond) } else { tent.Debug("Alarm has alternated RMR_SEED_RT=%s, so waiting 0.5 secs before restoring it", os.Getenv("RMR_SEED_RT")) time.Sleep(500 * time.Millisecond) rt.Enable() tent.Debug("rttable[%s]", rt.Table()) break } } if os.Getenv("RMR_SEED_RT") != rt.FileName() { tent.Error("Unittest timing issue with alarm RMR_SEED_RT=%s", os.Getenv("RMR_SEED_RT")) os.Exit(1) } //--------------------------------- // //--------------------------------- tent.Debug("### xapp1 stub run ###") xappConn1 = teststube2ap.CreateNewE2Stub("xappstub1", xapp1src, teststub.RmrRtgSvc{}, "RMRXAPP1STUB", teststubPortSeed, "RAN_NAME_1", "localhost", 13560, 8080) //--------------------------------- // //--------------------------------- tent.Debug("### xapp2 stub run ###") xappConn2 = teststube2ap.CreateNewE2Stub("xappstub2", xapp2src, teststub.RmrRtgSvc{}, "RMRXAPP2STUB", teststubPortSeed, "RAN_NAME_2", "localhost", 13660, 8080) //--------------------------------- // //--------------------------------- tent.Debug("### e2term1 stub run ###") e2termConn1 = teststube2ap.CreateNewE2termStub("e2termstub1", e2term1src, teststub.RmrRtgSvc{}, "RMRE2TERMSTUB1", teststubPortSeed) //--------------------------------- // //--------------------------------- tent.Debug("### e2term2 stub run ###") e2termConn2 = teststube2ap.CreateNewE2termStub("e2termstub2", e2term2src, teststub.RmrRtgSvc{}, "RMRE2TERMSTUB2", teststubPortSeed) //--------------------------------- // Just to test dummy stub //--------------------------------- tent.Debug("### dummy stub run ###") dummystub = teststubdummy.CreateNewRmrDummyStub("dummystub", dummysrc, teststub.RmrRtgSvc{}, "DUMMYSTUB", teststubPortSeed) //--------------------------------- // Testing message sending //--------------------------------- if teststub.RmrStubControlWaitAlive(10, teststubPortSeed, mainCtrl.c.RMRClient, tent) == false { os.Exit(1) } if os.Getenv("RMR_SEED_RT") != rt.FileName() { tent.Error("Unittest timing issue with alarm RMR_SEED_RT=%s", os.Getenv("RMR_SEED_RT")) os.Exit(1) } return func() { rt.Disable() } } //----------------------------------------------------------------------------- // //----------------------------------------------------------------------------- func TestMain(m *testing.M) { CaseBegin("TestMain start") cleanfn := ut_test_init() code := m.Run() cleanfn() os.Exit(code) }