Lines Matching refs:nfsrv_uc_queue_tbl
69 } nfsrv_uc_queue_tbl[NFS_UC_HASH_SZ];
95 struct nfsrv_uc_queue *myqueue = &nfsrv_uc_queue_tbl[qi];
148 struct nfsrv_uc_queue *myqueue = &nfsrv_uc_queue_tbl[ap->nua_qi];
180 TAILQ_INIT(nfsrv_uc_queue_tbl[i].ucq_queue);
181 nfsrv_uc_queue_tbl[i].ucq_lock = lck_mtx_alloc_init(nfsrv_uc_group, LCK_ATTR_NULL);
182 nfsrv_uc_queue_tbl[i].ucq_thd = THREAD_NULL;
183 nfsrv_uc_queue_tbl[i].ucq_flags = 0;
211 error = kernel_thread_start(nfsrv_uc_thread, (void *)(uintptr_t)i, &nfsrv_uc_queue_tbl[nfsrv_uc_thread_count].ucq_thd);
246 lck_mtx_lock(nfsrv_uc_queue_tbl[i].ucq_lock);
247 wakeup(&nfsrv_uc_queue_tbl[i]);
248 lck_mtx_unlock(nfsrv_uc_queue_tbl[i].ucq_lock);
258 if (nfsrv_uc_queue_tbl[i].ucq_thd != THREAD_NULL)
259 thread_deallocate(nfsrv_uc_queue_tbl[i].ucq_thd);
260 nfsrv_uc_queue_tbl[i].ucq_thd = THREAD_NULL;
286 struct nfsrv_uc_queue *queue = &nfsrv_uc_queue_tbl[i];
313 struct nfsrv_uc_queue *myqueue = &nfsrv_uc_queue_tbl[qi];