Lines Matching defs: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) ==
444 ipc_mqueue_post(mqueue, kmsg);
494 register ipc_kmsg_t kmsg)
500 * kmsg, so the ref in it for the port is still good.
520 * no receivers; queue kmsg
523 ipc_kmsg_enqueue_macro(&mqueue->imq_messages, kmsg);
544 msize = ipc_kmsg_copyout_size(kmsg, receiver->map);
561 receiver->ith_kmsg = kmsg;
667 * The kmsg is returned with clean header fields
906 ipc_kmsg_t kmsg;
914 kmsg = ipc_kmsg_queue_first(&mqueue->imq_messages);
915 assert(kmsg != IKM_NULL);
923 rcv_size = ipc_kmsg_copyout_size(kmsg, thread->map);
936 ipc_kmsg_rmqueue_first_macro(&mqueue->imq_messages, kmsg);
939 thread->ith_kmsg = kmsg;
1008 ipc_kmsg_t kmsg;
1030 while ((kmsg = ipc_kmsg_dequeue(kmqueue)) != IKM_NULL) {
1032 first = ipc_kmsg_delayed_destroy(kmsg);