Home
last modified time | relevance | path

Searched defs:queue (Results 1 – 25 of 36) sorted by relevance

12

/Zephyr-latest/subsys/bluetooth/controller/ll_sw/
Dull_tx_queue.c11 void ull_tx_q_init(struct ull_tx_q *queue) in ull_tx_q_init()
18 void ull_tx_q_pause_data(struct ull_tx_q *queue) in ull_tx_q_pause_data()
23 void ull_tx_q_resume_data(struct ull_tx_q *queue) in ull_tx_q_resume_data()
35 void ull_tx_q_enqueue_data(struct ull_tx_q *queue, struct node_tx *tx) in ull_tx_q_enqueue_data()
50 void ull_tx_q_enqueue_ctrl(struct ull_tx_q *queue, struct node_tx *tx) in ull_tx_q_enqueue_ctrl()
56 struct node_tx *ull_tx_q_peek(struct ull_tx_q *queue) in ull_tx_q_peek()
65 struct node_tx *ull_tx_q_dequeue(struct ull_tx_q *queue) in ull_tx_q_dequeue()
/Zephyr-latest/kernel/
Dqueue.c58 void z_impl_k_queue_init(struct k_queue *queue) in z_impl_k_queue_init()
73 static inline void z_vrfy_k_queue_init(struct k_queue *queue) in z_vrfy_k_queue_init()
87 static inline bool handle_poll_events(struct k_queue *queue, uint32_t state) in handle_poll_events()
99 void z_impl_k_queue_cancel_wait(struct k_queue *queue) in z_impl_k_queue_cancel_wait()
124 static inline void z_vrfy_k_queue_cancel_wait(struct k_queue *queue) in z_vrfy_k_queue_cancel_wait()
132 static int32_t queue_insert(struct k_queue *queue, void *prev, void *data, in queue_insert()
188 void k_queue_insert(struct k_queue *queue, void *prev, void *data) in k_queue_insert()
197 void k_queue_append(struct k_queue *queue, void *data) in k_queue_append()
206 void k_queue_prepend(struct k_queue *queue, void *data) in k_queue_prepend()
215 int32_t z_impl_k_queue_alloc_append(struct k_queue *queue, void *data) in z_impl_k_queue_alloc_append()
[all …]
Dwork.c187 static void queue_flusher_locked(struct k_work_q *queue, in queue_flusher_locked()
208 static inline void queue_remove_locked(struct k_work_q *queue, in queue_remove_locked()
227 static inline bool notify_queue_locked(struct k_work_q *queue) in notify_queue_locked()
257 static inline int queue_submit_locked(struct k_work_q *queue, in queue_submit_locked()
375 int z_work_submit_to_queue(struct k_work_q *queue, in z_work_submit_to_queue()
390 int k_work_submit_to_queue(struct k_work_q *queue, in k_work_submit_to_queue()
444 struct k_work_q *queue = work->queue; in work_flush_locked() local
611 struct k_work_q *queue = (struct k_work_q *)workq_ptr; in work_queue_main() local
714 void k_work_queue_init(struct k_work_q *queue) in k_work_queue_init()
725 void k_work_queue_start(struct k_work_q *queue, in k_work_queue_start()
[all …]
/Zephyr-latest/samples/arch/smp/pktqueue/src/
Dpktqueue.c10 void phdr_desc_enqueue(struct phdr_desc_queue *queue, struct phdr_desc *desc, in phdr_desc_enqueue()
30 struct phdr_desc *phdr_desc_dequeue(struct phdr_desc_queue *queue, in phdr_desc_dequeue()
Dmain.c57 void init_datagram_queue(struct phdr_desc_queue *queue, int queue_num) in init_datagram_queue()
/Zephyr-latest/lib/os/
Dp4wq.c79 struct k_p4wq *queue = p0; in p4wq_loop() local
133 void k_p4wq_init(struct k_p4wq *queue) in k_p4wq_init()
141 void k_p4wq_add_thread(struct k_p4wq *queue, struct k_thread *thread, in k_p4wq_add_thread()
194 void k_p4wq_enable_static_thread(struct k_p4wq *queue, struct k_thread *thread, in k_p4wq_enable_static_thread()
227 void k_p4wq_submit(struct k_p4wq *queue, struct k_p4wq_work *item) in k_p4wq_submit()
304 bool k_p4wq_cancel(struct k_p4wq *queue, struct k_p4wq_work *item) in k_p4wq_cancel()
/Zephyr-latest/tests/kernel/queue/
DCMakeLists.txt5 project(queue) project
/Zephyr-latest/include/zephyr/tracing/
Dtracking.h63 #define sys_port_track_k_work_queue_init(queue) argument
71 #define sys_port_track_k_queue_peek_tail(queue, ret) argument
72 #define sys_port_track_k_queue_peek_head(queue, ret) argument
73 #define sys_port_track_k_queue_cancel_wait(queue) argument
74 #define sys_port_track_k_queue_init(queue) \ argument
125 #define sys_port_track_k_work_queue_init(queue) argument
131 #define sys_port_track_k_queue_peek_tail(queue, ret) argument
132 #define sys_port_track_k_queue_peek_head(queue, ret) argument
133 #define sys_port_track_k_queue_cancel_wait(queue) argument
134 #define sys_port_track_k_queue_init(queue) argument
Dtracing.h326 #define sys_port_trace_k_work_submit_to_queue_enter(queue, work) argument
334 #define sys_port_trace_k_work_submit_to_queue_exit(queue, work, ret) argument
416 #define sys_port_trace_k_work_queue_init(queue) argument
422 #define sys_port_trace_k_work_queue_start_enter(queue) argument
428 #define sys_port_trace_k_work_queue_start_exit(queue) argument
435 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) argument
442 #define sys_port_trace_k_work_queue_stop_blocking(queue, timeout) argument
450 #define sys_port_trace_k_work_queue_stop_exit(queue, timeout, ret) argument
456 #define sys_port_trace_k_work_queue_drain_enter(queue) argument
463 #define sys_port_trace_k_work_queue_drain_exit(queue, ret) argument
[all …]
/Zephyr-latest/subsys/tracing/test/
Dtracing_string_format_test.c416 void sys_trace_k_queue_init(struct k_queue *queue) in sys_trace_k_queue_init()
421 void sys_trace_k_queue_cancel_wait(struct k_queue *queue) in sys_trace_k_queue_cancel_wait()
426 void sys_trace_k_queue_append_enter(struct k_queue *queue, void *data) in sys_trace_k_queue_append_enter()
431 void sys_trace_k_queue_append_exit(struct k_queue *queue, void *data) in sys_trace_k_queue_append_exit()
436 void sys_trace_k_queue_queue_insert_enter(struct k_queue *queue, bool alloc, void *data) in sys_trace_k_queue_queue_insert_enter()
441 void sys_trace_k_queue_queue_insert_exit(struct k_queue *queue, bool alloc, void *data, int ret) in sys_trace_k_queue_queue_insert_exit()
446 void sys_trace_k_queue_get_blocking(struct k_queue *queue, k_timeout_t timeout) in sys_trace_k_queue_get_blocking()
451 void sys_trace_k_queue_get_exit(struct k_queue *queue, k_timeout_t timeout, void *ret) in sys_trace_k_queue_get_exit()
456 void sys_trace_k_queue_peek_head(struct k_queue *queue, void *ret) in sys_trace_k_queue_peek_head()
461 void sys_trace_k_queue_peek_tail(struct k_queue *queue, void *ret) in sys_trace_k_queue_peek_tail()
[all …]
Dtracing_test.h68 #define sys_port_trace_k_work_submit_to_queue_enter(queue, work) argument
69 #define sys_port_trace_k_work_submit_to_queue_exit(queue, work, ret) argument
81 #define sys_port_trace_k_work_queue_init(queue) argument
82 #define sys_port_trace_k_work_queue_start_enter(queue) argument
83 #define sys_port_trace_k_work_queue_start_exit(queue) argument
84 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) argument
85 #define sys_port_trace_k_work_queue_stop_blocking(queue, timeout) argument
86 #define sys_port_trace_k_work_queue_stop_exit(queue, timeout, ret) argument
87 #define sys_port_trace_k_work_queue_drain_enter(queue) argument
88 #define sys_port_trace_k_work_queue_drain_exit(queue, ret) argument
[all …]
/Zephyr-latest/tests/kernel/queue/src/
Dtest_queue_fail.c25 static struct k_queue queue; in ZTEST() local
62 static struct k_queue queue; in ZTEST() local
108 static struct k_queue queue; in ZTEST() local
Dtest_queue_loop.c16 static struct k_queue queue; variable
/Zephyr-latest/subsys/tracing/user/
Dtracing_user.h143 #define sys_port_trace_k_work_submit_to_queue_enter(queue, work) argument
144 #define sys_port_trace_k_work_submit_to_queue_exit(queue, work, ret) argument
156 #define sys_port_trace_k_work_queue_init(queue) argument
157 #define sys_port_trace_k_work_queue_start_enter(queue) argument
158 #define sys_port_trace_k_work_queue_start_exit(queue) argument
159 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) argument
160 #define sys_port_trace_k_work_queue_stop_blocking(queue, timeout) argument
161 #define sys_port_trace_k_work_queue_stop_exit(queue, timeout, ret) argument
162 #define sys_port_trace_k_work_queue_drain_enter(queue) argument
163 #define sys_port_trace_k_work_queue_drain_exit(queue, ret) argument
[all …]
/Zephyr-latest/subsys/tracing/ctf/
Dtracing_ctf.h77 #define sys_port_trace_k_work_submit_to_queue_enter(queue, work) argument
78 #define sys_port_trace_k_work_submit_to_queue_exit(queue, work, ret) argument
90 #define sys_port_trace_k_work_queue_init(queue) argument
91 #define sys_port_trace_k_work_queue_start_enter(queue) argument
92 #define sys_port_trace_k_work_queue_start_exit(queue) argument
93 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) argument
94 #define sys_port_trace_k_work_queue_stop_blocking(queue, timeout) argument
95 #define sys_port_trace_k_work_queue_stop_exit(queue, timeout, ret) argument
96 #define sys_port_trace_k_work_queue_drain_enter(queue) argument
97 #define sys_port_trace_k_work_queue_drain_exit(queue, ret) argument
[all …]
/Zephyr-latest/drivers/ethernet/
Deth_sam_gmac.c252 struct gmac_queue *queue) in set_receive_buf_queue_pointer()
273 static int priority_queue_init(Gmac *gmac, struct gmac_queue *queue) in priority_queue_init()
324 static int priority_queue_init_as_idle(Gmac *gmac, struct gmac_queue *queue) in priority_queue_init_as_idle()
356 static int queue_init(Gmac *gmac, struct gmac_queue *queue) in queue_init()
370 struct gmac_queue *queue) in set_receive_buf_queue_pointer()
375 static int queue_init(Gmac *gmac, struct gmac_queue *queue) in queue_init()
473 static int rx_descriptors_init(Gmac *gmac, struct gmac_queue *queue) in rx_descriptors_init()
514 static void tx_descriptors_init(Gmac *gmac, struct gmac_queue *queue) in tx_descriptors_init()
698 static void tx_completed(Gmac *gmac, struct gmac_queue *queue) in tx_completed()
755 static void tx_error_handler(Gmac *gmac, struct gmac_queue *queue) in tx_error_handler()
[all …]
/Zephyr-latest/subsys/tracing/sysview/
Dtracing_sysview.h137 #define sys_port_trace_k_work_submit_to_queue_enter(queue, work) \ argument
141 #define sys_port_trace_k_work_submit_to_queue_exit(queue, work, ret) \ argument
173 #define sys_port_trace_k_work_queue_init(queue) \ argument
177 #define sys_port_trace_k_work_queue_start_enter(queue) \ argument
180 #define sys_port_trace_k_work_queue_start_exit(queue) \ argument
183 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) \ argument
187 #define sys_port_trace_k_work_queue_stop_blocking(queue, timeout) \ argument
191 #define sys_port_trace_k_work_queue_stop_exit(queue, timeout, ret) \ argument
194 #define sys_port_trace_k_work_queue_drain_enter(queue) \ argument
197 #define sys_port_trace_k_work_queue_drain_exit(queue, ret) \ argument
[all …]
/Zephyr-latest/modules/hal_infineon/abstraction-rtos/source/COMPONENT_ZEPHYR/
Dcyabs_rtos_zephyr.c619 cy_rslt_t cy_rtos_init_queue(cy_queue_t *queue, size_t length, size_t itemsize) in cy_rtos_init_queue()
635 cy_rslt_t cy_rtos_put_queue(cy_queue_t *queue, const void *item_ptr, cy_time_t timeout_ms, in cy_rtos_put_queue()
663 cy_rslt_t cy_rtos_get_queue(cy_queue_t *queue, void *item_ptr, cy_time_t timeout_ms, bool in_isr) in cy_rtos_get_queue()
690 cy_rslt_t cy_rtos_count_queue(cy_queue_t *queue, size_t *num_waiting) in cy_rtos_count_queue()
704 cy_rslt_t cy_rtos_space_queue(cy_queue_t *queue, size_t *num_spaces) in cy_rtos_space_queue()
718 cy_rslt_t cy_rtos_reset_queue(cy_queue_t *queue) in cy_rtos_reset_queue()
732 cy_rslt_t cy_rtos_deinit_queue(cy_queue_t *queue) in cy_rtos_deinit_queue()
/Zephyr-latest/include/zephyr/sys/
Dp4wq.h50 struct k_p4wq *queue; member
77 struct rbtree queue; member
94 struct k_p4wq *queue; member
/Zephyr-latest/tests/kernel/obj_tracking/src/
Dmain.c40 struct k_queue queue; in ZTEST() local
/Zephyr-latest/tests/kernel/mutex/mutex_error_case/src/
Dtest_mutex_error.c19 static struct k_queue queue; variable
/Zephyr-latest/subsys/tracing/
Dtracing_tracking.c113 void sys_track_k_queue_init(struct k_queue *queue) in sys_track_k_queue_init()
/Zephyr-latest/tests/posix/xsi_realtime/src/
Dmqueue.c19 static char queue[16] = "server"; variable
/Zephyr-latest/scripts/pylib/twister/twisterlib/
Dhandlers.py1258 def _enqueue_char(self, queue): argument
1277 queue, argument
/Zephyr-latest/drivers/wifi/nrf_wifi/src/
Dwifi_util.c273 void *queue = NULL; in nrf_wifi_util_tx_stats() local

12