266 		if (th->ith_state != MACH_RCV_IN_PROGRESS) {  in ipc_mqueue_add_locked()
268 			if (th->ith_state == MACH_PEEK_IN_PROGRESS) {  in ipc_mqueue_add_locked()
299 			th->ith_state = MACH_RCV_TOO_LARGE;  in ipc_mqueue_add_locked()
316 			th->ith_state = MACH_MSG_SUCCESS;  in ipc_mqueue_add_locked()
750 		if (receiver->ith_state == MACH_PEEK_IN_PROGRESS && mqueue->imq_msgcount > 0) {  in ipc_mqueue_post()
765 		if (receiver->ith_state != MACH_RCV_IN_PROGRESS) {  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()
855 		self->ith_state = MACH_RCV_TIMED_OUT;  in ipc_mqueue_receive_results()
859 		self->ith_state = MACH_RCV_INTERRUPTED;  in ipc_mqueue_receive_results()
864 		self->ith_state = MACH_RCV_PORT_CHANGED;  in ipc_mqueue_receive_results()
872 		switch (self->ith_state) {  in ipc_mqueue_receive_results()
894 			panic("ipc_mqueue_receive_results: strange ith_state %d", self->ith_state);  in ipc_mqueue_receive_results()
1067 		thread->ith_state = MACH_RCV_TIMED_OUT;  in ipc_mqueue_receive_on_thread_and_unlock()
1071 	thread->ith_state = MACH_RCV_IN_PROGRESS;  in ipc_mqueue_receive_on_thread_and_unlock()
1074 		thread->ith_state = MACH_PEEK_IN_PROGRESS;  in ipc_mqueue_receive_on_thread_and_unlock()
1182 	thread->ith_state = MACH_PEEK_READY;  in ipc_mqueue_peek_on_thread_locked()
1240 			thread->ith_state = mr;  in ipc_mqueue_select_on_thread_locked()
1254 	thread->ith_state = mr;  in ipc_mqueue_select_on_thread_locked()