Searched refs:wq (Results 1 – 4 of 4) sorted by relevance
| /Zephyr-latest/kernel/include/ |
| D | wait_q.h | 24 #define _WAIT_Q_FOR_EACH(wq, thread_ptr) \ argument
25 RB_FOR_EACH_CONTAINER(&(wq)->waitq.tree, thread_ptr, base.qnode_rb)
43 #define _WAIT_Q_FOR_EACH(wq, thread_ptr) \
44 SYS_DLIST_FOR_EACH_CONTAINER(&((wq)->waitq), thread_ptr, \
|
| /Zephyr-latest/tests/lib/p4workq/src/ |
| D | main.c | 16 K_P4WQ_DEFINE(wq, MAX_NUM_THREADS, 2048);
49 k_p4wq_submit(&wq, &item->item); in stress_sub()
129 SYS_DLIST_FOR_EACH_NODE(&wq.waitq.waitq, dummy) { in active_count()
158 k_p4wq_submit(&wq, item); in add_new_item()
222 k_p4wq_submit(&wq, item); in resubmit_handler()
227 zassert_false(k_p4wq_cancel(&wq, item), in resubmit_handler()
238 k_p4wq_submit(&wq, &simple_item); in ZTEST()
264 k_p4wq_submit(&wq, &simple_item); in ZTEST()
273 k_p4wq_submit(&wq, &simple_item); in ZTEST()
|
| /Zephyr-latest/tests/kernel/workq/work/src/ |
| D | main.c | 105 static inline int coop_counter(struct k_work_q *wq) in coop_counter() argument
107 return (wq == &coophi_queue) ? coophi_counter() in coop_counter()
108 : (wq == &cooplo_queue) ? cooplo_counter() in coop_counter()
1269 static bool try_queue_no_yield(struct k_work_q *wq) in try_queue_no_yield() argument
1272 bool is_high = (k_thread_priority_get(k_work_queue_thread_get(wq)) in try_queue_no_yield()
1284 rc = k_work_submit_to_queue(wq, &common_work); in try_queue_no_yield()
1286 rc = k_work_schedule_for_queue(wq, &dwork, K_NO_WAIT); in try_queue_no_yield()
1298 zassert_equal(coop_counter(wq), 2); in try_queue_no_yield()
|
| /Zephyr-latest/kernel/ |
| D | sched.c | 438 _wait_q_t *wq = &thread->join_queue; in z_thread_halt() local
440 wq = terminate ? wq : &thread->halt_queue; in z_thread_halt()
465 add_to_waitq_locked(arch_current_thread(), wq); in z_thread_halt()
|
