import (
"gerrit.o-ran-sc.org/r/ric-plt/submgr/pkg/teststub"
- "gerrit.o-ran-sc.org/r/ric-plt/submgr/pkg/xapptweaks"
"gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
"testing"
)
//-----------------------------------------------------------------------------
func (tc *RmrDummyStub) SendReq(t *testing.T, plen int) {
- tc.Logger.Info("SendReq")
+ tc.Info("SendReq")
len := plen
if len == 0 {
len = 100
}
- params := xapptweaks.NewParams(nil)
+ params := &xapp.RMRParams{}
params.Mtype = tc.reqMsg
params.SubId = -1
params.Xid = "TEST"
params.Mbuf = nil
- snderr := tc.RmrSend(params, 5)
+ snderr := tc.SendWithRetry(params, false, 5)
if snderr != nil {
tc.TestError(t, "%s", snderr.Error())
}
}
func (tc *RmrDummyStub) SendResp(t *testing.T, plen int) {
- tc.Logger.Info("SendReq")
+ tc.Info("SendReq")
len := plen
if len == 0 {
len = 100
}
- params := xapptweaks.NewParams(nil)
+ params := &xapp.RMRParams{}
params.Mtype = tc.respMsg
params.SubId = -1
params.Payload = make([]byte, len)
params.Xid = "TEST"
params.Mbuf = nil
- snderr := tc.RmrSend(params, 5)
+ snderr := tc.SendWithRetry(params, false, 5)
if snderr != nil {
tc.TestError(t, "%s", snderr.Error())
}
}
func (tc *RmrDummyStub) RecvReq(t *testing.T) bool {
- tc.Logger.Info("RecvReq")
+ tc.Info("RecvReq")
msg := tc.WaitMsg(15)
if msg != nil {
}
func (tc *RmrDummyStub) RecvResp(t *testing.T) bool {
- tc.Logger.Info("RecvResp")
+ tc.Info("RecvResp")
msg := tc.WaitMsg(15)
if msg != nil {