bsd/kern/pthread_synch.c

127 static boolean_t workqueue_run_nextreq(proc_t p, struct workqueue *wq, thread_t th, boolean_t force_oc,
132 static void wq_runreq(proc_t p, boolean_t overcommit, uint32_t priority, thread_t th, struct threadlist *tl,
135 static int setup_wqthread(proc_t p, thread_t th, boolean_t overcommit, uint32_t priority, int reuse_thread, struct threadlist *tl);
202 	thread_t th;
231 	kret = thread_create(ctask, &th);
234 	thread_reference(th);
236 	sright = (void *) convert_thread_to_port(th);
322 		thread_set_wq_state32(th, (thread_state_t)ts);
347 		thread_set_wq_state64(th, (thread_state_t)ts64);
370 		thread_set_wq_state32(th, (thread_state_t)ts);
386 		ret = proc_setthread_saved_importance(th, importance);
395 		thread_policy_set(th, THREAD_EXTENDED_POLICY, (thread_policy_t)&extinfo, THREAD_EXTENDED_POLICY_COUNT);
399 		thread_policy_set(th, THREAD_PRECEDENCE_POLICY, (thread_policy_t)&precedinfo, THREAD_PRECEDENCE_POLICY_COUNT);
405 	kret = thread_resume(th);
410 	thread_deallocate(th);	/* drop the creator reference */
423 	(void)thread_terminate(th);
424 	(void)thread_deallocate(th);
1020 	thread_t	th;
1052 	kret = thread_create_workq(wq->wq_task, (thread_continue_t)wq_unsuspend_continue, &th);
1092 		(void) thread_terminate(th);
1093 		thread_deallocate(th);
1098 	thread_reference(th);
1100 	sright = (void *) convert_thread_to_port(th);
1103 	thread_static_param(th, TRUE);
1107 	tl->th_thread = th;
1332 		        thread_t th = current_thread();
1333 		        struct uthread *uth = get_bsdthread_info(th);
1351 			(void)workqueue_run_nextreq(p, wq, th, FALSE, FALSE, 0, -1);
2174 wq_runreq(proc_t p, boolean_t overcommit, uint32_t priority, thread_t th, struct threadlist *tl,
2180 	KERNEL_DEBUG1(0xefffd004 | DBG_FUNC_START, tl->th_workq, tl->th_priority, tl->th_affinity_tag, thread_tid(current_thread()), thread_tid(th));
2182 	ret = setup_wqthread(p, th, overcommit, priority, reuse_thread, tl);
2202 	        KERNEL_DEBUG1(0xefffd014 | DBG_FUNC_END, tl->th_workq, 0, 0, thread_tid(current_thread()), thread_tid(th));
2220 			thread_resume(th);
2227 setup_wqthread(proc_t p, thread_t th, boolean_t overcommit, uint32_t priority, int reuse_thread, struct threadlist *tl)
2259 		thread_set_wq_state32(th, (thread_state_t)ts);
2278 		thread_set_wq_state64(th, (thread_state_t)ts64);