28 	mqueue_object *mqueue;  member
167 	msg_queue_desc->mqueue = msg_queue;  in mq_open()
196 	atomic_dec(&mqd->mqueue->ref_count);  in mq_close()
199 	if (mqd->mqueue->name == NULL) {  in mq_close()
200 		remove_mq(mqd->mqueue);  in mq_close()
310 	k_msgq_get_attrs(&mqd->mqueue->queue, &attrs);  in mq_getattr()
364 	mqueue_object *msg_queue = mqd->mqueue;  in mq_notify()
401 	mqueue_object *mqueue = (mqueue_object *)arg;  in mq_notify_thread()  local
402 	struct sigevent *sevp = &mqueue->not;  in mq_notify_thread()
412 	remove_notification(mqueue);  in mq_notify_thread()
451 	if (msg_len >  mqd->mqueue->queue.msg_size) {  in send_message()
456 	uint32_t msgq_num = k_msgq_num_used_get(&mqd->mqueue->queue);  in send_message()
458 	if (k_msgq_put(&mqd->mqueue->queue, (void *)msg_ptr, timeout) != 0) {  in send_message()
463 	if (k_msgq_num_used_get(&mqd->mqueue->queue) - msgq_num > 0) {  in send_message()
464 		struct sigevent *sevp = &mqd->mqueue->not;  in send_message()
474 					     mqd->mqueue);  in send_message()
491 	if (msg_len < mqd->mqueue->queue.msg_size) {  in receive_message()
500 	if (k_msgq_get(&mqd->mqueue->queue, (void *)msg_ptr, timeout) != 0) {  in receive_message()
503 		ret = mqd->mqueue->queue.msg_size;  in receive_message()