381 	struct waitq       *waitq)  in ipc_mqueue_changed()  argument
383 	ipc_object_t object = io_from_waitq(waitq);  in ipc_mqueue_changed()
432 	waitq_wakeup64_all_locked(waitq, IPC_MQUEUE_RECEIVE,  in ipc_mqueue_changed()
671 	struct waitq *waitq = &port->ip_waitq;  in ipc_mqueue_post()  local
694 		receiver = waitq_wakeup64_identify_locked(waitq,  in ipc_mqueue_post()
753 			waitq_resume_identified_thread(waitq, receiver,  in ipc_mqueue_post()
766 			waitq_resume_identified_thread(waitq, receiver,  in ipc_mqueue_post()
803 			waitq_resume_identified_thread(waitq, receiver,  in ipc_mqueue_post()
826 		waitq_resume_identified_thread(waitq, receiver,  in ipc_mqueue_post()
832 	waitq_clear_promotion_locked(waitq, current_thread());  in ipc_mqueue_post()
833 	waitq_unlock(waitq);  in ipc_mqueue_post()
937 	struct waitq           *waitq,  in ipc_mqueue_receive()  argument
946 	waitq_lock(waitq);  in ipc_mqueue_receive()
948 	wresult = ipc_mqueue_receive_on_thread_and_unlock(waitq, rcv_timeout,  in ipc_mqueue_receive()
978 	struct waitq           *waitq,  in ipc_mqueue_receive_on_thread_and_unlock()  argument
984 	ipc_object_t            object = io_from_waitq(waitq);  in ipc_mqueue_receive_on_thread_and_unlock()
992 	if (waitq_type(waitq) == WQT_PORT_SET) {  in ipc_mqueue_receive_on_thread_and_unlock()
995 		struct waitq *port_wq;  in ipc_mqueue_receive_on_thread_and_unlock()
1025 	} else if (waitq_type(waitq) == WQT_PORT) {  in ipc_mqueue_receive_on_thread_and_unlock()
1026 		port = ip_from_waitq(waitq);  in ipc_mqueue_receive_on_thread_and_unlock()
1031 		panic("Unknown waitq type (%p/0x%x)", waitq, waitq_type(waitq));  in ipc_mqueue_receive_on_thread_and_unlock()
1049 	if (!waitq_is_valid(waitq)) {  in ipc_mqueue_receive_on_thread_and_unlock()
1102 	if (waitq_type(waitq) == WQT_PORT) {  in ipc_mqueue_receive_on_thread_and_unlock()
1103 		port = ip_from_waitq(waitq);  in ipc_mqueue_receive_on_thread_and_unlock()
1113 	wresult = waitq_assert_wait64_locked(waitq,  in ipc_mqueue_receive_on_thread_and_unlock()