Home
last modified time | relevance | path

Searched refs:ip_waitq (Results 1 – 8 of 8) sorted by relevance

/xnu-12377.81.4/osfmk/ipc/
H A Dipc_mqueue.c219 kr = waitq_link_locked(&port->ip_waitq, wqset, linkp); in ipc_mqueue_add_locked()
247 waitq_link_prepost_locked(&port->ip_waitq, wqset); in ipc_mqueue_add_locked()
559 assert(waitq_is_valid(&port->ip_waitq)); in ipc_mqueue_override_send_locked()
624 waitq_clear_prepost_locked(&port->ip_waitq); in ipc_mqueue_release_msgcount()
646 struct waitq *waitq = &port->ip_waitq; in ipc_mqueue_post()
660 if (!waitq_is_valid(&port->ip_waitq)) { in ipc_mqueue_post()
1278 waitq_invalidate(&port->ip_waitq); in ipc_mqueue_destroy_locked()
1280 waitq_unlink_all_locked(&port->ip_waitq, NULL, free_l); in ipc_mqueue_destroy_locked()
H A Dipc_port.h128 WAITQ_FLAGS(ip_waitq
147 struct waitq ip_waitq; member
204 return !circle_queue_empty(&port->ip_waitq.waitq_links); in ip_in_pset()
222 #define port_rcv_turnstile_address(port) (&(port)->ip_waitq.waitq_ts)
303 #define ip_from_waitq(wq) __container_of(wq, struct ipc_port, ip_waitq)
H A Dipc_port.c166 waitq_lock(&port->ip_waitq); in ipc_port_lock()
173 waitq_lock(&port->ip_waitq); in ipc_port_lock_label_get()
181 waitq_lock(&port->ip_waitq); in ipc_port_lock_check_aligned()
189 return waitq_lock_try(&port->ip_waitq); in ipc_port_lock_try()
676 waitq_unlink_all_locked(&port->ip_waitq, NULL, free_l); in ipc_port_prepare_move()
685 ipc_mqueue_changed(ip_get_receiver(port), &port->ip_waitq); in ipc_port_prepare_move()
687 ipc_mqueue_changed(NULL, &port->ip_waitq); in ipc_port_prepare_move()
846 waitq_init(&port->ip_waitq, WQT_PORT, SYNC_POLICY_INIT_LOCKED); in ipc_port_init()
3203 if (waitq_type(&port->ip_waitq) == WQT_PORT) { in ipc_port_free()
3214 waitq_deinit(&port->ip_waitq); in ipc_port_free()
H A Dipc_object.c1205 offsetof(struct ipc_port, ip_waitq));
H A Dipc_pset.c357 if (!waitq_is_valid(&port->ip_waitq)) { in filt_port_filter_result()
H A Dmach_port.c1452 waitq_unlink_all_locked(&port->ip_waitq, keep_waitq_set, &free_l); in mach_port_move_member()
2230 link = waitq_unlink_locked(&port->ip_waitq, &pset->ips_wqset); in mach_port_extract_member()
/xnu-12377.81.4/tools/lldbmacros/
H A Dipc.py211 addressof(port.ip_waitq),
228 wq = Waitq(addressof(port.ip_waitq))
232 for wqs in Waitq(addressof(port.ip_waitq)).iterateSets():
938 nsets = len([s for s in Waitq(addressof(portval.ip_waitq)).iterateSets()])
/xnu-12377.81.4/osfmk/kern/
H A Dipc_mig.c463 ipc_mqueue_receive(&reply->ip_waitq, MACH_MSG_TIMEOUT_NONE, in kernel_mach_msg_rpc_common()