X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=tests%2Ftest_rmr.py;h=70d1c34e9377fe0d26b74476d2fb0f9bbf2b4adb;hb=bc44805e53a5c84a32c4dfe09d32fe4d503acaca;hp=614e839c22a4e257c78d47cd107e82d52c57f67a;hpb=884192bf7ab8d637e8007760fbe50dbcdccd4671;p=ric-plt%2Fxapp-frame-py.git

diff --git a/tests/test_rmr.py b/tests/test_rmr.py
index 614e839..70d1c34 100644
--- 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"
-    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():
@@ -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
-    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
-    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():
@@ -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
 
+    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)