Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
156 changes: 147 additions & 9 deletions kernel/sched/fair.c
Original file line number Diff line number Diff line change
Expand Up @@ -7805,6 +7805,54 @@ static int select_idle_cpu(struct task_struct *p, struct sched_domain *sd, bool
return idle_cpu;
}

/*
* Idle-capacity scan converts util_fits_cpu() outcomes into preference ranks,
* where lower values indicate a better fit - see select_idle_capacity().
*
* A CPU that both fits the task and sits on a fully-idle SMT core is returned
* immediately and is never assigned one of these ranks. On !SMT every CPU is
* its own "core", so the early return covers all fits-and-idle cases and the
* core-tier ranks below become unreachable.
*
* Rank Val Tier Meaning
* ------------------------------ --- ------ ---------------------------
* ASYM_IDLE_UCLAMP_MISFIT -4 core Idle core; capacity fits
* util but uclamp_min misses.
* ASYM_IDLE_COMPLETE_MISFIT -3 core Idle core; capacity does
* not fit. Still beats every
* thread-tier rank: a busy
* sibling cuts effective
* capacity more than a
* misfit hurts a quiet core.
* ASYM_IDLE_THREAD_FITS -2 thread Busy SMT sibling; capacity
* fits util + uclamp.
* ASYM_IDLE_THREAD_UCLAMP_MISFIT -1 thread Busy SMT sibling; capacity
* fits but uclamp_min misses
* (native util_fits_cpu()
* return value).
* ASYM_IDLE_THREAD_MISFIT 0 thread Busy SMT sibling; capacity
* does not fit.
*
* ASYM_IDLE_CORE_BIAS (-3) is an offset, not a state. On an idle core,
* fits += ASYM_IDLE_CORE_BIAS rebases thread-tier ranks into the core tier:
*
* ASYM_IDLE_THREAD_UCLAMP_MISFIT (-1) + BIAS -> ASYM_IDLE_UCLAMP_MISFIT (-4)
* ASYM_IDLE_THREAD_MISFIT (0) + BIAS -> ASYM_IDLE_COMPLETE_MISFIT (-3)
*
* ASYM_IDLE_THREAD_FITS (-2) is never rebased because a fully-fitting idle-core
* candidate early-returns from select_idle_capacity().
*/
enum asym_fits_state {
ASYM_IDLE_UCLAMP_MISFIT = -4,
ASYM_IDLE_COMPLETE_MISFIT,
ASYM_IDLE_THREAD_FITS,
ASYM_IDLE_THREAD_UCLAMP_MISFIT,
ASYM_IDLE_THREAD_MISFIT,

/* util_fits_cpu() bias for idle core */
ASYM_IDLE_CORE_BIAS = -3,
};

/*
* Scan the asym_capacity domain for idle CPUs; pick the first idle one on which
* the task fits. If no CPU is big enough, but there are idle ones, try to
Expand All @@ -7813,10 +7861,17 @@ static int select_idle_cpu(struct task_struct *p, struct sched_domain *sd, bool
static int
select_idle_capacity(struct task_struct *p, struct sched_domain *sd, int target)
{
/*
* On !SMT systems, has_idle_core is always false and preferred_core
* is always true (CPU == core), so the SMT preference logic below
* collapses to the plain capacity scan.
*/
bool has_idle_core = sched_smt_active() && test_idle_cores(target);
unsigned long task_util, util_min, util_max, best_cap = 0;
int fits, best_fits = 0;
int fits, best_fits = ASYM_IDLE_THREAD_MISFIT;
int cpu, best_cpu = -1;
struct cpumask *cpus;
int nr = INT_MAX;

cpus = this_cpu_cpumask_var_ptr(select_rq_mask);
cpumask_and(cpus, sched_domain_span(sd), p->cpus_ptr);
Expand All @@ -7825,26 +7880,75 @@ select_idle_capacity(struct task_struct *p, struct sched_domain *sd, int target)
util_min = uclamp_eff_value(p, UCLAMP_MIN);
util_max = uclamp_eff_value(p, UCLAMP_MAX);

if (sched_feat(SIS_UTIL) && sd->shared) {
/*
* Same nr_idle_scan hint as select_idle_cpu(), nr only limits
* the scan when not preferring an idle core.
*/
nr = READ_ONCE(sd->shared->nr_idle_scan) + 1;
/* overloaded domain is unlikely to have idle cpu/core */
if (nr == 1)
return -1;
}

