Change-Id: Iff676aba737712484942b593a03d19b113b06ffa
Signed-off-by: idanshal <idan.shalom@intl.att.com>
# The Jenkins job requires a tag to build the Docker image.
# Global-JJB script assumes this file is in the repo root.
---
# The Jenkins job requires a tag to build the Docker image.
# Global-JJB script assumes this file is in the repo root.
---
func (h E2TKeepAliveWorker) SendKeepAliveRequest() {
request := models.RmrMessage{MsgType: rmrCgo.E2_TERM_KEEP_ALIVE_REQ}
func (h E2TKeepAliveWorker) SendKeepAliveRequest() {
request := models.RmrMessage{MsgType: rmrCgo.E2_TERM_KEEP_ALIVE_REQ}
- h.rmrSender.SendWithoutLogs(&request)
+ h.rmrSender.Send(&request)
}
\ No newline at end of file
}
\ No newline at end of file
func TestSendKeepAliveRequest(t *testing.T) {
rmrMessengerMock, _, _, _, e2tKeepAliveWorker := initE2TKeepAliveTest(t)
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)
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) {
}
func TestShutdownExpiredE2T_InternalError(t *testing.T) {
readerMock.On("GetE2TAddresses").Return(addresses, nil)
readerMock.On("GetE2TInstances",addresses).Return([]*entities.E2TInstance{e2tInstance1}, nil)
e2tShutdownManagerMock.On("Shutdown", e2tInstance1).Return(nil)
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()
go e2tKeepAliveWorker.Execute()
var payload, xAction []byte
req := rmrCgo.NewMBuf(rmrCgo.E2_TERM_KEEP_ALIVE_REQ, 0, "", &payload, &xAction)
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
e2tShutdownManagerMock.AssertCalled(t, "Shutdown", e2tInstance1)
}
\ No newline at end of file