osfmk/kern/sched_prim.c

110 struct rt_queue	rt_runq;
712 	rt_runq.count = 0;
713 	queue_init(&rt_runq.queue);
1673 				if (rt_runq.count > 0) {
1676 					q = &rt_runq.queue;
1681 						SCHED_STATS_RUNQ_CHANGE(&rt_runq.runq_stats, rt_runq.count);
1682 						rt_runq.count--;
1695 			if (!inactive_state && (thread->sched_mode != TH_MODE_FAIRSHARE || SCHED(fairshare_runq_count)() == 0) && (rt_runq.count == 0 || BASEPRI_RTQUEUES < thread->sched_pri) &&
1715 				(SCHED(processor_queue_has_priority)(processor, rt_runq.count == 0 ? IDLEPRI : BASEPRI_RTQUEUES, TRUE) &&
1731 		if (rt_runq.count > 0) {
1732 			thread = (thread_t)dequeue_head(&rt_runq.queue);
1735 			SCHED_STATS_RUNQ_CHANGE(&rt_runq.runq_stats, rt_runq.count);
1736 			rt_runq.count--;
1792 		if (!SCHED(processor_queue_empty)(processor) || rt_runq.count > 0 || SCHED(fairshare_runq_count)() > 0)
2940 	queue_t				queue = &rt_runq.queue;
2970 	SCHED_STATS_RUNQ_CHANGE(&rt_runq.runq_stats, rt_runq.count);
2971 	rt_runq.count++;
3706 		if (rt_runq.count > 0)
3710 		if (rt_runq.count > 0 && BASEPRI_RTQUEUES >= processor->current_pri)
3875 		q = &rt_runq.queue;
3883 			SCHED_STATS_RUNQ_CHANGE(&rt_runq.runq_stats, rt_runq.count);
3884 			rt_runq.count--;
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);
4125 				(rt_runq.count > 0 && BASEPRI_RTQUEUES >= new_thread->sched_pri)	) {
4131 			KERNEL_DEBUG_CONSTANT(MACHDBG_CODE(DBG_MACH_SCHED, MACH_REDISPATCH), (uintptr_t)thread_tid(new_thread), new_thread->sched_pri, rt_runq.count, 0, 0);