| /* wait queue for multiple threads on kernel objects */ |
| |
| /* |
| * Copyright (c) 2015 Wind River Systems, Inc. |
| * |
| * SPDX-License-Identifier: Apache-2.0 |
| */ |
| |
| #ifndef ZEPHYR_KERNEL_INCLUDE_WAIT_Q_H_ |
| #define ZEPHYR_KERNEL_INCLUDE_WAIT_Q_H_ |
| |
| #include <zephyr/kernel_structs.h> |
| #include <zephyr/sys/dlist.h> |
| #include <zephyr/sys/rb.h> |
| #include <zephyr/kernel/sched_priq.h> |
| #include <zephyr/timeout_q.h> |
| |
| #ifdef __cplusplus |
| extern "C" { |
| #endif |
| |
| #ifdef CONFIG_WAITQ_SCALABLE |
| |
| #define _WAIT_Q_FOR_EACH(wq, thread_ptr) \ |
| RB_FOR_EACH_CONTAINER(&(wq)->waitq.tree, thread_ptr, base.qnode_rb) |
| |
| static inline void z_waitq_init(_wait_q_t *w) |
| { |
| w->waitq = (struct _priq_rb) { |
| .tree = { |
| .lessthan_fn = z_priq_rb_lessthan |
| } |
| }; |
| } |
| |
| static inline struct k_thread *z_waitq_head(_wait_q_t *w) |
| { |
| return (struct k_thread *)rb_get_min(&w->waitq.tree); |
| } |
| |
| #else /* !CONFIG_WAITQ_SCALABLE: */ |
| |
| #define _WAIT_Q_FOR_EACH(wq, thread_ptr) \ |
| SYS_DLIST_FOR_EACH_CONTAINER(&((wq)->waitq), thread_ptr, \ |
| base.qnode_dlist) |
| |
| static inline void z_waitq_init(_wait_q_t *w) |
| { |
| sys_dlist_init(&w->waitq); |
| } |
| |
| static inline struct k_thread *z_waitq_head(_wait_q_t *w) |
| { |
| return (struct k_thread *)sys_dlist_peek_head(&w->waitq); |
| } |
| |
| #endif /* !CONFIG_WAITQ_SCALABLE */ |
| |
| #ifdef __cplusplus |
| } |
| #endif |
| |
| #endif /* ZEPHYR_KERNEL_INCLUDE_WAIT_Q_H_ */ |