Home
last modified time | relevance | path

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

/xnu-12377.41.6/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.41.6/osfmk/kern/
H A Dsched_rt.c184 for (int pri = BASEPRI_RTQUEUES; pri <= MAXPRI; pri++) { in pset_rt_init()
185 int i = pri - BASEPRI_RTQUEUES; in pset_rt_init()
438 assert3u(thread->sched_pri, >=, BASEPRI_RTQUEUES); in sched_rt_choose_processor()
1212 for (int pri = BASEPRI_RTQUEUES; pri <= MAXPRI; pri++) { in check_rt_runq_consistency()
1213 int i = pri - BASEPRI_RTQUEUES; in check_rt_runq_consistency()
1225 assert(iter_thread->sched_pri == (i + BASEPRI_RTQUEUES)); in check_rt_runq_consistency()
1265 assert((pri >= BASEPRI_RTQUEUES) && (pri <= MAXPRI)); in rt_runq_enqueue()
1266 int i = pri - BASEPRI_RTQUEUES; in rt_runq_enqueue()
1308 os_atomic_store(&rt_run_queue->ed_index, pri - BASEPRI_RTQUEUES, relaxed); in rt_runq_enqueue()
1361 return i + BASEPRI_RTQUEUES; in rt_runq_priority()
[all …]
H A Dsched_amp_common.c242 if (thread->sched_pri >= BASEPRI_RTQUEUES) { in should_spill_to_ecores()
336 if ((eprocessor->current_pri < BASEPRI_RTQUEUES) && in sched_amp_balance()
428 if (thread && thread->sched_pri < BASEPRI_RTQUEUES) { in sched_amp_ipi_policy()
H A Dsched_prim.c1862 assert(thread->sched_pri < BASEPRI_RTQUEUES); in thread_bind_internal()
2114 (sprocessor->current_pri < BASEPRI_RTQUEUES)) { in sched_SMT_balance()
2232 if (new_thread->sched_pri >= BASEPRI_RTQUEUES) { in pset_commit_processor_to_new_thread()
2248 if (new_thread->sched_pri >= BASEPRI_RTQUEUES) { in pset_commit_processor_to_new_thread()
2410 …ok_to_run_realtime_thread |= (thread->sched_pri >= BASEPRI_RTQUEUES && processor->first_timeslice); in thread_select()
2486 …bool needs_smt_rebalance = !is_yielding && thread->sched_pri < BASEPRI_RTQUEUES && processor->proc… in thread_select()
2513 if (thread->sched_pri >= BASEPRI_RTQUEUES && processor->first_timeslice) { in thread_select()
2614 (thread_no_smt(thread) || (thread->sched_pri >= BASEPRI_RTQUEUES)) && in thread_select()
2703 …ocessor_primary != processor) && (processor->processor_primary->current_pri >= BASEPRI_RTQUEUES)) { in thread_select()
2825 if (thread->sched_pri >= BASEPRI_RTQUEUES) { in thread_select()
[all …]
H A Dsched_dualq.c580 …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.c3358 if (prev_thread->sched_pri >= BASEPRI_RTQUEUES) { in sched_clutch_processor_highest_thread()
5034 sched_clutch_edge edge = (thread->sched_pri >= BASEPRI_RTQUEUES) in sched_edge_thread_avoid_processor()
5053 edge = (thread->sched_pri >= BASEPRI_RTQUEUES) in sched_edge_thread_avoid_processor()
5075 if (thread->sched_pri >= BASEPRI_RTQUEUES) { in sched_edge_thread_avoid_processor()
5413 if (thread->sched_pri >= BASEPRI_RTQUEUES) { in sched_edge_migrate_candidate()
5904 if (thread->sched_pri >= BASEPRI_RTQUEUES) { in sched_edge_thread_eligible_for_pset()
5941 if (thread && thread->sched_pri < BASEPRI_RTQUEUES) { in sched_edge_ipi_policy()
H A Dwork_interval.c696 BASEPRI_RTQUEUES + 1, // 98
H A Dprocessor.c486 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.41.6/tests/sched/sched_test_harness/
H A Dsched_clutch_harness_impl.c270 return ((thread_t)thread)->sched_pri >= BASEPRI_RTQUEUES; in impl_get_thread_is_realtime()
289 if (((thread_t) thread)->sched_pri >= BASEPRI_RTQUEUES) { in clutch_impl_cpu_set_thread_current()
H A Dsched_edge_harness.c255 boolean_t non_rt_thr = (processor->current_pri < BASEPRI_RTQUEUES); in processor_state_update_running_foreign()
305 if (((thread_t) thread)->sched_pri >= BASEPRI_RTQUEUES) { in impl_cpu_enqueue_thread()
/xnu-12377.41.6/tests/sched/sched_test_harness/shadow_headers/
H A Dsched_prim.c370 if (thread->sched_pri >= BASEPRI_RTQUEUES) { in choose_processor()