Lines Matching refs:queue
37 rt_inline void rt_wqueue_init(rt_wqueue_t *queue) in rt_wqueue_init() argument
39 RT_ASSERT(queue != RT_NULL); in rt_wqueue_init()
41 queue->flag = RT_WQ_FLAG_CLEAN; in rt_wqueue_init()
42 rt_list_init(&(queue->waiting_list)); in rt_wqueue_init()
43 rt_spin_lock_init(&(queue->spinlock)); in rt_wqueue_init()
46 void rt_wqueue_add(rt_wqueue_t *queue, struct rt_wqueue_node *node);
48 int rt_wqueue_wait(rt_wqueue_t *queue, int condition, int timeout);
49 int rt_wqueue_wait_killable(rt_wqueue_t *queue, int condition, int timeout);
50 int rt_wqueue_wait_interruptible(rt_wqueue_t *queue, int condition, int timeout);
51 void rt_wqueue_wakeup(rt_wqueue_t *queue, void *key);
52 void rt_wqueue_wakeup_all(rt_wqueue_t *queue, void *key);