Home
last modified time | relevance | path

Searched refs:BASEPRI_RTQUEUES (Results 1 – 15 of 15) sorted by relevance

/xnu-12377.81.4/tests/sched/
H A Drt_migration.c39 threads[i] = create_thread(TH_BUCKET_FIXPRI, tg, BASEPRI_RTQUEUES);
84 thread_t thread = create_thread(TH_BUCKET_FIXPRI, tg, BASEPRI_RTQUEUES);
91 earlier_threads[i] = create_thread(TH_BUCKET_FIXPRI, tg, BASEPRI_RTQUEUES);
97 test_thread_t later_thread = create_thread(TH_BUCKET_FIXPRI, tg, BASEPRI_RTQUEUES);
225 thread_t thread = create_thread(TH_BUCKET_FIXPRI, tg, BASEPRI_RTQUEUES);
270 BASEPRI_RTQUEUES); in create_realtime_thread_with_deadline()
/xnu-12377.81.4/osfmk/kern/
H A Dsched_rt.c173 for (int pri = BASEPRI_RTQUEUES; pri <= MAXPRI; pri++) { in pset_rt_init()
174 int i = pri - BASEPRI_RTQUEUES; in pset_rt_init()
427 assert3u(thread->sched_pri, >=, BASEPRI_RTQUEUES); in sched_rt_choose_processor()
1187 for (int pri = BASEPRI_RTQUEUES; pri <= MAXPRI; pri++) { in check_rt_runq_consistency()
1188 int i = pri - BASEPRI_RTQUEUES; in check_rt_runq_consistency()
1200 assert(iter_thread->sched_pri == (i + BASEPRI_RTQUEUES)); in check_rt_runq_consistency()
1240 assert((pri >= BASEPRI_RTQUEUES) && (pri <= MAXPRI)); in rt_runq_enqueue()
1241 int i = pri - BASEPRI_RTQUEUES; in rt_runq_enqueue()
1283 os_atomic_store(&rt_run_queue->ed_index, pri - BASEPRI_RTQUEUES, relaxed); in rt_runq_enqueue()
1336 return i + BASEPRI_RTQUEUES; in rt_runq_priority()
[all …]
H A Dsched_amp_common.c267 if (thread->sched_pri >= BASEPRI_RTQUEUES) { in should_spill_to_ecores()
361 if ((eprocessor->current_pri < BASEPRI_RTQUEUES) && in sched_amp_balance()
453 if (thread && thread->sched_pri < BASEPRI_RTQUEUES) { in sched_amp_ipi_policy()
H A Dsched_prim.c1892 assert(thread->sched_pri < BASEPRI_RTQUEUES); in thread_bind_internal()
2144 (sprocessor->current_pri < BASEPRI_RTQUEUES)) { in sched_SMT_balance()
2262 if (new_thread->sched_pri >= BASEPRI_RTQUEUES) { in pset_commit_processor_to_new_thread()
2278 if (new_thread->sched_pri >= BASEPRI_RTQUEUES) { in pset_commit_processor_to_new_thread()
2440 …ok_to_run_realtime_thread |= (thread->sched_pri >= BASEPRI_RTQUEUES && processor->first_timeslice); in thread_select()
2516 …bool needs_smt_rebalance = !is_yielding && thread->sched_pri < BASEPRI_RTQUEUES && processor->proc… in thread_select()
2543 if (thread->sched_pri >= BASEPRI_RTQUEUES && processor->first_timeslice) { in thread_select()
2644 (thread_no_smt(thread) || (thread->sched_pri >= BASEPRI_RTQUEUES)) && in thread_select()
2733 …ocessor_primary != processor) && (processor->processor_primary->current_pri >= BASEPRI_RTQUEUES)) { in thread_select()
2855 if (thread->sched_pri >= BASEPRI_RTQUEUES) { in thread_select()
[all …]
H A Dsched_dualq.c565 …if ((primary->current_pri >= BASEPRI_RTQUEUES) && ((thread->sched_pri < BASEPRI_RTQUEUES) || !sche… in sched_dualq_thread_avoid_processor()
H A Dthread_policy.c294 if (info->priority != BASEPRI_RTQUEUES) { in thread_policy_set()
423 if ((info->priority < BASEPRI_RTQUEUES) || (info->priority > MAXPRI)) { in thread_policy_set_internal()
443 thread->realtime.priority_offset = (uint8_t)(info->priority - BASEPRI_RTQUEUES); in thread_policy_set_internal()
1068 priority = BASEPRI_RTQUEUES + i; in thread_recompute_priority()
1087 work_interval_get_priority(thread) < BASEPRI_RTQUEUES) { in thread_recompute_priority()
1364 info->priority = thread->realtime.priority_offset + BASEPRI_RTQUEUES; in thread_policy_get()
1380 info->priority = BASEPRI_RTQUEUES; in thread_policy_get()
2184 assert3u(pri, >=, BASEPRI_RTQUEUES); in thread_set_requested_policy_spinlocked()
2186 (uint8_t)(pri - BASEPRI_RTQUEUES) : 0; in thread_set_requested_policy_spinlocked()
H A Dsched.h143 #define BASEPRI_RTQUEUES (BASEPRI_REALTIME + 1) /* 97 */ macro
H A Dpriority.c291 assert((priority >= BASEPRI_RTQUEUES) && (priority <= MAXPRI)); in sched_set_thread_base_priority()
293 assert(priority < BASEPRI_RTQUEUES); in sched_set_thread_base_priority()
H A Dsched_clutch.c3381 if (prev_thread->sched_pri >= BASEPRI_RTQUEUES) { in sched_clutch_processor_highest_thread()
5400 sched_clutch_edge edge = (thread->sched_pri >= BASEPRI_RTQUEUES) in sched_edge_thread_avoid_processor()
5419 edge = (thread->sched_pri >= BASEPRI_RTQUEUES) in sched_edge_thread_avoid_processor()
5441 if (thread->sched_pri >= BASEPRI_RTQUEUES) { in sched_edge_thread_avoid_processor()
5779 if (thread->sched_pri >= BASEPRI_RTQUEUES) { in sched_edge_migrate_candidate()
6219 if (thread->sched_pri >= BASEPRI_RTQUEUES) { in sched_edge_thread_eligible_for_pset()
6256 if (thread && thread->sched_pri < BASEPRI_RTQUEUES) { in sched_edge_ipi_policy()
H A Dwork_interval.c696 BASEPRI_RTQUEUES + 1, // 98
H A Dprocessor.c522 boolean_t non_rt_thr = (processor->current_pri < BASEPRI_RTQUEUES); in processor_state_update_running_foreign()
H A Dtimer_call.c1868 bool timer_critical = (tpri >= BASEPRI_RTQUEUES) || in timer_compute_leeway()
/xnu-12377.81.4/tests/sched/sched_test_harness/
H A Dsched_clutch_harness_impl.c281 return ((thread_t)thread)->sched_pri >= BASEPRI_RTQUEUES; in impl_get_thread_is_realtime()
298 if (((thread_t) thread)->sched_pri >= BASEPRI_RTQUEUES) { in clutch_impl_cpu_set_thread_current()
H A Dsched_edge_harness.c245 if (((thread_t) thread)->sched_pri >= BASEPRI_RTQUEUES) { in impl_cpu_enqueue_thread()
/xnu-12377.81.4/tests/sched/sched_test_harness/shadow_headers/
H A Dsched_prim.c332 if (thread->sched_pri >= BASEPRI_RTQUEUES) { in choose_processor()