Skip to content

Commit 129efa3

Browse files
committed
add thread mbox test code
1 parent f8bc186 commit 129efa3

File tree

1 file changed

+109
-0
lines changed

1 file changed

+109
-0
lines changed
Lines changed: 109 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,109 @@
1+
/*
2+
* Copyright (c) 2006-2025, RT-Thread Development Team
3+
*
4+
* SPDX-License-Identifier: Apache-2.0
5+
*
6+
* Change Logs:
7+
* Date Author Notes
8+
* 2025-07-03 rcitach test case for mbox
9+
*/
10+
11+
#include <rtthread.h>
12+
#include <rthw.h>
13+
#include <rtdevice.h>
14+
#include <utest.h>
15+
#include <utest_assert.h>
16+
#include <perf_tc.h>
17+
18+
static rt_sem_t sem1 = RT_NULL;
19+
static rt_sem_t complete_sem = RT_NULL;
20+
static rt_mailbox_t perf_thread_mbox = RT_NULL;
21+
22+
static void perf_thread_mbox1(void *parameter)
23+
{
24+
rt_ubase_t recv = 0;
25+
rt_err_t ret = RT_EOK;
26+
rt_perf_t *perf = (rt_perf_t *)parameter;
27+
while (1)
28+
{
29+
ret = rt_mb_recv(perf_thread_mbox, &recv, RT_WAITING_FOREVER);
30+
rt_perf_stop(perf);
31+
if (ret != RT_EOK)
32+
{
33+
LOG_E("mbox recv value error!\n");
34+
rt_mb_delete(perf_thread_mbox);
35+
return;
36+
}
37+
38+
if (perf->count >= UTEST_SYS_PERF_TC_COUNT)
39+
{
40+
rt_mb_delete(perf_thread_mbox);
41+
rt_sem_delete(sem1);
42+
return;
43+
}
44+
rt_sem_release(sem1);
45+
}
46+
}
47+
48+
static void perf_thread_mbox2(void *parameter)
49+
{
50+
rt_perf_t *perf = (rt_perf_t *)parameter;
51+
rt_err_t ret = RT_EOK;
52+
while (1)
53+
{
54+
if (perf->count >= UTEST_SYS_PERF_TC_COUNT)
55+
{
56+
rt_sem_release(complete_sem);
57+
return;
58+
}
59+
rt_sem_take(sem1, RT_WAITING_FOREVER);
60+
rt_perf_start(perf);
61+
rt_mb_send(perf_thread_mbox, 1);
62+
}
63+
}
64+
65+
rt_err_t rt_perf_thread_mbox(rt_perf_t *perf)
66+
{
67+
rt_thread_t thread1 = RT_NULL;
68+
rt_thread_t thread2 = RT_NULL;
69+
70+
# if __STDC_VERSION__ >= 199901L
71+
rt_strcpy(perf->name,__func__);
72+
#else
73+
rt_strcpy(perf->name,"rt_perf_thread_mbox");
74+
#endif
75+
76+
perf_thread_mbox = rt_mb_create("perf_thread_mbox", 1, RT_IPC_FLAG_PRIO);
77+
if (perf_thread_mbox == RT_NULL)
78+
{
79+
LOG_E("perf thread mbox create failed.");
80+
return -RT_ERROR;
81+
}
82+
83+
sem1 = rt_sem_create("sem1", 1, RT_IPC_FLAG_FIFO);
84+
complete_sem = rt_sem_create("complete", 0, RT_IPC_FLAG_FIFO);
85+
86+
thread1 = rt_thread_create("perf_thread_mbox1", perf_thread_mbox1, perf,
87+
THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE);
88+
if (thread1 == RT_NULL)
89+
{
90+
LOG_E("perf_thread_mbox1 create failed.");
91+
return -RT_ERROR;
92+
}
93+
94+
thread2 = rt_thread_create("perf_thread_mbox2", perf_thread_mbox2, perf,
95+
THREAD_STACK_SIZE, THREAD_PRIORITY + 1, THREAD_TIMESLICE);
96+
if (thread2 == RT_NULL)
97+
{
98+
LOG_E("perf_thread_mbox2 create failed.");
99+
return -RT_ERROR;
100+
}
101+
102+
rt_thread_startup(thread1);
103+
rt_thread_startup(thread2);
104+
105+
rt_sem_take(complete_sem, RT_WAITING_FOREVER);
106+
rt_perf_dump(perf);
107+
rt_sem_delete(complete_sem);
108+
return RT_EOK;
109+
}

0 commit comments

Comments
 (0)