Lines Matching refs:mq_mutex
175 struct mtx mq_mutex; member
1606 mtx_init(&mq->mq_mutex, "mqueue lock", NULL, MTX_DEF); in mqueue_alloc()
1607 knlist_init_mtx(&mq->mq_rsel.si_note, &mq->mq_mutex); in mqueue_alloc()
1608 knlist_init_mtx(&mq->mq_wsel.si_note, &mq->mq_mutex); in mqueue_alloc()
1626 mtx_destroy(&mq->mq_mutex); in mqueue_free()
1762 mtx_lock(&mq->mq_mutex); in _mqueue_send()
1765 mtx_unlock(&mq->mq_mutex); in _mqueue_send()
1769 error = msleep(&mq->mq_senders, &mq->mq_mutex, in _mqueue_send()
1776 mtx_unlock(&mq->mq_mutex); in _mqueue_send()
1804 mtx_unlock(&mq->mq_mutex); in _mqueue_send()
1820 mtx_assert(&mq->mq_mutex, MA_OWNED); in mqueue_send_notification()
1918 mtx_lock(&mq->mq_mutex); in _mqueue_recv()
1921 mtx_unlock(&mq->mq_mutex); in _mqueue_recv()
1925 error = msleep(&mq->mq_receivers, &mq->mq_mutex, in _mqueue_recv()
1948 mtx_unlock(&mq->mq_mutex); in _mqueue_recv()
1994 mtx_assert(&mq->mq_mutex, MA_OWNED); in notifier_remove()
2397 mtx_lock(&mq->mq_mutex); in kern_kmq_notify()
2408 mtx_unlock(&mq->mq_mutex); in kern_kmq_notify()
2445 mtx_unlock(&mq->mq_mutex); in kern_kmq_notify()
2484 mtx_lock(&mq->mq_mutex); in mqueue_fdclose()
2496 mtx_unlock(&mq->mq_mutex); in mqueue_fdclose()
2514 mtx_lock(&mq->mq_mutex); in mq_proc_exit()
2516 mtx_unlock(&mq->mq_mutex); in mq_proc_exit()
2530 mtx_lock(&mq->mq_mutex); in mqf_poll()
2547 mtx_unlock(&mq->mq_mutex); in mqf_poll()
2663 mtx_assert(&mq->mq_mutex, MA_OWNED); in filt_mqread()
2672 mtx_assert(&mq->mq_mutex, MA_OWNED); in filt_mqwrite()