Searched refs:ip_messages (Results 1 – 8 of 8) sorted by relevance
| /xnu-12377.1.9/osfmk/ipc/ |
| H A D | ipc_port.h | 151 struct ipc_mqueue ip_messages; member 208 #define ip_receiver_name ip_messages.imq_receiver_name 209 #define ip_reply_context ip_messages.imq_context 210 #define ip_klist ip_messages.imq_klist 305 #define ip_from_mq(mq) __container_of(mq, struct ipc_port, ip_messages) 313 #define ip_full_kernel(port) imq_full_kernel(&(port)->ip_messages) 314 #define ip_full(port) imq_full(&(port)->ip_messages)
|
| H A D | ipc_port.c | 556 ipc_mqueue_override_send_locked(&port->ip_messages, qos_ovr); in ipc_port_request_sparm() 691 port->ip_messages.imq_seqno = 0; in ipc_port_prepare_move() 822 return ipc_mqueue_destroy_locked(&port->ip_messages, free_l); in ipc_port_mark_inactive() 860 ipc_mqueue_init(&port->ip_messages); in ipc_port_init() 1700 ipc_mqueue_t mqueue = &port->ip_messages; in ipc_port_send_update_inheritor() 1712 inheritor = port->ip_messages.imq_srp_owner_thread; in ipc_port_send_update_inheritor() 1734 inheritor = port->ip_messages.imq_inheritor_thread_ref; in ipc_port_send_update_inheritor() 2064 special_reply_port->ip_messages.imq_srp_owner_thread = NULL; in ipc_port_adjust_special_reply_port_locked() 2221 thread_deallocate_safe(port->ip_messages.imq_inheritor_thread_ref); in ipc_port_adjust_sync_link_state_locked() 2225 turnstile_deallocate(port->ip_messages.imq_inheritor_turnstile); in ipc_port_adjust_sync_link_state_locked() [all …]
|
| H A D | mach_port.c | 1012 found = ipc_mqueue_peek_locked(&port->ip_messages, seqnop, in mach_port_peek() 1105 ipc_mqueue_set_seqno_locked(&port->ip_messages, seqno); in mach_port_set_seqno() 1439 ipc_mqueue_add_locked(&port->ip_messages, nset, &link); in mach_port_move_member() 1745 statusp->mps_seqno = port->ip_messages.imq_seqno; in mach_port_get_status_helper() 1746 statusp->mps_qlimit = port->ip_messages.imq_qlimit; in mach_port_get_status_helper() 1747 statusp->mps_msgcount = port->ip_messages.imq_msgcount; in mach_port_get_status_helper() 1811 lp->mpl_qlimit = port->ip_messages.imq_qlimit; in mach_port_get_attributes() 1983 ipc_mqueue_set_qlimit_locked(&port->ip_messages, mplp->mpl_qlimit); in mach_port_set_attributes() 2173 kr = ipc_mqueue_add_locked(&port->ip_messages, pset, &link); in mach_port_insert_member() 2608 ipc_mqueue_set_qlimit_locked(&port->ip_messages, options->mpl.mpl_qlimit); in mach_port_construct()
|
| H A D | ipc_mqueue.c | 961 if (ipc_kmsg_queue_empty(&port->ip_messages.imq_messages)) { in ipc_mqueue_receive_on_thread_and_unlock() 969 ipc_mqueue_select_on_thread_locked(&port->ip_messages, in ipc_mqueue_receive_on_thread_and_unlock()
|
| H A D | ipc_pset.c | 366 first = ipc_kmsg_queue_first(&port->ip_messages.imq_messages); in filt_port_filter_result() 521 port->ip_messages.imq_inheritor_knote == kn) { in filt_machport_turnstile_complete_port()
|
| H A D | ipc_kmsg.c | 5228 port->ip_messages.imq_seqno++; in ipc_kmsg_send() 5280 error = ipc_mqueue_send_locked(&port->ip_messages, kmsg, in ipc_kmsg_send() 5522 if (src_port->ip_messages.imq_qlimit != MACH_PORT_QLIMIT_DEFAULT) { in ipc_kmsg_trace_send() 5574 if (dst_port->ip_messages.imq_qlimit != MACH_PORT_QLIMIT_DEFAULT) { in ipc_kmsg_trace_send() 5577 if (imq_full(&dst_port->ip_messages)) { in ipc_kmsg_trace_send()
|
| /xnu-12377.1.9/tools/lldbmacros/ |
| H A D | ipc.py | 188 receiver_name = port.ip_messages.imq_receiver_name 209 port.ip_messages.imq_msgcount, 218 port.ip_messages.imq_messages, "ipc_kmsg", "ikm_link" 768 name = unsigned(port.ip_messages.imq_receiver_name) 933 nmsgs = portval.ip_messages.imq_msgcount 1272 port.ip_messages.imq_msgcount, 1447 p.ip_messages.imq_messages, "ipc_kmsg", "ikm_link" 1478 p.ip_messages.imq_messages, "ipc_kmsg", "ikm_link" 1560 and eport.ip_messages.imq_msgcount > 0 1564 eport.ip_messages.imq_messages, "ipc_kmsg", "ikm_link" [all …]
|
| /xnu-12377.1.9/osfmk/kern/ |
| H A D | ipc_tt.c | 1437 port->ip_messages.imq_srp_owner_thread = thread; in ipc_port_bind_special_reply_port_locked()
|