123 	ipc_kmsg_t              kmsg,
219 	ipc_kmsg_t       kmsg;  in ipc_mqueue_add_locked()  local
234 	while ((kmsg = ipc_kmsg_queue_first(kmsgq)) != IKM_NULL) {  in ipc_mqueue_add_locked()
293 		msize = ipc_kmsg_copyout_size(kmsg, th->map);  in ipc_mqueue_add_locked()
295 		asize = kmsg->ikm_aux_size;  in ipc_mqueue_add_locked()
323 		ipc_kmsg_rmqueue(kmsgq, kmsg);  in ipc_mqueue_add_locked()
326 		mach_node_t  node = kmsg->ikm_node;  in ipc_mqueue_add_locked()
331 		th->ith_kmsg = kmsg;  in ipc_mqueue_add_locked()
459 	ipc_kmsg_t              kmsg,  in ipc_mqueue_send_locked()  argument
475 	    (MACH_MSGH_BITS_REMOTE(ikm_header(kmsg)->msgh_bits) ==  in ipc_mqueue_send_locked()
561 	ipc_mqueue_post(mqueue, kmsg, option);  in ipc_mqueue_send_locked()
667 	ipc_kmsg_t                 kmsg,  in ipc_mqueue_post()  argument
674 	ipc_kmsg_trace_send(kmsg, option);  in ipc_mqueue_post()
721 			} else if (!ipc_kmsg_enqueue_qos(&mqueue->imq_messages, kmsg)) {  in ipc_mqueue_post()
751 			ipc_kmsg_enqueue_qos(&mqueue->imq_messages, kmsg);  in ipc_mqueue_post()
778 		msize = ipc_kmsg_copyout_size(kmsg, receiver->map);  in ipc_mqueue_post()
780 		asize = kmsg->ikm_aux_size;  in ipc_mqueue_post()
798 			receiver->ith_kmsg = kmsg;  in ipc_mqueue_post()
801 			mach_node_t node = kmsg->ikm_node;  in ipc_mqueue_post()
836 		ipc_kmsg_destroy(kmsg, IPC_KMSG_DESTROY_ALL);  in ipc_mqueue_post()
1209 	ipc_kmsg_t kmsg;  in ipc_mqueue_select_on_thread_locked()  local
1217 	kmsg = ipc_kmsg_queue_first(&port_mq->imq_messages);  in ipc_mqueue_select_on_thread_locked()
1218 	assert(kmsg != IKM_NULL);  in ipc_mqueue_select_on_thread_locked()
1226 	msize = ipc_kmsg_copyout_size(kmsg, thread->map);  in ipc_mqueue_select_on_thread_locked()
1228 	asize = kmsg->ikm_aux_size;  in ipc_mqueue_select_on_thread_locked()
1234 			(void)ipc_kmsg_validate_signature(kmsg);  in ipc_mqueue_select_on_thread_locked()
1245 	ipc_kmsg_rmqueue(&port_mq->imq_messages, kmsg);  in ipc_mqueue_select_on_thread_locked()
1247 	if (MACH_NODE_VALID(kmsg->ikm_node) && FPORT_VALID(port_mq->imq_fport)) {  in ipc_mqueue_select_on_thread_locked()
1248 		flipc_msg_ack(kmsg->ikm_node, port_mq, TRUE);  in ipc_mqueue_select_on_thread_locked()
1253 	thread->ith_kmsg = kmsg;  in ipc_mqueue_select_on_thread_locked()
1283 	ipc_kmsg_t kmsg;  in ipc_mqueue_peek_locked()  local
1305 	kmsg = ipc_kmsg_queue_first(kmsgq);  in ipc_mqueue_peek_locked()
1306 	while (msgoff-- && kmsg != IKM_NULL) {  in ipc_mqueue_peek_locked()
1307 		kmsg = ipc_kmsg_queue_next(kmsgq, kmsg);  in ipc_mqueue_peek_locked()
1309 	if (kmsg == IKM_NULL) {  in ipc_mqueue_peek_locked()
1320 	(void)ipc_kmsg_validate_signature(kmsg);  in ipc_mqueue_peek_locked()
1322 	hdr = ikm_header(kmsg);  in ipc_mqueue_peek_locked()
1334 		*msg_trailerp = *ipc_kmsg_get_trailer(kmsg);  in ipc_mqueue_peek_locked()
1337 		*kmsgp = kmsg;  in ipc_mqueue_peek_locked()
1448 	ipc_kmsg_t kmsg;  in ipc_mqueue_destroy_locked()  local
1450 	cqe_foreach_element_safe(kmsg, &mqueue->imq_messages, ikm_link) {  in ipc_mqueue_destroy_locked()
1451 		if (MACH_NODE_VALID(kmsg->ikm_node) &&  in ipc_mqueue_destroy_locked()
1453 			flipc_msg_ack(kmsg->ikm_node, mqueue, TRUE);  in ipc_mqueue_destroy_locked()