Home
last modified time | relevance | path

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

123

/Zephyr-latest/kernel/
Dmsg_q.c33 static inline void handle_poll_events(struct k_msgq *msgq, uint32_t state) in handle_poll_events()
39 void k_msgq_init(struct k_msgq *msgq, char *buffer, size_t msg_size, in k_msgq_init()
60 SYS_PORT_TRACING_OBJ_INIT(k_msgq, msgq); in k_msgq_init()
65 int z_impl_k_msgq_alloc_init(struct k_msgq *msgq, size_t msg_size, in z_impl_k_msgq_alloc_init()
72 SYS_PORT_TRACING_OBJ_FUNC_ENTER(k_msgq, alloc_init, msgq); in z_impl_k_msgq_alloc_init()
87 SYS_PORT_TRACING_OBJ_FUNC_EXIT(k_msgq, alloc_init, msgq, ret); in z_impl_k_msgq_alloc_init()
93 int z_vrfy_k_msgq_alloc_init(struct k_msgq *msgq, size_t msg_size, in z_vrfy_k_msgq_alloc_init()
103 int k_msgq_cleanup(struct k_msgq *msgq) in k_msgq_cleanup()
105 SYS_PORT_TRACING_OBJ_FUNC_ENTER(k_msgq, cleanup, msgq); in k_msgq_cleanup()
108 SYS_PORT_TRACING_OBJ_FUNC_EXIT(k_msgq, cleanup, msgq, -EBUSY); in k_msgq_cleanup()
[all …]
/Zephyr-latest/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-latest/tests/benchmarks/app_kernel/src/
Dmaster.h94 extern struct k_msgq DEMOQX1;
95 extern struct k_msgq DEMOQX4;
96 extern struct k_msgq DEMOQX192;
97 extern struct k_msgq MB_COMM;
98 extern struct k_msgq CH_COMM;
/Zephyr-latest/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 ZTEST_USER()
90 struct k_msgq *q; in ZTEST_USER()
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 ZTEST_USER()
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_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 ZTEST_USER()
Dmain.c26 extern struct k_msgq kmsgq;
27 extern struct k_msgq msgq;
/Zephyr-latest/subsys/tracing/
Dtracing_tracking.c28 struct k_msgq *_track_list_k_msgq;
94 void sys_track_k_msgq_init(struct k_msgq *msgq) in sys_track_k_msgq_init()
96 SYS_PORT_TRACING_TYPE_MASK(k_msgq, in sys_track_k_msgq_init()
156 SYS_PORT_TRACING_TYPE_MASK(k_msgq, in sys_track_static_init()
157 SYS_TRACK_STATIC_INIT(k_msgq)); in sys_track_static_init()
/Zephyr-latest/samples/subsys/smf/hsm_psicc2/src/
Dhsm_psicc2_thread.h44 extern struct k_msgq hsm_psicc2_msgq;
/Zephyr-latest/include/zephyr/shell/
Dshell_rpmsg.h46 struct k_msgq rx_q;
/Zephyr-latest/modules/hal_infineon/abstraction-rtos/include/COMPONENT_ZEPHYR/
Dcyabs_rtos_impl.h91 typedef struct k_msgq cy_queue_t;
/Zephyr-latest/modules/lvgl/include/
Dlvgl_common_input.h19 struct k_msgq *event_msgq;
/Zephyr-latest/subsys/portability/cmsis_rtos_v2/
Dwrapper.h60 struct k_msgq z_msgq;
/Zephyr-latest/include/zephyr/tracing/
Dtracking.h42 extern struct k_msgq *_track_list_k_msgq;
106 void sys_track_k_msgq_init(struct k_msgq *msgq);
/Zephyr-latest/tests/drivers/can/api/src/
Dcommon.h58 extern struct k_msgq can_msgq;
/Zephyr-latest/include/zephyr/
Dkernel.h74 struct k_msgq;
4551 struct k_msgq { struct
4576 SYS_PORT_TRACING_TRACKING_FIELD(k_msgq) argument
4641 STRUCT_SECTION_ITERABLE(k_msgq, q_name) = \
4659 void k_msgq_init(struct k_msgq *msgq, char *buffer, size_t msg_size,
4681 __syscall int k_msgq_alloc_init(struct k_msgq *msgq, size_t msg_size,
4694 int k_msgq_cleanup(struct k_msgq *msgq);
4716 __syscall int k_msgq_put(struct k_msgq *msgq, const void *data, k_timeout_t timeout);
4738 __syscall int k_msgq_get(struct k_msgq *msgq, void *data, k_timeout_t timeout);
4754 __syscall int k_msgq_peek(struct k_msgq *msgq, void *data);
[all …]
/Zephyr-latest/tests/kernel/obj_tracking/src/
Dmain.c37 struct k_msgq msgq; in ZTEST()
107 list = SYS_PORT_TRACK_NEXT((struct k_msgq *)list); in ZTEST()
/Zephyr-latest/include/zephyr/sip_svc/
Dsip_svc_controller.h92 struct k_msgq req_msgq;
/Zephyr-latest/subsys/tracing/test/
Dtracing_test.h649 void sys_trace_k_msgq_init(struct k_msgq *msgq);
650 void sys_trace_k_msgq_alloc_init_enter(struct k_msgq *msgq, size_t msg_size, uint32_t max_msgs);
651 void sys_trace_k_msgq_alloc_init_exit(struct k_msgq *msgq, size_t msg_size, uint32_t max_msgs,
653 void sys_trace_k_msgq_cleanup_enter(struct k_msgq *msgq);
654 void sys_trace_k_msgq_cleanup_exit(struct k_msgq *msgq, int ret);
655 void sys_trace_k_msgq_put_enter(struct k_msgq *msgq, const void *data, k_timeout_t timeout);
656 void sys_trace_k_msgq_put_blocking(struct k_msgq *msgq, const void *data, k_timeout_t timeout);
657 void sys_trace_k_msgq_put_exit(struct k_msgq *msgq, const void *data, k_timeout_t timeout, int ret);
658 void sys_trace_k_msgq_get_enter(struct k_msgq *msgq, const void *data, k_timeout_t timeout);
659 void sys_trace_k_msgq_get_blocking(struct k_msgq *msgq, const void *data, k_timeout_t timeout);
[all …]
/Zephyr-latest/drivers/sdhc/
Dsdhc_esp32.h82 struct k_msgq *event_queue;
/Zephyr-latest/modules/openthread/platform/
Dhdlc_interface.hpp182 struct k_msgq spinel_hdlc_msgq;
/Zephyr-latest/drivers/stepper/step_dir/
Dstep_dir_stepper_common.h87 struct k_msgq event_msgq;
/Zephyr-latest/tests/benchmarks/thread_metric/src/
Dtm_porting_layer_zephyr.c43 static struct k_msgq test_msgq[TM_TEST_NUM_MESSAGE_QUEUES];
/Zephyr-latest/drivers/can/
Dcan_common.c108 struct k_msgq *msgq = (struct k_msgq *)user_data; in can_msgq_put()
121 int z_impl_can_add_rx_filter_msgq(const struct device *dev, struct k_msgq *msgq, in z_impl_can_add_rx_filter_msgq()

123