| /Zephyr-latest/include/zephyr/posix/ |
| D | mqueue.h | 34 int mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len,
36 int mq_send(mqd_t mqdes, const char *msg_ptr, size_t msg_len,
40 int mq_timedreceive(mqd_t mqdes, char *msg_ptr, size_t msg_len,
42 int mq_timedsend(mqd_t mqdes, const char *msg_ptr, size_t msg_len,
|
| /Zephyr-latest/subsys/portability/cmsis_rtos_v2/ |
| D | msgq.c | 89 osStatus_t osMessageQueuePut(osMessageQueueId_t msgq_id, const void *msg_ptr, in osMessageQueuePut() argument
107 retval = k_msgq_put(&msgq->z_msgq, (void *)msg_ptr, K_NO_WAIT); in osMessageQueuePut()
109 retval = k_msgq_put(&msgq->z_msgq, (void *)msg_ptr, K_FOREVER); in osMessageQueuePut()
111 retval = k_msgq_put(&msgq->z_msgq, (void *)msg_ptr, in osMessageQueuePut()
127 osStatus_t osMessageQueueGet(osMessageQueueId_t msgq_id, void *msg_ptr, in osMessageQueueGet() argument
145 retval = k_msgq_get(&msgq->z_msgq, msg_ptr, K_NO_WAIT); in osMessageQueueGet()
147 retval = k_msgq_get(&msgq->z_msgq, msg_ptr, K_FOREVER); in osMessageQueueGet()
149 retval = k_msgq_get(&msgq->z_msgq, msg_ptr, in osMessageQueueGet()
|
| /Zephyr-latest/lib/posix/options/ |
| D | mqueue.c | 39 static int32_t send_message(mqueue_desc *mqd, const char *msg_ptr, size_t msg_len,
41 static int32_t receive_message(mqueue_desc *mqd, char *msg_ptr, size_t msg_len,
239 int mq_send(mqd_t mqdes, const char *msg_ptr, size_t msg_len, in mq_send() argument
244 return send_message(mqd, msg_ptr, msg_len, K_FOREVER); in mq_send()
254 int mq_timedsend(mqd_t mqdes, const char *msg_ptr, size_t msg_len, in mq_timedsend() argument
260 return send_message(mqd, msg_ptr, msg_len, K_MSEC(timeout)); in mq_timedsend()
270 int mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len, in mq_receive() argument
275 return receive_message(mqd, msg_ptr, msg_len, K_FOREVER); in mq_receive()
285 int mq_timedreceive(mqd_t mqdes, char *msg_ptr, size_t msg_len, in mq_timedreceive() argument
291 return receive_message(mqd, msg_ptr, msg_len, K_MSEC(timeout)); in mq_timedreceive()
[all …]
|
| /Zephyr-latest/tests/kernel/poll/src/ |
| D | test_poll.c | 62 struct fifo_msg msg = { NULL, FIFO_MSG_VALUE }, *msg_ptr; in ZTEST_USER() local
146 msg_ptr = k_fifo_get(&no_wait_fifo, K_NO_WAIT); in ZTEST_USER()
147 zassert_not_null(msg_ptr, ""); in ZTEST_USER()
148 zassert_equal(msg_ptr, &msg, ""); in ZTEST_USER()
149 zassert_equal(msg_ptr->msg, FIFO_MSG_VALUE, ""); in ZTEST_USER()
248 struct fifo_msg *msg_ptr; in check_results() local
273 msg_ptr = k_fifo_get(&wait_fifo, K_NO_WAIT); in check_results()
274 zassert_not_null(msg_ptr, ""); in check_results()
275 zassert_equal(msg_ptr, &wait_msg, ""); in check_results()
276 zassert_equal(msg_ptr->msg, FIFO_MSG_VALUE, ""); in check_results()
|
| /Zephyr-latest/subsys/logging/ |
| D | log_core.c | 716 STRUCT_SECTION_FOREACH(log_msg_ptr, msg_ptr) { in z_log_msg_claim_oldest()
722 if (msg_ptr->msg == NULL) { in z_log_msg_claim_oldest()
723 msg_ptr->msg = (union log_msg_generic *)mpsc_pbuf_claim(&buf->buf); in z_log_msg_claim_oldest()
727 if (msg_ptr->msg) { in z_log_msg_claim_oldest()
728 log_timestamp_t t = log_msg_get_timestamp(&msg_ptr->msg->log); in z_log_msg_claim_oldest()
732 msg = msg_ptr->msg; in z_log_msg_claim_oldest()
733 chosen = msg_ptr; in z_log_msg_claim_oldest()
819 STRUCT_SECTION_FOREACH(log_msg_ptr, msg_ptr) { in z_log_msg_pending()
822 if (msg_ptr->msg) { in z_log_msg_pending()
|
| /Zephyr-latest/subsys/mgmt/ec_host_cmd/backends/ |
| D | ec_host_cmd_backend_shi_npcx.c | 245 uint8_t *msg_ptr = data->tx_msg; in shi_npcx_write_half_outbuf() local
249 *obuf_ptr++ = *msg_ptr++; in shi_npcx_write_half_outbuf()
254 data->tx_msg = msg_ptr; in shi_npcx_write_half_outbuf()
367 uint8_t *msg_ptr; in shi_npcx_write_first_pkg_outbuf() local
373 msg_ptr = data->tx_msg; in shi_npcx_write_first_pkg_outbuf()
380 *obuf_ptr++ = *msg_ptr++; in shi_npcx_write_first_pkg_outbuf()
395 *obuf_ptr++ = *msg_ptr++; in shi_npcx_write_first_pkg_outbuf()
401 data->tx_msg = msg_ptr; in shi_npcx_write_first_pkg_outbuf()
|
| /Zephyr-latest/include/zephyr/portability/ |
| D | cmsis_os2.h | 708 osStatus_t osMessageQueuePut(osMessageQueueId_t mq_id, const void *msg_ptr, uint8_t msg_prio, uint3…
716 osStatus_t osMessageQueueGet(osMessageQueueId_t mq_id, void *msg_ptr, uint8_t *msg_prio, uint32_t t…
|
