Home
last modified time | relevance | path

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

12

/Zephyr-latest/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 void handle_poll_events(struct k_queue *queue, uint32_t state) in handle_poll_events()
97 void z_impl_k_queue_cancel_wait(struct k_queue *queue) in z_impl_k_queue_cancel_wait()
99 SYS_PORT_TRACING_OBJ_FUNC(k_queue, cancel_wait, queue); in z_impl_k_queue_cancel_wait()
115 static inline void z_vrfy_k_queue_cancel_wait(struct k_queue *queue) in z_vrfy_k_queue_cancel_wait()
123 static int32_t queue_insert(struct k_queue *queue, void *prev, void *data, in queue_insert()
129 SYS_PORT_TRACING_OBJ_FUNC_ENTER(k_queue, queue_insert, queue, alloc); in queue_insert()
137 SYS_PORT_TRACING_OBJ_FUNC_BLOCKING(k_queue, queue_insert, queue, alloc, K_FOREVER); in queue_insert()
[all …]
/Zephyr-latest/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-latest/tests/bluetooth/host/conn/mocks/
Dkernel.c25 DEFINE_FAKE_VOID_FUNC(k_queue_init, struct k_queue *);
26 DEFINE_FAKE_VOID_FUNC(k_queue_append, struct k_queue *, void *);
27 DEFINE_FAKE_VALUE_FUNC(int, k_queue_is_empty, struct k_queue *);
28 DEFINE_FAKE_VALUE_FUNC(void *, k_queue_get, struct k_queue *, k_timeout_t);
29 DEFINE_FAKE_VOID_FUNC(k_queue_prepend, struct k_queue *, void *);
Dkernel.h48 DECLARE_FAKE_VOID_FUNC(k_queue_init, struct k_queue *);
49 DECLARE_FAKE_VOID_FUNC(k_queue_append, struct k_queue *, void *);
50 DECLARE_FAKE_VALUE_FUNC(int, k_queue_is_empty, struct k_queue *);
51 DECLARE_FAKE_VALUE_FUNC(void *, k_queue_get, struct k_queue *, k_timeout_t);
52 DECLARE_FAKE_VOID_FUNC(k_queue_prepend, struct k_queue *, void *);
/Zephyr-latest/samples/userspace/prod_consumer/src/
Dapp_shared.h24 extern struct k_queue shared_queue_incoming;
25 extern struct k_queue shared_queue_outgoing;
/Zephyr-latest/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-latest/subsys/tracing/
Dtracing_tracking.c39 struct k_queue *_track_list_k_queue;
114 void sys_track_k_queue_init(struct k_queue *queue) in sys_track_k_queue_init()
116 SYS_PORT_TRACING_TYPE_MASK(k_queue, in sys_track_k_queue_init()
167 SYS_PORT_TRACING_TYPE_MASK(k_queue, in sys_track_static_init()
168 SYS_TRACK_STATIC_INIT(k_queue)); in sys_track_static_init()
/Zephyr-latest/subsys/tracing/test/
Dtracing_string_format_test.c411 void sys_trace_k_queue_init(struct k_queue *queue) in sys_trace_k_queue_init()
416 void sys_trace_k_queue_cancel_wait(struct k_queue *queue) in sys_trace_k_queue_cancel_wait()
421 void sys_trace_k_queue_append_enter(struct k_queue *queue, void *data) in sys_trace_k_queue_append_enter()
426 void sys_trace_k_queue_append_exit(struct k_queue *queue, void *data) in sys_trace_k_queue_append_exit()
431 void sys_trace_k_queue_queue_insert_enter(struct k_queue *queue, bool alloc, void *data) in sys_trace_k_queue_queue_insert_enter()
436 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()
441 void sys_trace_k_queue_get_blocking(struct k_queue *queue, k_timeout_t timeout) in sys_trace_k_queue_get_blocking()
446 void sys_trace_k_queue_get_exit(struct k_queue *queue, k_timeout_t timeout, void *ret) in sys_trace_k_queue_get_exit()
451 void sys_trace_k_queue_peek_head(struct k_queue *queue, void *ret) in sys_trace_k_queue_peek_head()
456 void sys_trace_k_queue_peek_tail(struct k_queue *queue, void *ret) in sys_trace_k_queue_peek_tail()
[all …]
Dtracing_test.h539 void sys_trace_k_queue_init(struct k_queue *queue);
540 void sys_trace_k_queue_cancel_wait(struct k_queue *queue);
541 void sys_trace_k_queue_queue_insert_enter(struct k_queue *queue, bool alloc, void *data);
542 void sys_trace_k_queue_queue_insert_blocking(struct k_queue *queue, bool alloc, void *data);
543 void sys_trace_k_queue_queue_insert_exit(struct k_queue *queue, bool alloc, void *data, int ret);
544 void sys_trace_k_queue_append_enter(struct k_queue *queue, void *data);
545 void sys_trace_k_queue_append_exit(struct k_queue *queue, void *data);
546 void sys_trace_k_queue_alloc_append_enter(struct k_queue *queue, void *data);
547 void sys_trace_k_queue_alloc_append_exit(struct k_queue *queue, void *data, int ret);
548 void sys_trace_k_queue_prepend_enter(struct k_queue *queue, void *data);
[all …]
/Zephyr-latest/include/zephyr/
Dkernel.h77 struct k_queue;
1956 struct k_queue { struct
1963 SYS_PORT_TRACING_TRACKING_FIELD(k_queue) argument
1995 __syscall void k_queue_init(struct k_queue *queue);
2010 __syscall void k_queue_cancel_wait(struct k_queue *queue);
2024 void k_queue_append(struct k_queue *queue, void *data);
2042 __syscall int32_t k_queue_alloc_append(struct k_queue *queue, void *data);
2056 void k_queue_prepend(struct k_queue *queue, void *data);
2074 __syscall int32_t k_queue_alloc_prepend(struct k_queue *queue, void *data);
2089 void k_queue_insert(struct k_queue *queue, void *prev, void *data);
[all …]
/Zephyr-latest/soc/andestech/ae350/common_linker/
Dram_start_nonzero.ld10 * ex: tests/kernel/queue, k_queue_get() return k_queue address
/Zephyr-latest/include/zephyr/tracing/
Dtracking.h45 extern struct k_queue *_track_list_k_queue;
109 void sys_track_k_queue_init(struct k_queue *queue);
/Zephyr-latest/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-latest/tests/kernel/mutex/mutex_error_case/src/
Dtest_mutex_error.c19 static struct k_queue queue;
/Zephyr-latest/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-latest/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-latest/include/zephyr/linker/
Dcommon-ram.ld86 ITERABLE_SECTION_RAM_GC_ALLOWED(k_queue, Z_LINK_ITERABLE_SUBALIGN)
/Zephyr-latest/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-latest/cmake/linker_script/common/
Dcommon-ram.cmake45 zephyr_iterable_section(NAME k_queue GROUP DATA_REGION ${XIP_ALIGN_WITH_INPUT} SUBALIGN ${CONFIG_LI…
/Zephyr-latest/doc/releases/
Drelease-notes-1.8.rst28 * Added k_queue API for Kernel
/Zephyr-latest/doc/services/tracing/
Dindex.rst632 struct k_queue *_track_list_k_queue;
/Zephyr-latest/doc/kernel/services/threads/
Dworkqueue.rst411 example when it's put into a :c:struct:`k_queue` by some thread and processed

12