50     if (pthread_mutex_init(&fqp->mtx, NULL) != 0) {  in mkuz_fqueue_ctor()
67     pthread_mutex_lock(&fqp->mtx);  in mkuz_fqueue_enq()
78     pthread_mutex_unlock(&fqp->mtx);  in mkuz_fqueue_enq()
88     pthread_mutex_lock(&fqp->mtx);  in mkuz_fqueue_enq_all()
100     pthread_mutex_unlock(&fqp->mtx);  in mkuz_fqueue_enq_all()
124     pthread_mutex_lock(&fqp->mtx);  in mkuz_fqueue_deq_when()
126         pthread_cond_wait(&fqp->cvar, &fqp->mtx);  in mkuz_fqueue_deq_when()
156     pthread_mutex_unlock(&fqp->mtx);  in mkuz_fqueue_deq_when()
169     pthread_mutex_lock(&fqp->mtx);  in mkuz_fqueue_deq()
171         pthread_cond_wait(&fqp->cvar, &fqp->mtx);  in mkuz_fqueue_deq()
185     pthread_mutex_unlock(&fqp->mtx);  in mkuz_fqueue_deq()
198     pthread_mutex_lock(&fqp->mtx);  in mkuz_fqueue_deq_all()
200         pthread_cond_wait(&fqp->cvar, &fqp->mtx);  in mkuz_fqueue_deq_all()
209     pthread_mutex_unlock(&fqp->mtx);  in mkuz_fqueue_deq_all()