Lines Matching refs:kmsg
229 ipc_kmsg_t kmsg, next;
245 for (kmsg = ipc_kmsg_queue_first(kmsgq);
246 kmsg != IKM_NULL;
247 kmsg = next) {
248 next = ipc_kmsg_queue_next(kmsgq, kmsg);
283 msize = ipc_kmsg_copyout_size(kmsg, th->map);
306 ipc_kmsg_rmqueue(kmsgq, kmsg);
309 th->ith_kmsg = kmsg;
364 ipc_kmsg_t kmsg,
380 (MACH_MSGH_BITS_REMOTE(kmsg->ikm_header->msgh_bits) ==
446 ipc_mqueue_post(mqueue, kmsg);
497 register ipc_kmsg_t kmsg)
503 * kmsg, so the ref in it for the port is still good.
523 * no receivers; queue kmsg
526 ipc_kmsg_enqueue_macro(&mqueue->imq_messages, kmsg);
547 msize = ipc_kmsg_copyout_size(kmsg, receiver->map);
564 receiver->ith_kmsg = kmsg;
671 * The kmsg is returned with clean header fields
912 ipc_kmsg_t kmsg;
920 kmsg = ipc_kmsg_queue_first(&mqueue->imq_messages);
921 assert(kmsg != IKM_NULL);
929 rcv_size = ipc_kmsg_copyout_size(kmsg, thread->map);
942 ipc_kmsg_rmqueue_first_macro(&mqueue->imq_messages, kmsg);
945 thread->ith_kmsg = kmsg;
972 ipc_kmsg_t kmsg;
995 kmsg = ipc_kmsg_queue_first(kmsgq);
996 while (msgoff-- && kmsg != IKM_NULL) {
997 kmsg = ipc_kmsg_queue_next(kmsgq, kmsg);
999 if (kmsg == IKM_NULL)
1006 *msg_sizep = kmsg->ikm_header->msgh_size;
1008 *msg_idp = kmsg->ikm_header->msgh_id;
1011 (mach_msg_max_trailer_t *)((vm_offset_t)kmsg->ikm_header +
1012 round_msg(kmsg->ikm_header->msgh_size)),
1131 ipc_kmsg_t kmsg;
1152 while ((kmsg = ipc_kmsg_dequeue(kmqueue)) != IKM_NULL) {
1154 first = ipc_kmsg_delayed_destroy(kmsg);