| /Zephyr-4.2.1/kernel/ |
| D | queue.c | 58 void z_impl_k_queue_init(struct k_queue *queue) in z_impl_k_queue_init() argument
60 sys_sflist_init(&queue->data_q); in z_impl_k_queue_init()
61 queue->lock = (struct k_spinlock) {}; in z_impl_k_queue_init()
62 z_waitq_init(&queue->wait_q); in z_impl_k_queue_init()
64 sys_dlist_init(&queue->poll_events); in z_impl_k_queue_init()
67 SYS_PORT_TRACING_OBJ_INIT(k_queue, queue); in z_impl_k_queue_init()
69 k_object_init(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() argument
75 K_OOPS(K_SYSCALL_OBJ_NEVER_INIT(queue, K_OBJ_QUEUE)); in z_vrfy_k_queue_init()
76 z_impl_k_queue_init(queue); in z_vrfy_k_queue_init()
[all …]
|
| D | work.c | 190 static void queue_flusher_locked(struct k_work_q *queue, in queue_flusher_locked() argument
197 sys_slist_insert(&queue->pending, &work->node, in queue_flusher_locked()
200 sys_slist_prepend(&queue->pending, &flusher->work.node); in queue_flusher_locked()
211 static inline void queue_remove_locked(struct k_work_q *queue, in queue_remove_locked() argument
215 (void)sys_slist_find_and_remove(&queue->pending, &work->node); in queue_remove_locked()
230 static inline bool notify_queue_locked(struct k_work_q *queue) in notify_queue_locked() argument
234 if (queue != NULL) { in notify_queue_locked()
235 rv = z_sched_wake(&queue->notifyq, 0, NULL); in notify_queue_locked()
260 static inline int queue_submit_locked(struct k_work_q *queue, in queue_submit_locked() argument
263 if (queue == NULL) { in queue_submit_locked()
[all …]
|
| /Zephyr-4.2.1/subsys/bluetooth/controller/ll_sw/ |
| D | ull_tx_queue.c | 11 void ull_tx_q_init(struct ull_tx_q *queue) in ull_tx_q_init() argument
13 queue->pause_data = 0U; in ull_tx_q_init()
14 sys_slist_init(&queue->tx_list); in ull_tx_q_init()
15 sys_slist_init(&queue->data_list); in ull_tx_q_init()
18 void ull_tx_q_pause_data(struct ull_tx_q *queue) in ull_tx_q_pause_data() argument
20 queue->pause_data++; in ull_tx_q_pause_data()
23 void ull_tx_q_resume_data(struct ull_tx_q *queue) in ull_tx_q_resume_data() argument
25 if (queue->pause_data > 0) { in ull_tx_q_resume_data()
26 queue->pause_data--; in ull_tx_q_resume_data()
30 if (!queue->pause_data && !sys_slist_is_empty(&queue->data_list)) { in ull_tx_q_resume_data()
[all …]
|
| D | ull_tx_queue.h | 22 void ull_tx_q_init(struct ull_tx_q *queue);
29 void ull_tx_q_pause_data(struct ull_tx_q *queue);
36 void ull_tx_q_resume_data(struct ull_tx_q *queue);
44 void ull_tx_q_enqueue_data(struct ull_tx_q *queue, struct node_tx *tx);
52 void ull_tx_q_enqueue_ctrl(struct ull_tx_q *queue, struct node_tx *tx);
61 struct node_tx *ull_tx_q_peek(struct ull_tx_q *queue);
70 struct node_tx *ull_tx_q_dequeue(struct ull_tx_q *queue);
|
| /Zephyr-4.2.1/lib/os/ |
| D | p4wq.c | 79 struct k_p4wq *queue = p0; in p4wq_loop() local
80 k_spinlock_key_t k = k_spin_lock(&queue->lock); in p4wq_loop()
83 struct rbnode *r = rb_get_max(&queue->queue); in p4wq_loop()
89 rb_remove(&queue->queue, r); in p4wq_loop()
91 sys_dlist_append(&queue->active, &w->dlnode); in p4wq_loop()
95 k_spin_unlock(&queue->lock, k); in p4wq_loop()
99 k = k_spin_lock(&queue->lock); in p4wq_loop()
108 if (queue->done_handler) { in p4wq_loop()
109 k_spin_unlock(&queue->lock, k); in p4wq_loop()
110 queue->done_handler(w); in p4wq_loop()
[all …]
|
| /Zephyr-4.2.1/samples/arch/smp/pktqueue/src/ |
| D | pktqueue.c | 10 void phdr_desc_enqueue(struct phdr_desc_queue *queue, struct phdr_desc *desc, in phdr_desc_enqueue() argument
16 if (queue->count == 0) { in phdr_desc_enqueue()
17 queue->head = queue->tail = desc; in phdr_desc_enqueue()
19 queue->tail->next = desc; in phdr_desc_enqueue()
20 queue->tail = desc; in phdr_desc_enqueue()
22 queue->count++; in phdr_desc_enqueue()
30 struct phdr_desc *phdr_desc_dequeue(struct phdr_desc_queue *queue, in phdr_desc_dequeue() argument
36 if (queue->count != 0) { in phdr_desc_dequeue()
37 queue->count--; in phdr_desc_dequeue()
38 return_ptr = queue->head; in phdr_desc_dequeue()
[all …]
|
| /Zephyr-4.2.1/samples/subsys/portability/cmsis_rtos_v1/timer_synchronization/ |
| D | README.rst | 11 The main thread creates a preemptive thread which writes message to message queue
32 Wrote to message queue: 5
33 Read from message queue: 5
35 Wrote to message queue: 6
36 Read from message queue: 6
38 Wrote to message queue: 7
39 Read from message queue: 7
41 Wrote to message queue: 8
42 Read from message queue: 8
44 Wrote to message queue: 9
[all …]
|
| /Zephyr-4.2.1/samples/subsys/portability/cmsis_rtos_v2/timer_synchronization/ |
| D | README.rst | 11 The main thread creates a preemptive thread which writes message to message queue
32 Wrote to message queue: 5
33 Read from message queue: 5
35 Wrote to message queue: 6
36 Read from message queue: 6
38 Wrote to message queue: 7
39 Read from message queue: 7
41 Wrote to message queue: 8
42 Read from message queue: 8
44 Wrote to message queue: 9
[all …]
|
| /Zephyr-4.2.1/modules/nrf_wifi/bus/ |
| D | spsc_qm.c | 23 bool spsc32_push(spsc_queue_t *queue, uint32_t value) in spsc32_push() argument
28 if (spsc_pbuf_alloc(queue, len, &pbuf) != len) { in spsc32_push()
34 spsc_pbuf_commit(queue, len); in spsc32_push()
39 bool spsc32_pop(spsc_queue_t *queue, uint32_t *out_value) in spsc32_pop() argument
42 uint16_t plen = spsc_pbuf_claim(queue, &buf); in spsc32_pop()
49 spsc_pbuf_free(queue, plen); in spsc32_pop()
56 bool spsc32_read_head(spsc_queue_t *queue, uint32_t *out_value) in spsc32_read_head() argument
59 uint16_t plen = spsc_pbuf_claim(queue, &buf); in spsc32_read_head()
71 bool spsc32_is_empty(spsc_queue_t *queue) in spsc32_is_empty() argument
75 return spsc_pbuf_claim(queue, &buf) == 0; in spsc32_is_empty()
[all …]
|
| /Zephyr-4.2.1/drivers/ethernet/intel/ |
| D | eth_intel_igc.c | 59 uint8_t queue) in get_tx_desc_idx() argument
65 tx_desc_base = (union dma_tx_desc *)&data->tx.desc[queue * cfg->num_tx_desc]; in get_tx_desc_idx()
75 uint8_t queue) in get_rx_desc_idx() argument
81 rx_desc_base = (union dma_rx_desc *)&data->rx.desc[queue * cfg->num_rx_desc]; 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() argument
113 k_sem_take(&data->tx.sem[queue], K_FOREVER); in eth_intel_igc_get_tx_desc()
115 current_wr_idx = data->tx.ring_wr_ptr[queue]; in eth_intel_igc_get_tx_desc()
118 if (is_desc_unavailable(next_wr_idx, data->tx.ring_rd_ptr[queue])) { in eth_intel_igc_get_tx_desc()
119 k_sem_give(&data->tx.sem[queue]); in eth_intel_igc_get_tx_desc()
123 desc = data->tx.desc + (queue * cfg->num_tx_desc + current_wr_idx); in eth_intel_igc_get_tx_desc()
[all …]
|
| /Zephyr-4.2.1/tests/kernel/queue/src/ |
| D | test_queue_fail.c | 25 static struct k_queue queue; in ZTEST() local
27 k_queue_init(&queue); in ZTEST()
29 zassert_is_null(k_queue_get(&queue, K_NO_WAIT), NULL); in ZTEST()
30 zassert_is_null(k_queue_get(&queue, TIMEOUT), NULL); in ZTEST()
62 static struct k_queue queue; in ZTEST() local
65 k_queue_init(&queue); in ZTEST()
69 zassert_true(k_queue_append_list(&queue, (uint32_t *)head, in ZTEST()
75 zassert_true(k_queue_append_list(&queue, (uint32_t *)head, in ZTEST()
79 k_queue_init(&queue); in ZTEST()
85 k_thread_create(&tdata, tstack, STACK_SIZE, tThread_entry, &queue, in ZTEST()
[all …]
|
| D | test_queue_contexts.c | 17 struct k_queue queue; variable
157 k_queue_init(&queue); in ZTEST()
158 tqueue_thread_thread(&queue); in ZTEST()
181 k_queue_init(&queue); in ZTEST()
182 tqueue_thread_isr(&queue); in ZTEST()
203 k_queue_init(&queue); in ZTEST()
204 tqueue_isr_thread(&queue); in ZTEST()
250 k_queue_init(&queue); in ZTEST()
252 tqueue_get_2threads(&queue); in ZTEST()
310 k_queue_init(&queue); in ZTEST()
[all …]
|
| /Zephyr-4.2.1/include/zephyr/tracing/ |
| D | tracing.h | 336 #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 …]
|
| D | tracking.h | 84 #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
96 sys_track_k_queue_init(queue)
130 void sys_track_k_queue_init(struct k_queue *queue);
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
[all …]
|
| /Zephyr-4.2.1/include/zephyr/sys/ |
| D | p4wq.h | 50 struct k_p4wq *queue; member
77 struct rbtree queue; member
94 struct k_p4wq *queue; member
124 .queue = &name, \
163 .queue = name, \
187 void k_p4wq_init(struct k_p4wq *queue);
201 void k_p4wq_add_thread(struct k_p4wq *queue, struct k_thread *thread,
226 void k_p4wq_submit(struct k_p4wq *queue, struct k_p4wq_work *item);
238 bool k_p4wq_cancel(struct k_p4wq *queue, struct k_p4wq_work *item);
245 void k_p4wq_enable_static_thread(struct k_p4wq *queue, struct k_thread *thread,
|
| /Zephyr-4.2.1/drivers/ethernet/ |
| D | eth_sam_gmac.c | 140 #error Not enough RX buffers to allocate descriptors for each HW queue
195 static int rx_descriptors_init(Gmac *gmac, struct gmac_queue *queue);
196 static void tx_descriptors_init(Gmac *gmac, struct gmac_queue *queue);
197 static int nonpriority_queue_init(Gmac *gmac, struct gmac_queue *queue);
201 struct gmac_queue *queue) in set_receive_buf_queue_pointer() argument
204 if (queue->que_idx == GMAC_QUE_0) { in set_receive_buf_queue_pointer()
205 gmac->GMAC_RBQB = (uint32_t)queue->rx_desc_list.buf; in set_receive_buf_queue_pointer()
207 gmac->GMAC_RBQBAPQ[queue->que_idx - 1] = in set_receive_buf_queue_pointer()
208 (uint32_t)queue->rx_desc_list.buf; in set_receive_buf_queue_pointer()
222 static int priority_queue_init(Gmac *gmac, struct gmac_queue *queue) in priority_queue_init() argument
[all …]
|
| /Zephyr-4.2.1/subsys/tracing/test/ |
| D | tracing_test.h | 68 #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 …]
|
| D | tracing_string_format_test.c | 438 void sys_trace_k_queue_init(struct k_queue *queue) in sys_trace_k_queue_init() argument
440 TRACING_STRING("%s: %p\n", __func__, 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() argument
445 TRACING_STRING("%s: %p\n", __func__, 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() argument
450 TRACING_STRING("%s: %p\n", __func__, queue); 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() argument
455 TRACING_STRING("%s: %p\n", __func__, queue); 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() argument
460 TRACING_STRING("%s: %p\n", __func__, queue); in sys_trace_k_queue_queue_insert_enter()
[all …]
|
| /Zephyr-4.2.1/lib/posix/options/ |
| D | Kconfig.mqueue | 6 bool "POSIX message queue support"
8 This enabled POSIX message queue related APIs.
13 int "Maximum number of messages in a POSIX message queue"
16 Mention maximum number of messages in message queue in POSIX compliant
32 int "Maximum POSIX message queue name size"
36 Mention size of message queue name in number of characters.
|
| /Zephyr-4.2.1/doc/kernel/services/data_passing/ |
| D | message_queues.rst | 6 A :dfn:`message queue` is a kernel object that implements a simple
7 message queue, allowing threads and ISRs to asynchronously send and receive
18 Each message queue is referenced by its memory address.
20 A message queue has the following key properties:
28 A message queue must be initialized before it can be used.
31 A data item can be **sent** to a message queue by a thread or an ISR.
33 if one exists; otherwise the item is copied to the message queue's ring buffer,
35 *must* equal the message queue's data item size.
43 A data item can be **received** from a message queue by a thread.
45 the size of the receiving area *must* equal the message queue's data item size.
[all …]
|
| /Zephyr-4.2.1/subsys/tracing/sysview/ |
| D | tracing_sysview.h | 137 #define sys_port_trace_k_work_submit_to_queue_enter(queue, work) \ argument
138 SEGGER_SYSVIEW_RecordU32x2(TID_WORK_SUBMIT_TO_QUEUE, (uint32_t)(uintptr_t)queue, \
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
174 SEGGER_SYSVIEW_RecordU32(TID_WORK_QUEUE_INIT, (uint32_t)(uintptr_t)queue)
176 #define sys_port_trace_k_work_queue_start_enter(queue) \ argument
177 SEGGER_SYSVIEW_RecordU32(TID_WORK_QUEUE_START, (uint32_t)(uintptr_t)queue)
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
183 SEGGER_SYSVIEW_RecordU32x2(TID_WORK_QUEUE_STOP, (uint32_t)(uintptr_t)queue, \
[all …]
|
| /Zephyr-4.2.1/samples/subsys/zbus/async_listeners/ |
| D | README.rst | 11 conventional listener, (ii) an asynchronous listener that utilizes the system's work queue, and
12 (iii) an asynchronous listener that employs an isolated work queue.
36 I: From async listener -> Evt=0 | My work queue
39 I: From async listener -> Evt=1 | My work queue
42 I: From async listener -> Evt=2 | My work queue
45 I: From async listener -> Evt=3 | My work queue
49 I: From async listener -> Evt=0 | My work queue
52 I: From async listener -> Evt=1 | My work queue
55 I: From async listener -> Evt=2 | My work queue
58 I: From async listener -> Evt=3 | My work queue
|
| /Zephyr-4.2.1/subsys/tracing/user/ |
| D | tracing_user.h | 174 #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.2.1/tests/posix/xsi_realtime/src/ |
| D | mqueue.c | 19 static char queue[16] = "server"; variable
37 mqd = mq_open(queue, O_WRONLY); in sender_thread()
53 mqd = mq_open(queue, O_RDONLY); in receiver_thread()
77 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
92 zassert_false(mq_unlink(queue), "Not able to unlink Queue"); in ZTEST()
102 mqd = mq_open(queue, O_RDONLY); in notify_function_basic()
131 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
140 zassert_ok(mq_unlink(queue), "Unable to unlink queue"); in ZTEST()
151 mqd = mq_open(queue, O_RDONLY); in notify_function_thread()
180 mqd = mq_open(queue, flags, mode, &attrs); in ZTEST()
[all …]
|
| /Zephyr-4.2.1/subsys/tracing/ctf/ |
| D | tracing_ctf.h | 81 #define sys_port_trace_k_work_submit_to_queue_enter(queue, work) \ argument
82 sys_trace_k_work_submit_to_queue_enter(queue, work)
83 #define sys_port_trace_k_work_submit_to_queue_exit(queue, work, ret) \ argument
84 sys_trace_k_work_submit_to_queue_exit(queue, work, ret)
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
104 sys_trace_k_work_queue_stop_enter(queue, timeout)
105 #define sys_port_trace_k_work_queue_stop_blocking(queue, timeout) \ argument
[all …]
|
