Home
last modified time | relevance | path

Searched refs:imq_messages (Results 1 – 5 of 5) sorted by relevance

/xnu-8019.80.24/osfmk/ipc/
H A Dipc_mqueue.c132 ipc_kmsg_queue_init(&mqueue->imq_messages); in ipc_mqueue_init()
197 kmsgq = &port_mqueue->imq_messages; in ipc_mqueue_add_unlock()
536 ipc_kmsg_t first = ipc_kmsg_queue_first(&mqueue->imq_messages); in ipc_mqueue_override_send_locked()
538 if (first && ipc_kmsg_override_qos(&mqueue->imq_messages, first, qos_ovr)) { in ipc_mqueue_override_send_locked()
577 assert(port_mq->imq_msgcount > 1 || ipc_kmsg_queue_empty(&port_mq->imq_messages)); in ipc_mqueue_release_msgcount()
607 if (ipc_kmsg_queue_empty(&port_mq->imq_messages)) { in ipc_mqueue_release_msgcount()
683 if (ipc_kmsg_enqueue_qos(&mqueue->imq_messages, kmsg)) { in ipc_mqueue_post()
713 ipc_kmsg_enqueue_qos(&mqueue->imq_messages, kmsg); in ipc_mqueue_post()
968 if (ipc_kmsg_queue_empty(&port->ip_messages.imq_messages)) { in ipc_mqueue_receive_on_thread()
1015 kmsgs = &port->ip_messages.imq_messages; in ipc_mqueue_receive_on_thread()
[all …]
H A Dflipc.c167 kmsg = ipc_kmsg_queue_first(&port_mq->imq_messages); in flipc_port_destroy()
169 ipc_kmsg_rmqueue(&port_mq->imq_messages, kmsg); in flipc_port_destroy()
469 kmsg = ipc_kmsg_queue_first(&port_mq->imq_messages); in flipc_msg_to_remote_node()
471 ipc_kmsg_rmqueue(&port_mq->imq_messages, kmsg); in flipc_msg_to_remote_node()
H A Dipc_mqueue.h91 struct ipc_kmsg_queue imq_messages; member
H A Dipc_pset.c404 ipc_kmsg_queue_t kmsgs = &port->ip_messages.imq_messages; in filt_machport_filter_result()
420 first = ipc_kmsg_queue_first(&port->ip_messages.imq_messages); in filt_machport_filter_result()
/xnu-8019.80.24/tools/lldbmacros/
H A Dipc.py110 kmsgp = Cast(portp.ip_messages.imq_messages.ikmq_base, 'ipc_kmsg_t')
1107 p_kmsgp = Cast(p.ip_messages.imq_messages.ikmq_base, 'ipc_kmsg_t')
1142 p_kmsgp = Cast(p.ip_messages.imq_messages.ikmq_base, 'ipc_kmsg_t')
1220 kmsgp = Cast(eport.ip_messages.imq_messages.ikmq_base, 'ipc_kmsg_t')
1341 kmsgp = Cast(ipc_port.ip_messages.imq_messages.ikmq_base, 'ipc_kmsg_t')