X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fteststub%2FcontrolRmrStub.go;fp=pkg%2Fteststub%2FcontrolRmrStub.go;h=f14bd1fd386b4a363390bb91e288b714f9b691ec;hb=7348625b9ef03d41dd5a0ca0f6c508376259717e;hp=05a8e32206c1a68212ab2afc605920a836180608;hpb=ad41feaeb9dde8ccd6b8b508eb3df8df5d207134;p=ric-plt%2Fsubmgr.git diff --git a/pkg/teststub/controlRmrStub.go b/pkg/teststub/controlRmrStub.go index 05a8e32..f14bd1f 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, rtfile string, port uint16, rtport uint16, 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, rtfile, port, rtport) tc.RmrWrapper.Init() - tc.Rmr = xapp.NewRMRClientWithParams("tcp:"+port, 65534, 1, 0, stat) + tc.Rmr = xapp.NewRMRClientWithParams("tcp:"+strconv.FormatUint(uint64(port), 10), 65534, 1, 0, stat) tc.Rmr.SetReadyCB(tc.ReadyCB, nil) go tc.Rmr.Start(tc)