Home
last modified time | relevance | path

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

12

/Zephyr-Core-2.7.6/kernel/
Dmsg_q.c29 static inline void handle_poll_events(struct k_msgq *msgq, uint32_t state) in handle_poll_events()
35 void k_msgq_init(struct k_msgq *msgq, char *buffer, size_t msg_size, in k_msgq_init()
52 SYS_PORT_TRACING_OBJ_INIT(k_msgq, msgq); in k_msgq_init()
57 int z_impl_k_msgq_alloc_init(struct k_msgq *msgq, size_t msg_size, in z_impl_k_msgq_alloc_init()
64 SYS_PORT_TRACING_OBJ_FUNC_ENTER(k_msgq, alloc_init, msgq); in z_impl_k_msgq_alloc_init()
79 SYS_PORT_TRACING_OBJ_FUNC_EXIT(k_msgq, alloc_init, msgq, ret); in z_impl_k_msgq_alloc_init()
85 int z_vrfy_k_msgq_alloc_init(struct k_msgq *msgq, size_t msg_size, in z_vrfy_k_msgq_alloc_init()
95 int k_msgq_cleanup(struct k_msgq *msgq) in k_msgq_cleanup()
97 SYS_PORT_TRACING_OBJ_FUNC_ENTER(k_msgq, cleanup, msgq); in k_msgq_cleanup()
100 SYS_PORT_TRACING_OBJ_FUNC_EXIT(k_msgq, cleanup, msgq, -EBUSY); in k_msgq_cleanup()
[all …]
/Zephyr-Core-2.7.6/tests/kernel/msgq/msgq_usage/src/
Dmain.c18 struct k_msgq service1_msgq;
19 struct k_msgq service2_msgq;
20 struct k_msgq client_msgq;
35 static ZTEST_DMEM struct k_msgq *services[NUM_SERVICES];
36 static ZTEST_DMEM struct k_msgq *pclient;
59 pclient = (struct k_msgq *)data[1]; in service_manager_entry()
63 services[0] = (struct k_msgq *)data[1]; in service_manager_entry()
67 services[1] = (struct k_msgq *)data[1]; in service_manager_entry()
72 if (services[i] == (struct k_msgq *)data[1]) { in service_manager_entry()
77 k_msgq_purge((struct k_msgq *)data[1]); in service_manager_entry()
[all …]
/Zephyr-Core-2.7.6/tests/kernel/msgq/msgq_api/src/
Dtest_msgq_fail.c10 extern struct k_msgq msgq;
12 static void put_fail(struct k_msgq *q) in put_fail()
29 static void get_fail(struct k_msgq *q) in get_fail()
64 struct k_msgq *q; in test_msgq_user_put_fail()
90 struct k_msgq *q; in test_msgq_user_get_fail()
Dtest_msgq_contexts.c12 struct k_msgq msgq;
13 struct k_msgq msgq1;
25 static void put_msgq(struct k_msgq *pmsgq) in put_msgq()
50 static void get_msgq(struct k_msgq *pmsgq) in get_msgq()
72 static void purge_msgq(struct k_msgq *pmsgq) in purge_msgq()
84 put_msgq((struct k_msgq *)p); in tisr_entry()
89 get_msgq((struct k_msgq *)p1); in thread_entry()
93 static void msgq_thread(struct k_msgq *pmsgq) in msgq_thread()
125 static void msgq_thread_overflow(struct k_msgq *pmsgq) in msgq_thread_overflow()
150 static void msgq_isr(struct k_msgq *pmsgq) in msgq_isr()
[all …]
Dtest_msgq_purge.c11 extern struct k_msgq msgq;
17 int ret = k_msgq_put((struct k_msgq *)p1, (void *)&data[0], TIMEOUT); in tThread_entry()
22 static void purge_when_put(struct k_msgq *q) in purge_when_put()
72 struct k_msgq *q; in test_msgq_user_purge_when_put()
Dtest_msgq_attrs.c8 extern struct k_msgq msgq;
13 static void attrs_get(struct k_msgq *q) in attrs_get()
64 struct k_msgq *q; in test_msgq_user_attrs_get()
Dmain.c56 extern struct k_msgq kmsgq;
57 extern struct k_msgq msgq;
/Zephyr-Core-2.7.6/tests/benchmarks/app_kernel/src/
Dmaster.h135 extern struct k_msgq DEMOQX1;
136 extern struct k_msgq DEMOQX4;
137 extern struct k_msgq MB_COMM;
138 extern struct k_msgq CH_COMM;
/Zephyr-Core-2.7.6/drivers/can/
Dcan_handlers.c59 struct k_msgq *msgq, in z_vrfy_can_attach_msgq()
69 (struct k_msgq *)msgq, in z_vrfy_can_attach_msgq()
Dsocket_can_generic.h31 struct k_msgq *msgq;
133 k_msgq_get((struct k_msgq *)socket_context->msgq, &msg, in rx_thread()
Dcan_common.c32 struct k_msgq *msgq = (struct k_msgq *)arg; in can_msgq_put()
43 int z_impl_can_attach_msgq(const struct device *dev, struct k_msgq *msg_q, in z_impl_can_attach_msgq()
/Zephyr-Core-2.7.6/include/
Dkernel.h67 struct k_msgq;
4153 struct k_msgq { struct
4239 STRUCT_SECTION_ITERABLE(k_msgq, q_name) = \
4261 void k_msgq_init(struct k_msgq *msgq, char *buffer, size_t msg_size,
4283 __syscall int k_msgq_alloc_init(struct k_msgq *msgq, size_t msg_size,
4296 int k_msgq_cleanup(struct k_msgq *msgq);
4319 __syscall int k_msgq_put(struct k_msgq *msgq, const void *data, k_timeout_t timeout);
4341 __syscall int k_msgq_get(struct k_msgq *msgq, void *data, k_timeout_t timeout);
4357 __syscall int k_msgq_peek(struct k_msgq *msgq, void *data);
4370 __syscall void k_msgq_purge(struct k_msgq *msgq);
[all …]
/Zephyr-Core-2.7.6/subsys/tracing/test/
Dtracing_test.h615 void sys_trace_k_msgq_init(struct k_msgq *msgq);
616 void sys_trace_k_msgq_alloc_init_enter(struct k_msgq *msgq, size_t msg_size, uint32_t max_msgs);
617 void sys_trace_k_msgq_alloc_init_exit(struct k_msgq *msgq, size_t msg_size, uint32_t max_msgs,
619 void sys_trace_k_msgq_cleanup_enter(struct k_msgq *msgq);
620 void sys_trace_k_msgq_cleanup_exit(struct k_msgq *msgq, int ret);
621 void sys_trace_k_msgq_put_enter(struct k_msgq *msgq, const void *data, k_timeout_t timeout);
622 void sys_trace_k_msgq_put_blocking(struct k_msgq *msgq, const void *data, k_timeout_t timeout);
623 void sys_trace_k_msgq_put_exit(struct k_msgq *msgq, const void *data, k_timeout_t timeout, int ret);
624 void sys_trace_k_msgq_get_enter(struct k_msgq *msgq, const void *data, k_timeout_t timeout);
625 void sys_trace_k_msgq_get_blocking(struct k_msgq *msgq, const void *data, k_timeout_t timeout);
[all …]
/Zephyr-Core-2.7.6/subsys/portability/cmsis_rtos_v2/
Dwrapper.h56 struct k_msgq z_msgq;
/Zephyr-Core-2.7.6/drivers/neural_net/
Dintel_gna.h192 struct k_msgq request_queue;
194 struct k_msgq response_queue;
/Zephyr-Core-2.7.6/include/shell/
Dshell_log_backend.h38 struct k_msgq *msgq;
/Zephyr-Core-2.7.6/tests/kernel/poll/src/
Dtest_poll.c29 static struct k_msgq no_wait_msgq;
63 struct k_msgq *mq; in test_poll_no_wait()
178 static struct k_msgq wait_msgq;
179 static struct k_msgq *wait_msgq_ptr;
/Zephyr-Core-2.7.6/include/portability/
Dcmsis_os.h212 struct k_msgq *msgq;
606 struct k_msgq msgq_##name; \
/Zephyr-Core-2.7.6/include/linker/
Dcommon-ram.ld84 ITERABLE_SECTION_RAM_GC_ALLOWED(k_msgq, 4)
/Zephyr-Core-2.7.6/include/drivers/
Dcan.h343 struct k_msgq *msg_q,
574 __syscall int can_attach_msgq(const struct device *dev, struct k_msgq *msg_q,
/Zephyr-Core-2.7.6/cmake/linker_script/common/
Dcommon-ram.cmake55 zephyr_iterable_section(NAME k_msgq GROUP DATA_REGION ${XIP_ALIGN_WITH_INPUT} SUBALIGN 4)
/Zephyr-Core-2.7.6/samples/kernel/metairq_dispatch/src/
Dmain.c20 struct k_msgq msgq;
/Zephyr-Core-2.7.6/doc/reference/kernel/data_passing/
Dmessage_queues.rst73 A message queue is defined using a variable of type :c:struct:`k_msgq`.
88 struct k_msgq my_msgq;
/Zephyr-Core-2.7.6/tests/kernel/mem_protect/mem_protect/src/
Dkobject.c1260 struct k_msgq *m; in test_alloc_kobjects()
1321 struct k_msgq mq;
/Zephyr-Core-2.7.6/drivers/i2s/
Di2s_nrfx.c24 struct k_msgq tx_queue;
26 struct k_msgq rx_queue;

12