2 // Copyright 2019 AT&T Intellectual Property
3 // Copyright 2019 Nokia
5 // Licensed under the Apache License, Version 2.0 (the "License");
6 // you may not use this file except in compliance with the License.
7 // You may obtain a copy of the License at
9 // http://www.apache.org/licenses/LICENSE-2.0
11 // Unless required by applicable law or agreed to in writing, software
12 // distributed under the License is distributed on an "AS IS" BASIS,
13 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 // See the License for the specific language governing permissions and
15 // limitations under the License.
18 package httpmsghandlers
22 "e2mgr/e2managererrors"
27 "e2mgr/services/rmrsender"
30 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common"
31 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
32 "github.com/stretchr/testify/assert"
33 "github.com/stretchr/testify/mock"
38 func setupTest(t *testing.T) (*logger.Logger, *configuration.Configuration, *mocks.RnibReaderMock, *mocks.RnibWriterMock, services.RNibDataService, *mocks.RmrMessengerMock) {
40 config := configuration.ParseConfiguration()
42 readerMock := &mocks.RnibReaderMock{}
44 writerMock := &mocks.RnibWriterMock{}
46 rnibDataService := services.NewRnibDataService(log, config, readerMock, writerMock)
47 rmrMessengerMock := &mocks.RmrMessengerMock{}
48 return log, config, readerMock, writerMock, rnibDataService, rmrMessengerMock
51 func TestHandleBeforeTimerGetListNodebIdsFailedFlow(t *testing.T) {
52 log, config, readerMock, _, rnibDataService, rmrMessengerMock := setupTest(t)
54 handler := NewDeleteAllRequestHandler(log, getRmrSender(rmrMessengerMock, log), config, rnibDataService)
56 rnibErr := &common.ResourceNotFoundError{}
57 var nbIdentityList []*entities.NbIdentity
58 readerMock.On("GetListNodebIds").Return(nbIdentityList, rnibErr)
60 expected := &e2managererrors.RnibDbError{}
61 _, actual := handler.Handle(nil)
62 if reflect.TypeOf(actual) != reflect.TypeOf(expected) {
63 t.Errorf("Error actual = %v, and Expected = %v.", actual, expected)
67 func TestHandleAfterTimerGetListNodebIdsFailedFlow(t *testing.T) {
68 log, config, readerMock, writerMock, rnibDataService, rmrMessengerMock := setupTest(t)
70 config.BigRedButtonTimeoutSec = 1
72 handler := NewDeleteAllRequestHandler(log, getRmrSender(rmrMessengerMock, log), config, rnibDataService)
74 rnibErr := &common.ResourceNotFoundError{}
75 //Before timer: Disconnected->ShutDown, ShuttingDown->Ignore, Connected->ShuttingDown
76 nbIdentityList := createIdentityList()
78 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil).Return(nbIdentityList, rnibErr)
80 nb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_DISCONNECTED,}
81 nb2 := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
82 nb3 := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_CONNECTED,}
83 readerMock.On("GetNodeb", "RanName_1").Return(nb1, nil)
84 readerMock.On("GetNodeb", "RanName_2").Return(nb2, nil)
85 readerMock.On("GetNodeb", "RanName_3").Return(nb3, nil)
87 updatedNb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
88 updatedNb3 := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
89 writerMock.On("SaveNodeb", mock.Anything, updatedNb1).Return(nil)
90 writerMock.On("SaveNodeb", mock.Anything, updatedNb3).Return(nil)
92 expected := &e2managererrors.RnibDbError{}
93 _, actual := handler.Handle(nil)
95 if reflect.TypeOf(actual) != reflect.TypeOf(expected) {
96 t.Errorf("Error actual = %v, and Expected = %v.", actual, expected)
100 func TestHandleSuccessFlow(t *testing.T) {
101 log, config, readerMock, writerMock, rnibDataService, rmrMessengerMock := setupTest(t)
103 config.BigRedButtonTimeoutSec = 1
104 handler := NewDeleteAllRequestHandler(log, getRmrSender(rmrMessengerMock, log), config, rnibDataService)
106 //Before timer: Disconnected->ShutDown, ShuttingDown->Ignore, Connected->ShuttingDown
107 nbIdentityList := createIdentityList()
108 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil)
110 nb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_DISCONNECTED,}
111 nb2 := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
112 nb3 := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_CONNECTED,}
113 readerMock.On("GetNodeb", "RanName_1").Return(nb1, nil)
114 readerMock.On("GetNodeb", "RanName_2").Return(nb2, nil)
115 readerMock.On("GetNodeb", "RanName_3").Return(nb3, nil)
117 updatedNb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
118 updatedNb3 := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
119 writerMock.On("SaveNodeb", mock.Anything, updatedNb1).Return(nil)
120 writerMock.On("SaveNodeb", mock.Anything, updatedNb3).Return(nil)
122 //after timer: ShutDown->Ignore, ShuttingDown->ShutDown
123 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil)
125 nb1AfterTimer := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
126 nb2AfterTimer := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
127 nb3AfterTimer := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
128 readerMock.On("GetNodeb", "RanName_1").Return(nb1AfterTimer, nil)
129 readerMock.On("GetNodeb", "RanName_2").Return(nb2AfterTimer, nil)
130 readerMock.On("GetNodeb", "RanName_3").Return(nb3AfterTimer, nil)
132 updatedNb2AfterTimer := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
133 updatedNb3AfterTimer := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
134 writerMock.On("SaveNodeb", mock.Anything, updatedNb2AfterTimer).Return(nil)
135 writerMock.On("SaveNodeb", mock.Anything, updatedNb3AfterTimer).Return(nil)
137 mbuf := rmrCgo.NewMBuf(tests.MessageType, tests.MaxMsgSize, "RanName", &tests.DummyPayload, &tests.DummyXAction)
138 rmrMessengerMock.On("SendMsg", mock.AnythingOfType(fmt.Sprintf("%T", mbuf))).Return(mbuf, nil)
140 _, actual := handler.Handle(nil)
142 assert.Nil(t, actual)
145 func TestHandleSuccessGetNextStatusFlow(t *testing.T) {
146 log, config, readerMock, writerMock, rnibDataService, rmrMessengerMock := setupTest(t)
148 config.BigRedButtonTimeoutSec = 1
149 handler := NewDeleteAllRequestHandler(log, getRmrSender(rmrMessengerMock, log), config, rnibDataService)
151 nbIdentityList := []*entities.NbIdentity{{InventoryName: "RanName_1"}}
152 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil)
154 nb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_CONNECTED,}
155 readerMock.On("GetNodeb", "RanName_1").Return(nb1, nil)
157 updatedNb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
158 writerMock.On("SaveNodeb", mock.Anything, updatedNb1).Return(nil)
160 //after timer: ShutDown->Ignore, ShuttingDown->ShutDown
161 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil)
163 nb1AfterTimer := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
164 readerMock.On("GetNodeb", "RanName_1").Return(nb1AfterTimer, nil)
166 updatedNb1AfterTimer := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
167 writerMock.On("SaveNodeb", mock.Anything, updatedNb1AfterTimer).Return(nil)
169 mbuf := rmrCgo.NewMBuf(tests.MessageType, tests.MaxMsgSize, "RanName", &tests.DummyPayload, &tests.DummyXAction)
170 rmrMessengerMock.On("SendMsg", mock.AnythingOfType(fmt.Sprintf("%T", mbuf))).Return(mbuf, nil)
172 _, actual := handler.Handle(nil)
174 assert.Nil(t, actual)
177 func TestHandleShuttingDownStatusFlow(t *testing.T) {
178 log, config, readerMock, writerMock, rnibDataService, rmrMessengerMock := setupTest(t)
180 config.BigRedButtonTimeoutSec = 1
181 handler := NewDeleteAllRequestHandler(log, getRmrSender(rmrMessengerMock, log), config, rnibDataService)
183 nbIdentityList := []*entities.NbIdentity{{InventoryName: "RanName_1"}}
184 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil)
186 nb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
187 readerMock.On("GetNodeb", "RanName_1").Return(nb1, nil)
189 //after timer: ShutDown->Ignore, ShuttingDown->ShutDown
190 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil)
192 nb1AfterTimer := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
193 readerMock.On("GetNodeb", "RanName_1").Return(nb1AfterTimer, nil)
195 updatedNb1AfterTimer := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
196 writerMock.On("SaveNodeb", mock.Anything, updatedNb1AfterTimer).Return(nil)
198 mbuf := rmrCgo.NewMBuf(tests.MessageType, tests.MaxMsgSize, "RanName", &tests.DummyPayload, &tests.DummyXAction)
199 rmrMessengerMock.On("SendMsg", mock.AnythingOfType(fmt.Sprintf("%T", mbuf))).Return(mbuf, nil)
201 _, actual := handler.Handle(nil)
203 assert.Nil(t, actual)
206 func TestHandleGetNodebFailedFlow(t *testing.T) {
207 log, config, readerMock, writerMock, rnibDataService, rmrMessengerMock := setupTest(t)
209 config.BigRedButtonTimeoutSec = 1
210 handler := NewDeleteAllRequestHandler(log, getRmrSender(rmrMessengerMock, log), config, rnibDataService)
212 //Before timer: Disconnected->ShutDown(will fail), ShuttingDown->Ignore, Connected->ShuttingDown
213 nbIdentityList := createIdentityList()
214 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil)
216 errRnib := &common.ResourceNotFoundError{}
217 nb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_DISCONNECTED,}
218 nb2 := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
219 nb3 := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_CONNECTED,}
220 readerMock.On("GetNodeb", "RanName_1").Return(nb1, errRnib)
221 readerMock.On("GetNodeb", "RanName_2").Return(nb2, nil)
222 readerMock.On("GetNodeb", "RanName_3").Return(nb3, nil)
224 updatedNb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
225 updatedNb3 := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
226 writerMock.On("SaveNodeb", mock.Anything, updatedNb1).Return(errRnib)
227 writerMock.On("SaveNodeb", mock.Anything, updatedNb3).Return(nil)
229 //after timer: ShutDown->Ignore, ShuttingDown->ShutDown
230 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil)
232 nb1AfterTimer := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
233 nb2AfterTimer := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
234 nb3AfterTimer := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
235 readerMock.On("GetNodeb", "RanName_1").Return(nb1AfterTimer, errRnib)
236 readerMock.On("GetNodeb", "RanName_2").Return(nb2AfterTimer, nil)
237 readerMock.On("GetNodeb", "RanName_3").Return(nb3AfterTimer, nil)
239 updatedNb2AfterTimer := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
240 updatedNb3AfterTimer := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
241 writerMock.On("SaveNodeb", mock.Anything, updatedNb2AfterTimer).Return(nil)
242 writerMock.On("SaveNodeb", mock.Anything, updatedNb3AfterTimer).Return(nil)
244 mbuf := rmrCgo.NewMBuf(tests.MessageType, tests.MaxMsgSize, "RanName", &tests.DummyPayload, &tests.DummyXAction)
245 rmrMessengerMock.On("SendMsg", mock.AnythingOfType(fmt.Sprintf("%T", mbuf))).Return(mbuf, nil)
247 _, actual := handler.Handle(nil)
249 assert.Nil(t, actual)
252 func TestHandleSaveFailedFlow(t *testing.T) {
253 log, config, readerMock, writerMock, rnibDataService, rmrMessengerMock := setupTest(t)
255 config.BigRedButtonTimeoutSec = 1
256 handler := NewDeleteAllRequestHandler(log, getRmrSender(rmrMessengerMock, log), config, rnibDataService)
258 //Before timer: Disconnected->ShutDown, ShuttingDown->Ignore, Connected->ShuttingDown(will fail)
259 nbIdentityList := createIdentityList()
260 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil)
262 nb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_DISCONNECTED,}
263 nb2 := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
264 nb3 := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_CONNECTED,}
265 readerMock.On("GetNodeb", "RanName_1").Return(nb1, nil)
266 readerMock.On("GetNodeb", "RanName_2").Return(nb2, nil)
267 readerMock.On("GetNodeb", "RanName_3").Return(nb3, nil)
269 errRnib := &common.ResourceNotFoundError{}
270 updatedNb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
271 updatedNb3 := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
272 writerMock.On("SaveNodeb", mock.Anything, updatedNb1).Return(nil)
273 writerMock.On("SaveNodeb", mock.Anything, updatedNb3).Return(errRnib)
275 //after timer: ShutDown->Ignore, ShuttingDown->ShutDown(will fail)
276 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil)
278 nb1AfterTimer := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
279 nb2AfterTimer := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
280 nb3AfterTimer := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
281 readerMock.On("GetNodeb", "RanName_1").Return(nb1AfterTimer, nil)
282 readerMock.On("GetNodeb", "RanName_2").Return(nb2AfterTimer, nil)
283 readerMock.On("GetNodeb", "RanName_3").Return(nb3AfterTimer, nil)
285 updatedNb2AfterTimer := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
286 updatedNb3AfterTimer := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
287 writerMock.On("SaveNodeb", mock.Anything, updatedNb2AfterTimer).Return(nil)
288 writerMock.On("SaveNodeb", mock.Anything, updatedNb3AfterTimer).Return(errRnib)
290 mbuf := rmrCgo.NewMBuf(tests.MessageType, tests.MaxMsgSize, "RanName", &tests.DummyPayload, &tests.DummyXAction)
291 rmrMessengerMock.On("SendMsg", mock.AnythingOfType(fmt.Sprintf("%T", mbuf))).Return(mbuf, nil)
293 _, actual := handler.Handle(nil)
295 assert.Nil(t, actual)
298 func TestHandleSendRmrFailedFlow(t *testing.T) {
299 log, config, readerMock, writerMock, rnibDataService, rmrMessengerMock := setupTest(t)
301 config.BigRedButtonTimeoutSec = 1
302 handler := NewDeleteAllRequestHandler(log, getRmrSender(rmrMessengerMock, log), config, rnibDataService)
304 //Before timer: Disconnected->ShutDown, ShuttingDown->Ignore, Connected->ShuttingDown(will fail)
305 nbIdentityList := createIdentityList()
306 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil)
308 nb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_DISCONNECTED,}
309 nb2 := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
310 nb3 := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_CONNECTED,}
311 readerMock.On("GetNodeb", "RanName_1").Return(nb1, nil)
312 readerMock.On("GetNodeb", "RanName_2").Return(nb2, nil)
313 readerMock.On("GetNodeb", "RanName_3").Return(nb3, nil)
315 updatedNb1 := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
316 updatedNb3 := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
317 writerMock.On("SaveNodeb", mock.Anything, updatedNb1).Return(nil)
318 writerMock.On("SaveNodeb", mock.Anything, updatedNb3).Return(nil)
320 //after timer: ShutDown->Ignore, ShuttingDown->ShutDown(will fail)
321 readerMock.On("GetListNodebIds").Return(nbIdentityList, nil)
323 nb1AfterTimer := &entities.NodebInfo{RanName: "RanName_1", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
324 nb2AfterTimer := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
325 nb3AfterTimer := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
326 readerMock.On("GetNodeb", "RanName_1").Return(nb1AfterTimer, nil)
327 readerMock.On("GetNodeb", "RanName_2").Return(nb2AfterTimer, nil)
328 readerMock.On("GetNodeb", "RanName_3").Return(nb3AfterTimer, nil)
330 updatedNb2AfterTimer := &entities.NodebInfo{RanName: "RanName_2", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
331 updatedNb3AfterTimer := &entities.NodebInfo{RanName: "RanName_3", ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN,}
332 writerMock.On("SaveNodeb", mock.Anything, updatedNb2AfterTimer).Return(nil)
333 writerMock.On("SaveNodeb", mock.Anything, updatedNb3AfterTimer).Return(nil)
335 expected := e2managererrors.NewRmrError()
336 mbuf := rmrCgo.NewMBuf(tests.MessageType, tests.MaxMsgSize, "RanName", &tests.DummyPayload, &tests.DummyXAction)
337 rmrMessengerMock.On("SendMsg", mock.AnythingOfType(fmt.Sprintf("%T", mbuf))).Return(mbuf, expected)
339 _, actual := handler.Handle(nil)
341 if reflect.TypeOf(actual) != reflect.TypeOf(expected) {
342 t.Errorf("Error actual = %v, and Expected = %v.", actual, expected)
346 func TestHandleGetListEnbIdsEmptyFlow(t *testing.T) {
347 log, config, readerMock, _, rnibDataService, rmrMessengerMock := setupTest(t)
349 handler := NewDeleteAllRequestHandler(log, getRmrSender(rmrMessengerMock, log), config, rnibDataService)
352 nbIdentityList := []*entities.NbIdentity{}
354 readerMock.On("GetListNodebIds").Return(nbIdentityList, rnibError)
356 _, actual := handler.Handle(nil)
357 readerMock.AssertNumberOfCalls(t, "GetNodeb", 0)
358 assert.Nil(t, actual)
361 func createIdentityList() []*entities.NbIdentity {
362 nbIdentity1 := entities.NbIdentity{InventoryName: "RanName_1"}
363 nbIdentity2 := entities.NbIdentity{InventoryName: "RanName_2"}
364 nbIdentity3 := entities.NbIdentity{InventoryName: "RanName_3"}
366 var nbIdentityList []*entities.NbIdentity
367 nbIdentityList = append(nbIdentityList, &nbIdentity1)
368 nbIdentityList = append(nbIdentityList, &nbIdentity2)
369 nbIdentityList = append(nbIdentityList, &nbIdentity3)
371 return nbIdentityList
374 func initLog(t *testing.T) *logger.Logger {
375 log, err := logger.InitLogger(logger.InfoLevel)
377 t.Errorf("#initLog test - failed to initialize logger, error: %s", err)
382 func getRmrSender(rmrMessengerMock *mocks.RmrMessengerMock, log *logger.Logger) *rmrsender.RmrSender {
383 rmrMessenger := rmrCgo.RmrMessenger(rmrMessengerMock)
384 rmrMessengerMock.On("Init", tests.GetPort(), tests.MaxMsgSize, tests.Flags, log).Return(&rmrMessenger)
385 return rmrsender.NewRmrSender(log, rmrMessenger)