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)
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 {