Searched refs:ip_waitq (Results 1 – 7 of 7) sorted by relevance
112 WAITQ_FLAGS(ip_waitq135 struct waitq ip_waitq; member190 #define ip_preposts ip_waitq.waitq_prepost_id195 return port->ip_waitq.waitq_set_id.wqr_value != 0; in ip_in_pset()217 #define port_rcv_turnstile_address(port) (&(port)->ip_waitq.waitq_ts)276 #define ip_from_waitq(wq) __container_of(wq, struct ipc_port, ip_waitq)
159 struct waitq *port_waitq = &port->ip_waitq; in ipc_mqueue_add_unlock()533 assert(waitq_is_valid(&port->ip_waitq)); in ipc_mqueue_override_send_locked()609 waitq_clear_prepost_locked(&port->ip_waitq); in ipc_mqueue_release_msgcount()631 struct waitq *waitq = &port->ip_waitq; in ipc_mqueue_post()647 if (!waitq_is_valid(&port->ip_waitq)) { in ipc_mqueue_post()1348 waitq_clear_prepost_locked(&port->ip_waitq); in ipc_mqueue_release_peek_ref()1416 if (waitq_member_locked(&port->ip_waitq, wqset)) { in ipc_mqueue_set_gather_member_names()1495 waitq_invalidate(&port->ip_waitq); in ipc_mqueue_destroy_locked()1498 waitq_clear_prepost_locked(&port->ip_waitq); in ipc_mqueue_destroy_locked()
687 ipc_mqueue_changed(ip_get_receiver(port), &port->ip_waitq); in ipc_port_clear_receiver()689 ipc_mqueue_changed(NULL, &port->ip_waitq); in ipc_port_clear_receiver()754 waitq_init(&port->ip_waitq, policy); in ipc_port_init()1431 return port->ip_waitq.waitq_tspriv; in ipc_port_watchport_elem()1447 port->ip_waitq.waitq_tspriv = we; in ipc_port_update_watchport_elem()1463 port->ip_waitq.waitq_priv_pid = pid; in ipc_special_reply_stash_pid_locked()1479 return port->ip_waitq.waitq_priv_pid; in ipc_special_reply_get_pid_locked()3099 if (waitq_is_turnstile_proxy(&port->ip_waitq)) { in ipc_port_finalize()3131 waitq_deinit(&port->ip_waitq); in ipc_port_finalize()
235 return waitq_unlink_locked(&port->ip_waitq, &pset->ips_wqset); in ipc_pset_remove_locked()295 assert(waitq_is_valid(&port->ip_waitq)); in ipc_pset_remove_from_all_unlock()296 waitq_unlink_all_unlock(&port->ip_waitq); in ipc_pset_remove_from_all_unlock()
1327 offsetof(struct ipc_port, ip_waitq));
363 ipc_mqueue_receive(&reply->ip_waitq, in kernel_mach_msg_rpc()
366 waitq = addressof(portval.ip_waitq)367 psets = GetWaitqSets(addressof(portval.ip_waitq))680 set_str = GetWaitqSets(addressof(portval.ip_waitq))