Home
last modified time | relevance | path

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

/Zephyr-latest/lib/os/
Duser_work.c12 struct k_work_user_q *work_q = work_q_ptr; in z_work_user_q_main() local
21 work = k_queue_get(&work_q->queue, K_FOREVER); in z_work_user_q_main()
42 void k_work_user_queue_start(struct k_work_user_q *work_q, k_thread_stack_t *stack, in k_work_user_queue_start() argument
45 k_queue_init(&work_q->queue); in k_work_user_queue_start()
50 k_thread_create(&work_q->thread, stack, stack_size, z_work_user_q_main, in k_work_user_queue_start()
51 work_q, NULL, NULL, prio, K_USER | K_INHERIT_PERMS, in k_work_user_queue_start()
53 k_object_access_grant(&work_q->queue, &work_q->thread); in k_work_user_queue_start()
55 k_thread_name_set(&work_q->thread, name); in k_work_user_queue_start()
58 k_thread_start(&work_q->thread); in k_work_user_queue_start()
/Zephyr-latest/tests/kernel/workq/work_queue/src/
Dstart_stop.c28 struct k_work_q work_q; in ZTEST() local
35 zassert_equal(k_work_queue_stop(&work_q, K_FOREVER), -EALREADY, in ZTEST()
37 k_work_queue_start(&work_q, work_q_stack, K_THREAD_STACK_SIZEOF(work_q_stack), in ZTEST()
42 zassert_equal(k_work_submit_to_queue(&work_q, &works[i]), 1, in ZTEST()
49 zassert_equal(k_work_queue_stop(&work_q, K_FOREVER), -EBUSY, in ZTEST()
51 zassert_true(k_work_queue_drain(&work_q, true) >= 0, "Failed to drain & plug work queue"); in ZTEST()
52 zassert_ok(k_work_queue_stop(&work_q, K_FOREVER), "Failed to stop work queue"); in ZTEST()
55 zassert_equal(k_work_submit_to_queue(&work_q, &work), -ENODEV, in ZTEST()
/Zephyr-latest/tests/kernel/workq/user_work/src/
Dmain.c102 static void twork_submit_1(struct k_work_user_q *work_q, struct k_work_user *w, in twork_submit_1() argument
111 zassert_false(k_work_user_submit_to_queue(work_q, w), in twork_submit_1()
117 struct k_work_user_q *work_q = (struct k_work_user_q *)data; in twork_submit() local
120 twork_submit_1(work_q, &work[i], work_handler); in twork_submit()
/Zephyr-latest/kernel/
Dpoll.c613 struct k_work_q *work_q = twork->workq; in signal_triggered_work() local
617 z_work_submit_to_queue(work_q, &twork->work); in signal_triggered_work()
666 int k_work_poll_submit_to_queue(struct k_work_q *work_q, in k_work_poll_submit_to_queue() argument
675 __ASSERT(work_q != NULL, "NULL work_q\n"); in k_work_poll_submit_to_queue()
680 SYS_PORT_TRACING_FUNC_ENTER(k_work_poll, submit_to_queue, work_q, work, timeout); in k_work_poll_submit_to_queue()
685 if (work->workq == work_q) { in k_work_poll_submit_to_queue()
692 SYS_PORT_TRACING_FUNC_EXIT(k_work_poll, submit_to_queue, work_q, in k_work_poll_submit_to_queue()
700 SYS_PORT_TRACING_FUNC_EXIT(k_work_poll, submit_to_queue, work_q, in k_work_poll_submit_to_queue()
709 work->workq = work_q; in k_work_poll_submit_to_queue()
744 SYS_PORT_TRACING_FUNC_EXIT(k_work_poll, submit_to_queue, work_q, work, timeout, 0); in k_work_poll_submit_to_queue()
[all …]
/Zephyr-latest/include/zephyr/net/
Dopenthread.h69 struct k_work_q work_q; member
/Zephyr-latest/drivers/wifi/eswifi/
Deswifi_core.c388 k_work_reschedule_for_queue(&eswifi->work_q, &eswifi->status_work, in eswifi_status_work()
408 k_work_reschedule_for_queue(&eswifi->work_q, &eswifi->status_work, in eswifi_request_work()
547 k_work_submit_to_queue(&eswifi->work_q, &eswifi->request_work); in eswifi_mgmt_scan()
563 k_work_submit_to_queue(&eswifi->work_q, &eswifi->request_work); in eswifi_mgmt_disconnect()
612 k_work_submit_to_queue(&eswifi->work_q, in eswifi_mgmt_connect()
782 k_work_queue_start(&eswifi->work_q, eswifi_work_q_stack, in eswifi_init()
Deswifi_offload.c131 k_work_submit_to_queue(&eswifi->work_q, &socket->connect_work); in eswifi_off_connect()
277 k_work_submit_to_queue(&eswifi->work_q, &socket->send_work); in eswifi_off_send()
333 k_work_submit_to_queue(&eswifi->work_q, &socket->send_work); in eswifi_off_sendto()
435 k_work_reschedule_for_queue(&eswifi->work_q, &socket->read_work, in eswifi_off_get()
Deswifi.h65 struct k_work_q work_q; member
Deswifi_socket_offload.c341 ret = k_work_reschedule_for_queue(&eswifi->work_q, &socket->read_work, K_NO_WAIT); in eswifi_socket_recv()
458 k_work_reschedule_for_queue(&eswifi->work_q, &socket->read_work, in eswifi_socket_open()
503 ret = k_work_reschedule_for_queue(&eswifi->work_q, &socket->read_work, K_NO_WAIT); in eswifi_socket_poll()
Deswifi_socket.c186 err = k_work_reschedule_for_queue(&eswifi->work_q, &socket->read_work, in eswifi_off_read_work()
/Zephyr-latest/drivers/sensor/ite/ite_vcmp_it8xxx2/
Dvcmp_ite_it8xxx2.c84 struct k_work_q *work_q; variable
260 k_work_submit_to_queue(work_q, in vcmp_it8xxx2_isr()
379 work_q = &vcmp_it8xxx2_work_q; in vcmp_it8xxx2_init_work_q()
/Zephyr-latest/subsys/net/l2/openthread/
Dopenthread.c118 return ot_context ? (k_tid_t)&ot_context->work_q.thread : 0; in openthread_thread_id_get()
176 k_work_submit_to_queue(&ot_context->work_q, &ot_context->api_work); in otTaskletsSignalPending()
593 k_work_queue_start(&ot_context->work_q, ot_stack_area, in openthread_init()
597 (void)k_work_submit_to_queue(&ot_context->work_q, &ot_context->api_work); in openthread_init()
/Zephyr-latest/drivers/dma/
Ddma_emul.c65 struct k_work_q work_q; member
448 ret = k_work_submit_to_queue(&data->work_q, &data->work.work); in dma_emul_start()
548 k_work_queue_init(&data->work_q); in dma_emul_init()
550 k_work_queue_start(&data->work_q, config->work_q_stack, config->work_q_stack_size, in dma_emul_init()
/Zephyr-latest/drivers/adc/
Dadc_npcx.c128 struct k_work_q *work_q; variable
259 k_work_submit_to_queue(work_q ? work_q : &k_sys_work_q, in adc_npcx_isr()
764 work_q = &adc_npcx_work_q; in adc_npcx_init_cmp_work_q()
/Zephyr-latest/include/zephyr/tracing/
Dtracing.h625 #define sys_port_trace_k_work_poll_submit_to_queue_enter(work_q, work, timeout) argument
633 #define sys_port_trace_k_work_poll_submit_to_queue_blocking(work_q, work, timeout) argument
642 #define sys_port_trace_k_work_poll_submit_to_queue_exit(work_q, work, timeout, ret) argument
/Zephyr-latest/subsys/tracing/user/
Dtracing_user.h186 #define sys_port_trace_k_work_poll_submit_to_queue_enter(work_q, work, \ argument
188 #define sys_port_trace_k_work_poll_submit_to_queue_blocking(work_q, work, \ argument
190 #define sys_port_trace_k_work_poll_submit_to_queue_exit(work_q, work, timeout, \ argument
/Zephyr-latest/subsys/tracing/sysview/
Dtracing_sysview.h262 #define sys_port_trace_k_work_poll_submit_to_queue_enter(work_q, work, timeout) \ argument
263 SEGGER_SYSVIEW_RecordU32x3(TID_WORK_POLL_SUBMIT_TO_QUEUE, (uint32_t)(uintptr_t)work_q, \
266 #define sys_port_trace_k_work_poll_submit_to_queue_blocking(work_q, work, timeout) argument
268 #define sys_port_trace_k_work_poll_submit_to_queue_exit(work_q, work, timeout, ret) \ argument
DSYSVIEW_Zephyr.txt137 125 k_work_poll_submit_to_queue work_q=%I, work=%I, Timeout=%TimeOut
/Zephyr-latest/include/zephyr/
Dkernel.h4336 static inline int k_work_user_submit_to_queue(struct k_work_user_q *work_q, in k_work_user_submit_to_queue() argument
4343 ret = k_queue_alloc_append(&work_q->queue, work); in k_work_user_submit_to_queue()
4376 void k_work_user_queue_start(struct k_work_user_q *work_q,
4391 static inline k_tid_t k_work_user_queue_thread_get(struct k_work_user_q *work_q) in k_work_user_queue_thread_get() argument
4393 return &work_q->thread; in k_work_user_queue_thread_get()
4482 int k_work_poll_submit_to_queue(struct k_work_q *work_q,
/Zephyr-latest/subsys/tracing/ctf/
Dtracing_ctf.h121 #define sys_port_trace_k_work_poll_submit_to_queue_enter(work_q, work, \ argument
123 #define sys_port_trace_k_work_poll_submit_to_queue_blocking(work_q, work, \ argument
125 #define sys_port_trace_k_work_poll_submit_to_queue_exit(work_q, work, timeout, \ argument
/Zephyr-latest/subsys/tracing/test/
Dtracing_test.h110 #define sys_port_trace_k_work_poll_submit_to_queue_enter(work_q, work, timeout) argument
111 #define sys_port_trace_k_work_poll_submit_to_queue_blocking(work_q, work, timeout) argument
112 #define sys_port_trace_k_work_poll_submit_to_queue_exit(work_q, work, timeout, ret) argument
/Zephyr-latest/boards/qemu/x86/
Dqemu_x86_tiny.ld205 LIB_ZEPHYR_OBJECT_FILE_IN_SECT(lsect, work_q)
/Zephyr-latest/doc/releases/
Dmigration-guide-4.0.rst511 * The ``work_q`` parameter to ``NET_SOCKET_SERVICE_SYNC_DEFINE`` and
Drelease-notes-4.0.rst1153 * Removed ``work_q`` parameter from socket service macros as it was no longer
Drelease-notes-2.0.rst1306 * :github:`14733` - kernel/work_q.c: Improve code coverage to 100%