Lines Matching refs:rcv_mqueue
674 ipc_mqueue_t rcv_mqueue;
921 rcv_mqueue = &reply_port->ip_messages;
1086 rcv_mqueue = &rcv_pset->ips_messages;
1108 rcv_mqueue = &rcv_port->ip_messages;
1146 * rcv_mqueue is set, and rcv_object holds a ref
1238 imq_lock(rcv_mqueue);
1240 if (ipc_kmsg_queue_first(&rcv_mqueue->imq_messages) != IKM_NULL) {
1241 imq_unlock(rcv_mqueue);
1261 waitq = &rcv_mqueue->imq_wait_queue;
1267 imq_unlock(rcv_mqueue);
1591 rcv_mqueue = &reply_port->ip_messages;
1666 rcv_mqueue = &reply_port->ip_messages;
1667 imq_lock(rcv_mqueue);
1678 if (!wait_queue_empty(&rcv_mqueue->imq_wait_queue) ||
1679 (ipc_kmsg_queue_first(&rcv_mqueue->imq_messages) != IKM_NULL))
1681 imq_unlock(rcv_mqueue);
1699 temp_seqno = rcv_mqueue->imq_seqno++;
1700 imq_unlock(rcv_mqueue);
1742 &rcv_mqueue, &rcv_object);
1757 ipc_mqueue_receive(rcv_mqueue,