X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fteststub%2FcontrolRmrStub.go;h=05a8e32206c1a68212ab2afc605920a836180608;hb=429cfe6e2302ee69e067402489660f8e22319eeb;hp=a8c861f6c1e3cace3bc5edef7fe261363716ce53;hpb=5f8ffa07163f52d65092d63f5d173149cd5c46ad;p=ric-plt%2Fsubmgr.git

diff --git a/pkg/teststub/controlRmrStub.go b/pkg/teststub/controlRmrStub.go
index a8c861f..05a8e32 100644
--- a/pkg/teststub/controlRmrStub.go
+++ b/pkg/teststub/controlRmrStub.go
@@ -74,7 +74,7 @@ func (tc *RmrStubControl) Init(desc string, rtfile string, port string, stat str
 	tc.RmrControl.Init(desc, rtfile, port)
 	tc.RmrWrapper.Init()
 
-	tc.Rmr = xapp.NewRMRClientWithParams("tcp:"+port, 4096, 1, stat)
+	tc.Rmr = xapp.NewRMRClientWithParams("tcp:"+port, 65534, 1, 0, stat)
 	tc.Rmr.SetReadyCB(tc.ReadyCB, nil)
 	go tc.Rmr.Start(tc)
 
@@ -147,12 +147,16 @@ func RmrStubControlWaitAlive(seconds int, mtype int, rmr xapptweaks.XAppWrapperI
 	params.Xid = "TESTPING"
 	params.Mbuf = nil
 
+	if len(allRmrStubs) == 0 {
+		rmr.GetLogger().Info("No rmr stubs so no need to wait those to be alive")
+		return true
+	}
 	status := false
 	i := 1
 	for ; i <= seconds*2 && status == false; i++ {
 
 		rmr.GetLogger().Info("SEND TESTPING: %s", params.String())
-		rmr.RmrSend(params)
+		rmr.RmrSend(params, 0)
 
 		status = true
 		for _, val := range allRmrStubs {