Lines Matching refs: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);
279 msize = ipc_kmsg_copyout_size(kmsg, th->map);
302 ipc_kmsg_rmqueue(kmsgq, kmsg);
305 th->ith_kmsg = kmsg;
360 ipc_kmsg_t kmsg,
376 (MACH_MSGH_BITS_REMOTE(kmsg->ikm_header->msgh_bits) ==
442 ipc_mqueue_post(mqueue, kmsg);
493 register ipc_kmsg_t kmsg)
499 * kmsg, so the ref in it for the port is still good.
519 * no receivers; queue kmsg
522 ipc_kmsg_enqueue_macro(&mqueue->imq_messages, kmsg);
543 msize = ipc_kmsg_copyout_size(kmsg, receiver->map);
560 receiver->ith_kmsg = kmsg;
667 * The kmsg is returned with clean header fields
873 ipc_kmsg_t kmsg;
881 kmsg = ipc_kmsg_queue_first(&mqueue->imq_messages);
882 assert(kmsg != IKM_NULL);
890 rcv_size = ipc_kmsg_copyout_size(kmsg, thread->map);
903 ipc_kmsg_rmqueue_first_macro(&mqueue->imq_messages, kmsg);
906 thread->ith_kmsg = kmsg;
933 ipc_kmsg_t kmsg;
956 kmsg = ipc_kmsg_queue_first(kmsgq);
957 while (msgoff-- && kmsg != IKM_NULL) {
958 kmsg = ipc_kmsg_queue_next(kmsgq, kmsg);
960 if (kmsg == IKM_NULL)
967 *msg_sizep = kmsg->ikm_header->msgh_size;
969 *msg_idp = kmsg->ikm_header->msgh_id;
972 (mach_msg_max_trailer_t *)((vm_offset_t)kmsg->ikm_header +
973 round_msg(kmsg->ikm_header->msgh_size)),
1092 ipc_kmsg_t kmsg;
1113 while ((kmsg = ipc_kmsg_dequeue(kmqueue)) != IKM_NULL) {
1115 first = ipc_kmsg_delayed_destroy(kmsg);