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"
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
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