1*10465441SEvalZero /*
2*10465441SEvalZero * Copyright (c) 2006-2018, RT-Thread Development Team
3*10465441SEvalZero *
4*10465441SEvalZero * SPDX-License-Identifier: Apache-2.0
5*10465441SEvalZero *
6*10465441SEvalZero * Change Logs:
7*10465441SEvalZero * Date Author Notes
8*10465441SEvalZero * 2018/06/26 Bernard Fix the wait queue issue when wakeup a soon
9*10465441SEvalZero * to blocked thread.
10*10465441SEvalZero */
11*10465441SEvalZero
12*10465441SEvalZero #ifndef WAITQUEUE_H__
13*10465441SEvalZero #define WAITQUEUE_H__
14*10465441SEvalZero
15*10465441SEvalZero #include <rtthread.h>
16*10465441SEvalZero
17*10465441SEvalZero #define RT_WQ_FLAG_CLEAN 0x00
18*10465441SEvalZero #define RT_WQ_FLAG_WAKEUP 0x01
19*10465441SEvalZero
20*10465441SEvalZero struct rt_wqueue_node;
21*10465441SEvalZero typedef int (*rt_wqueue_func_t)(struct rt_wqueue_node *wait, void *key);
22*10465441SEvalZero
23*10465441SEvalZero struct rt_wqueue_node
24*10465441SEvalZero {
25*10465441SEvalZero rt_thread_t polling_thread;
26*10465441SEvalZero rt_list_t list;
27*10465441SEvalZero
28*10465441SEvalZero rt_wqueue_func_t wakeup;
29*10465441SEvalZero rt_uint32_t key;
30*10465441SEvalZero };
31*10465441SEvalZero typedef struct rt_wqueue_node rt_wqueue_node_t;
32*10465441SEvalZero
33*10465441SEvalZero int __wqueue_default_wake(struct rt_wqueue_node *wait, void *key);
34*10465441SEvalZero
rt_wqueue_init(rt_wqueue_t * queue)35*10465441SEvalZero rt_inline void rt_wqueue_init(rt_wqueue_t *queue)
36*10465441SEvalZero {
37*10465441SEvalZero RT_ASSERT(queue != RT_NULL);
38*10465441SEvalZero
39*10465441SEvalZero queue->flag = RT_WQ_FLAG_CLEAN;
40*10465441SEvalZero rt_list_init(&(queue->waiting_list));
41*10465441SEvalZero }
42*10465441SEvalZero
43*10465441SEvalZero void rt_wqueue_add(rt_wqueue_t *queue, struct rt_wqueue_node *node);
44*10465441SEvalZero void rt_wqueue_remove(struct rt_wqueue_node *node);
45*10465441SEvalZero int rt_wqueue_wait(rt_wqueue_t *queue, int condition, int timeout);
46*10465441SEvalZero void rt_wqueue_wakeup(rt_wqueue_t *queue, void *key);
47*10465441SEvalZero
48*10465441SEvalZero #define DEFINE_WAIT_FUNC(name, function) \
49*10465441SEvalZero struct rt_wqueue_node name = { \
50*10465441SEvalZero rt_current_thread, \
51*10465441SEvalZero RT_LIST_OBJECT_INIT(((name).list)), \
52*10465441SEvalZero \
53*10465441SEvalZero function, \
54*10465441SEvalZero 0 \
55*10465441SEvalZero }
56*10465441SEvalZero
57*10465441SEvalZero #define DEFINE_WAIT(name) DEFINE_WAIT_FUNC(name, __wqueue_default_wake)
58*10465441SEvalZero
59*10465441SEvalZero #endif
60