Code Review
/
ric-plt
/
xapp-frame-py.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fixes typo in `examples/pong_xapp.py`
[ric-plt/xapp-frame-py.git]
/
tests
/
test_rmr.py
diff --git
a/tests/test_rmr.py
b/tests/test_rmr.py
index
614e839
..
70d1c34
100644
(file)
--- a/
tests/test_rmr.py
+++ b/
tests/test_rmr.py
@@
-165,7
+165,7
@@
def test_rcv_timeout():
summary = rmr.message_summary(sbuf_rcv)
assert summary[rmr.RMR_MS_MSG_STATE] == rmr.RMR_ERR_TIMEOUT
assert summary[rmr.RMR_MS_MSG_STATUS] == "RMR_ERR_TIMEOUT"
summary = rmr.message_summary(sbuf_rcv)
assert summary[rmr.RMR_MS_MSG_STATE] == rmr.RMR_ERR_TIMEOUT
assert summary[rmr.RMR_MS_MSG_STATUS] == "RMR_ERR_TIMEOUT"
- assert(time.time() - start_rcv_sec > 0.5) # test duration should be longer than the timeout
+ assert
(time.time() - start_rcv_sec > 0.5) # test duration should be longer than the timeout
def test_send_rcv():
def test_send_rcv():
@@
-325,12
+325,12
@@
def test_rcv_all():
start_rcv_sec = time.time()
bundle = helpers.rmr_rcvall_msgs(MRC_RCV, timeout=1001) # non-zero timeout means wait
assert len(bundle) == 0 # we should get none
start_rcv_sec = time.time()
bundle = helpers.rmr_rcvall_msgs(MRC_RCV, timeout=1001) # non-zero timeout means wait
assert len(bundle) == 0 # we should get none
- assert(time.time() - start_rcv_sec > 1) # test duration should be longer than 1 second
+ assert
(time.time() - start_rcv_sec > 1) # test duration should be longer than 1 second
start_rcv_sec = time.time()
bundle = helpers.rmr_rcvall_msgs_raw(MRC_RCV, timeout=1002) # non-zero timeout means wait
assert len(bundle) == 0 # we should get none
start_rcv_sec = time.time()
bundle = helpers.rmr_rcvall_msgs_raw(MRC_RCV, timeout=1002) # non-zero timeout means wait
assert len(bundle) == 0 # we should get none
- assert(time.time() - start_rcv_sec > 1) # test duration should be longer than 1 second
+ assert
(time.time() - start_rcv_sec > 1) # test duration should be longer than 1 second
def test_bad_buffer():
def test_bad_buffer():
@@
-388,6
+388,13
@@
def test_wh():
assert send_summary[rmr.RMR_MS_MSG_TYPE] == rcv_summary[rmr.RMR_MS_MSG_TYPE] == mtype
assert send_summary[rmr.RMR_MS_PAYLOAD] == rcv_summary[rmr.RMR_MS_PAYLOAD] == payload
assert send_summary[rmr.RMR_MS_MSG_TYPE] == rcv_summary[rmr.RMR_MS_MSG_TYPE] == mtype
assert send_summary[rmr.RMR_MS_PAYLOAD] == rcv_summary[rmr.RMR_MS_PAYLOAD] == payload
+ sbuf_send = rmr.rmr_alloc_msg(MRC_SEND, SIZE)
+ _assert_new_sbuf(sbuf_send)
+ mtype = 1
+ sbuf_send.contents.mtype = mtype
+ payload = b"Birds like worms"
+ rmr.set_payload_and_length(payload, sbuf_send)
+
# send without waiting for a response
rmr.rmr_wh_send_msg(MRC_SEND, whid, sbuf_send)
# send without waiting for a response
rmr.rmr_wh_send_msg(MRC_SEND, whid, sbuf_send)