1 /*
2  * Copyright (c) 2006-2023, RT-Thread Development Team
3  *
4  * SPDX-License-Identifier: Apache-2.0
5  *
6  * Change Logs:
7  * Date           Author       Notes
8  * 2023-11-20     Shell        add test suites
9  */
10 
11 #include "common.h"
12 #include "utest_assert.h"
13 
14 #include <rtdevice.h>
15 #include <rtdef.h>
16 #define STACK_SIZE (0x2000)
17 
18 static struct rt_mutex _local_mtx;
19 static struct rt_condvar _local_cv;
20 
waker_thr(void * param)21 static void waker_thr(void *param)
22 {
23     int err;
24     rt_mutex_t mutex = &_local_mtx;
25     rt_condvar_t cond = &_local_cv;
26     rt_mutex_take(mutex, RT_WAITING_FOREVER);
27     err = rt_condvar_signal(cond);
28 
29     if (err != 0)
30     {
31         LOG_E("errno=%d, ret=%d\n", errno, err);
32         LOG_E("rt_condvar_signal() error");
33         uassert_false(1);
34     }
35     else
36     {
37         uassert_false(0);
38     }
39     rt_mutex_release(mutex);
40 
41     return;
42 }
43 
condvar_signal_tc(void)44 static void condvar_signal_tc(void)
45 {
46     rt_thread_t waker;
47     rt_mutex_t mutex = &_local_mtx;
48     rt_condvar_t cond = &_local_cv;
49     int err;
50 
51     waker = rt_thread_create("waker", waker_thr, 0, STACK_SIZE, 25, 50);
52     uassert_not_null(waker);
53 
54     if (rt_mutex_take(mutex, RT_WAITING_FOREVER) != 0)
55     {
56         LOG_E("pthread_mutex_lock() error");
57         uassert_false(1);
58         return;
59     }
60     else
61     {
62         uassert_false(0);
63     }
64 
65     rt_thread_startup(waker);
66 
67     err = rt_condvar_timedwait(cond, mutex, RT_KILLABLE, 100);
68     if (err != 0)
69     {
70         if (err == -EINTR || err == -ETIMEDOUT)
71         {
72             puts("wait timed out");
73             uassert_false(0);
74         }
75         else
76         {
77             LOG_E("errno=%d, ret=%d\n", errno, err);
78             LOG_E("pthread_cond_timedwait() error");
79             uassert_false(1);
80         }
81     }
82 
83     err = rt_mutex_release(mutex);
84     if (err != 0)
85     {
86         LOG_E("errno=%d, ret=%d\n", errno, err);
87         LOG_E("rt_mutex_release() error");
88         uassert_false(1);
89     }
90     else
91     {
92         uassert_false(0);
93     }
94 
95     return ;
96 }
97 
utest_tc_init(void)98 static rt_err_t utest_tc_init(void)
99 {
100     if (rt_mutex_init(&_local_mtx, "utest", RT_IPC_FLAG_PRIO) != 0)
101     {
102         perror("pthread_mutex_init() error");
103         uassert_false(1);
104         return -1;
105     }
106 
107     rt_condvar_init(&_local_cv, NULL);
108     return RT_EOK;
109 }
110 
utest_tc_cleanup(void)111 static rt_err_t utest_tc_cleanup(void)
112 {
113     rt_mutex_detach(&_local_mtx);
114     rt_condvar_detach(&_local_cv);
115     return RT_EOK;
116 }
117 
testcase(void)118 static void testcase(void)
119 {
120     UTEST_UNIT_RUN(condvar_signal_tc);
121 }
122 UTEST_TC_EXPORT(testcase, "testcases.ipc.condvar.signal", utest_tc_init, utest_tc_cleanup, 10);
123