X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fteststubdummy%2FstubRmrDummy.go;h=2520c54cee279549d183be28284fe4d12e23f384;hb=9dc5adc78d459157a42ef8997eeced82a3616f01;hp=b3b4352f766bef4380e14e6ba0de3ca3a7c8a691;hpb=f3f4efb9be78f25d3417ecbbce3ea988550e5381;p=ric-plt%2Fsubmgr.git diff --git a/pkg/teststubdummy/stubRmrDummy.go b/pkg/teststubdummy/stubRmrDummy.go index b3b4352..2520c54 100644 --- a/pkg/teststubdummy/stubRmrDummy.go +++ b/pkg/teststubdummy/stubRmrDummy.go @@ -25,7 +25,6 @@ package teststubdummy 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" ) @@ -55,12 +54,12 @@ func CreateNewRmrDummyStub(desc string, srcId teststub.RmrSrcId, rtgSvc teststub //----------------------------------------------------------------------------- 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 @@ -70,7 +69,7 @@ func (tc *RmrDummyStub) SendReq(t *testing.T, plen int) { 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()) } @@ -78,12 +77,12 @@ func (tc *RmrDummyStub) SendReq(t *testing.T, plen int) { } 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) @@ -92,7 +91,7 @@ func (tc *RmrDummyStub) SendResp(t *testing.T, plen int) { 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()) } @@ -100,7 +99,7 @@ func (tc *RmrDummyStub) SendResp(t *testing.T, plen int) { } func (tc *RmrDummyStub) RecvReq(t *testing.T) bool { - tc.Logger.Info("RecvReq") + tc.Info("RecvReq") msg := tc.WaitMsg(15) if msg != nil { @@ -116,7 +115,7 @@ func (tc *RmrDummyStub) RecvReq(t *testing.T) bool { } func (tc *RmrDummyStub) RecvResp(t *testing.T) bool { - tc.Logger.Info("RecvResp") + tc.Info("RecvResp") msg := tc.WaitMsg(15) if msg != nil {