X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fmanagers%2Fe2t_keep_alive_worker_test.go;fp=E2Manager%2Fmanagers%2Fe2t_keep_alive_worker_test.go;h=d6a2fb0089551f664ce112a7a36dfc30a9543cb6;hb=9c0ec49990e7b83e59c34365dfaa0500da6acc52;hp=0100f285d1ac6257c3be722b9bdb6052466e8d7a;hpb=380b7a2a46087a054ebfac57f3dbf7949d318cc6;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 0100f28..d6a2fb0 100644 --- a/E2Manager/managers/e2t_keep_alive_worker_test.go +++ b/E2Manager/managers/e2t_keep_alive_worker_test.go @@ -59,14 +59,14 @@ func initE2TKeepAliveTest(t *testing.T) (*mocks.RmrMessengerMock, *mocks.RnibRea func TestSendKeepAliveRequest(t *testing.T) { rmrMessengerMock, _, _, _, e2tKeepAliveWorker := initE2TKeepAliveTest(t) - rmrMessengerMock.On("SendMsg", mock.Anything, false).Return(&rmrCgo.MBuf{}, nil) + rmrMessengerMock.On("SendMsg", mock.Anything, true).Return(&rmrCgo.MBuf{}, nil) e2tKeepAliveWorker.SendKeepAliveRequest() var payload, xAction []byte req := rmrCgo.NewMBuf(rmrCgo.E2_TERM_KEEP_ALIVE_REQ, 0, "", &payload, &xAction) - rmrMessengerMock.AssertCalled(t, "SendMsg", req, false) + rmrMessengerMock.AssertCalled(t, "SendMsg", req, true) } func TestShutdownExpiredE2T_InternalError(t *testing.T) { @@ -188,7 +188,7 @@ func TestExecute_Two_E2TExpired(t *testing.T) { readerMock.On("GetE2TAddresses").Return(addresses, nil) readerMock.On("GetE2TInstances",addresses).Return([]*entities.E2TInstance{e2tInstance1}, nil) e2tShutdownManagerMock.On("Shutdown", e2tInstance1).Return(nil) - rmrMessengerMock.On("SendMsg", mock.Anything, false).Return(&rmrCgo.MBuf{}, nil) + rmrMessengerMock.On("SendMsg", mock.Anything, true).Return(&rmrCgo.MBuf{}, nil) go e2tKeepAliveWorker.Execute() @@ -197,6 +197,6 @@ func TestExecute_Two_E2TExpired(t *testing.T) { var payload, xAction []byte req := rmrCgo.NewMBuf(rmrCgo.E2_TERM_KEEP_ALIVE_REQ, 0, "", &payload, &xAction) - rmrMessengerMock.AssertCalled(t, "SendMsg", req, false) + rmrMessengerMock.AssertCalled(t, "SendMsg", req, true) e2tShutdownManagerMock.AssertCalled(t, "Shutdown", e2tInstance1) } \ No newline at end of file