[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-ID: <2aa7380b-bebd-4bb9-8597-49e06d1dcc6d@os.amperecomputing.com>
Date: Thu, 30 Oct 2025 15:22:34 +0800
From: Adam Li <adamli@...amperecomputing.com>
To: Peter Zijlstra <peterz@...radead.org>,
 Joseph Salisbury <joseph.salisbury@...cle.com>
Cc: Chris Mason <clm@...a.com>, clm@...com,
 Vincent Guittot <vincent.guittot@...aro.org>,
 Juri Lelli <juri.lelli@...hat.com>, Ingo Molnar <mingo@...hat.com>,
 dietmar.eggemann@....com, Steven Rostedt <rostedt@...dmis.org>,
 bsegall@...gle.com, mgorman@...e.de, vschneid@...hat.com,
 LKML <linux-kernel@...r.kernel.org>
Subject: Re: [External] : Re: [REGRESSION][v6.17-rc1]sched/fair: Bump
 sd->max_newidle_lb_cost when newidle balance fails
Hi Peter,
I tested your patch on AmpereOne arm64 server with SpecJBB benchmark.
Please see details bellow:
On 10/11/2025 1:09 AM, Peter Zijlstra wrote:
> On Thu, Oct 09, 2025 at 09:04:40PM -0400, Joseph Salisbury wrote:
> 
>> I ran some Phoronix tests (phoronix-test-suite benchmark apache) while
>> collecting drgn data.  I attached two files:
>>
>> *apache_drgn_log_WITH-155213a2aed4.HAS_REGRESSION.txt*
>> and
>> *apache_drgn_log_WITHOUT-155213a2aed4.BASELINE.txt*
>>
>> As the names imply, the first files 'WITH-155213a2aed4' has commit
>> 155213a2aed4 applied and experiences a performance regression.  The other
>> file, does not have the commit applied and is the baseline.
> 
> That's quite a clear difference there. The one WITH is more or less
> stuck at 5e5 while the one WITHOUT seems to hoover around 3e4.
> 
> So yeah, too aggressive for that workload. 
> 
> Ooh, Chris, note how you clip after checking for being larger. This
> means that you're constantly pushing the last_max value forward,
> impeding decay. '(3*max)/2 > max' is 'true' and all that.
> 
> Anyway, I've been playing around with various schemes today, see patch
> below. NI_TARGET is basically a revert of the patch in question +- decay
> speed.
> 
> For schbench -- the only benchmark I've tried so far, I get roughly
> similar performance using TARGET+RUNNABLE+RANDOM.
> 
> Feel free to play around with the settings or invent more options ;-)
> 
Commit 155213a2aed4 brings ~6% regression for SpecJBB critical-jOPS on
AmpereOne server. 
Baseline: v6.17 kernel + patch. Compared with baseline:
NI_TARGET	+7%
NI_SPARE	-3%
NI_RUNNABLE	-4%
NI_RANDOM	-3%
So NI_TARGET reverts the performance regression.
The other options brings more regression for SpecJBB.
> ---
> 
> diff --git a/include/linux/sched/topology.h b/include/linux/sched/topology.h
> index 5263746b63e8..f984f5972b76 100644
> --- a/include/linux/sched/topology.h
> +++ b/include/linux/sched/topology.h
> @@ -77,6 +77,7 @@ struct sched_domain_shared {
>  	atomic_t	nr_busy_cpus;
>  	int		has_idle_cores;
>  	int		nr_idle_scan;
> +	int		has_spare_tasks;
>  };
>  
>  struct sched_domain {
> @@ -101,7 +102,11 @@ struct sched_domain {
>  	unsigned int nr_balance_failed; /* initialise to 0 */
>  
>  	/* idle_balance() stats */
> +	unsigned int newidle_call;
> +	unsigned int newidle_success;
> +	unsigned int newidle_ratio;
>  	u64 max_newidle_lb_cost;
> +	u64 max_newidle_lb_target;
>  	unsigned long last_decay_max_lb_cost;
>  
>  #ifdef CONFIG_SCHEDSTATS
> diff --git a/kernel/sched/core.c b/kernel/sched/core.c
> index ccba6fc3c3fe..a80601481472 100644
> --- a/kernel/sched/core.c
> +++ b/kernel/sched/core.c
> @@ -119,6 +119,7 @@ EXPORT_TRACEPOINT_SYMBOL_GPL(sched_update_nr_running_tp);
>  EXPORT_TRACEPOINT_SYMBOL_GPL(sched_compute_energy_tp);
>  
>  DEFINE_PER_CPU_SHARED_ALIGNED(struct rq, runqueues);
> +DEFINE_PER_CPU(struct rnd_state, sched_rnd_state);
>  
>  #ifdef CONFIG_SCHED_PROXY_EXEC
>  DEFINE_STATIC_KEY_TRUE(__sched_proxy_exec);
> @@ -8621,6 +8622,8 @@ void __init sched_init_smp(void)
>  {
>  	sched_init_numa(NUMA_NO_NODE);
>  
> +	prandom_init_once(&sched_rnd_state);
> +
>  	/*
>  	 * There's no userspace yet to cause hotplug operations; hence all the
>  	 * CPU masks are stable and all blatant races in the below code cannot
> diff --git a/kernel/sched/fair.c b/kernel/sched/fair.c
> index 8ce56a8d507f..10378135368e 100644
> --- a/kernel/sched/fair.c
> +++ b/kernel/sched/fair.c
> @@ -10255,7 +10255,6 @@ static inline void update_sg_lb_stats(struct lb_env *env,
>  				      bool *sg_overutilized)
>  {
>  	int i, nr_running, local_group, sd_flags = env->sd->flags;
> -	bool balancing_at_rd = !env->sd->parent;
>  
>  	memset(sgs, 0, sizeof(*sgs));
>  
> @@ -10285,8 +10284,7 @@ static inline void update_sg_lb_stats(struct lb_env *env,
>  			continue;
>  		}
>  
> -		/* Overload indicator is only updated at root domain */
> -		if (balancing_at_rd && nr_running > 1)
> +		if (nr_running > 1)
>  			*sg_overloaded = 1;
>  
>  #ifdef CONFIG_NUMA_BALANCING
> @@ -10969,7 +10967,6 @@ static inline void update_sd_lb_stats(struct lb_env *env, struct sd_lb_stats *sd
>  	if (sds->busiest)
>  		sds->prefer_sibling = !!(sds->busiest->flags & SD_PREFER_SIBLING);
>  
> -
>  	if (env->sd->flags & SD_NUMA)
>  		env->fbq_type = fbq_classify_group(&sds->busiest_stat);
>  
> @@ -10983,6 +10980,9 @@ static inline void update_sd_lb_stats(struct lb_env *env, struct sd_lb_stats *sd
>  		set_rd_overutilized(env->dst_rq->rd, sg_overutilized);
>  	}
>  
> +	if (env->sd->shared)
> +		env->sd->shared->has_spare_tasks = sg_overloaded;
> +
>  	update_idle_cpu_scan(env, sum_util);
>  }
>  
> @@ -12055,29 +12055,82 @@ void update_max_interval(void)
>  	max_load_balance_interval = HZ*num_online_cpus()/10;
>  }
>  
> -static inline bool update_newidle_cost(struct sched_domain *sd, u64 cost)
> +static inline void update_newidle_stats(struct sched_domain *sd, unsigned int success)
>  {
> -	if (cost > sd->max_newidle_lb_cost) {
> +	sd->newidle_call++;
> +	sd->newidle_success += success;
> +
> +	if (sd->newidle_call >= 1024) {
> +		sd->newidle_ratio = sd->newidle_success;
> +		sd->newidle_call /= 2;
> +		sd->newidle_success /= 2;
> +	}
> +}
> +
> +static inline bool
> +update_newidle_cost(struct rq *rq, struct sched_domain *sd, u64 cost, unsigned int success)
> +{
> +	unsigned long last_decay = sd->last_decay_max_lb_cost + HZ/10;
> +	unsigned long now = jiffies;
> +	u64 target = cost;
> +
> +	update_newidle_stats(sd, success);
> +
> +	/*
> +	 * Failing newidle means it is not effective;
> +	 * bump the cost so we end up doing less of it.
> +	 */
> +	if (!success) {
> +		cost = (3 * sd->max_newidle_lb_cost) / 2; /* + 50% */
>  		/*
> -		 * Track max cost of a domain to make sure to not delay the
> -		 * next wakeup on the CPU.
> -		 *
> -		 * sched_balance_newidle() bumps the cost whenever newidle
> -		 * balance fails, and we don't want things to grow out of
> -		 * control.  Use the sysctl_sched_migration_cost as the upper
> -		 * limit, plus a litle extra to avoid off by ones.
> +		 * We don't want things to grow out of control.  Use the
> +		 * sysctl_sched_migration_cost as the upper limit, plus a
> +		 * litle extra to avoid off by ones.
>  		 */
> -		sd->max_newidle_lb_cost =
> -			min(cost, sysctl_sched_migration_cost + 200);
> -		sd->last_decay_max_lb_cost = jiffies;
> -	} else if (time_after(jiffies, sd->last_decay_max_lb_cost + HZ)) {
> +		cost = min(cost, sysctl_sched_migration_cost + 200);
> +	}
> +
> +	if (cost > sd->max_newidle_lb_cost) {
> +		sd->max_newidle_lb_cost = cost;
> +		sd->last_decay_max_lb_cost = now;
> +	}
> +
> +	if (target > sd->max_newidle_lb_target) {
> +		sd->max_newidle_lb_target = target;
> +		sd->last_decay_max_lb_cost = now;
> +	}
> +
> +	if (time_after(now, last_decay)) {
> +		s64 diff, max_cost;
> +
> +		trace_printk("CPU-%d %s runnable: %ld target: %Ld cost: %Ld has_spare: %d call: %u success: %u\n",
> +			     rq->cpu, sd->name,
> +			     cpu_runnable(rq),
> +			     sd->max_newidle_lb_target,
> +			     sd->max_newidle_lb_cost,
> +			     sd->shared ? sd->shared->has_spare_tasks : -1,
> +			     sd->newidle_call, sd->newidle_success);
> +
>  		/*
> -		 * Decay the newidle max times by ~1% per second to ensure that
> +		 * Decay the newidle max times by ~1% per 10ms to ensure that
>  		 * it is not outdated and the current max cost is actually
>  		 * shorter.
>  		 */
> -		sd->max_newidle_lb_cost = (sd->max_newidle_lb_cost * 253) / 256;
> -		sd->last_decay_max_lb_cost = jiffies;
> +		sd->max_newidle_lb_target = (sd->max_newidle_lb_target * 253) / 256;
> +
> +		/*
> +		 * Decay the newidle max cost 25% towards the target -- the
> +		 * value it would have been but for the failure boosts above.
> +		 */
> +		max_cost = sd->max_newidle_lb_cost;
> +		diff = sd->max_newidle_lb_target - max_cost;
> +		diff /= 4;
> +		max_cost += diff;
> +		if (max_cost < 0)
> +			max_cost = 0;
> +		sd->max_newidle_lb_cost = max_cost;
> +
> +		sd->last_decay_max_lb_cost = now;
>  
>  		return true;
>  	}
> @@ -12110,7 +12163,7 @@ static void sched_balance_domains(struct rq *rq, enum cpu_idle_type idle)
>  		 * Decay the newidle max times here because this is a regular
>  		 * visit to all the domains.
>  		 */
> -		need_decay = update_newidle_cost(sd, 0);
> +		need_decay = update_newidle_cost(rq, sd, 0, false);
>  		max_cost += sd->max_newidle_lb_cost;
>  
>  		/*
> @@ -12726,12 +12779,20 @@ static int sched_balance_newidle(struct rq *this_rq, struct rq_flags *rf)
>  
>  	rcu_read_lock();
>  	sd = rcu_dereference_check_sched_domain(this_rq->sd);
> +	if (!sd) {
> +		rcu_read_unlock();
> +		goto out;
> +	}
> +
> +	u64 newidle_cost = sd->max_newidle_lb_cost;
> +
> +	if (sched_feat(NI_TARGET))
> +		newidle_cost = sd->max_newidle_lb_target;
>  
>  	if (!get_rd_overloaded(this_rq->rd) ||
> -	    (sd && this_rq->avg_idle < sd->max_newidle_lb_cost)) {
> +	    this_rq->avg_idle < newidle_cost) {
>  
> -		if (sd)
> -			update_next_balance(sd, &next_balance);
> +		update_next_balance(sd, &next_balance);
>  		rcu_read_unlock();
>  
>  		goto out;
> @@ -12749,10 +12810,46 @@ static int sched_balance_newidle(struct rq *this_rq, struct rq_flags *rf)
>  
>  		update_next_balance(sd, &next_balance);
>  
> -		if (this_rq->avg_idle < curr_cost + sd->max_newidle_lb_cost)
> +		if (this_rq->avg_idle < curr_cost + newidle_cost)
>  			break;
>  
>  		if (sd->flags & SD_BALANCE_NEWIDLE) {
> +			unsigned int weight = 1;
> +			bool success;
> +
> +			if (sched_feat(NI_SPARE)) {
> +				/*
> +				 * If there are no spare tasks to be found in
> +				 * this domain, then searching for them is
> +				 * pointless.
> +				 */
> +				if (sd->shared && !sd->shared->has_spare_tasks)
> +					continue;
> +			}
> +
> +			if (sched_feat(NI_RUNNABLE)) {
> +				/*
> +				 * If we are over 99% runnable, maybe we don't
> +				 * need more tasks?
> +				 */
> +				if (cpu_runnable(this_rq) > 1014)
> +					continue;
> +			}
> +
> +			if (sched_feat(NI_RANDOM)) {
> +				/*
> +				 * Throw a 1k sided dice; and only run
> +				 * newidle_balance according to the success
> +				 * rate.
> +				 */
> +				u32 d1k = sched_rng() % 1024;
> +				weight = 1 + sd->newidle_ratio;
> +				if (d1k > weight) {
> +					update_newidle_stats(sd, 0);
> +					continue;
> +				}
> +				weight = (1024 + weight/2) / weight;
> +			}
>  
>  			pulled_task = sched_balance_rq(this_cpu, this_rq,
>  						   sd, CPU_NEWLY_IDLE,
> @@ -12763,14 +12860,13 @@ static int sched_balance_newidle(struct rq *this_rq, struct rq_flags *rf)
>  			curr_cost += domain_cost;
>  			t0 = t1;
>  
> +			success = !!pulled_task;
> +
>  			/*
> -			 * Failing newidle means it is not effective;
> -			 * bump the cost so we end up doing less of it.
> +			 * Track max cost of a domain to make sure to not delay the
> +			 * next wakeup on the CPU.
>  			 */
> -			if (!pulled_task)
> -				domain_cost = (3 * sd->max_newidle_lb_cost) / 2;
> -
> -			update_newidle_cost(sd, domain_cost);
> +			update_newidle_cost(this_rq, sd, domain_cost, weight * success);
>  		}
>  
>  		/*
> diff --git a/kernel/sched/features.h b/kernel/sched/features.h
> index 3c12d9f93331..5ded210701d0 100644
> --- a/kernel/sched/features.h
> +++ b/kernel/sched/features.h
> @@ -121,3 +121,8 @@ SCHED_FEAT(WA_BIAS, true)
>  SCHED_FEAT(UTIL_EST, true)
>  
>  SCHED_FEAT(LATENCY_WARN, false)
> +
> +SCHED_FEAT(NI_TARGET, false)
> +SCHED_FEAT(NI_SPARE, false)
> +SCHED_FEAT(NI_RUNNABLE, false)
> +SCHED_FEAT(NI_RANDOM, false)
> diff --git a/kernel/sched/sched.h b/kernel/sched/sched.h
> index cf2109b67f9a..d269eb864583 100644
> --- a/kernel/sched/sched.h
> +++ b/kernel/sched/sched.h
> @@ -5,6 +5,7 @@
>  #ifndef _KERNEL_SCHED_SCHED_H
>  #define _KERNEL_SCHED_SCHED_H
>  
> +#include <linux/prandom.h>
>  #include <linux/sched/affinity.h>
>  #include <linux/sched/autogroup.h>
>  #include <linux/sched/cpufreq.h>
> @@ -1346,6 +1347,12 @@ static inline bool is_migration_disabled(struct task_struct *p)
>  }
>  
>  DECLARE_PER_CPU_SHARED_ALIGNED(struct rq, runqueues);
> +DECLARE_PER_CPU(struct rnd_state, sched_rnd_state);
> +
> +static inline u32 sched_rng(void)
> +{
> +	return prandom_u32_state(this_cpu_ptr(&sched_rnd_state));
> +}
>  
>  #define cpu_rq(cpu)		(&per_cpu(runqueues, (cpu)))
>  #define this_rq()		this_cpu_ptr(&runqueues)
> diff --git a/kernel/sched/topology.c b/kernel/sched/topology.c
> index 6e2f54169e66..2e2d4b5fd5e9 100644
> --- a/kernel/sched/topology.c
> +++ b/kernel/sched/topology.c
> @@ -1670,6 +1670,12 @@ sd_init(struct sched_domain_topology_level *tl,
>  
>  		.last_balance		= jiffies,
>  		.balance_interval	= sd_weight,
> +
> +		/* 50% success rate */
> +		.newidle_call		= 512,
> +		.newidle_success	= 256,
> +		.newidle_ratio		= 512,
> +
>  		.max_newidle_lb_cost	= 0,
>  		.last_decay_max_lb_cost	= jiffies,
>  		.child			= child,
> 
Thanks,
-adam
Powered by blists - more mailing lists
 
