Lines Matching refs:myqueue
95 struct nfsrv_uc_queue *myqueue = &nfsrv_uc_queue_tbl[qi];
99 lck_mtx_lock(myqueue->ucq_lock);
101 while (!nfsrv_uc_shutdown && TAILQ_EMPTY(myqueue->ucq_queue)) {
102 myqueue->ucq_flags |= NFS_UC_QUEUE_SLEEPING;
103 error = msleep(myqueue, myqueue->ucq_lock, PSOCK, "nfsd_upcall_handler", NULL);
104 myqueue->ucq_flags &= ~NFS_UC_QUEUE_SLEEPING;
110 lck_mtx_unlock(myqueue->ucq_lock);
115 ep = TAILQ_FIRST(myqueue->ucq_queue);
116 DPRINT("nfsrv_uc_thread:%d dequeue %p from %p\n", qi, ep, myqueue);
118 TAILQ_REMOVE(myqueue->ucq_queue, ep, nua_svcq);
122 lck_mtx_unlock(myqueue->ucq_lock);
148 struct nfsrv_uc_queue *myqueue = &nfsrv_uc_queue_tbl[ap->nua_qi];
158 lck_mtx_lock(myqueue->ucq_lock);
161 TAILQ_REMOVE(myqueue->ucq_queue, ap, nua_svcq);
167 lck_mtx_unlock(myqueue->ucq_lock);
313 struct nfsrv_uc_queue *myqueue = &nfsrv_uc_queue_tbl[qi];
315 lck_mtx_lock(myqueue->ucq_lock);
317 DPRINT("\tUp-call queued on %d for wakeup of %p\n", qi, myqueue);
319 lck_mtx_unlock(myqueue->ucq_lock);
326 TAILQ_INSERT_TAIL(myqueue->ucq_queue, uap, nua_svcq);
329 if (myqueue->ucq_flags | NFS_UC_QUEUE_SLEEPING)
330 wakeup(myqueue);
345 lck_mtx_unlock(myqueue->ucq_lock);