osfmk/kern/sched_prim.c

573 	SCHED(init)();
574 	SCHED(fairshare_init)();
579 	SCHED(pset_init)(&pset0);
580 	SCHED(processor_init)(master_processor);
591 	SCHED(timebase_init)();
1642 		if (SCHED(can_update_priority)(thread))
1643 			SCHED(update_priority)(thread);
1695 			if (!inactive_state && (thread->sched_mode != TH_MODE_FAIRSHARE || SCHED(fairshare_runq_count)() == 0) && (rt_runq.count == 0 || BASEPRI_RTQUEUES < thread->sched_pri) &&
1696 					(new_thread = SCHED(choose_thread)(processor, thread->sched_mode == TH_MODE_FAIRSHARE ? MINPRI : thread->sched_pri)) == THREAD_NULL) {
1704 				pset_count_hint(pset, processor, SCHED(processor_runq_count)(processor));
1715 				(SCHED(processor_queue_has_priority)(processor, rt_runq.count == 0 ? IDLEPRI : BASEPRI_RTQUEUES, TRUE) &&
1716 					 (new_thread = SCHED(choose_thread)(processor, MINPRI)) != THREAD_NULL)) {
1722 					pset_count_hint(pset, processor, SCHED(processor_runq_count)(processor));
1751 		if ((new_thread = SCHED(fairshare_dequeue)()) != THREAD_NULL) {
1783 		new_thread = SCHED(steal_thread)(pset);
1792 		if (!SCHED(processor_queue_empty)(processor) || rt_runq.count > 0 || SCHED(fairshare_runq_count)() > 0)
2004 				if (SCHED(priority_is_urgent)(pri)) {
2380 					thread->current_quantum += SCHED(initial_quantum_size)(thread);
2663 		thread->current_quantum = SCHED(initial_quantum_size)(thread);
2822 	if (SCHED(priority_is_urgent)(rq->highq)) {
2866 	if (SCHED(priority_is_urgent)(thread->sched_pri))
2891 	if (SCHED(priority_is_urgent)(thread->sched_pri)) {
2922 	SCHED(fairshare_enqueue)(thread);
3087 	if ( (SCHED(direct_dispatch_to_idle_processors) ||
3106 	if (SCHED(priority_is_urgent)(thread->sched_pri) && thread->sched_pri > processor->current_pri)
3116 	if (!SCHED(processor_enqueue)(processor, thread, options))
3415 															SCHED(processor_runq_count)(cset->low_count) < SCHED(processor_runq_count)(processor)))) {
3534 	if (SCHED(can_update_priority)(thread))
3535 		SCHED(update_priority)(thread);
3550 			processor = SCHED(choose_processor)(pset, PROCESSOR_NULL, thread);
3560 			processor = SCHED(choose_processor)(pset, processor, thread);
3584 			processor = SCHED(choose_processor)(pset, PROCESSOR_NULL, thread);
3658 				if (SCHED(priority_is_urgent)(pri)) {
3714 	result = SCHED(processor_csw_check)(processor);
3718 	if (SCHED(should_current_thread_rechoose_processor)(processor))
3867 			return SCHED(fairshare_queue_remove)(thread);
3871 			return SCHED(processor_queue_remove)(processor, thread);
3933 				if (SCHED(priority_is_urgent)(pri)) {
4089 	while (processor->next_thread == THREAD_NULL && SCHED(processor_queue_empty)(processor) && rt_runq.count == 0 && SCHED(fairshare_runq_count)() == 0 &&
4092 			MACHDBG_CODE(DBG_MACH_SCHED,MACH_IDLE) | DBG_FUNC_NONE, (uintptr_t)thread_tid(thread), rt_runq.count, SCHED(processor_runq_count)(processor), -1, 0);
4103 			MACHDBG_CODE(DBG_MACH_SCHED,MACH_IDLE) | DBG_FUNC_NONE, (uintptr_t)thread_tid(thread), rt_runq.count, SCHED(processor_runq_count)(processor), -2, 0);
4124 		if (SCHED(processor_queue_has_priority)(processor, new_thread->sched_pri, FALSE)					||
4256 										  (void *)SCHED(maintenance_continuation),
4430 				if (SCHED(can_update_priority)(thread))
4431 					SCHED(update_priority)(thread);