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)
411 mqueue->imq_msgcount++; in ipc_mqueue_send_locked()412 assert(mqueue->imq_msgcount > 0); in ipc_mqueue_send_locked()552 assert(port_mq->imq_msgcount > 1 || ipc_kmsg_queue_empty(&port_mq->imq_messages)); in ipc_mqueue_release_msgcount()554 port_mq->imq_msgcount--; in ipc_mqueue_release_msgcount()578 port_mq->imq_msgcount++; in ipc_mqueue_release_msgcount()648 if (mqueue->imq_msgcount == 0) { in ipc_mqueue_post()683 if (receiver->ith_state == MACH_PEEK_IN_PROGRESS && mqueue->imq_msgcount > 0) { in ipc_mqueue_post()1224 seqno < mq->imq_seqno + mq->imq_msgcount) { in ipc_mqueue_peek_locked()1399 mqueue->imq_msgcount = 0; in ipc_mqueue_destroy_locked()1455 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()
140 port.ip_messages.imq_msgcount, splabel_name, dest_str))726 nmsgs = portval.ip_messages.imq_msgcount1006 …format(unsigned(port), 'in-transit', disp_str, 0, 0, port.ip_messages.imq_msgcount, unsigned(holdi…1264 if follow_busyports and unsigned(eport) > 0 and eport.ip_messages.imq_msgcount > 0:1378 if unsigned(ipc_port) != 0 and ipc_port.ip_messages.imq_msgcount > 0:1603 if wq.asPort().ip_messages.imq_msgcount > 0:1620 if port.ip_messages.imq_msgcount > 0: