Home
last modified time | relevance | path

Searched refs:ip_messages (Results 1 – 9 of 9) sorted by relevance

/xnu-10063.141.1/osfmk/ipc/
H A Dflipc.c72 flipc_port_t fport = lport->ip_messages.imq_fport; in mnl_name_from_port()
110 assert(!FPORT_VALID(lport->ip_messages.imq_fport)); in flipc_port_create()
127 lport->ip_messages.imq_fport = fport; in flipc_port_create()
132 lport->ip_messages.imq_fport = FPORT_NULL; in flipc_port_create()
151 ipc_mqueue_t port_mq = &lport->ip_messages; in flipc_port_destroy()
179 lport->ip_messages.imq_fport = FPORT_NULL; in flipc_port_destroy()
237 fmsg->object = ikm_header(kmsg)->msgh_remote_port->ip_messages.imq_fport->obj.name; in mnl_msg_from_kmsg()
329 ipc_mqueue_t lport_mq = &lport->ip_messages; in flipc_cmd_ack()
630 ack_mqueue = &ack_port->ip_messages; in flipc_msg_ack()
H A Dipc_port.h154 struct ipc_mqueue ip_messages; member
222 #define ip_receiver_name ip_messages.imq_receiver_name
223 #define ip_reply_context ip_messages.imq_context
224 #define ip_klist ip_messages.imq_klist
318 #define ip_from_mq(mq) __container_of(mq, struct ipc_port, ip_messages)
326 #define ip_full_kernel(port) imq_full_kernel(&(port)->ip_messages)
327 #define ip_full(port) imq_full(&(port)->ip_messages)
H A Dipc_port.c528 ipc_mqueue_override_send_locked(&port->ip_messages, qos_ovr); in ipc_port_request_sparm()
693 ipc_mqueue_t mqueue = &port->ip_messages; in ipc_port_clear_receiver()
841 ipc_mqueue_init(&port->ip_messages); in ipc_port_init()
1671 ipc_mqueue_t mqueue = &port->ip_messages; in ipc_port_send_update_inheritor()
1683 inheritor = port->ip_messages.imq_srp_owner_thread; in ipc_port_send_update_inheritor()
1705 inheritor = port->ip_messages.imq_inheritor_thread_ref; in ipc_port_send_update_inheritor()
2035 special_reply_port->ip_messages.imq_srp_owner_thread = NULL; in ipc_port_adjust_special_reply_port_locked()
2192 thread_deallocate_safe(port->ip_messages.imq_inheritor_thread_ref); in ipc_port_adjust_sync_link_state_locked()
2196 turnstile_deallocate_safe(port->ip_messages.imq_inheritor_turnstile); in ipc_port_adjust_sync_link_state_locked()
2204 port->ip_messages.imq_inheritor_knote = inheritor; in ipc_port_adjust_sync_link_state_locked()
[all …]
H A Dmach_port.c996 found = ipc_mqueue_peek_locked(&port->ip_messages, seqnop, in mach_port_peek()
1089 ipc_mqueue_set_seqno_locked(&port->ip_messages, seqno); in mach_port_set_seqno()
1427 ipc_mqueue_add_locked(&port->ip_messages, nset, &link); in mach_port_move_member()
1791 statusp->mps_seqno = port->ip_messages.imq_seqno; in mach_port_get_status_helper()
1792 statusp->mps_qlimit = port->ip_messages.imq_qlimit; in mach_port_get_status_helper()
1793 statusp->mps_msgcount = port->ip_messages.imq_msgcount; in mach_port_get_status_helper()
1859 lp->mpl_qlimit = port->ip_messages.imq_qlimit; in mach_port_get_attributes()
2030 ipc_mqueue_set_qlimit_locked(&port->ip_messages, mplp->mpl_qlimit); in mach_port_set_attributes()
2233 kr = ipc_mqueue_add_locked(&port->ip_messages, pset, &link); in mach_port_insert_member()
2758 ipc_mqueue_set_qlimit_locked(&port->ip_messages, options->mpl.mpl_qlimit); in mach_port_construct()
H A Dipc_mqueue.c1027 if (ipc_kmsg_queue_empty(&port->ip_messages.imq_messages)) { in ipc_mqueue_receive_on_thread_and_unlock()
1037 ipc_mqueue_peek_on_thread_locked(&port->ip_messages, in ipc_mqueue_receive_on_thread_and_unlock()
1042 ipc_mqueue_select_on_thread_locked(&port->ip_messages, in ipc_mqueue_receive_on_thread_and_unlock()
H A Dipc_kmsg.c5294 if (MACH_NODE_VALID(kmsg->ikm_node) && FPORT_VALID(port->ip_messages.imq_fport)) { in ipc_kmsg_send()
5295 flipc_msg_ack(kmsg->ikm_node, &port->ip_messages, FALSE); in ipc_kmsg_send()
5317 port->ip_messages.imq_seqno++; in ipc_kmsg_send()
5369 error = ipc_mqueue_send_locked(&port->ip_messages, kmsg, in ipc_kmsg_send()
5418 if (MACH_NODE_VALID(kmsg->ikm_node) && FPORT_VALID(port->ip_messages.imq_fport)) { in ipc_kmsg_send()
5419 flipc_msg_ack(kmsg->ikm_node, &port->ip_messages, FALSE); in ipc_kmsg_send()
5435 if (MACH_NODE_VALID(kmsg->ikm_node) && FPORT_VALID(port->ip_messages.imq_fport)) { in ipc_kmsg_send()
5436 flipc_msg_ack(kmsg->ikm_node, &port->ip_messages, FALSE); in ipc_kmsg_send()
5621 if (src_port->ip_messages.imq_qlimit != MACH_PORT_QLIMIT_DEFAULT) { in ipc_kmsg_trace_send()
5673 if (dst_port->ip_messages.imq_qlimit != MACH_PORT_QLIMIT_DEFAULT) { in ipc_kmsg_trace_send()
[all …]
H A Dipc_pset.c334 first = ipc_kmsg_queue_first(&port->ip_messages.imq_messages); in filt_port_filter_result()
489 port->ip_messages.imq_inheritor_knote == kn) { in filt_machport_turnstile_complete_port()
/xnu-10063.141.1/tools/lldbmacros/
H A Dipc.py120 receiver_name = port.ip_messages.imq_receiver_name
142 port.ip_messages.imq_msgcount, splabel_name, dest_str))
146 for kmsgp in IterateCircleQueue(port.ip_messages.imq_messages, 'ipc_kmsg', 'ikm_link'):
614 name = unsigned(port.ip_messages.imq_receiver_name)
746 nmsgs = portval.ip_messages.imq_msgcount
1028 …out_str = format_str.format(unsigned(port), 'in-transit', disp_str, 0, 0, port.ip_messages.imq_msg…
1188 for p_kmsgp in IterateCircleQueue(p.ip_messages.imq_messages, 'ipc_kmsg', 'ikm_link'):
1217 for p_kmsgp in IterateCircleQueue(p.ip_messages.imq_messages, 'ipc_kmsg', 'ikm_link'):
1293 if follow_busyports and unsigned(eport) > 0 and eport.ip_messages.imq_msgcount > 0:
1295 … for kmsgp in IterateCircleQueue(eport.ip_messages.imq_messages, 'ipc_kmsg', 'ikm_link'):
[all …]
/xnu-10063.141.1/osfmk/kern/
H A Dipc_tt.c1549 port->ip_messages.imq_srp_owner_thread = thread; in ipc_port_bind_special_reply_port_locked()