Lines Matching refs:th
118 static boolean_t workqueue_run_nextreq(proc_t p, struct workqueue *wq, thread_t th, boolean_t force_oc,
123 static void wq_runreq(proc_t p, boolean_t overcommit, pthread_priority_t priority, thread_t th, struct threadlist *tl,
126 static int _setup_wqthread(proc_t p, thread_t th, boolean_t overcommit, pthread_priority_t priority, int reuse_thread, struct threadlist *tl);
186 thread_t th;
207 kret = pthread_kern->thread_create(ctask, &th);
210 thread_reference(th);
212 sright = (void *)pthread_kern->convert_thread_to_port(th);
295 error = pthread_kern->thread_set_wq_state32(th, (thread_state_t)ts);
316 error = pthread_kern->thread_set_wq_state64(th, (thread_state_t)ts64);
344 (void) pthread_kern->thread_set_wq_state32(th, (thread_state_t)ts);
364 thread_policy_set(th, THREAD_EXTENDED_POLICY, (thread_policy_t)&extinfo, THREAD_EXTENDED_POLICY_COUNT);
368 thread_policy_set(th, THREAD_PRECEDENCE_POLICY, (thread_policy_t)&precedinfo, THREAD_PRECEDENCE_POLICY_COUNT);
378 pthread_kern->thread_policy_set_internal(th, THREAD_QOS_POLICY, (thread_policy_t)&qos, THREAD_QOS_POLICY_COUNT);
381 kret = pthread_kern->thread_resume(th);
386 thread_deallocate(th); /* drop the creator reference */
400 (void)thread_terminate(th);
401 (void)thread_deallocate(th);
533 thread_t th;
559 if ((th = port_name_to_thread(kport)) == THREAD_NULL) {
564 if (th != current_thread()) {
565 thread_deallocate(th);
572 /* pthread_kern->thread_static_param(th, TRUE); */ // see <rdar://problem/16433744>, for details
574 thread_deallocate(th);
580 util_get_thread_threadlist_entry(thread_t th)
582 struct uthread *uth = pthread_kern->get_bsdthread_info(th);
591 wq_thread_override_reset(thread_t th)
593 struct uthread *uth = pthread_kern->get_bsdthread_info(th);
740 thread_t th;
747 if ((th = port_name_to_thread(kport)) == THREAD_NULL) {
751 struct uthread *uth = pthread_kern->get_bsdthread_info(th);
754 struct threadlist *tl = util_get_thread_threadlist_entry(th);
760 PTHREAD_TRACE(TRACE_wq_override_start | DBG_FUNC_NONE, tl->th_workq, thread_tid(th), o+1, priority, 0);
766 thread_deallocate(th);
773 thread_t th;
780 if ((th = port_name_to_thread(kport)) == THREAD_NULL) {
784 struct uthread *uth = pthread_kern->get_bsdthread_info(th);
786 struct threadlist *tl = util_get_thread_threadlist_entry(th);
790 PTHREAD_TRACE(TRACE_wq_override_end | DBG_FUNC_NONE, tl->th_workq, thread_tid(th), o-1, 0, 0);
794 thread_deallocate(th);
801 thread_deallocate(th);
808 thread_t th;
815 if ((th = port_name_to_thread(kport)) == THREAD_NULL) {
819 struct uthread *uth = pthread_kern->get_bsdthread_info(th);
822 struct threadlist *tl = util_get_thread_threadlist_entry(th);
824 thread_deallocate(th);
832 PTHREAD_TRACE(TRACE_wq_override_dispatch | DBG_FUNC_NONE, tl->th_workq, thread_tid(th), o+1, priority, 0);
837 thread_deallocate(th);
844 thread_t th;
852 th = current_thread();
853 tl = util_get_thread_threadlist_entry(th);
856 wq_thread_override_reset(th);
1425 thread_t th;
1458 kret = pthread_kern->thread_create_workq(wq->wq_task, (thread_continue_t)wq_unsuspend_continue, &th);
1498 (void) thread_terminate(th);
1499 thread_deallocate(th);
1504 thread_reference(th);
1506 sright = (void *)pthread_kern->convert_thread_to_port(th);
1509 pthread_kern->thread_static_param(th, TRUE);
1513 tl->th_thread = th;
1720 thread_t th = current_thread();
1721 struct uthread *uth = pthread_kern->get_bsdthread_info(th);
1722 struct threadlist *tl = util_get_thread_threadlist_entry(th);
1732 wq_thread_override_reset(th);
1745 (void)workqueue_run_nextreq(p, wq, th, FALSE, FALSE, 0);
2351 wq_runreq(proc_t p, boolean_t overcommit, pthread_priority_t priority, thread_t th, struct threadlist *tl,
2357 PTHREAD_TRACE1(TRACE_wq_runitem | DBG_FUNC_START, tl->th_workq, overcommit, priority, thread_tid(current_thread()), thread_tid(th));
2359 ret = _setup_wqthread(p, th, overcommit, priority, reuse_thread, tl);
2378 PTHREAD_TRACE1(TRACE_wq_thread_suspend | DBG_FUNC_END, tl->th_workq, 0, 0, thread_tid(current_thread()), thread_tid(th));
2397 pthread_kern->thread_resume(th);
2404 _setup_wqthread(proc_t p, thread_t th, boolean_t overcommit, pthread_priority_t priority, int reuse_thread, struct threadlist *tl)
2441 (void)pthread_kern->thread_set_wq_state32(th, (thread_state_t)ts);
2460 error = pthread_kern->thread_set_wq_state64(th, (thread_state_t)ts64);