Lines Matching refs:msg_ptr
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()
374 static int32_t send_message(mqueue_desc *mqd, const char *msg_ptr, size_t msg_len, in send_message() argument
393 if (k_msgq_put(&mqd->mqueue->queue, (void *)msg_ptr, timeout) != 0) { in send_message()
401 static int32_t receive_message(mqueue_desc *mqd, char *msg_ptr, size_t msg_len, in receive_message() argument
420 if (k_msgq_get(&mqd->mqueue->queue, (void *)msg_ptr, timeout) != 0) { in receive_message()