Lines Matching defs:kmsg
225 ipc_kmsg_t kmsg, next;
241 for (kmsg = ipc_kmsg_queue_first(kmsgq);
242 kmsg != IKM_NULL;
243 kmsg = next) {
244 next = ipc_kmsg_queue_next(kmsgq, kmsg);
268 kmsg->ikm_header->msgh_size +
271 th->ith_msize = kmsg->ikm_header->msgh_size;
289 ipc_kmsg_rmqueue(kmsgq, kmsg);
292 th->ith_kmsg = kmsg;
347 ipc_kmsg_t kmsg,
366 (MACH_MSGH_BITS_REMOTE(kmsg->ikm_header->msgh_bits) ==
428 ipc_mqueue_post(mqueue, kmsg);
478 register ipc_kmsg_t kmsg)
485 * kmsg, so the ref in it for the port is still good.
504 * no receivers; queue kmsg
507 ipc_kmsg_enqueue_macro(&mqueue->imq_messages, kmsg);
517 (kmsg->ikm_header->msgh_size) +
519 receiver->ith_msize = kmsg->ikm_header->msgh_size;
533 receiver->ith_kmsg = kmsg;
639 * The kmsg is returned with clean header fields
843 ipc_kmsg_t kmsg;
854 kmsg = ipc_kmsg_queue_first(&mqueue->imq_messages);
855 assert(kmsg != IKM_NULL);
863 rcv_size = ipc_kmsg_copyout_size(kmsg, self->map);
875 ipc_kmsg_rmqueue_first_macro(&mqueue->imq_messages, kmsg);
878 self->ith_kmsg = kmsg;
899 ipc_kmsg_t kmsg;
917 while ((kmsg = ipc_kmsg_dequeue(kmqueue)) != IKM_NULL) {
921 ipc_kmsg_destroy_dest(kmsg);