Home
last modified time | relevance | path

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

12

/Zephyr-4.3.0/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-4.3.0/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.c190 static void queue_flusher_locked(struct k_work_q *queue, in queue_flusher_locked()
211 static inline void queue_remove_locked(struct k_work_q *queue, in queue_remove_locked()
230 static inline bool notify_queue_locked(struct k_work_q *queue) in notify_queue_locked()
260 static inline int queue_submit_locked(struct k_work_q *queue, in queue_submit_locked()
378 int z_work_submit_to_queue(struct k_work_q *queue, in z_work_submit_to_queue()
393 int k_work_submit_to_queue(struct k_work_q *queue, in k_work_submit_to_queue()
447 struct k_work_q *queue = work->queue; in work_flush_locked() local
608 struct k_work_q *queue = CONTAINER_OF(record, struct k_work_q, work_timeout_record); in work_timeout_handler() local
631 static void work_timeout_start_locked(struct k_work_q *queue, struct k_work *work) in work_timeout_start_locked()
641 static void work_timeout_stop_locked(struct k_work_q *queue) in work_timeout_stop_locked()
[all …]
/Zephyr-4.3.0/modules/nrf_wifi/bus/
Dspsc_qm.c23 bool spsc32_push(spsc_queue_t *queue, uint32_t value) in spsc32_push()
39 bool spsc32_pop(spsc_queue_t *queue, uint32_t *out_value) in spsc32_pop()
56 bool spsc32_read_head(spsc_queue_t *queue, uint32_t *out_value) in spsc32_read_head()
71 bool spsc32_is_empty(spsc_queue_t *queue) in spsc32_is_empty()
78 bool spsc32_is_full(spsc_queue_t *queue) in spsc32_is_full()
/Zephyr-4.3.0/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()
/Zephyr-4.3.0/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-4.3.0/drivers/ethernet/intel/
Deth_intel_igc.c59 uint8_t queue) in get_tx_desc_idx()
75 uint8_t queue) in get_rx_desc_idx()
106 static union dma_tx_desc *eth_intel_igc_get_tx_desc(const struct device *dev, uint8_t queue) in eth_intel_igc_get_tx_desc()
136 static union dma_tx_desc *eth_intel_igc_release_tx_desc(const struct device *dev, uint8_t queue) in eth_intel_igc_release_tx_desc()
165 static uint32_t eth_intel_igc_completed_txdesc_num(const struct device *dev, uint8_t queue) in eth_intel_igc_completed_txdesc_num()
189 static union dma_rx_desc *eth_intel_igc_get_rx_desc(const struct device *dev, uint8_t queue) in eth_intel_igc_get_rx_desc()
219 static union dma_rx_desc *eth_intel_igc_release_rx_desc(const struct device *dev, uint8_t queue) in eth_intel_igc_release_rx_desc()
247 static uint32_t eth_intel_igc_completed_rxdesc_num(const struct device *dev, uint8_t queue) in eth_intel_igc_completed_rxdesc_num()
395 int index, uint8_t queue) in eth_intel_igc_set_mac_filter()
535 for (uint8_t queue = 0; queue < cfg->num_queues; queue++) { in eth_intel_igc_get_stats() local
[all …]
/Zephyr-4.3.0/tests/kernel/queue/
DCMakeLists.txt5 project(queue) project
/Zephyr-4.3.0/include/zephyr/tracing/
Dtracking.h84 #define sys_port_track_k_work_queue_init(queue) argument
92 #define sys_port_track_k_queue_peek_tail(queue, ret) argument
93 #define sys_port_track_k_queue_peek_head(queue, ret) argument
94 #define sys_port_track_k_queue_cancel_wait(queue) argument
95 #define sys_port_track_k_queue_init(queue) \ argument
146 #define sys_port_track_k_work_queue_init(queue) argument
152 #define sys_port_track_k_queue_peek_tail(queue, ret) argument
153 #define sys_port_track_k_queue_peek_head(queue, ret) argument
154 #define sys_port_track_k_queue_cancel_wait(queue) argument
155 #define sys_port_track_k_queue_init(queue) argument
Dtracing.h336 #define sys_port_trace_k_work_submit_to_queue_enter(queue, work) argument
344 #define sys_port_trace_k_work_submit_to_queue_exit(queue, work, ret) argument
426 #define sys_port_trace_k_work_queue_init(queue) argument
432 #define sys_port_trace_k_work_queue_start_enter(queue) argument
438 #define sys_port_trace_k_work_queue_start_exit(queue) argument
445 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) argument
452 #define sys_port_trace_k_work_queue_stop_blocking(queue, timeout) argument
460 #define sys_port_trace_k_work_queue_stop_exit(queue, timeout, ret) argument
466 #define sys_port_trace_k_work_queue_drain_enter(queue) argument
473 #define sys_port_trace_k_work_queue_drain_exit(queue, ret) argument
[all …]
/Zephyr-4.3.0/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-4.3.0/subsys/tracing/test/
Dtracing_string_format_test.c438 void sys_trace_k_queue_init(struct k_queue *queue) in sys_trace_k_queue_init()
443 void sys_trace_k_queue_cancel_wait(struct k_queue *queue) in sys_trace_k_queue_cancel_wait()
448 void sys_trace_k_queue_append_enter(struct k_queue *queue, void *data) in sys_trace_k_queue_append_enter()
453 void sys_trace_k_queue_append_exit(struct k_queue *queue, void *data) in sys_trace_k_queue_append_exit()
458 void sys_trace_k_queue_queue_insert_enter(struct k_queue *queue, bool alloc, void *data) in sys_trace_k_queue_queue_insert_enter()
463 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()
468 void sys_trace_k_queue_get_blocking(struct k_queue *queue, k_timeout_t timeout) in sys_trace_k_queue_get_blocking()
473 void sys_trace_k_queue_get_exit(struct k_queue *queue, k_timeout_t timeout, void *ret) in sys_trace_k_queue_get_exit()
478 void sys_trace_k_queue_peek_head(struct k_queue *queue, void *ret) in sys_trace_k_queue_peek_head()
483 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-4.3.0/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
176 #define sys_port_trace_k_work_queue_start_enter(queue) \ argument
179 #define sys_port_trace_k_work_queue_start_exit(queue) \ argument
182 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) \ argument
186 #define sys_port_trace_k_work_queue_stop_blocking(queue, timeout) \ argument
190 #define sys_port_trace_k_work_queue_stop_exit(queue, timeout, ret) \ argument
193 #define sys_port_trace_k_work_queue_drain_enter(queue) \ argument
196 #define sys_port_trace_k_work_queue_drain_exit(queue, ret) \ argument
[all …]
/Zephyr-4.3.0/subsys/tracing/ctf/
Dtracing_ctf.h81 #define sys_port_trace_k_work_submit_to_queue_enter(queue, work) \ argument
83 #define sys_port_trace_k_work_submit_to_queue_exit(queue, work, ret) \ argument
100 #define sys_port_trace_k_work_queue_init(queue) sys_trace_k_work_queue_init(queue) argument
101 #define sys_port_trace_k_work_queue_start_enter(queue) sys_trace_k_work_queue_start_enter(queue) argument
102 #define sys_port_trace_k_work_queue_start_exit(queue) sys_trace_k_work_queue_start_exit(queue) argument
103 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) \ argument
105 #define sys_port_trace_k_work_queue_stop_blocking(queue, timeout) \ argument
107 #define sys_port_trace_k_work_queue_stop_exit(queue, timeout, ret) \ argument
109 #define sys_port_trace_k_work_queue_drain_enter(queue) sys_trace_k_work_queue_drain_enter(queue) argument
110 #define sys_port_trace_k_work_queue_drain_exit(queue, ret) \ argument
[all …]
Dctf_top.c521 void sys_trace_k_work_submit_to_queue_enter(struct k_work_q *queue, struct k_work *work) in sys_trace_k_work_submit_to_queue_enter()
526 void sys_trace_k_work_submit_to_queue_exit(struct k_work_q *queue, struct k_work *work, int ret) in sys_trace_k_work_submit_to_queue_exit()
585 void sys_trace_k_work_queue_init(struct k_work_q *queue) in sys_trace_k_work_queue_init()
590 void sys_trace_k_work_queue_start_enter(struct k_work_q *queue) in sys_trace_k_work_queue_start_enter()
595 void sys_trace_k_work_queue_start_exit(struct k_work_q *queue) in sys_trace_k_work_queue_start_exit()
600 void sys_trace_k_work_queue_stop_enter(struct k_work_q *queue, k_timeout_t timeout) in sys_trace_k_work_queue_stop_enter()
606 void sys_trace_k_work_queue_stop_blocking(struct k_work_q *queue, k_timeout_t timeout) in sys_trace_k_work_queue_stop_blocking()
612 void sys_trace_k_work_queue_stop_exit(struct k_work_q *queue, k_timeout_t timeout, int ret) in sys_trace_k_work_queue_stop_exit()
618 void sys_trace_k_work_queue_drain_enter(struct k_work_q *queue) in sys_trace_k_work_queue_drain_enter()
623 void sys_trace_k_work_queue_drain_exit(struct k_work_q *queue, int ret) in sys_trace_k_work_queue_drain_exit()
[all …]
/Zephyr-4.3.0/subsys/tracing/user/
Dtracing_user.h174 #define sys_port_trace_k_work_submit_to_queue_enter(queue, work) argument
175 #define sys_port_trace_k_work_submit_to_queue_exit(queue, work, ret) argument
187 #define sys_port_trace_k_work_queue_init(queue) argument
188 #define sys_port_trace_k_work_queue_start_enter(queue) argument
189 #define sys_port_trace_k_work_queue_start_exit(queue) argument
190 #define sys_port_trace_k_work_queue_stop_enter(queue, timeout) argument
191 #define sys_port_trace_k_work_queue_stop_blocking(queue, timeout) argument
192 #define sys_port_trace_k_work_queue_stop_exit(queue, timeout, ret) argument
193 #define sys_port_trace_k_work_queue_drain_enter(queue) argument
194 #define sys_port_trace_k_work_queue_drain_exit(queue, ret) argument
[all …]
/Zephyr-4.3.0/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-4.3.0/include/zephyr/sys/
Dp4wq.h50 struct k_p4wq *queue; member
77 struct rbtree queue; member
94 struct k_p4wq *queue; member
/Zephyr-4.3.0/drivers/ethernet/
Deth_sam_gmac.c201 struct gmac_queue *queue) in set_receive_buf_queue_pointer()
222 static int priority_queue_init(Gmac *gmac, struct gmac_queue *queue) in priority_queue_init()
273 static int priority_queue_init_as_idle(Gmac *gmac, struct gmac_queue *queue) in priority_queue_init_as_idle()
305 static int queue_init(Gmac *gmac, struct gmac_queue *queue) in queue_init()
319 struct gmac_queue *queue) in set_receive_buf_queue_pointer()
324 static int queue_init(Gmac *gmac, struct gmac_queue *queue) in queue_init()
422 static int rx_descriptors_init(Gmac *gmac, struct gmac_queue *queue) in rx_descriptors_init()
463 static void tx_descriptors_init(Gmac *gmac, struct gmac_queue *queue) in tx_descriptors_init()
647 static void tx_completed(Gmac *gmac, struct gmac_queue *queue) in tx_completed()
704 static void tx_error_handler(Gmac *gmac, struct gmac_queue *queue) in tx_error_handler()
[all …]
/Zephyr-4.3.0/tests/kernel/obj_tracking/src/
Dmain.c40 struct k_queue queue; in ZTEST() local
/Zephyr-4.3.0/tests/kernel/workq/work_queue/src/
Dstart_stop.c84 struct k_work_q *queue = (struct k_work_q *)workq_ptr; in run_q_main() local
/Zephyr-4.3.0/tests/kernel/mutex/mutex_error_case/src/
Dtest_mutex_error.c19 static struct k_queue queue; variable
/Zephyr-4.3.0/subsys/net/lib/zperf/
Dzperf_tcp_uploader.c277 struct k_work_q *queue; in zperf_tcp_upload_async() local

12