Lines Matching refs:ret
39 rt_err_t ret; in test_mq_init() local
40 ret = rt_mq_init(&static_mq,"testmq1", mq_buf, MSG_SIZE, sizeof(mq_buf), RT_IPC_FLAG_FIFO); in test_mq_init()
41 uassert_true(ret == RT_EOK); in test_mq_init()
55 rt_err_t ret = RT_EOK; in mq_send_case() local
60 ret = rt_mq_send_wait(testmq, &send_buf[var], sizeof(send_buf[0]), RT_WAITING_FOREVER); in mq_send_case()
61 uassert_true(ret == RT_EOK); in mq_send_case()
64 ret = rt_mq_send(testmq, &send_buf[MAX_MSGS], sizeof(send_buf[0])); in mq_send_case()
65 uassert_true(ret == -RT_EFULL); in mq_send_case()
67 ret = rt_mq_send_wait(testmq, &send_buf[MAX_MSGS], sizeof(send_buf[0]), RT_WAITING_FOREVER); in mq_send_case()
68 uassert_true(ret == RT_EOK); in mq_send_case()
75 ret = rt_mq_send(testmq, &send_buf[1], sizeof(send_buf[0])); in mq_send_case()
76 uassert_true(ret == RT_EOK); in mq_send_case()
78 ret = rt_mq_send(testmq, &send_buf[2], sizeof(send_buf[0])); in mq_send_case()
79 uassert_true(ret == RT_EOK); in mq_send_case()
81 ret = rt_mq_urgent(testmq, &send_buf[0], sizeof(send_buf[0])); in mq_send_case()
82 uassert_true(ret == RT_EOK); in mq_send_case()
90 ret = rt_mq_send_wait_prio(testmq, &send_buf[3], sizeof(send_buf[0]), 3, 0, RT_UNINTERRUPTIBLE); in mq_send_case()
91 uassert_true(ret == RT_EOK); in mq_send_case()
92 ret = rt_mq_send_wait_prio(testmq, &send_buf[0], sizeof(send_buf[0]), 0, 0, RT_UNINTERRUPTIBLE); in mq_send_case()
93 uassert_true(ret == RT_EOK); in mq_send_case()
95 ret = rt_mq_send_wait_prio(testmq, &send_buf[2], sizeof(send_buf[0]), 1, 0, RT_UNINTERRUPTIBLE); in mq_send_case()
96 uassert_true(ret == RT_EOK); in mq_send_case()
97 ret = rt_mq_send_wait_prio(testmq, &send_buf[4], sizeof(send_buf[0]), 4, 0, RT_UNINTERRUPTIBLE); in mq_send_case()
98 uassert_true(ret == RT_EOK); in mq_send_case()
99 ret = rt_mq_send_wait_prio(testmq, &send_buf[1], sizeof(send_buf[0]), 1, 0, RT_UNINTERRUPTIBLE); in mq_send_case()
100 uassert_true(ret == RT_EOK); in mq_send_case()
108 ret = rt_mq_send(testmq, &send_buf[1], sizeof(send_buf[0])); in mq_send_case()
109 uassert_true(ret == RT_EOK); in mq_send_case()
110 ret = rt_mq_control(testmq, RT_IPC_CMD_RESET, RT_NULL); in mq_send_case()
111 uassert_true(ret == RT_EOK); in mq_send_case()
132 rt_ssize_t ret = RT_EOK; in mq_recv_case() local
136 ret = rt_mq_recv(testmq, &recv_buf[var], sizeof(recv_buf[0]), RT_WAITING_FOREVER); in mq_recv_case()
137 uassert_true(ret >= 0); in mq_recv_case()
143 ret = rt_mq_recv(testmq, &recv_buf[var], sizeof(recv_buf[0]), RT_WAITING_FOREVER); in mq_recv_case()
144 uassert_true(ret >= 0); in mq_recv_case()
155 …ret = rt_mq_recv_prio(testmq, &recv_buf[var], sizeof(recv_buf[0]), &msg_prio, RT_WAITING_FOREVER, … in mq_recv_case()
157 uassert_true(ret >= 0); in mq_recv_case()
186 rt_err_t ret = rt_mq_detach(&static_mq); in test_mq_detach() local
187 uassert_true(ret == RT_EOK); in test_mq_detach()
193 rt_err_t ret = rt_mq_delete(dynamic_mq); in test_mq_delete() local
194 uassert_true(ret == RT_EOK); in test_mq_delete()
200 rt_err_t ret ; in utest_tc_init() local
201 …ret = rt_thread_init(&mq_send_thread, "mq_send", mq_send_entry, RT_NULL, mq_send_stack, sizeof(mq_… in utest_tc_init()
202 if(ret != RT_EOK) in utest_tc_init()
205 …ret = rt_thread_init(&mq_recv_thread, "mq_recv", mq_recv_entry, RT_NULL, mq_recv_stack, sizeof(mq_… in utest_tc_init()
206 if(ret != RT_EOK) in utest_tc_init()
214 ret = rt_event_init(&finish_e, "finish", RT_IPC_FLAG_FIFO); in utest_tc_init()
215 if(ret != RT_EOK) in utest_tc_init()