X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fteststub%2FcontrolRmrStub.go;h=0f207e833cb0c05e65b1cd81635fa3fcb2471ffa;hb=cd78aeeae3212fa722be4ba9768cac711305badf;hp=05a8e32206c1a68212ab2afc605920a836180608;hpb=c2a6b3a80ba41f292e0fa31334e53ab278d103fe;p=ric-plt%2Fsubmgr.git diff --git a/pkg/teststub/controlRmrStub.go b/pkg/teststub/controlRmrStub.go index 05a8e32..0f207e8 100644 --- a/pkg/teststub/controlRmrStub.go +++ b/pkg/teststub/controlRmrStub.go @@ -21,6 +21,7 @@ package teststub import ( "gerrit.o-ran-sc.org/r/ric-plt/submgr/pkg/xapptweaks" "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" + "strconv" "strings" "testing" "time" @@ -67,14 +68,14 @@ func (tc *RmrStubControl) TestMsgChanEmpty(t *testing.T) { } } -func (tc *RmrStubControl) Init(desc string, rtfile string, port string, stat string, initMsg int) { +func (tc *RmrStubControl) Init(desc string, srcId RmrSrcId, rtgSvc RmrRtgSvc, stat string, initMsg int) { tc.InitMsg = initMsg tc.Active = false tc.RecvChan = make(chan *xapptweaks.RMRParams) - tc.RmrControl.Init(desc, rtfile, port) + tc.RmrControl.Init(desc, srcId, rtgSvc) tc.RmrWrapper.Init() - tc.Rmr = xapp.NewRMRClientWithParams("tcp:"+port, 65534, 1, 0, stat) + tc.Rmr = xapp.NewRMRClientWithParams("tcp:"+strconv.FormatUint(uint64(srcId.Port), 10), 65534, 1, 0, stat) tc.Rmr.SetReadyCB(tc.ReadyCB, nil) go tc.Rmr.Start(tc)