X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fmanagers%2Fe2t_keep_alive_worker_test.go;h=c15aedbb3b9880075b6ba4c696575b314cb87a8e;hb=9b5156ceeeca10c0039016761182f31aeaf2b39c;hp=21d26b7a94e0d697980f72dcf2450acb89c7b3e1;hpb=49144464f0450ce157a716010cbbd7c3143d332f;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/managers/e2t_keep_alive_worker_test.go b/E2Manager/managers/e2t_keep_alive_worker_test.go index 21d26b7..c15aedb 100644 --- a/E2Manager/managers/e2t_keep_alive_worker_test.go +++ b/E2Manager/managers/e2t_keep_alive_worker_test.go @@ -32,6 +32,7 @@ import ( "github.com/stretchr/testify/mock" "testing" "time" + "unsafe" ) func initE2TKeepAliveTest(t *testing.T) (*mocks.RmrMessengerMock, *mocks.RnibReaderMock, *mocks.RnibWriterMock, *mocks.E2TShutdownManagerMock, *E2TKeepAliveWorker) { @@ -64,7 +65,8 @@ func TestSendKeepAliveRequest(t *testing.T) { e2tKeepAliveWorker.SendKeepAliveRequest() var payload, xAction []byte - req := rmrCgo.NewMBuf(rmrCgo.E2_TERM_KEEP_ALIVE_REQ, 0, "", &payload, &xAction) + var msgSrc unsafe.Pointer + req := rmrCgo.NewMBuf(rmrCgo.E2_TERM_KEEP_ALIVE_REQ, 0, "", &payload, &xAction, msgSrc) rmrMessengerMock.AssertCalled(t, "SendMsg", req, false) } @@ -195,7 +197,8 @@ func TestExecute_Two_E2TExpired(t *testing.T) { time.Sleep(time.Duration(500) * time.Millisecond) var payload, xAction []byte - req := rmrCgo.NewMBuf(rmrCgo.E2_TERM_KEEP_ALIVE_REQ, 0, "", &payload, &xAction) + var msgSrc unsafe.Pointer + req := rmrCgo.NewMBuf(rmrCgo.E2_TERM_KEEP_ALIVE_REQ, 0, "", &payload, &xAction, msgSrc) rmrMessengerMock.AssertCalled(t, "SendMsg", req, false) e2tShutdownManagerMock.AssertCalled(t, "Shutdown", e2tInstance1)