Searched refs:imq_msgcount (Results 1 – 5 of 5) sorted by relevance
94 uint16_t imq_msgcount; member125 #define imq_full(mq) ((mq)->imq_msgcount >= (mq)->imq_qlimit)126 #define imq_full_kernel(mq) ((mq)->imq_msgcount >= MACH_PORT_QLIMIT_KERNEL)
425 mqueue->imq_msgcount++; in ipc_mqueue_send_locked()426 assert(mqueue->imq_msgcount > 0); in ipc_mqueue_send_locked()577 assert(port_mq->imq_msgcount > 1 || ipc_kmsg_queue_empty(&port_mq->imq_messages)); in ipc_mqueue_release_msgcount()579 port_mq->imq_msgcount--; in ipc_mqueue_release_msgcount()603 port_mq->imq_msgcount++; in ipc_mqueue_release_msgcount()682 if (mqueue->imq_msgcount > 0) { in ipc_mqueue_post()712 if (receiver->ith_state == MACH_PEEK_IN_PROGRESS && mqueue->imq_msgcount > 0) { in ipc_mqueue_post()1248 seqno < mq->imq_seqno + mq->imq_msgcount) { in ipc_mqueue_peek_locked()1489 mqueue->imq_msgcount = 0; in ipc_mqueue_destroy_locked()1552 mqueue->imq_msgcount++; /* give it to the awakened thread */ in ipc_mqueue_set_qlimit_locked()
158 int m = port_mq->imq_msgcount; in flipc_port_destroy()
1806 statusp->mps_msgcount = port->ip_messages.imq_msgcount; in mach_port_get_status_helper()
63 if port.ip_messages.imq_msgcount > 0:65 nmsgs += port.ip_messages.imq_msgcount682 nmsgs = portval.ip_messages.imq_msgcount953 …format(unsigned(port), 'in-transit', disp_str, 0, 0, port.ip_messages.imq_msgcount, unsigned(holdi…1106 if p.ip_messages.imq_msgcount > 0:1141 if p.ip_messages.imq_msgcount > 0:1218 if follow_busyports and unsigned(eport) > 0 and eport.ip_messages.imq_msgcount > 0:1337 if unsigned(ipc_port) != 0 and ipc_port.ip_messages.imq_msgcount > 0:1497 if port.ip_messages.imq_msgcount > 0: