Lines Matching defs:uth
985 struct uthread *uth;
991 uth = get_bsdthread_info(th_act);
992 sel = &uth->uu_select;
1098 if (uth->uu_allocsize) {
1099 if (uth->uu_wqset == 0)
1102 if (size > uth->uu_allocsize) {
1103 kfree(uth->uu_wqset, uth->uu_allocsize);
1104 uth->uu_allocsize = size;
1105 uth->uu_wqset = (wait_queue_set_t)kalloc(size);
1106 if (uth->uu_wqset == (wait_queue_set_t)NULL)
1110 uth->uu_allocsize = size;
1111 uth->uu_wqset = (wait_queue_set_t)kalloc(uth->uu_allocsize);
1112 if (uth->uu_wqset == (wait_queue_set_t)NULL)
1115 bzero(uth->uu_wqset, size);
1116 sel->wql = (char *)uth->uu_wqset + SIZEOF_WAITQUEUE_SET;
1117 wait_queue_set_init(uth->uu_wqset, (SYNC_POLICY_FIFO | SYNC_POLICY_PREPOST));
1153 struct uthread *uth;
1168 uth = get_bsdthread_info(th_act);
1169 sel = &uth->uu_select;
1190 wait_queue_sub_clearrefs(uth->uu_wqset);
1192 error = selscan(p, sel, uap->nd, retval, sel_pass, (wait_queue_sub_t)uth->uu_wqset);
1245 wait_result = wait_queue_assert_wait((wait_queue_t)uth->uu_wqset,
1264 wait_subqueue_unlink_all(uth->uu_wqset);
1751 uthread_t uth = get_bsdthread_info(current_thread());
1789 if ((fp->f_flags & FP_INSELECT) && (fp->f_waddr == (void *)uth->uu_wqset)) {