| /Zephyr-Core-2.7.6/kernel/ |
| D | msg_q.c | 29 static inline void handle_poll_events(struct k_msgq *msgq, uint32_t state) in handle_poll_events() argument
31 z_handle_obj_poll_events(&msgq->poll_events, state); in handle_poll_events()
35 void k_msgq_init(struct k_msgq *msgq, char *buffer, size_t msg_size, in k_msgq_init() argument
38 msgq->msg_size = msg_size; in k_msgq_init()
39 msgq->max_msgs = max_msgs; in k_msgq_init()
40 msgq->buffer_start = buffer; in k_msgq_init()
41 msgq->buffer_end = buffer + (max_msgs * msg_size); in k_msgq_init()
42 msgq->read_ptr = buffer; in k_msgq_init()
43 msgq->write_ptr = buffer; in k_msgq_init()
44 msgq->used_msgs = 0; in k_msgq_init()
[all …]
|
| D | poll.c | 84 if (event->msgq->used_msgs > 0) { in is_condition_met()
146 __ASSERT(event->msgq != NULL, "invalid message queue\n"); in register_event()
147 add_event(&event->msgq->poll_events, event, poller); in register_event()
181 __ASSERT(event->msgq != NULL, "invalid message queue\n"); in clear_event_registration()
398 Z_OOPS(Z_SYSCALL_OBJ(e->msgq, K_OBJ_MSGQ)); in z_vrfy_k_poll()
|
| /Zephyr-Core-2.7.6/subsys/portability/cmsis_rtos_v2/ |
| D | msgq.c | 29 struct cv2_msgq *msgq; in osMessageQueueNew() local
47 if (k_mem_slab_alloc(&cv2_msgq_slab, (void **)&msgq, K_MSEC(100)) == 0) { in osMessageQueueNew()
48 (void)memset(msgq, 0, sizeof(struct cv2_msgq)); in osMessageQueueNew()
58 msgq->pool = k_calloc(msg_count, msg_size); in osMessageQueueNew()
59 if (msgq->pool == NULL) { in osMessageQueueNew()
60 k_mem_slab_free(&cv2_msgq_slab, (void *) &msgq); in osMessageQueueNew()
63 msgq->is_dynamic_allocation = TRUE; in osMessageQueueNew()
65 msgq->pool = attr->mq_mem; in osMessageQueueNew()
66 msgq->is_dynamic_allocation = FALSE; in osMessageQueueNew()
69 k_msgq_init(&msgq->z_msgq, msgq->pool, msg_size, msg_count); in osMessageQueueNew()
[all …]
|
| D | CMakeLists.txt | 17 msgq.c
|
| /Zephyr-Core-2.7.6/subsys/portability/cmsis_rtos_v1/ |
| D | cmsis_msgq.c | 24 k_msgq_init(queue_def->msgq, queue_def->pool, in osMessageCreate()
42 retval = k_msgq_put(queue_def->msgq, (void *)&info, K_NO_WAIT); in osMessagePut()
44 retval = k_msgq_put(queue_def->msgq, (void *)&info, K_FOREVER); in osMessagePut()
46 retval = k_msgq_put(queue_def->msgq, (void *)&info, in osMessagePut()
75 retval = k_msgq_get(queue_def->msgq, &info, K_NO_WAIT); in osMessageGet()
77 retval = k_msgq_get(queue_def->msgq, &info, K_FOREVER); in osMessageGet()
79 retval = k_msgq_get(queue_def->msgq, &info, K_MSEC(millisec)); in osMessageGet()
|
| /Zephyr-Core-2.7.6/tests/kernel/msgq/msgq_api/src/ |
| D | test_msgq_fail.c | 10 extern struct k_msgq msgq;
53 k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); in test_msgq_put_fail()
54 put_fail(&msgq); in test_msgq_put_fail()
79 k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); in test_msgq_get_fail()
80 get_fail(&msgq); in test_msgq_get_fail()
|
| D | test_msgq_attrs.c | 8 extern struct k_msgq msgq;
51 k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); in test_msgq_attrs_get()
52 attrs_get(&msgq); in test_msgq_attrs_get()
|
| D | test_msgq_purge.c | 11 extern struct k_msgq msgq;
60 k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); in test_msgq_purge_when_put()
62 purge_when_put(&msgq); in test_msgq_purge_when_put()
|
| D | main.c | 57 extern struct k_msgq msgq;
65 k_thread_access_grant(k_current_get(), &kmsgq, &msgq, &end_sema, in test_main()
|
| D | test_msgq_contexts.c | 12 struct k_msgq msgq; variable
258 k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); in test_msgq_thread()
262 msgq_thread(&msgq); in test_msgq_thread()
275 k_msgq_init(&msgq, tbuffer, MSG_SIZE, 1); in test_msgq_thread_overflow()
279 msgq_thread_overflow(&msgq); in test_msgq_thread_overflow()
|
| /Zephyr-Core-2.7.6/subsys/tracing/test/ |
| D | tracing_test.h | 293 #define sys_port_trace_k_msgq_init(msgq) sys_trace_k_msgq_init(msgq) argument
295 #define sys_port_trace_k_msgq_alloc_init_enter(msgq) \ argument
296 sys_trace_k_msgq_alloc_init_enter(msgq, msg_size, max_msgs)
298 #define sys_port_trace_k_msgq_alloc_init_exit(msgq, ret) \ argument
299 sys_trace_k_msgq_alloc_init_exit(msgq, msg_size, max_msgs, ret)
301 #define sys_port_trace_k_msgq_cleanup_enter(msgq) sys_trace_k_msgq_cleanup_enter(msgq) argument
303 #define sys_port_trace_k_msgq_cleanup_exit(msgq, ret) sys_trace_k_msgq_cleanup_exit(msgq, ret) argument
305 #define sys_port_trace_k_msgq_put_enter(msgq, timeout) \ argument
306 sys_trace_k_msgq_put_enter(msgq, data, timeout)
308 #define sys_port_trace_k_msgq_put_blocking(msgq, timeout) \ argument
[all …]
|
| /Zephyr-Core-2.7.6/subsys/tracing/user/ |
| D | tracing_user.h | 222 #define sys_port_trace_k_msgq_init(msgq) argument
223 #define sys_port_trace_k_msgq_alloc_init_enter(msgq) argument
224 #define sys_port_trace_k_msgq_alloc_init_exit(msgq, ret) argument
225 #define sys_port_trace_k_msgq_cleanup_enter(msgq) argument
226 #define sys_port_trace_k_msgq_cleanup_exit(msgq, ret) argument
227 #define sys_port_trace_k_msgq_put_enter(msgq, timeout) argument
228 #define sys_port_trace_k_msgq_put_blocking(msgq, timeout) argument
229 #define sys_port_trace_k_msgq_put_exit(msgq, timeout, ret) argument
230 #define sys_port_trace_k_msgq_get_enter(msgq, timeout) argument
231 #define sys_port_trace_k_msgq_get_blocking(msgq, timeout) argument
[all …]
|
| /Zephyr-Core-2.7.6/include/tracing/ |
| D | tracing.h | 1414 #define sys_port_trace_k_msgq_init(msgq) argument
1420 #define sys_port_trace_k_msgq_alloc_init_enter(msgq) argument
1427 #define sys_port_trace_k_msgq_alloc_init_exit(msgq, ret) argument
1433 #define sys_port_trace_k_msgq_cleanup_enter(msgq) argument
1440 #define sys_port_trace_k_msgq_cleanup_exit(msgq, ret) argument
1447 #define sys_port_trace_k_msgq_put_enter(msgq, timeout) argument
1454 #define sys_port_trace_k_msgq_put_blocking(msgq, timeout) argument
1462 #define sys_port_trace_k_msgq_put_exit(msgq, timeout, ret) argument
1469 #define sys_port_trace_k_msgq_get_enter(msgq, timeout) argument
1476 #define sys_port_trace_k_msgq_get_blocking(msgq, timeout) argument
[all …]
|
| /Zephyr-Core-2.7.6/subsys/tracing/ctf/ |
| D | tracing_ctf.h | 241 #define sys_port_trace_k_msgq_init(msgq) argument
242 #define sys_port_trace_k_msgq_alloc_init_enter(msgq) argument
243 #define sys_port_trace_k_msgq_alloc_init_exit(msgq, ret) argument
244 #define sys_port_trace_k_msgq_cleanup_enter(msgq) argument
245 #define sys_port_trace_k_msgq_cleanup_exit(msgq, ret) argument
246 #define sys_port_trace_k_msgq_put_enter(msgq, timeout) argument
247 #define sys_port_trace_k_msgq_put_blocking(msgq, timeout) argument
248 #define sys_port_trace_k_msgq_put_exit(msgq, timeout, ret) argument
249 #define sys_port_trace_k_msgq_get_enter(msgq, timeout) argument
250 #define sys_port_trace_k_msgq_get_blocking(msgq, timeout) argument
[all …]
|
| /Zephyr-Core-2.7.6/drivers/can/ |
| D | can_handlers.c | 59 struct k_msgq *msgq, in z_vrfy_can_attach_msgq() argument
66 Z_OOPS(Z_SYSCALL_OBJ(msgq, K_OBJ_MSGQ)); in z_vrfy_can_attach_msgq()
69 (struct k_msgq *)msgq, in z_vrfy_can_attach_msgq()
|
| D | socket_can_generic.h | 31 struct k_msgq *msgq; member
96 ret = can_attach_msgq(socket_context->can_dev, socket_context->msgq, in socket_can_setsockopt()
133 k_msgq_get((struct k_msgq *)socket_context->msgq, &msg, in rx_thread()
|
| D | Kconfig.rcar | 18 Defines the array size of the callback/msgq pointers.
|
| D | Kconfig.stm32 | 22 Defines the array size of the callback/msgq pointers.
|
| D | can_common.c | 32 struct k_msgq *msgq = (struct k_msgq *)arg; in can_msgq_put() local
35 __ASSERT_NO_MSG(msgq); in can_msgq_put()
37 ret = k_msgq_put(msgq, frame, K_NO_WAIT); in can_msgq_put()
|
| /Zephyr-Core-2.7.6/samples/kernel/metairq_dispatch/src/ |
| D | main.c | 20 struct k_msgq msgq; member
64 int ret = k_msgq_put(&threads[m.target].msgq, &m, K_NO_WAIT); in metairq_fn()
180 int ret = k_msgq_get(&threads[id].msgq, &m, K_FOREVER); in thread_fn()
229 k_msgq_init(&threads[i].msgq, (char *)threads[i].msgq_buf, in main()
|
| /Zephyr-Core-2.7.6/include/shell/ |
| D | shell_log_backend.h | 38 struct k_msgq *msgq; member
89 .msgq = IS_ENABLED(CONFIG_LOG_MODE_DEFERRED) ? \
|
| /Zephyr-Core-2.7.6/subsys/shell/ |
| D | shell_log_backend.c | 25 err = k_msgq_get(backend->msgq, &msg, K_NO_WAIT); in msg_from_fifo()
76 struct k_msgq *msgq = shell->log_backend->msgq; in flush_expired_messages() local
81 err = k_msgq_peek(msgq, &msg); in flush_expired_messages()
84 (void)k_msgq_get(msgq, &msg, K_NO_WAIT); in flush_expired_messages()
108 err = k_msgq_put(shell->log_backend->msgq, &t_msg, in msg_to_fifo()
|
| /Zephyr-Core-2.7.6/subsys/tracing/sysview/ |
| D | tracing_sysview.h | 632 #define sys_port_trace_k_msgq_init(msgq) argument
633 #define sys_port_trace_k_msgq_alloc_init_enter(msgq) argument
634 #define sys_port_trace_k_msgq_alloc_init_exit(msgq, ret) argument
635 #define sys_port_trace_k_msgq_cleanup_enter(msgq) argument
636 #define sys_port_trace_k_msgq_cleanup_exit(msgq, ret) argument
637 #define sys_port_trace_k_msgq_put_enter(msgq, timeout) argument
638 #define sys_port_trace_k_msgq_put_blocking(msgq, timeout) argument
639 #define sys_port_trace_k_msgq_put_exit(msgq, timeout, ret) argument
640 #define sys_port_trace_k_msgq_get_enter(msgq, timeout) argument
641 #define sys_port_trace_k_msgq_get_blocking(msgq, timeout) argument
[all …]
|
| D | SYSVIEW_Zephyr.txt | 65 59 k_msgq_init msgq=%I, buffer=%p, msg_size=%u, max_msgs=%us
66 60 k_msgq_put msgq=%I, data=%p, Timeout=%TimeOut | Returns %ErrCodeMsg
67 61 k_msgq_get msgq=%I, data=%p, Timeout=%TimeOut | Returns %ErrCodeMsg
68 62 k_msgq_cleanup msgq=%I | Returns %ErrCodePosix
69 63 k_msgq_peek msgq=%I, data=%p | Returns %ErrCodeMsg
70 64 k_msgq_purge msgq=%I
|
| /Zephyr-Core-2.7.6/include/ |
| D | kernel.h | 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);
4382 __syscall uint32_t k_msgq_num_free_get(struct k_msgq *msgq);
4394 __syscall void k_msgq_get_attrs(struct k_msgq *msgq,
4398 static inline uint32_t z_impl_k_msgq_num_free_get(struct k_msgq *msgq) in z_impl_k_msgq_num_free_get() argument
[all …]
|
