Searched refs:imq_messages (Results 1 – 5 of 5) sorted by relevance
| /xnu-8020.140.41/osfmk/ipc/ |
| H A D | ipc_mqueue.c | 132 ipc_kmsg_queue_init(&mqueue->imq_messages); in ipc_mqueue_init() 156 ipc_kmsg_queue_t kmsgq = &port_mqueue->imq_messages; in ipc_mqueue_add_locked() 503 ipc_kmsg_t first = ipc_kmsg_queue_first(&mqueue->imq_messages); in ipc_mqueue_override_send_locked() 505 if (first && ipc_kmsg_override_qos(&mqueue->imq_messages, first, qos_ovr)) { in ipc_mqueue_override_send_locked() 544 assert(port_mq->imq_msgcount > 1 || ipc_kmsg_queue_empty(&port_mq->imq_messages)); in ipc_mqueue_release_msgcount() 574 if (ipc_kmsg_queue_empty(&port_mq->imq_messages)) { in ipc_mqueue_release_msgcount() 649 } else if (!ipc_kmsg_enqueue_qos(&mqueue->imq_messages, kmsg)) { in ipc_mqueue_post() 678 ipc_kmsg_enqueue_qos(&mqueue->imq_messages, kmsg); in ipc_mqueue_post() 939 if (ipc_kmsg_queue_empty(&port->ip_messages.imq_messages)) { in ipc_mqueue_receive_on_thread_and_unlock() 1080 assert(ipc_kmsg_queue_first(&port_mq->imq_messages) != IKM_NULL); in ipc_mqueue_peek_on_thread_locked() [all …]
|
| H A D | flipc.c | 167 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 D | ipc_mqueue.h | 91 struct ipc_kmsg_queue imq_messages; member
|
| H A D | ipc_pset.c | 311 first = ipc_kmsg_queue_first(&port->ip_messages.imq_messages); in filt_machport_filter_result()
|
| /xnu-8020.140.41/tools/lldbmacros/ |
| H A D | ipc.py | 109 kmsgp = Cast(portp.ip_messages.imq_messages.ikmq_base, 'ipc_kmsg_t') 1070 p_kmsgp = Cast(p.ip_messages.imq_messages.ikmq_base, 'ipc_kmsg_t') 1105 p_kmsgp = Cast(p.ip_messages.imq_messages.ikmq_base, 'ipc_kmsg_t') 1179 kmsgp = Cast(eport.ip_messages.imq_messages.ikmq_base, 'ipc_kmsg_t') 1300 kmsgp = Cast(ipc_port.ip_messages.imq_messages.ikmq_base, 'ipc_kmsg_t')
|