| /subsys/portability/cmsis_rtos_v2/ |
| A D | msgq.c | 80 k_msgq_init(&msgq->z_msgq, msgq->pool, msg_size, msg_count); in osMessageQueueNew()
98 if (msgq == NULL) { in osMessageQueuePut()
135 if (msgq == NULL) { in osMessageQueueGet()
170 if (msgq == NULL) { in osMessageQueueGetCapacity()
184 if (msgq == NULL) { in osMessageQueueGetMsgSize()
198 if (msgq == NULL) { in osMessageQueueGetCount()
212 if (msgq == NULL) { in osMessageQueueGetSpace()
227 if (msgq == NULL) { in osMessageQueueGetName()
230 return msgq->name; in osMessageQueueGetName()
240 if (msgq == NULL) { in osMessageQueueReset()
[all …]
|
| A D | CMakeLists.txt | 17 msgq.c
|
| /subsys/portability/cmsis_rtos_v1/ |
| A 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()
|
| /subsys/tracing/test/ |
| A D | tracing_test.h | 296 #define sys_port_trace_k_msgq_init(msgq) sys_trace_k_msgq_init(msgq) argument
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
309 sys_trace_k_msgq_put_enter(msgq, data, timeout)
312 sys_trace_k_msgq_put_blocking(msgq, data, timeout)
324 sys_trace_k_msgq_get_enter(msgq, data, timeout)
326 sys_trace_k_msgq_get_blocking(msgq, data, timeout)
329 #define sys_port_trace_k_msgq_peek(msgq, ret) sys_trace_k_msgq_peek(msgq, data, ret) argument
330 #define sys_port_trace_k_msgq_purge(msgq) sys_trace_k_msgq_purge(msgq) argument
686 void sys_trace_k_msgq_init(struct k_msgq *msgq);
[all …]
|
| /subsys/tracing/user/ |
| A D | tracing_user.h | 299 #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
310 #define sys_port_trace_k_msgq_get_enter(msgq, timeout) argument
311 #define sys_port_trace_k_msgq_get_blocking(msgq, timeout) argument
313 #define sys_port_trace_k_msgq_peek(msgq, ret) argument
[all …]
|
| /subsys/tracing/sysview/ |
| A D | tracing_sysview.h | 508 #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
519 #define sys_port_trace_k_msgq_get_enter(msgq, timeout) argument
520 #define sys_port_trace_k_msgq_get_blocking(msgq, timeout) argument
522 #define sys_port_trace_k_msgq_peek(msgq, ret) argument
[all …]
|
| A D | SYSVIEW_Zephyr.txt | 64 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
|
| /subsys/tracing/ctf/ |
| A D | tracing_ctf.h | 262 #define sys_port_trace_k_msgq_init(msgq) argument
263 #define sys_port_trace_k_msgq_alloc_init_enter(msgq) argument
264 #define sys_port_trace_k_msgq_alloc_init_exit(msgq, ret) argument
265 #define sys_port_trace_k_msgq_cleanup_enter(msgq) argument
266 #define sys_port_trace_k_msgq_cleanup_exit(msgq, ret) argument
267 #define sys_port_trace_k_msgq_put_enter(msgq, timeout) argument
268 #define sys_port_trace_k_msgq_put_blocking(msgq, timeout) argument
273 #define sys_port_trace_k_msgq_get_enter(msgq, timeout) argument
274 #define sys_port_trace_k_msgq_get_blocking(msgq, timeout) argument
276 #define sys_port_trace_k_msgq_peek(msgq, ret) argument
[all …]
|
| /subsys/tracing/ |
| A D | tracing_tracking.c | 92 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()
|
| /subsys/net/lib/ocpp/ |
| A D | ocpp.c | 226 while (!k_msgq_get(ctx->msgq, &msg, K_FOREVER)) { in ocpp_internal_handler()
591 k_msgq_put(ctx->msgq, &msg, K_NO_WAIT); in timer_heartbeat_cb()
601 k_msgq_put(ctx->msgq, &msg, K_NO_WAIT); in timer_meter_cb()
724 ctx->msgq = &ocpp_iq; in ocpp_init()
|
| A D | core.c | 393 ret = k_msgq_put(ctx->msgq, msg, K_MSEC(100)); in ocpp_remote_start_transaction()
435 ret = k_msgq_put(ctx->msgq, msg, K_MSEC(100)); in ocpp_remote_stop_transaction()
462 ret = k_msgq_put(ctx->msgq, msg, K_MSEC(100)); in ocpp_unlock_connector()
|
| A D | ocpp_i.h | 155 struct k_msgq *msgq; member
|
| /subsys/sip_svc/ |
| A D | Kconfig | 43 Depth of msgq used inside sip_svc controller.
|