31 	mqueue_object *mqueue;  member
169 	msg_queue_desc->mqueue = msg_queue;  in mq_open()
198 	atomic_dec(&mqd->mqueue->ref_count);  in mq_close()
201 	if (mqd->mqueue->name == NULL) {  in mq_close()
202 		remove_mq(mqd->mqueue);  in mq_close()
322 	k_msgq_get_attrs(&mqd->mqueue->queue, &attrs);  in mq_getattr()
376 	mqueue_object *msg_queue = mqd->mqueue;  in mq_notify()
413 	mqueue_object *mqueue = (mqueue_object *)arg;  in mq_notify_thread()  local
414 	struct sigevent *sevp = &mqueue->not;  in mq_notify_thread()
424 	remove_notification(mqueue);  in mq_notify_thread()
463 	if (msg_len >  mqd->mqueue->queue.msg_size) {  in send_message()
468 	uint32_t msgq_num = k_msgq_num_used_get(&mqd->mqueue->queue);  in send_message()
470 	if (k_msgq_put(&mqd->mqueue->queue, (void *)msg_ptr, timeout) != 0) {  in send_message()
475 	if (k_msgq_num_used_get(&mqd->mqueue->queue) - msgq_num > 0) {  in send_message()
476 		struct sigevent *sevp = &mqd->mqueue->not;  in send_message()
486 					     mqd->mqueue);  in send_message()
503 	if (msg_len < mqd->mqueue->queue.msg_size) {  in receive_message()
512 	if (k_msgq_get(&mqd->mqueue->queue, (void *)msg_ptr, timeout) != 0) {  in receive_message()
515 		ret = mqd->mqueue->queue.msg_size;  in receive_message()