Code Review
/
ric-plt
/
submgr.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Some cleaning and bug fixes
[ric-plt/submgr.git]
/
pkg
/
control
/
ut_messaging_test.go
diff --git
a/pkg/control/ut_messaging_test.go
b/pkg/control/ut_messaging_test.go
index
40207b3
..
2e8bc0e
100644
(file)
--- a/
pkg/control/ut_messaging_test.go
+++ b/
pkg/control/ut_messaging_test.go
@@
-56,7
+56,7
@@
func TestSubReqAndRouteNok(t *testing.T) {
waiter.WaitResult(t)
//Wait that subs is cleaned
waiter.WaitResult(t)
//Wait that subs is cleaned
- mainCtrl.wait_subs_clean(t,
int(newSubsId)
, 10)
+ mainCtrl.wait_subs_clean(t,
newSubsId
, 10)
xappConn1.TestMsgCnt(t)
xappConn2.TestMsgCnt(t)
xappConn1.TestMsgCnt(t)
xappConn2.TestMsgCnt(t)
@@
-585,7
+585,7
@@
func TestSubReqRetryNoRespSubDelRespInSubmgr(t *testing.T) {
e2termConn.handle_e2term_subs_del_resp(t, delreq, delmsg)
// Wait that subs is cleaned
e2termConn.handle_e2term_subs_del_resp(t, delreq, delmsg)
// Wait that subs is cleaned
- mainCtrl.wait_subs_clean(t,
int(delreq.RequestId.Seq)
, 10)
+ mainCtrl.wait_subs_clean(t,
delreq.RequestId.Seq
, 10)
xappConn1.TestMsgCnt(t)
xappConn2.TestMsgCnt(t)
xappConn1.TestMsgCnt(t)
xappConn2.TestMsgCnt(t)
@@
-642,7
+642,7
@@
func TestSubReqTwoRetriesNoRespAtAllInSubmgr(t *testing.T) {
delreq, _ := e2termConn.handle_e2term_subs_del_req(t)
// Wait that subs is cleaned
delreq, _ := e2termConn.handle_e2term_subs_del_req(t)
// Wait that subs is cleaned
- mainCtrl.wait_subs_clean(t,
int(delreq.RequestId.Seq)
, 15)
+ mainCtrl.wait_subs_clean(t,
delreq.RequestId.Seq
, 15)
xappConn1.TestMsgCnt(t)
xappConn2.TestMsgCnt(t)
xappConn1.TestMsgCnt(t)
xappConn2.TestMsgCnt(t)
@@
-1156,7
+1156,7
@@
func TestSubReqAndSubDelNoAnswerSameActionParallel(t *testing.T) {
e2termConn.handle_e2term_subs_del_resp(t, delreq1, delmsg1)
//Wait that subs is cleaned
e2termConn.handle_e2term_subs_del_resp(t, delreq1, delmsg1)
//Wait that subs is cleaned
- mainCtrl.wait_subs_clean(t,
int(delreq1.RequestId.Seq)
, 10)
+ mainCtrl.wait_subs_clean(t,
delreq1.RequestId.Seq
, 10)
xappConn1.TestMsgCnt(t)
xappConn2.TestMsgCnt(t)
xappConn1.TestMsgCnt(t)
xappConn2.TestMsgCnt(t)