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()
49 	msgq->buffer_end = buffer + (max_msgs * msg_size);  in k_msgq_init()
69 int z_impl_k_msgq_alloc_init(struct k_msgq *msgq, size_t msg_size,  in z_impl_k_msgq_alloc_init()  argument
78 	if (size_mul_overflow(msg_size, max_msgs, &total_size)) {  in z_impl_k_msgq_alloc_init()
83 			k_msgq_init(msgq, buffer, msg_size, max_msgs);  in z_impl_k_msgq_alloc_init()
97 int z_vrfy_k_msgq_alloc_init(struct k_msgq *msgq, size_t msg_size,  in z_vrfy_k_msgq_alloc_init()  argument
102 	return z_impl_k_msgq_alloc_init(msgq, msg_size, max_msgs);  in z_vrfy_k_msgq_alloc_init()
148 			(void)memcpy(pending_thread->base.swap_data, data, msgq->msg_size);  in z_impl_k_msgq_put()
156 			(void)memcpy(msgq->write_ptr, (char *)data, msgq->msg_size);  in z_impl_k_msgq_put()
157 			msgq->write_ptr += msgq->msg_size;  in z_impl_k_msgq_put()
195 	K_OOPS(K_SYSCALL_MEMORY_READ(data, msgq->msg_size));  in z_vrfy_k_msgq_put()
204 	attrs->msg_size = msgq->msg_size;  in z_impl_k_msgq_get_attrs()
235 		(void)memcpy((char *)data, msgq->read_ptr, msgq->msg_size);  in z_impl_k_msgq_get()
236 		msgq->read_ptr += msgq->msg_size;  in z_impl_k_msgq_get()
251 			       msgq->msg_size);  in z_impl_k_msgq_get()
252 			msgq->write_ptr += msgq->msg_size;  in z_impl_k_msgq_get()
294 	K_OOPS(K_SYSCALL_MEMORY_WRITE(data, msgq->msg_size));  in z_vrfy_k_msgq_get()
310 		(void)memcpy((char *)data, msgq->read_ptr, msgq->msg_size);  in z_impl_k_msgq_peek()
328 	K_OOPS(K_SYSCALL_MEMORY_WRITE(data, msgq->msg_size));  in z_vrfy_k_msgq_peek()
347 		byte_offset = idx * msgq->msg_size;  in z_impl_k_msgq_peek_at()
356 		(void)memcpy(data, start_addr + byte_offset, msgq->msg_size);  in z_impl_k_msgq_peek_at()
374 	K_OOPS(K_SYSCALL_MEMORY_WRITE(data, msgq->msg_size));  in z_vrfy_k_msgq_peek_at()