692 		thread_t receiver;  in ipc_mqueue_post()  local
694 		receiver = waitq_wakeup64_identify_locked(waitq,  in ipc_mqueue_post()
698 		if (receiver == THREAD_NULL) {  in ipc_mqueue_post()
750 		if (receiver->ith_state == MACH_PEEK_IN_PROGRESS && mqueue->imq_msgcount > 0) {  in ipc_mqueue_post()
752 			ipc_mqueue_peek_on_thread_locked(mqueue, receiver->ith_option, receiver);  in ipc_mqueue_post()
753 			waitq_resume_identified_thread(waitq, receiver,  in ipc_mqueue_post()
765 		if (receiver->ith_state != MACH_RCV_IN_PROGRESS) {  in ipc_mqueue_post()
766 			waitq_resume_identified_thread(waitq, receiver,  in ipc_mqueue_post()
778 		msize = ipc_kmsg_copyout_size(kmsg, receiver->map);  in ipc_mqueue_post()
779 		tsize = ipc_kmsg_trailer_size(receiver->ith_option, receiver->map);  in ipc_mqueue_post()
782 		if (ipc_mqueue_msg_too_large(msize, tsize, asize, receiver->ith_option,  in ipc_mqueue_post()
783 		    &receiver->ith_recv_bufs)) {  in ipc_mqueue_post()
784 			receiver->ith_msize = msize;  in ipc_mqueue_post()
785 			receiver->ith_asize = asize;  in ipc_mqueue_post()
786 			receiver->ith_state = MACH_RCV_TOO_LARGE;  in ipc_mqueue_post()
788 			receiver->ith_state = MACH_MSG_SUCCESS;  in ipc_mqueue_post()
796 		if ((receiver->ith_state == MACH_MSG_SUCCESS) ||  in ipc_mqueue_post()
797 		    !(receiver->ith_option & MACH_RCV_LARGE)) {  in ipc_mqueue_post()
798 			receiver->ith_kmsg = kmsg;  in ipc_mqueue_post()
799 			receiver->ith_seqno = mqueue->imq_seqno++;  in ipc_mqueue_post()
803 			waitq_resume_identified_thread(waitq, receiver,  in ipc_mqueue_post()
822 		receiver->ith_receiver_name = mqueue->imq_receiver_name;  in ipc_mqueue_post()
823 		receiver->ith_kmsg = IKM_NULL;  in ipc_mqueue_post()
824 		receiver->ith_seqno = 0;  in ipc_mqueue_post()
826 		waitq_resume_identified_thread(waitq, receiver,  in ipc_mqueue_post()