Home
last modified time | relevance | path

Searched refs:msgq (Results 1 – 25 of 47) sorted by relevance

12

/Zephyr-latest/kernel/
Dmsg_q.c32 static inline bool handle_poll_events(struct k_msgq *msgq) in handle_poll_events() argument
35 return z_handle_obj_poll_events(&msgq->poll_events, in handle_poll_events()
38 ARG_UNUSED(msgq); in handle_poll_events()
43 void k_msgq_init(struct k_msgq *msgq, char *buffer, size_t msg_size, in k_msgq_init() argument
46 msgq->msg_size = msg_size; in k_msgq_init()
47 msgq->max_msgs = max_msgs; in k_msgq_init()
48 msgq->buffer_start = buffer; in k_msgq_init()
49 msgq->buffer_end = buffer + (max_msgs * msg_size); in k_msgq_init()
50 msgq->read_ptr = buffer; in k_msgq_init()
51 msgq->write_ptr = buffer; in k_msgq_init()
[all …]
/Zephyr-latest/subsys/portability/cmsis_rtos_v2/
Dmsgq.c30 struct cmsis_rtos_msgq_cb *msgq; in osMessageQueueNew() local
49 msgq = (struct cmsis_rtos_msgq_cb *)attr->cb_mem; in osMessageQueueNew()
50 } else if (k_mem_slab_alloc(&cmsis_rtos_msgq_cb_slab, (void **)&msgq, K_MSEC(100)) != 0) { in osMessageQueueNew()
53 (void)memset(msgq, 0, sizeof(struct cmsis_rtos_msgq_cb)); in osMessageQueueNew()
54 msgq->is_cb_dynamic_allocation = attr->cb_mem == NULL; in osMessageQueueNew()
61 msgq->pool = k_calloc(msg_count, msg_size); in osMessageQueueNew()
62 if (msgq->pool == NULL) { in osMessageQueueNew()
63 if (msgq->is_cb_dynamic_allocation) { in osMessageQueueNew()
64 k_mem_slab_free(&cmsis_rtos_msgq_cb_slab, (void *)msgq); in osMessageQueueNew()
68 msgq->is_dynamic_allocation = TRUE; in osMessageQueueNew()
[all …]
DCMakeLists.txt17 msgq.c
/Zephyr-latest/subsys/portability/cmsis_rtos_v1/
Dcmsis_msgq.c24 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-latest/tests/kernel/msgq/msgq_api/src/
Dtest_msgq_fail.c10 extern struct k_msgq msgq;
53 k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); in ZTEST()
54 put_fail(&msgq); in ZTEST()
79 k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); in ZTEST()
80 get_fail(&msgq); in ZTEST()
Dtest_msgq_attrs.c8 extern struct k_msgq msgq;
51 k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); in ZTEST()
52 attrs_get(&msgq); in ZTEST()
Dtest_msgq_purge.c12 extern struct k_msgq msgq;
61 k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); in ZTEST()
63 purge_when_put(&msgq); in ZTEST()
Dmain.c27 extern struct k_msgq msgq;
35 k_thread_access_grant(k_current_get(), &kmsgq, &msgq, &end_sema, in msgq_api_setup()
Dtest_msgq_contexts.c12 struct k_msgq msgq; variable
259 k_msgq_init(&msgq, tbuffer, MSG_SIZE, MSGQ_LEN); in ZTEST()
263 msgq_thread(&msgq); in ZTEST()
276 k_msgq_init(&msgq, tbuffer, MSG_SIZE, 2); in ZTEST()
280 ret = k_msgq_put(&msgq, (void *)&data[0], K_FOREVER); in ZTEST()
283 msgq_thread_overflow(&msgq); in ZTEST()
287 zassert_false(msgq.write_ptr == msgq.buffer_start, in ZTEST()
/Zephyr-latest/include/zephyr/tracing/
Dtracking.h85 #define sys_port_track_k_msgq_purge(msgq) argument
86 #define sys_port_track_k_msgq_peek(msgq, ret) argument
87 #define sys_port_track_k_msgq_init(msgq) \ argument
88 sys_track_k_msgq_init(msgq)
106 void sys_track_k_msgq_init(struct k_msgq *msgq);
141 #define sys_port_track_k_msgq_purge(msgq) argument
142 #define sys_port_track_k_msgq_peek(msgq, ret) argument
143 #define sys_port_track_k_msgq_init(msgq) argument
Dtracing.h1372 #define sys_port_trace_k_msgq_init(msgq) argument
1378 #define sys_port_trace_k_msgq_alloc_init_enter(msgq) argument
1385 #define sys_port_trace_k_msgq_alloc_init_exit(msgq, ret) argument
1391 #define sys_port_trace_k_msgq_cleanup_enter(msgq) argument
1398 #define sys_port_trace_k_msgq_cleanup_exit(msgq, ret) argument
1405 #define sys_port_trace_k_msgq_put_enter(msgq, timeout) argument
1412 #define sys_port_trace_k_msgq_put_blocking(msgq, timeout) argument
1420 #define sys_port_trace_k_msgq_put_exit(msgq, timeout, ret) argument
1427 #define sys_port_trace_k_msgq_get_enter(msgq, timeout) argument
1434 #define sys_port_trace_k_msgq_get_blocking(msgq, timeout) argument
[all …]
/Zephyr-latest/subsys/tracing/test/
Dtracing_test.h296 #define sys_port_trace_k_msgq_init(msgq) sys_trace_k_msgq_init(msgq) argument
298 #define sys_port_trace_k_msgq_alloc_init_enter(msgq) \ argument
299 sys_trace_k_msgq_alloc_init_enter(msgq, msg_size, max_msgs)
301 #define sys_port_trace_k_msgq_alloc_init_exit(msgq, ret) \ argument
302 sys_trace_k_msgq_alloc_init_exit(msgq, msg_size, max_msgs, ret)
304 #define sys_port_trace_k_msgq_cleanup_enter(msgq) sys_trace_k_msgq_cleanup_enter(msgq) argument
306 #define sys_port_trace_k_msgq_cleanup_exit(msgq, ret) sys_trace_k_msgq_cleanup_exit(msgq, ret) argument
308 #define sys_port_trace_k_msgq_put_enter(msgq, timeout) \ argument
309 sys_trace_k_msgq_put_enter(msgq, data, timeout)
311 #define sys_port_trace_k_msgq_put_blocking(msgq, timeout) \ argument
[all …]
/Zephyr-latest/subsys/tracing/user/
Dtracing_user.h299 #define sys_port_trace_k_msgq_init(msgq) argument
300 #define sys_port_trace_k_msgq_alloc_init_enter(msgq) argument
301 #define sys_port_trace_k_msgq_alloc_init_exit(msgq, ret) argument
302 #define sys_port_trace_k_msgq_cleanup_enter(msgq) argument
303 #define sys_port_trace_k_msgq_cleanup_exit(msgq, ret) argument
304 #define sys_port_trace_k_msgq_put_enter(msgq, timeout) argument
305 #define sys_port_trace_k_msgq_put_blocking(msgq, timeout) argument
306 #define sys_port_trace_k_msgq_put_exit(msgq, timeout, ret) argument
307 #define sys_port_trace_k_msgq_get_enter(msgq, timeout) argument
308 #define sys_port_trace_k_msgq_get_blocking(msgq, timeout) argument
[all …]
/Zephyr-latest/samples/kernel/metairq_dispatch/src/
Dmain.c20 struct k_msgq msgq; member
64 int ret = k_msgq_put(&threads[m.target].msgq, &m, K_NO_WAIT); in metairq_fn()
188 int ret = k_msgq_get(&threads[id].msgq, &m, K_FOREVER); in thread_fn()
236 k_msgq_init(&threads[i].msgq, (char *)threads[i].msgq_buf, in main()
/Zephyr-latest/tests/kernel/obj_tracking/src/
Dmain.c37 struct k_msgq msgq; in ZTEST() local
100 k_msgq_init(&msgq, (char *)msgq_buffer, sizeof(int), 8); in ZTEST()
104 if (list == &msgq || list == &msgq_s) { in ZTEST()
/Zephyr-latest/drivers/can/
Dcan_common.c108 struct k_msgq *msgq = (struct k_msgq *)user_data; in can_msgq_put() local
113 __ASSERT_NO_MSG(msgq); in can_msgq_put()
115 ret = k_msgq_put(msgq, frame, K_NO_WAIT); in can_msgq_put()
117 LOG_ERR("Msgq %p overflowed. Frame ID: 0x%x", msgq, frame->id); 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() argument
126 return api->add_rx_filter(dev, can_msgq_put, msgq, filter); in z_impl_can_add_rx_filter_msgq()
DKconfig.rcar20 Defines the array size of the callback/msgq pointers.
Dcan_handlers.c220 struct k_msgq *msgq, in z_vrfy_can_add_rx_filter_msgq() argument
226 K_OOPS(K_SYSCALL_OBJ(msgq, K_OBJ_MSGQ)); in z_vrfy_can_add_rx_filter_msgq()
229 return z_impl_can_add_rx_filter_msgq(dev, msgq, &filter_copy); in z_vrfy_can_add_rx_filter_msgq()
/Zephyr-latest/subsys/tracing/sysview/
DSYSVIEW_Zephyr.txt64 59 k_msgq_init msgq=%I, buffer=%p, msg_size=%u, max_msgs=%us
65 60 k_msgq_put msgq=%I, data=%p, Timeout=%TimeOut | Returns %ErrCodeMsg
66 61 k_msgq_get msgq=%I, data=%p, Timeout=%TimeOut | Returns %ErrCodeMsg
67 62 k_msgq_cleanup msgq=%I | Returns %ErrCodePosix
68 63 k_msgq_peek msgq=%I, data=%p | Returns %ErrCodeMsg
69 64 k_msgq_purge msgq=%I
Dtracing_sysview.h508 #define sys_port_trace_k_msgq_init(msgq) argument
509 #define sys_port_trace_k_msgq_alloc_init_enter(msgq) argument
510 #define sys_port_trace_k_msgq_alloc_init_exit(msgq, ret) argument
511 #define sys_port_trace_k_msgq_cleanup_enter(msgq) argument
512 #define sys_port_trace_k_msgq_cleanup_exit(msgq, ret) argument
513 #define sys_port_trace_k_msgq_put_enter(msgq, timeout) argument
514 #define sys_port_trace_k_msgq_put_blocking(msgq, timeout) argument
515 #define sys_port_trace_k_msgq_put_exit(msgq, timeout, ret) argument
516 #define sys_port_trace_k_msgq_get_enter(msgq, timeout) argument
517 #define sys_port_trace_k_msgq_get_blocking(msgq, timeout) argument
[all …]
/Zephyr-latest/drivers/i2s/
Di2s_ll_stm32.h27 struct k_msgq *msgq; member
Di2s_ll_stm32.c66 while (queue_get(s->msgq, &mem_block, &size, 0) == 0) { in stream_queue_drop()
358 if ((queue_is_empty(stream->msgq) == false) || in i2s_stm32_trigger()
418 ret = queue_get(dev_data->rx.msgq, mem_block, size, dev_data->rx.cfg.timeout); in i2s_stm32_read()
438 return queue_put(dev_data->tx.msgq, mem_block, size, dev_data->tx.cfg.timeout); in i2s_stm32_write()
562 ret = queue_put(stream->msgq, mblk_tmp, in dma_rx_callback()
616 if (queue_is_empty(stream->msgq) == true) { in dma_tx_callback()
638 ret = queue_get(stream->msgq, &stream->mem_block, in dma_tx_callback()
799 ret = queue_get(stream->msgq, &stream->mem_block, in tx_stream_start()
934 .msgq = &dir##_##index##_queue, \
/Zephyr-latest/subsys/tracing/
Dtracing_tracking.c92 void sys_track_k_msgq_init(struct k_msgq *msgq) in sys_track_k_msgq_init() argument
95 SYS_TRACK_LIST_PREPEND(_track_list_k_msgq, msgq)); in sys_track_k_msgq_init()
/Zephyr-latest/subsys/tracing/ctf/
Dtracing_ctf.h258 #define sys_port_trace_k_msgq_init(msgq) argument
259 #define sys_port_trace_k_msgq_alloc_init_enter(msgq) argument
260 #define sys_port_trace_k_msgq_alloc_init_exit(msgq, ret) argument
261 #define sys_port_trace_k_msgq_cleanup_enter(msgq) argument
262 #define sys_port_trace_k_msgq_cleanup_exit(msgq, ret) argument
263 #define sys_port_trace_k_msgq_put_enter(msgq, timeout) argument
264 #define sys_port_trace_k_msgq_put_blocking(msgq, timeout) argument
265 #define sys_port_trace_k_msgq_put_exit(msgq, timeout, ret) argument
266 #define sys_port_trace_k_msgq_get_enter(msgq, timeout) argument
267 #define sys_port_trace_k_msgq_get_blocking(msgq, timeout) argument
[all …]
/Zephyr-latest/include/zephyr/
Dkernel.h4661 void k_msgq_init(struct k_msgq *msgq, char *buffer, size_t msg_size,
4683 __syscall int k_msgq_alloc_init(struct k_msgq *msgq, size_t msg_size,
4696 int k_msgq_cleanup(struct k_msgq *msgq);
4718 __syscall int k_msgq_put(struct k_msgq *msgq, const void *data, k_timeout_t timeout);
4740 __syscall int k_msgq_get(struct k_msgq *msgq, void *data, k_timeout_t timeout);
4756 __syscall int k_msgq_peek(struct k_msgq *msgq, void *data);
4774 __syscall int k_msgq_peek_at(struct k_msgq *msgq, void *data, uint32_t idx);
4785 __syscall void k_msgq_purge(struct k_msgq *msgq);
4797 __syscall uint32_t k_msgq_num_free_get(struct k_msgq *msgq);
4807 __syscall void k_msgq_get_attrs(struct k_msgq *msgq,
[all …]

12