X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fservices%2Frmrsender%2Frmr_sender_test.go;h=0c0129c69c6cf786eb293cdbc71576c76563a491;hb=a07b8597afc9d063a7f37a376a5bcf29ba29b557;hp=bc45307542fe433b8fa9bdb51fd767defd9a9fe7;hpb=efcb4528362460aa2249d319c9752b63bb720fe2;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/services/rmrsender/rmr_sender_test.go b/E2Manager/services/rmrsender/rmr_sender_test.go index bc45307..0c0129c 100644 --- a/E2Manager/services/rmrsender/rmr_sender_test.go +++ b/E2Manager/services/rmrsender/rmr_sender_test.go @@ -28,6 +28,7 @@ import ( "fmt" "github.com/stretchr/testify/assert" "testing" + "unsafe" ) func initRmrSenderTest(t *testing.T) (*logger.Logger, *mocks.RmrMessengerMock) { @@ -54,9 +55,10 @@ func TestRmrSenderSendSuccess(t *testing.T) { ranName := "test" payload := []byte("some payload") var xAction []byte - mbuf := rmrCgo.NewMBuf(123, len(payload), ranName, &payload, &xAction) + var msgSrc unsafe.Pointer + mbuf := rmrCgo.NewMBuf(123, len(payload), ranName, &payload, &xAction, msgSrc) rmrMessengerMock.On("SendMsg", mbuf, true).Return(&rmrCgo.MBuf{}, nil) - rmrMsg := models.NewRmrMessage(123, ranName, payload, xAction) + rmrMsg := models.NewRmrMessage(123, ranName, payload, xAction, nil) rmrMessenger := rmrCgo.RmrMessenger(rmrMessengerMock) rmrSender := NewRmrSender(logger, rmrMessenger) err := rmrSender.Send(rmrMsg) @@ -71,9 +73,10 @@ func TestRmrSenderSendFailure(t *testing.T) { ranName := "test" payload := []byte("some payload") var xAction []byte - mbuf := rmrCgo.NewMBuf(123, len(payload), ranName, &payload, &xAction) + var msgSrc unsafe.Pointer + mbuf := rmrCgo.NewMBuf(123, len(payload), ranName, &payload, &xAction, msgSrc) rmrMessengerMock.On("SendMsg", mbuf, true).Return(mbuf, fmt.Errorf("rmr send failure")) - rmrMsg := models.NewRmrMessage(123, ranName, payload, xAction) + rmrMsg := models.NewRmrMessage(123, ranName, payload, xAction, nil) rmrMessenger := rmrCgo.RmrMessenger(rmrMessengerMock) rmrSender := NewRmrSender(logger, rmrMessenger) err := rmrSender.Send(rmrMsg)