Searched refs:mq (Results 1 – 5 of 5) sorted by relevance
116 #define imq_full(mq) ((mq)->imq_msgcount >= (mq)->imq_qlimit) argument117 #define imq_full_kernel(mq) ((mq)->imq_msgcount >= MACH_PORT_QLIMIT_KERNEL) argument
1157 ipc_mqueue_t mq, in ipc_mqueue_peek_locked() argument1176 seqno = mq->imq_seqno; in ipc_mqueue_peek_locked()1178 } else if (seqno >= mq->imq_seqno && in ipc_mqueue_peek_locked()1179 seqno < mq->imq_seqno + mq->imq_msgcount) { in ipc_mqueue_peek_locked()1180 msgoff = seqno - mq->imq_seqno; in ipc_mqueue_peek_locked()1186 kmsgq = &mq->imq_messages; in ipc_mqueue_peek_locked()
304 #define ip_from_mq(mq) __container_of(mq, struct ipc_port, ip_messages) argument
546 struct ipfq *q, *mq = &mgr->ipfm_q; in ipf_process() local574 for (q = mq->ipfq_next; q != mq; q = q->ipfq_next) { in ipf_process()586 if (q == mq) { in ipf_process()597 ipfq_insque(q, mq); in ipf_process()
1207 MBUFQ_HEAD(counted_mbufq) mq;1215 MBUFQ_INIT(&q->mq); in mbufq_init()1223 MBUFQ_ENQUEUE_MULTI(&q->mq, head, tail); in mbufq_enqueue()1237 return MBUFQ_FIRST(&q->mq); in mbufq_first()1243 return MBUFQ_LAST(&q->mq); in mbufq_last()