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)
414 mqueue->imq_msgcount++; in ipc_mqueue_send_locked()415 assert(mqueue->imq_msgcount > 0); in ipc_mqueue_send_locked()555 assert(port_mq->imq_msgcount > 1 || ipc_kmsg_queue_empty(&port_mq->imq_messages)); in ipc_mqueue_release_msgcount()557 port_mq->imq_msgcount--; in ipc_mqueue_release_msgcount()581 port_mq->imq_msgcount++; in ipc_mqueue_release_msgcount()651 if (mqueue->imq_msgcount == 0) { in ipc_mqueue_post()686 if (receiver->ith_state == MACH_PEEK_IN_PROGRESS && mqueue->imq_msgcount > 0) { in ipc_mqueue_post()1227 seqno < mq->imq_seqno + mq->imq_msgcount) { in ipc_mqueue_peek_locked()1402 mqueue->imq_msgcount = 0; in ipc_mqueue_destroy_locked()1458 mqueue->imq_msgcount++; /* give it to the awakened thread */ in ipc_mqueue_set_qlimit_locked()
157 int m = port_mq->imq_msgcount; in flipc_port_destroy()
1792 statusp->mps_msgcount = port->ip_messages.imq_msgcount; in mach_port_get_status_helper()
142 port.ip_messages.imq_msgcount, splabel_name, dest_str))737 nmsgs = portval.ip_messages.imq_msgcount1019 …format(unsigned(port), 'in-transit', disp_str, 0, 0, port.ip_messages.imq_msgcount, unsigned(holdi…1279 if follow_busyports and unsigned(eport) > 0 and eport.ip_messages.imq_msgcount > 0:1393 …!= 0 and unsigned(ipc_port) != xnudefines.MACH_PORT_DEAD and ipc_port.ip_messages.imq_msgcount > 0:1618 if wq.asPort().ip_messages.imq_msgcount > 0:1635 if port.ip_messages.imq_msgcount > 0: