| /Zephyr-Core-2.7.6/include/posix/ |
| D | mqueue.h | 33 int mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len,
35 int mq_send(mqd_t mqdes, const char *msg_ptr, size_t msg_len,
39 int mq_timedreceive(mqd_t mqdes, char *msg_ptr, size_t msg_len,
41 int mq_timedsend(mqd_t mqdes, const char *msg_ptr, size_t msg_len,
|
| /Zephyr-Core-2.7.6/lib/posix/ |
| D | mqueue.c | 35 static int32_t send_message(mqueue_desc *mqd, const char *msg_ptr, size_t msg_len,
37 static int receive_message(mqueue_desc *mqd, char *msg_ptr, size_t msg_len,
243 int mq_send(mqd_t mqdes, const char *msg_ptr, size_t msg_len, in mq_send() argument
248 return send_message(mqd, msg_ptr, msg_len, K_FOREVER); in mq_send()
258 int mq_timedsend(mqd_t mqdes, const char *msg_ptr, size_t msg_len, in mq_timedsend() argument
264 return send_message(mqd, msg_ptr, msg_len, K_MSEC(timeout)); in mq_timedsend()
274 int mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len, in mq_receive() argument
279 return receive_message(mqd, msg_ptr, msg_len, K_FOREVER); in mq_receive()
289 int mq_timedreceive(mqd_t mqdes, char *msg_ptr, size_t msg_len, in mq_timedreceive() argument
295 return receive_message(mqd, msg_ptr, msg_len, K_MSEC(timeout)); in mq_timedreceive()
[all …]
|
| /Zephyr-Core-2.7.6/subsys/portability/cmsis_rtos_v2/ |
| D | msgq.c | 84 osStatus_t osMessageQueuePut(osMessageQueueId_t msgq_id, const void *msg_ptr, in osMessageQueuePut() argument
102 retval = k_msgq_put(&msgq->z_msgq, (void *)msg_ptr, K_NO_WAIT); in osMessageQueuePut()
104 retval = k_msgq_put(&msgq->z_msgq, (void *)msg_ptr, K_FOREVER); in osMessageQueuePut()
106 retval = k_msgq_put(&msgq->z_msgq, (void *)msg_ptr, in osMessageQueuePut()
122 osStatus_t osMessageQueueGet(osMessageQueueId_t msgq_id, void *msg_ptr, in osMessageQueueGet() argument
140 retval = k_msgq_get(&msgq->z_msgq, msg_ptr, K_NO_WAIT); in osMessageQueueGet()
142 retval = k_msgq_get(&msgq->z_msgq, msg_ptr, K_FOREVER); in osMessageQueueGet()
144 retval = k_msgq_get(&msgq->z_msgq, msg_ptr, in osMessageQueueGet()
|
| /Zephyr-Core-2.7.6/tests/kernel/poll/src/ |
| D | test_poll.c | 58 struct fifo_msg msg = { NULL, FIFO_MSG_VALUE }, *msg_ptr; in test_poll_no_wait() local
139 msg_ptr = k_fifo_get(&no_wait_fifo, K_NO_WAIT); in test_poll_no_wait()
140 zassert_not_null(msg_ptr, ""); in test_poll_no_wait()
141 zassert_equal(msg_ptr, &msg, ""); in test_poll_no_wait()
142 zassert_equal(msg_ptr->msg, FIFO_MSG_VALUE, ""); in test_poll_no_wait()
241 struct fifo_msg *msg_ptr; in check_results() local
266 msg_ptr = k_fifo_get(&wait_fifo, K_NO_WAIT); in check_results()
267 zassert_not_null(msg_ptr, ""); in check_results()
268 zassert_equal(msg_ptr, &wait_msg, ""); in check_results()
269 zassert_equal(msg_ptr->msg, FIFO_MSG_VALUE, ""); in check_results()
|
| /Zephyr-Core-2.7.6/include/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…
|
