osfmk/kern/sched_prim.c

813 		if (!timer_call_enter(&thread->wait_timer, deadline, thread->sched_pri >= BASEPRI_RTQUEUES ? TIMER_CALL_CRITICAL : 0))
831 		if (!timer_call_enter(&thread->wait_timer, deadline, thread->sched_pri >= BASEPRI_RTQUEUES ? TIMER_CALL_CRITICAL : 0))
981 			(uintptr_t)thread_tid(thread), thread->sched_pri, thread->wait_result, 0, 0);
1645 		processor->current_pri = thread->sched_pri;
1664 				(thread->sched_pri >= BASEPRI_RTQUEUES		||
1671 			if (	thread->sched_pri >= BASEPRI_RTQUEUES	&&
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) {
1720 					pset_pri_hint(pset, processor, new_thread->sched_pri);
1823 		if ((thread->state & (TH_IDLE|TH_TERMINATE|TH_SUSP)) || !(thread->state & TH_WAIT) || thread->wake_active || thread->sched_pri >= BASEPRI_RTQUEUES)
1919 	else if ((thread->sched_pri <= MAXPRI_THROTTLE) &&
1921 		thread_tell_urgency(THREAD_URGENCY_BACKGROUND, thread->sched_pri, thread->priority);
1923 		thread_tell_urgency(THREAD_URGENCY_NORMAL, thread->sched_pri, thread->priority);
2119 			processor->current_pri = thread->sched_pri;
2150 				self->reason, (uintptr_t)thread_tid(thread), self->sched_pri, thread->sched_pri, 0);
2159 			SCHED_STATS_CSW(processor, self->reason, self->sched_pri, thread->sched_pri);
2187 				self->reason, (uintptr_t)thread_tid(thread), self->sched_pri, thread->sched_pri, 0);
2218 				self->reason, (uintptr_t)thread_tid(thread), self->sched_pri, thread->sched_pri, 0);
2229 	processor->current_pri = thread->sched_pri;
2264 		self->reason, (uintptr_t)thread_tid(thread), self->sched_pri, thread->sched_pri, 0);
2273 	SCHED_STATS_CSW(processor, self->reason, self->sched_pri, thread->sched_pri);
2469 		else if ((self->sched_pri <= MAXPRI_THROTTLE) &&
2471 			thread_tell_urgency(THREAD_URGENCY_BACKGROUND, self->sched_pri, self->priority);
2473 			thread_tell_urgency(THREAD_URGENCY_NORMAL, self->sched_pri, self->priority);
2848 	queue_t			queue = rq->queues + thread->sched_pri;
2854 		setbit(MAXPRI - thread->sched_pri, rq->bitmap);
2855 		if (thread->sched_pri > rq->highq) {
2856 			rq->highq = thread->sched_pri;
2866 	if (SCHED(priority_is_urgent)(thread->sched_pri))
2891 	if (SCHED(priority_is_urgent)(thread->sched_pri)) {
2895 	if (queue_empty(rq->queues + thread->sched_pri)) {
2897 		if (thread->sched_pri != IDLEPRI)
2898 			clrbit(MAXPRI - thread->sched_pri, rq->bitmap);
3106 	if (SCHED(priority_is_urgent)(thread->sched_pri) && thread->sched_pri > processor->current_pri)
3111 	if ((thread->sched_mode == TH_MODE_TIMESHARE) && thread->sched_pri < thread->priority)
3131 				(thread->sched_pri >= processor->current_pri	||
3138 			thread->sched_pri >= processor->current_pri	) {
3320 			    ((thread->sched_pri >= BASEPRI_RTQUEUES) &&
3336 		if (thread->sched_pri >= BASEPRI_RTQUEUES) {
3353 			    (lp_processor->current_pri < thread->sched_pri))
3389 			if (thread->sched_pri > lowest_unpaired)
3394 			if (thread->sched_pri > lowest_priority)
3408 							(thread->sched_pri > BASEPRI_DEFAULT && cset->low_pri->current_pri < thread->sched_pri))) {
3414 						(processor == PROCESSOR_NULL || (thread->sched_pri <= BASEPRI_DEFAULT &&
3602 	if (thread->sched_pri >= BASEPRI_RTQUEUES)
3746 	thread->sched_pri = priority;
3781 	if (thread->sched_pri > MAXPRI || thread->sched_pri < MINPRI)
3782 		panic("run_queue_check: thread sched_pri");
3784 	q = &rq->queues[thread->sched_pri];
3870 		if (thread->sched_pri < BASEPRI_RTQUEUES) {
4039 		} else if ((thread->sched_pri <= MAXPRI_THROTTLE) &&
4041 			KERNEL_DEBUG(MACHDBG_CODE(DBG_MACH_SCHED, MACH_SCHED_GET_URGENCY), THREAD_URGENCY_BACKGROUND, thread->sched_pri, thread->priority, 0, 0);
4124 		if (SCHED(processor_queue_has_priority)(processor, new_thread->sched_pri, FALSE)					||
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);
4232 	thread->sched_pri = thread->priority = IDLEPRI;