Lines Matching refs:mq_msgq
181 struct msgq mq_msgq; member
1594 TAILQ_INIT(&mq->mq_msgq); in mqueue_alloc()
1617 while ((msg = TAILQ_FIRST(&mq->mq_msgq)) != NULL) { in mqueue_free()
1618 TAILQ_REMOVE(&mq->mq_msgq, msg, msg_link); in mqueue_free()
1776 if (TAILQ_EMPTY(&mq->mq_msgq)) { in _mqueue_send()
1777 TAILQ_INSERT_HEAD(&mq->mq_msgq, msg, msg_link); in _mqueue_send()
1779 if (msg->msg_prio <= TAILQ_LAST(&mq->mq_msgq, msgq)->msg_prio) { in _mqueue_send()
1780 TAILQ_INSERT_TAIL(&mq->mq_msgq, msg, msg_link); in _mqueue_send()
1782 TAILQ_FOREACH(msg2, &mq->mq_msgq, msg_link) { in _mqueue_send()
1915 while ((*msg = TAILQ_FIRST(&mq->mq_msgq)) == NULL && error == 0) { in _mqueue_recv()
1929 TAILQ_REMOVE(&mq->mq_msgq, *msg, msg_link); in _mqueue_recv()
1941 !TAILQ_EMPTY(&mq->mq_msgq)) { in _mqueue_recv()
2406 !TAILQ_EMPTY(&mq->mq_msgq)) in kern_kmq_notify()