[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-Id: <20231115113341.13261-2-CruzZhao@linux.alibaba.com>
Date: Wed, 15 Nov 2023 19:33:38 +0800
From: Cruz Zhao <CruzZhao@...ux.alibaba.com>
To: mingo@...hat.com, peterz@...radead.org, juri.lelli@...hat.com,
vincent.guittot@...aro.org, dietmar.eggemann@....com,
rostedt@...dmis.org, bsegall@...gle.com, mgorman@...e.de,
bristot@...hat.com, vschneid@...hat.com, joel@...lfernandes.org
Cc: linux-kernel@...r.kernel.org
Subject: [PATCH 1/4] sched/core: introduce core_id to struct rq
Introduce core_id to struct rq, indates the cpu id of the core, which
is used for getting cpu id of rq->core quickly.
Signed-off-by: Cruz Zhao <CruzZhao@...ux.alibaba.com>
---
kernel/sched/core.c | 16 ++++++++++++----
kernel/sched/sched.h | 1 +
2 files changed, 13 insertions(+), 4 deletions(-)
diff --git a/kernel/sched/core.c b/kernel/sched/core.c
index a708d225c28e..7a685fae73c4 100644
--- a/kernel/sched/core.c
+++ b/kernel/sched/core.c
@@ -6400,7 +6400,7 @@ static void sched_core_cpu_starting(unsigned int cpu)
{
const struct cpumask *smt_mask = cpu_smt_mask(cpu);
struct rq *rq = cpu_rq(cpu), *core_rq = NULL;
- int t;
+ int t, core_id;
guard(core_lock)(&cpu);
@@ -6417,6 +6417,7 @@ static void sched_core_cpu_starting(unsigned int cpu)
rq = cpu_rq(t);
if (rq->core == rq) {
core_rq = rq;
+ core_id = t;
break;
}
}
@@ -6428,8 +6429,10 @@ static void sched_core_cpu_starting(unsigned int cpu)
for_each_cpu(t, smt_mask) {
rq = cpu_rq(t);
- if (t == cpu)
+ if (t == cpu) {
rq->core = core_rq;
+ rq->core_id = core_id;
+ }
WARN_ON_ONCE(rq->core != core_rq);
}
@@ -6439,7 +6442,7 @@ static void sched_core_cpu_deactivate(unsigned int cpu)
{
const struct cpumask *smt_mask = cpu_smt_mask(cpu);
struct rq *rq = cpu_rq(cpu), *core_rq = NULL;
- int t;
+ int t, core_id;
guard(core_lock)(&cpu);
@@ -6458,6 +6461,7 @@ static void sched_core_cpu_deactivate(unsigned int cpu)
if (t == cpu)
continue;
core_rq = cpu_rq(t);
+ core_id = t;
break;
}
@@ -6483,6 +6487,7 @@ static void sched_core_cpu_deactivate(unsigned int cpu)
for_each_cpu(t, smt_mask) {
rq = cpu_rq(t);
rq->core = core_rq;
+ rq->core_id = core_id;
}
}
@@ -6490,8 +6495,10 @@ static inline void sched_core_cpu_dying(unsigned int cpu)
{
struct rq *rq = cpu_rq(cpu);
- if (rq->core != rq)
+ if (rq->core != rq) {
rq->core = rq;
+ rq->core_id = cpu;
+ }
}
#else /* !CONFIG_SCHED_CORE */
@@ -10008,6 +10015,7 @@ void __init sched_init(void)
#ifdef CONFIG_SCHED_CORE
rq->core = rq;
+ rq->core_id = i;
rq->core_pick = NULL;
rq->core_enabled = 0;
rq->core_tree = RB_ROOT;
diff --git a/kernel/sched/sched.h b/kernel/sched/sched.h
index 2e5a95486a42..1b62165fc840 100644
--- a/kernel/sched/sched.h
+++ b/kernel/sched/sched.h
@@ -1121,6 +1121,7 @@ struct rq {
#ifdef CONFIG_SCHED_CORE
/* per rq */
struct rq *core;
+ unsigned int core_id;
struct task_struct *core_pick;
unsigned int core_enabled;
unsigned int core_sched_seq;
--
2.39.3
Powered by blists - more mailing lists