for_each_cpu_wrap(cpu, cpus, target) {
bool preferred_core = !has_idle_core || is_core_idle(cpu);
unsigned long cpu_cap = capacity_of(cpu);

/*
* Stop when the nr_idle_scan is exhausted (mirrors
* select_idle_cpu() logic).
*/
if (!has_idle_core && --nr <= 0)
return best_cpu;

if (!available_idle_cpu(cpu) && !sched_idle_cpu(cpu))
continue;

fits = util_fits_cpu(task_util, util_min, util_max, cpu);

/* This CPU fits with all requirements */
if (fits > 0)
/*
* Perfect fit: capacity satisfies util + uclamp and the CPU
* sits on a fully-idle SMT core, this is a !SMT system, or
* there is no idle core to find.
* Short-circuit the rank-based selection and return
* immediately.
*/
if (fits > 0 && preferred_core)
return cpu;
/*
* Only the min performance hint (i.e. uclamp_min) doesn't fit.
* Look for the CPU with best capacity.
*/
else if (fits < 0)
cpu_cap = get_actual_cpu_capacity(cpu);
/*
* fits > 0 implies we are not on a preferred core, but the util
* fits CPU capacity. Set fits to ASYM_IDLE_THREAD_FITS
* so the effective range becomes
* [ASYM_IDLE_THREAD_FITS, ASYM_IDLE_THREAD_MISFIT], where:
* ASYM_IDLE_THREAD_MISFIT - does not fit
* ASYM_IDLE_THREAD_UCLAMP_MISFIT - fits with the exception of UCLAMP_MIN
* ASYM_IDLE_THREAD_FITS - fits with the exception of preferred_core
*/
else if (fits > 0)
fits = ASYM_IDLE_THREAD_FITS;

/*
* First, select CPU which fits better (-1 being better than 0).
* If we are on a preferred core, translate the range of fits
* of [ASYM_IDLE_THREAD_UCLAMP_MISFIT, ASYM_IDLE_THREAD_MISFIT] to
* [ASYM_IDLE_UCLAMP_MISFIT, ASYM_IDLE_COMPLETE_MISFIT].
* This ensures that an idle core is always given priority over
* (partially) busy core.
*
* A fully fitting idle core would have returned early and hence
* fits > 0 for preferred_core need not be dealt with.
*/
if (preferred_core)
fits += ASYM_IDLE_CORE_BIAS;

/*
* First, select CPU which fits better (lower is more preferred).
* Then, select the one with best capacity at same level.
*/
if ((fits < best_fits) ||
Expand All @@ -7855,6 +7959,19 @@ select_idle_capacity(struct task_struct *p, struct sched_domain *sd, int target)
}
}

/*
* A value in the [ASYM_IDLE_UCLAMP_MISFIT, ASYM_IDLE_COMPLETE_MISFIT]
* range means the chosen CPU is in a fully idle SMT core. Values above
* ASYM_IDLE_COMPLETE_MISFIT mean we never ranked such a CPU best.
*
* The asym-capacity wakeup path returns from select_idle_sibling()
* after this function and never runs select_idle_cpu(), so the usual
* select_idle_cpu() tail that clears idle cores must live here when the
* idle-core preference did not win.
*/
if (has_idle_core && best_fits > ASYM_IDLE_COMPLETE_MISFIT)
set_idle_cores(target, false);

return best_cpu;
}

Expand All @@ -7863,12 +7980,22 @@ static inline bool asym_fits_cpu(unsigned long util,
unsigned long util_max,
int cpu)
{
if (sched_asym_cpucap_active())
if (sched_asym_cpucap_active()) {
/*
* Return true only if the cpu fully fits the task requirements
* which include the utilization and the performance hints.
*
* When SMT is active, also require that the core has no busy
* siblings.
*
* Note: gating on is_core_idle() also makes the early-bailout
* candidates in select_idle_sibling() (target, prev,
* recent_used_cpu) idle-core-aware on ASYM+SMT, which the
* NO_ASYM path does not do.
*/
return (util_fits_cpu(util, util_min, util_max, cpu) > 0);
return (!sched_smt_active() || is_core_idle(cpu)) &&
(util_fits_cpu(util, util_min, util_max, cpu) > 0);
}

return true;
}
Expand Down Expand Up @@ -9388,6 +9515,7 @@ struct lb_env {

int dst_cpu;
struct rq *dst_rq;
bool dst_core_idle;

struct cpumask *dst_grpmask;
int new_dst_cpu;
Expand Down Expand Up @@ -10629,10 +10757,16 @@ static bool update_sd_pick_busiest(struct lb_env *env,
* We can use max_capacity here as reduction in capacity on some
* CPUs in the group should either be possible to resolve
* internally or be covered by avg_load imbalance (eventually).
*
* When SMT is active, only pull a misfit to dst_cpu if it is on a
* fully idle core; otherwise the effective capacity of the core is
* reduced and we may not actually provide more capacity than the
* source.
*/
if ((env->sd->flags & SD_ASYM_CPUCAPACITY) &&
(sgs->group_type == group_misfit_task) &&
(!capacity_greater(capacity_of(env->dst_cpu), sg->sgc->max_capacity) ||
(!env->dst_core_idle ||
!capacity_greater(capacity_of(env->dst_cpu), sg->sgc->max_capacity) ||
sds->local_stat.group_type != group_has_spare))
return false;

Expand Down Expand Up @@ -11199,6 +11333,8 @@ static inline void update_sd_lb_stats(struct lb_env *env, struct sd_lb_stats *sd
unsigned long sum_util = 0;
bool sg_overloaded = 0, sg_overutilized = 0;

env->dst_core_idle = !sched_smt_active() || is_core_idle(env->dst_cpu);

do {
struct sg_lb_stats *sgs = &tmp_sgs;
int local_group;
Expand Down Expand Up @@ -12663,7 +12799,8 @@ static void set_cpu_sd_state_busy(int cpu)
goto unlock;
sd->nohz_idle = 0;

atomic_inc(&sd->shared->nr_busy_cpus);
if (sd->shared)
atomic_inc(&sd->shared->nr_busy_cpus);
unlock:
rcu_read_unlock();
}
Expand Down Expand Up @@ -12693,7 +12830,8 @@ static void set_cpu_sd_state_idle(int cpu)
goto unlock;
sd->nohz_idle = 1;

atomic_dec(&sd->shared->nr_busy_cpus);
if (sd->shared)
atomic_dec(&sd->shared->nr_busy_cpus);
unlock:
rcu_read_unlock();
}
Expand Down
Loading