Searched refs:ip_waitq (Results 1 – 7 of 7) sorted by relevance
| /xnu-8020.101.4/osfmk/ipc/ |
| H A D | ipc_mqueue.c | 160 kr = waitq_link_locked(&port->ip_waitq, wqset, linkp); in ipc_mqueue_add_locked()
191 waitq_link_prepost_locked(&port->ip_waitq, wqset); in ipc_mqueue_add_locked()
500 assert(waitq_is_valid(&port->ip_waitq)); in ipc_mqueue_override_send_locked()
575 waitq_clear_prepost_locked(&port->ip_waitq); in ipc_mqueue_release_msgcount()
597 struct waitq *waitq = &port->ip_waitq; in ipc_mqueue_post()
611 if (!waitq_is_valid(&port->ip_waitq)) { in ipc_mqueue_post()
1295 waitq_clear_prepost_locked(&port->ip_waitq); in ipc_mqueue_release_peek_ref()
1370 waitq_invalidate(&port->ip_waitq); in ipc_mqueue_destroy_locked()
1372 waitq_unlink_all_locked(&port->ip_waitq, NULL, free_l); in ipc_mqueue_destroy_locked()
|
| H A D | ipc_port.h | 112 WAITQ_FLAGS(ip_waitq
137 struct waitq ip_waitq; member
202 return !circle_queue_empty(&port->ip_waitq.waitq_links); in ip_in_pset()
224 #define port_rcv_turnstile_address(port) (&(port)->ip_waitq.waitq_ts)
283 #define ip_from_waitq(wq) __container_of(wq, struct ipc_port, ip_waitq)
|
| H A D | ipc_port.c | 655 waitq_unlink_all_locked(&port->ip_waitq, NULL, free_l); in ipc_port_clear_receiver()
664 ipc_mqueue_changed(ip_get_receiver(port), &port->ip_waitq); in ipc_port_clear_receiver()
666 ipc_mqueue_changed(NULL, &port->ip_waitq); in ipc_port_clear_receiver()
731 waitq_init(&port->ip_waitq, WQT_PORT, policy); in ipc_port_init()
3102 if (waitq_type(&port->ip_waitq) == WQT_PORT) { in ipc_port_finalize()
3134 waitq_deinit(&port->ip_waitq); in ipc_port_finalize()
|
| H A D | ipc_object.c | 1329 offsetof(struct ipc_port, ip_waitq));
|
| H A D | mach_port.c | 1468 waitq_unlink_all_locked(&port->ip_waitq, keep_waitq_set, &free_l); in mach_port_move_member()
2228 link = waitq_unlink_locked(&port->ip_waitq, &pset->ips_wqset); in mach_port_extract_member()
|
| /xnu-8020.101.4/osfmk/kern/ |
| H A D | ipc_mig.c | 363 ipc_mqueue_receive(&reply->ip_waitq, in kernel_mach_msg_rpc()
|
| /xnu-8020.101.4/tools/lldbmacros/ |
| H A D | ipc.py | 104 print(prefix + format_string.format(unsigned(portp), addressof(portp.ip_waitq),
118 wq = Waitq(addressof(portp.ip_waitq))
121 for wqs in Waitq(addressof(portp.ip_waitq)).iterateSets():
636 nsets = len([s for s in Waitq(addressof(portval.ip_waitq)).iterateSets()])
|