Lines Matching refs:mq_lock
189 mutex_t mq_lock; /* Protects items below */ member
234 VERIFY0(mutex_destroy(&mqp->mq_lock)); in mergeq_fini()
268 if ((ret = mutex_init(&mqp->mq_lock, USYNC_THREAD | LOCK_ERRORCHECK, in mergeq_init()
281 VERIFY0(mutex_destroy(&mqp->mq_lock)); in mergeq_init()
300 VERIFY(MUTEX_HELD(&mqp->mq_lock)); in mergeq_reset()
323 VERIFY(MUTEX_HELD(&mqp->mq_lock)); in mergeq_grow()
345 VERIFY0(mutex_lock(&mqp->mq_lock)); in mergeq_add()
347 VERIFY0(mutex_unlock(&mqp->mq_lock)); in mergeq_add()
355 VERIFY0(mutex_unlock(&mqp->mq_lock)); in mergeq_add()
363 VERIFY0(mutex_unlock(&mqp->mq_lock)); in mergeq_add()
372 VERIFY(MUTEX_HELD(&mqp->mq_lock)); in mergeq_slot()
397 VERIFY(MUTEX_HELD(&mqp->mq_lock)); in mergeq_push()
406 (void) cond_wait(&mqp->mq_cond, &mqp->mq_lock); in mergeq_push()
454 VERIFY(MUTEX_HELD(&mqp->mq_lock)); in mergeq_pop()
459 (void) cond_wait(&mqp->mq_cond, &mqp->mq_lock); in mergeq_pop()
481 VERIFY0(mutex_lock(&mqp->mq_lock)); in mergeq_thr_merge()
487 VERIFY0(mutex_unlock(&mqp->mq_lock)); in mergeq_thr_merge()
497 VERIFY0(mutex_unlock(&mqp->mq_lock)); in mergeq_thr_merge()
502 VERIFY0(mutex_unlock(&mqp->mq_lock)); in mergeq_thr_merge()
509 VERIFY0(mutex_unlock(&mqp->mq_lock)); in mergeq_thr_merge()
511 VERIFY0(mutex_lock(&mqp->mq_lock)); in mergeq_thr_merge()
520 VERIFY0(mutex_unlock(&mqp->mq_lock)); in mergeq_thr_merge()
539 VERIFY0(mutex_lock(&mqp->mq_lock)); in mergeq_merge()
541 VERIFY0(mutex_unlock(&mqp->mq_lock)); in mergeq_merge()
548 VERIFY0(mutex_unlock(&mqp->mq_lock)); in mergeq_merge()
576 VERIFY0(mutex_unlock(&mqp->mq_lock)); in mergeq_merge()
584 VERIFY0(mutex_lock(&mqp->mq_lock)); in mergeq_merge()
600 VERIFY0(mutex_unlock(&mqp->mq_lock)); in mergeq_merge()