Home
last modified time | relevance | path

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

12

/Zephyr-4.2.1/kernel/
Dqueue.c58 void z_impl_k_queue_init(struct k_queue *queue) in z_impl_k_queue_init()
67 SYS_PORT_TRACING_OBJ_INIT(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()
101 SYS_PORT_TRACING_OBJ_FUNC(k_queue, cancel_wait, 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()
140 SYS_PORT_TRACING_OBJ_FUNC_ENTER(k_queue, queue_insert, queue, alloc); in queue_insert()
148 SYS_PORT_TRACING_OBJ_FUNC_BLOCKING(k_queue, queue_insert, queue, alloc, K_FOREVER); in queue_insert()
[all …]
/Zephyr-4.2.1/tests/kernel/queue/src/
Dtest_queue_loop.c16 static struct k_queue queue;
21 static void tqueue_append(struct k_queue *pqueue) in tqueue_append()
39 static void tqueue_get(struct k_queue *pqueue) in tqueue_get()
58 static void tqueue_find_and_remove(struct k_queue *pqueue) in tqueue_find_and_remove()
70 tqueue_find_and_remove((struct k_queue *)p); in tIsr_entry()
71 tqueue_get((struct k_queue *)p); in tIsr_entry()
72 tqueue_append((struct k_queue *)p); in tIsr_entry()
77 tqueue_find_and_remove((struct k_queue *)p1); in tThread_entry()
78 tqueue_get((struct k_queue *)p1); in tThread_entry()
80 tqueue_append((struct k_queue *)p1); in tThread_entry()
[all …]
Dtest_queue_contexts.c17 struct k_queue queue;
34 static void tqueue_append(struct k_queue *pqueue) in tqueue_append()
65 static void tqueue_get(struct k_queue *pqueue) in tqueue_get()
96 tqueue_append((struct k_queue *)p); in tIsr_entry_append()
101 tqueue_get((struct k_queue *)p); in tIsr_entry_get()
106 tqueue_get((struct k_queue *)p1); in tThread_entry()
110 static void tqueue_thread_thread(struct k_queue *pqueue) in tqueue_thread_thread()
122 static void tqueue_thread_isr(struct k_queue *pqueue) in tqueue_thread_isr()
130 static void tqueue_isr_thread(struct k_queue *pqueue) in tqueue_isr_thread()
212 zassert_true(k_queue_get((struct k_queue *)p1, K_FOREVER) != NULL, in tThread_get()
[all …]
Dtest_queue_fail.c25 static struct k_queue queue; in ZTEST()
39 qdata_t *p = k_queue_get((struct k_queue *)p1, K_FOREVER); in tThread_entry()
62 static struct k_queue queue; in ZTEST()
108 static struct k_queue queue; in ZTEST()
257 struct k_queue *q; in ZTEST_USER()
Dtest_queue_user.c30 struct k_queue *q = p1; in child_thread_get()
79 struct k_queue *q; in ZTEST()
135 struct k_queue *q; in ZTEST_USER()
169 struct k_queue *q; in ZTEST_USER()
/Zephyr-4.2.1/tests/bluetooth/host/conn/mocks/
Dkernel.c29 DEFINE_FAKE_VOID_FUNC(k_queue_init, struct k_queue *);
30 DEFINE_FAKE_VOID_FUNC(k_queue_append, struct k_queue *, void *);
31 DEFINE_FAKE_VALUE_FUNC(int, k_queue_is_empty, struct k_queue *);
32 DEFINE_FAKE_VALUE_FUNC(void *, k_queue_get, struct k_queue *, k_timeout_t);
33 DEFINE_FAKE_VOID_FUNC(k_queue_prepend, struct k_queue *, void *);
Dkernel.h53 DECLARE_FAKE_VOID_FUNC(k_queue_init, struct k_queue *);
54 DECLARE_FAKE_VOID_FUNC(k_queue_append, struct k_queue *, void *);
55 DECLARE_FAKE_VALUE_FUNC(int, k_queue_is_empty, struct k_queue *);
56 DECLARE_FAKE_VALUE_FUNC(void *, k_queue_get, struct k_queue *, k_timeout_t);
57 DECLARE_FAKE_VOID_FUNC(k_queue_prepend, struct k_queue *, void *);
/Zephyr-4.2.1/samples/userspace/prod_consumer/src/
Dapp_shared.h24 extern struct k_queue shared_queue_incoming;
25 extern struct k_queue shared_queue_outgoing;
/Zephyr-4.2.1/samples/modules/tflite-micro/tflm_ethosu/src/
Dmain.cpp65 InferenceProcessParams(k_queue *_queue, uint8_t *_tensorArena, size_t _arenaSize) in InferenceProcessParams()
70 k_queue *queueHandle;
84 const vector<DataPtr> &_expectedOutput, k_queue *_queue) in xInferenceJob()
90 k_queue *responseQueue;
161 k_queue *inferenceQueue = static_cast<k_queue *>(_queue); in inferenceSenderTask()
168 k_queue senderQueue; in inferenceSenderTask()
224 k_queue inferenceQueue; in main()
/Zephyr-4.2.1/subsys/tracing/
Dtracing_tracking.c37 struct k_queue *_track_list_k_queue;
113 void sys_track_k_queue_init(struct k_queue *queue) in sys_track_k_queue_init()
115 SYS_PORT_TRACING_TYPE_MASK(k_queue, in sys_track_k_queue_init()
164 SYS_PORT_TRACING_TYPE_MASK(k_queue, in sys_track_static_init()
165 SYS_TRACK_STATIC_INIT(k_queue)); in sys_track_static_init()
/Zephyr-4.2.1/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.h544 void sys_trace_k_queue_init(struct k_queue *queue);
545 void sys_trace_k_queue_cancel_wait(struct k_queue *queue);
546 void sys_trace_k_queue_queue_insert_enter(struct k_queue *queue, bool alloc, void *data);
547 void sys_trace_k_queue_queue_insert_blocking(struct k_queue *queue, bool alloc, void *data);
548 void sys_trace_k_queue_queue_insert_exit(struct k_queue *queue, bool alloc, void *data, int ret);
549 void sys_trace_k_queue_append_enter(struct k_queue *queue, void *data);
550 void sys_trace_k_queue_append_exit(struct k_queue *queue, void *data);
551 void sys_trace_k_queue_alloc_append_enter(struct k_queue *queue, void *data);
552 void sys_trace_k_queue_alloc_append_exit(struct k_queue *queue, void *data, int ret);
553 void sys_trace_k_queue_prepend_enter(struct k_queue *queue, void *data);
[all …]
/Zephyr-4.2.1/tests/subsys/ipc/ipc_sessions/src/
Ddata_queue.h11 struct k_queue q;
/Zephyr-4.2.1/include/zephyr/
Dkernel.h78 struct k_queue;
2185 struct k_queue { struct
2192 SYS_PORT_TRACING_TRACKING_FIELD(k_queue) argument
2224 __syscall void k_queue_init(struct k_queue *queue);
2239 __syscall void k_queue_cancel_wait(struct k_queue *queue);
2253 void k_queue_append(struct k_queue *queue, void *data);
2271 __syscall int32_t k_queue_alloc_append(struct k_queue *queue, void *data);
2285 void k_queue_prepend(struct k_queue *queue, void *data);
2303 __syscall int32_t k_queue_alloc_prepend(struct k_queue *queue, void *data);
2318 void k_queue_insert(struct k_queue *queue, void *prev, void *data);
[all …]
/Zephyr-4.2.1/soc/andestech/ae350/
Dram_start_nonzero.ld10 * ex: tests/kernel/queue, k_queue_get() return k_queue address
/Zephyr-4.2.1/soc/egis/et171/common_linker/
Dram_start_nonzero.ld10 * ex: tests/kernel/queue, k_queue_get() return k_queue address
/Zephyr-4.2.1/tests/kernel/obj_tracking/src/
Dmain.c40 struct k_queue queue; in ZTEST()
140 list = SYS_PORT_TRACK_NEXT((struct k_queue *)list); in ZTEST()
/Zephyr-4.2.1/include/zephyr/tracing/
Dtracking.h65 extern struct k_queue *_track_list_k_queue;
130 void sys_track_k_queue_init(struct k_queue *queue);
/Zephyr-4.2.1/tests/kernel/mutex/mutex_error_case/src/
Dtest_mutex_error.c19 static struct k_queue queue;
/Zephyr-4.2.1/cmake/sca/eclair/ECL/
Dextra.ecl71 …|k_mem_slab|k_mem_pool|k_heap|k_mutex|k_stack|k_msgq|k_mbox|k_pipe|k_sem|k_queue)_list_(start|end)…
/Zephyr-4.2.1/samples/userspace/prod_consumer/
DREADME.rst23 application-to-application IPC (using ``k_queue``)
42 of the shared memory pool, and enqueue this data into a ``k_queue`` being
/Zephyr-4.2.1/include/zephyr/linker/
Dcommon-ram.ld89 ITERABLE_SECTION_RAM_GC_ALLOWED(k_queue, Z_LINK_ITERABLE_SUBALIGN)
/Zephyr-4.2.1/tests/kernel/mem_protect/mem_protect/src/
Dkobject.c83 struct k_queue *q; in ZTEST_USER()
1256 struct k_queue *q; in ZTEST()
1320 struct k_queue q;
/Zephyr-4.2.1/cmake/linker_script/common/
Dcommon-ram.cmake70 zephyr_iterable_section(NAME k_queue GROUP ${K_OBJECTS_GROUP} ${XIP_ALIGN_WITH_INPUT})
/Zephyr-4.2.1/drivers/input/
Dinput_renesas_ra_ctsu.c33 struct k_queue scan_q;

12