Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 60) sorted by relevance

123

/subsys/bluetooth/controller/ll_sw/
A Dull_tx_queue.c13 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()
20 queue->pause_data++; in ull_tx_q_pause_data()
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()
31 sys_slist_merge_slist(&queue->tx_list, &queue->data_list); in ull_tx_q_resume_data()
39 if (queue->pause_data) { in ull_tx_q_enqueue_data()
41 list = &queue->data_list; in ull_tx_q_enqueue_data()
[all …]
A Dull_tx_queue.h22 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);
/subsys/tracing/test/
A Dtracing_test.h160 #define sys_port_trace_k_queue_init(queue) sys_trace_k_queue_init(queue) argument
161 #define sys_port_trace_k_queue_cancel_wait(queue) sys_trace_k_queue_cancel_wait(queue) argument
168 #define sys_port_trace_k_queue_append_enter(queue) sys_trace_k_queue_append_enter(queue, data) argument
169 #define sys_port_trace_k_queue_append_exit(queue) sys_trace_k_queue_append_exit(queue, data) argument
174 #define sys_port_trace_k_queue_prepend_enter(queue) sys_trace_k_queue_prepend_enter(queue, data) argument
175 #define sys_port_trace_k_queue_prepend_exit(queue) sys_trace_k_queue_prepend_exit(queue, data) argument
180 #define sys_port_trace_k_queue_insert_enter(queue) sys_trace_k_queue_insert_enter(queue, prev, data) argument
183 #define sys_port_trace_k_queue_insert_exit(queue) sys_trace_k_queue_insert_exit(queue, prev, data) argument
196 #define sys_port_trace_k_queue_remove_enter(queue) sys_trace_k_queue_remove_enter(queue, data) argument
203 #define sys_port_trace_k_queue_peek_head(queue, ret) sys_trace_k_queue_peek_head(queue, ret) argument
[all …]
A Dtracing_string_format_test.c422 TRACING_STRING("%s: %p\n", __func__, queue); in sys_trace_k_queue_init()
427 TRACING_STRING("%s: %p\n", __func__, queue); in sys_trace_k_queue_cancel_wait()
432 TRACING_STRING("%s: %p\n", __func__, queue); in sys_trace_k_queue_append_enter()
437 TRACING_STRING("%s: %p\n", __func__, queue); in sys_trace_k_queue_append_exit()
442 TRACING_STRING("%s: %p\n", __func__, queue); in sys_trace_k_queue_queue_insert_enter()
447 TRACING_STRING("%s: %p\n", __func__, queue); in sys_trace_k_queue_queue_insert_exit()
452 TRACING_STRING("%s: %p\n", __func__, queue); in sys_trace_k_queue_get_blocking()
457 TRACING_STRING("%s: %p\n", __func__, queue); in sys_trace_k_queue_get_exit()
462 TRACING_STRING("%s: %p\n", __func__, queue); in sys_trace_k_queue_peek_head()
467 TRACING_STRING("%s: %p\n", __func__, queue); in sys_trace_k_queue_peek_tail()
[all …]
/subsys/tracing/sysview/
A Dtracing_sysview.h173 #define sys_port_trace_k_work_queue_init(queue) \ argument
175 (uint32_t)(uintptr_t)queue)
353 SEGGER_SYSVIEW_RecordU32(TID_QUEUE_INIT, (uint32_t)(uintptr_t)queue)
358 #define sys_port_trace_k_queue_queue_insert_enter(queue, alloc) argument
360 #define sys_port_trace_k_queue_queue_insert_exit(queue, alloc, ret) argument
387 #define sys_port_trace_k_queue_insert_blocking(queue, timeout) argument
397 #define sys_port_trace_k_queue_merge_slist_enter(queue) argument
398 #define sys_port_trace_k_queue_merge_slist_exit(queue, ret) argument
404 #define sys_port_trace_k_queue_get_blocking(queue, timeout) argument
415 #define sys_port_trace_k_queue_unique_append_enter(queue) argument
[all …]
A DSYSVIEW_Zephyr.txt130 118 k_work_queue_drain queue=%I
138 126 k_work_queue_start queue=%I
140 128 k_work_reschedule_for_queue queue=%I, dwork=%I, Delay=%TimeOut | Returns %u
142 130 k_work_reschedule_for_queue queue=%I, dwork=%I, Delay=%TimeOut | Returns %u
144 132 k_work_submit_to_queue queue=%I, work=%I | Returns %ErrCodePosix
145 133 k_work_queue_unplug queue=%I | Returns %ErrCodePosix
/subsys/tracing/user/
A Dtracing_user.h156 #define sys_port_trace_k_work_queue_init(queue) argument
230 #define sys_port_trace_k_queue_init(queue) argument
231 #define sys_port_trace_k_queue_cancel_wait(queue) argument
235 #define sys_port_trace_k_queue_append_enter(queue) argument
236 #define sys_port_trace_k_queue_append_exit(queue) argument
239 #define sys_port_trace_k_queue_prepend_enter(queue) argument
240 #define sys_port_trace_k_queue_prepend_exit(queue) argument
243 #define sys_port_trace_k_queue_insert_enter(queue) argument
245 #define sys_port_trace_k_queue_insert_exit(queue) argument
253 #define sys_port_trace_k_queue_remove_enter(queue) argument
[all …]
/subsys/tracing/ctf/
A Dtracing_ctf.h94 #define sys_port_trace_k_work_queue_init(queue) argument
96 #define sys_port_trace_k_work_queue_start_exit(queue) argument
193 #define sys_port_trace_k_queue_init(queue) argument
194 #define sys_port_trace_k_queue_cancel_wait(queue) argument
198 #define sys_port_trace_k_queue_append_enter(queue) argument
199 #define sys_port_trace_k_queue_append_exit(queue) argument
202 #define sys_port_trace_k_queue_prepend_enter(queue) argument
203 #define sys_port_trace_k_queue_prepend_exit(queue) argument
206 #define sys_port_trace_k_queue_insert_enter(queue) argument
208 #define sys_port_trace_k_queue_insert_exit(queue) argument
[all …]
/subsys/fs/virtiofs/
A DKconfig29 bool "Omit notification queue (idx 1) and assume that idx 1 is the first request queue"
32 According to virtio specification v1.3 section 5.11.2 queue at idx 1 is notification queue and
34 the first request queue
/subsys/net/ip/
A DKconfig.mgmt31 a message queue.
34 bool "System work queue"
36 Submit work to the system work queue to schedule calling network
39 a message queue.
55 Hidden option to enable the network event's queue if asynchronous
71 int "Size of event queue"
79 notification. Thus the size of this queue has to be tweaked depending
83 int "Timeout for event queue"
88 Timeout in milliseconds for the event queue. This timeout is used to
89 wait for the queue to be available.
A DKconfig.tcp25 int "TCP work queue thread stack size"
30 Set the TCP work queue thread stack size in bytes.
33 int "Priority of the TCP work queue"
37 Set the priority of the TCP worker queue, that handles all
131 int "How long to queue received data (in ms)"
136 If we receive out-of-order TCP data, we queue it. This value tells
140 Note that we only queue data sequentially in current version i.e.,
141 there should be no holes in the queue. For example, if we receive
/subsys/shell/
A DKconfig.template.shell_log_queue_size4 int "Log message queue size"
8 by shell thread. Too small queue may lead to the logger thread being blocked
9 (see $(module)_LOG_MESSAGE_QUEUE_TIMEOUT). Too big queue on relatively
A DKconfig.template.shell_log_queue_timeout8 If queue with pending log messages is full, oldest log message is
9 dropped if queue is still full after requested time (-1 is forever).
/subsys/ipc/ipc_service/backends/
A DKconfig.rpmsg7 int "Size of RX work queue stack"
10 Size of stack used by work queue RX thread. This work queue is
13 work queue. Size is the same for all instances.
/subsys/rtio/
A DKconfig15 thread for each completion queue event until the wait count is met. This
17 use polling on the completion queue with a k_yield() in between iterations.
27 calling thread for each completion queue event until the wait count is met.
29 will use polling on the completion queue with a k_yield() in between
/subsys/ipc/ipc_service/lib/
A DKconfig.icmsg45 int "Size of RX work queue stack"
48 Size of stack used by work queue RX thread. This work queue is
50 from the system work queue. The queue is shared among instances.
53 int "Priority of RX work queue thread"
57 Priority of the ICMSG RX work queue thread.
/subsys/ipc/rpmsg_service/
A DKconfig55 int "Size of RX work queue stack"
58 Size of stack used by work queue RX thread. This work queue is
60 service users about received data from the system work queue.
/subsys/net/lib/zperf/
A Dzperf_tcp_uploader.c277 struct k_work_q *queue; in zperf_tcp_upload_async() local
301 queue = zperf->queue; in zperf_tcp_upload_async()
302 if (queue == NULL) { in zperf_tcp_upload_async()
307 tid = k_work_queue_thread_get(queue); in zperf_tcp_upload_async()
A DKconfig37 int "zperf work queue thread priority"
40 Priority of the thread that handles zperf work queue.
43 int "zperf work queue thread stack size"
46 Stack size of the thread that handles zperf work queue.
A Dzperf_common.c70 .queue = &zperf_work_q_##i, \
284 k_work_submit_to_queue(zperf_work_q[proto * SESSION_INDEX + session_id].queue, work); in zperf_async_work_submit()
310 k_work_queue_init(zperf_work_q[i].queue); in zperf_init()
312 k_work_queue_start(zperf_work_q[i].queue, in zperf_init()
A Dzperf_udp_uploader.c417 struct k_work_q *queue; in zperf_udp_upload_async() local
441 queue = zperf->queue; in zperf_udp_upload_async()
442 if (queue == NULL) { in zperf_udp_upload_async()
447 tid = k_work_queue_thread_get(queue); in zperf_udp_upload_async()
/subsys/input/
A DKconfig35 Input events are added to a message queue and the callbacks are
56 int "Input queue max messages"
59 Maximum number of messages in the input event queue.
/subsys/usb/device/
A DKconfig141 bool "Use a dedicate work queue in the USB subsystem"
144 This option provides a dedicated work queue that is used for
149 queue from making progress on the USB tasks that would
152 Without this the system work queue is used for all USB
168 By default, USB work queue priority is the lowest cooperative
/subsys/usb/device_next/class/
A DKconfig.cdc_acm22 Use the dedicated queue in CDC ACM implementation if the systemwork
23 queue cannot be used due to performance issues or other conflicts.
/subsys/bluetooth/mesh/
A Dfriend.c185 purge_buffers(&frnd->queue); in friend_clear()
190 purge_buffers(&seg->queue); in friend_clear()
696 net_buf_slist_put(&frnd->queue, buf); in enqueue_buf()
754 if (sys_slist_is_empty(&frnd->queue)) { in bt_mesh_friend_poll()
1146 net_buf_slist_put(&seg->queue, buf); in enqueue_friend_pdu()
1149 sys_slist_merge_slist(&frnd->queue, &seg->queue); in enqueue_friend_pdu()
1355 sys_slist_init(&frnd->queue); in bt_mesh_friend_init()
1361 sys_slist_init(&frnd->seg[j].queue); in bt_mesh_friend_init()
1411 for (cur = sys_slist_peek_head(&frnd->queue); in friend_purge_old_ack()
1418 sys_slist_remove(&frnd->queue, prev, cur); in friend_purge_old_ack()
[all …]

Completed in 58 milliseconds

123