Skip to content

Commit 89e1f67

Browse files
Zecheng LiPeter Zijlstra
authored andcommitted
sched/fair: Remove task_group->se pointer array
Now that struct sched_entity is co-located with struct cfs_rq for non-root task groups, the task_group->se pointer array is redundant. The associated sched_entity can be loaded directly from the cfs_rq. This patch performs the access conversion with the helpers: - is_root_task_group(tg): checks if a task group is the root task group. It compares the task group's address with the global root_task_group variable. - tg_se(tg, cpu): retrieves the cfs_rq and returns the address of the co-located se. This function checks if tg is the root task group to ensure behaving the same of previous tg->se[cpu]. Replaces all accesses that use the tg->se[cpu] pointer array with calls to the new tg_se(tg, cpu) accessor. - cfs_rq_se(cfs_rq): simplifies access paths like cfs_rq->tg->se[...] to use the co-located sched_entity. This function also checks if tg is the root task group to ensure same behavior. Since tg_se is not in very hot code paths, and the branch is a register comparison with an immediate value (`&root_task_group`), the performance impact is expected to be negligible. Signed-off-by: Zecheng Li <zecheng@google.com> Signed-off-by: Zecheng Li <zli94@ncsu.edu> Signed-off-by: Peter Zijlstra (Intel) <peterz@infradead.org> Reviewed-by: K Prateek Nayak <kprateek.nayak@amd.com> Reviewed-by: Josh Don <joshdon@google.com> Link: https://patch.msgid.link/20260522141623.600235-3-zli94@ncsu.edu
1 parent dfcfc97 commit 89e1f67

4 files changed

Lines changed: 38 additions & 27 deletions

File tree

kernel/sched/core.c

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8923,7 +8923,7 @@ void __init sched_init(void)
89238923
wait_bit_init();
89248924

89258925
#ifdef CONFIG_FAIR_GROUP_SCHED
8926-
ptr += 2 * nr_cpu_ids * sizeof(void **);
8926+
ptr += nr_cpu_ids * sizeof(void **);
89278927
#endif
89288928
#ifdef CONFIG_RT_GROUP_SCHED
89298929
ptr += 2 * nr_cpu_ids * sizeof(void **);
@@ -8932,9 +8932,6 @@ void __init sched_init(void)
89328932
ptr = (unsigned long)kzalloc(ptr, GFP_NOWAIT);
89338933

89348934
#ifdef CONFIG_FAIR_GROUP_SCHED
8935-
root_task_group.se = (struct sched_entity **)ptr;
8936-
ptr += nr_cpu_ids * sizeof(void **);
8937-
89388935
root_task_group.cfs_rq = (struct cfs_rq **)ptr;
89398936
ptr += nr_cpu_ids * sizeof(void **);
89408937

@@ -10016,7 +10013,7 @@ static int cpu_cfs_stat_show(struct seq_file *sf, void *v)
1001610013
int i;
1001710014

1001810015
for_each_possible_cpu(i) {
10019-
stats = __schedstats_from_se(tg->se[i]);
10016+
stats = __schedstats_from_se(tg_se(tg, i));
1002010017
ws += schedstat_val(stats->wait_sum);
1002110018
}
1002210019

kernel/sched/debug.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -808,7 +808,7 @@ void dirty_sched_domain_sysctl(int cpu)
808808
#ifdef CONFIG_FAIR_GROUP_SCHED
809809
static void print_cfs_group_stats(struct seq_file *m, int cpu, struct task_group *tg)
810810
{
811-
struct sched_entity *se = tg->se[cpu];
811+
struct sched_entity *se = tg_se(tg, cpu);
812812

813813
#define P(F) SEQ_printf(m, " .%-30s: %lld\n", #F, (long long)F)
814814
#define P_SCHEDSTAT(F) SEQ_printf(m, " .%-30s: %lld\n", \

kernel/sched/fair.c

Lines changed: 9 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -6876,7 +6876,7 @@ void unthrottle_cfs_rq(struct cfs_rq *cfs_rq)
68766876
{
68776877
struct rq *rq = rq_of(cfs_rq);
68786878
struct cfs_bandwidth *cfs_b = tg_cfs_bandwidth(cfs_rq->tg);
6879-
struct sched_entity *se = cfs_rq->tg->se[cpu_of(rq)];
6879+
struct sched_entity *se = cfs_rq_se(cfs_rq);
68806880

68816881
/*
68826882
* It's possible we are called with runtime_remaining < 0 due to things
@@ -11102,7 +11102,6 @@ static bool __update_blocked_fair(struct rq *rq, bool *done)
1110211102
{
1110311103
struct cfs_rq *cfs_rq, *pos;
1110411104
bool decayed = false;
11105-
int cpu = cpu_of(rq);
1110611105

1110711106
/*
1110811107
* Iterates the task_group tree in a bottom up fashion, see
@@ -11122,7 +11121,7 @@ static bool __update_blocked_fair(struct rq *rq, bool *done)
1112211121
}
1112311122

1112411123
/* Propagate pending load changes to the parent, if any: */
11125-
se = cfs_rq->tg->se[cpu];
11124+
se = cfs_rq_se(cfs_rq);
1112611125
if (se && !skip_blocked_update(se))
1112711126
update_load_avg(cfs_rq_of(se), se, UPDATE_TG);
1112811127

@@ -11148,8 +11147,7 @@ static bool __update_blocked_fair(struct rq *rq, bool *done)
1114811147
*/
1114911148
static void update_cfs_rq_h_load(struct cfs_rq *cfs_rq)
1115011149
{
11151-
struct rq *rq = rq_of(cfs_rq);
11152-
struct sched_entity *se = cfs_rq->tg->se[cpu_of(rq)];
11150+
struct sched_entity *se = cfs_rq_se(cfs_rq);
1115311151
unsigned long now = jiffies;
1115411152
unsigned long load;
1115511153

@@ -15086,7 +15084,6 @@ void free_fair_sched_group(struct task_group *tg)
1508615084
}
1508715085

1508815086
kfree(tg->cfs_rq);
15089-
kfree(tg->se);
1509015087
}
1509115088

1509215089
int alloc_fair_sched_group(struct task_group *tg, struct task_group *parent)
@@ -15099,9 +15096,6 @@ int alloc_fair_sched_group(struct task_group *tg, struct task_group *parent)
1509915096
tg->cfs_rq = kzalloc_objs(cfs_rq, nr_cpu_ids);
1510015097
if (!tg->cfs_rq)
1510115098
goto err;
15102-
tg->se = kzalloc_objs(se, nr_cpu_ids);
15103-
if (!tg->se)
15104-
goto err;
1510515099

1510615100
tg->shares = NICE_0_LOAD;
1510715101

@@ -15116,7 +15110,7 @@ int alloc_fair_sched_group(struct task_group *tg, struct task_group *parent)
1511615110
cfs_rq = &state->cfs_rq;
1511715111
se = &state->se;
1511815112
init_cfs_rq(cfs_rq);
15119-
init_tg_cfs_entry(tg, cfs_rq, se, i, parent->se[i]);
15113+
init_tg_cfs_entry(tg, cfs_rq, se, i, tg_se(parent, i));
1512015114
init_entity_runnable_average(se);
1512115115
}
1512215116

@@ -15135,7 +15129,7 @@ void online_fair_sched_group(struct task_group *tg)
1513515129

1513615130
for_each_possible_cpu(i) {
1513715131
rq = cpu_rq(i);
15138-
se = tg->se[i];
15132+
se = tg_se(tg, i);
1513915133
rq_lock_irq(rq, &rf);
1514015134
update_rq_clock(rq);
1514115135
attach_entity_cfs_rq(se);
@@ -15152,7 +15146,7 @@ void unregister_fair_sched_group(struct task_group *tg)
1515215146

1515315147
for_each_possible_cpu(cpu) {
1515415148
struct cfs_rq *cfs_rq = tg->cfs_rq[cpu];
15155-
struct sched_entity *se = tg->se[cpu];
15149+
struct sched_entity *se = tg_se(tg, cpu);
1515615150
struct rq *rq = cpu_rq(cpu);
1515715151

1515815152
if (se) {
@@ -15189,7 +15183,6 @@ void init_tg_cfs_entry(struct task_group *tg, struct cfs_rq *cfs_rq,
1518915183
init_cfs_rq_runtime(cfs_rq);
1519015184

1519115185
tg->cfs_rq[cpu] = cfs_rq;
15192-
tg->se[cpu] = se;
1519315186

1519415187
/* se could be NULL for root_task_group */
1519515188
if (!se)
@@ -15220,7 +15213,7 @@ static int __sched_group_set_shares(struct task_group *tg, unsigned long shares)
1522015213
/*
1522115214
* We can't change the weight of the root cgroup.
1522215215
*/
15223-
if (!tg->se[0])
15216+
if (is_root_task_group(tg))
1522415217
return -EINVAL;
1522515218

1522615219
shares = clamp(shares, scale_load(MIN_SHARES), scale_load(MAX_SHARES));
@@ -15231,7 +15224,7 @@ static int __sched_group_set_shares(struct task_group *tg, unsigned long shares)
1523115224
tg->shares = shares;
1523215225
for_each_possible_cpu(i) {
1523315226
struct rq *rq = cpu_rq(i);
15234-
struct sched_entity *se = tg->se[i];
15227+
struct sched_entity *se = tg_se(tg, i);
1523515228
struct rq_flags rf;
1523615229

1523715230
/* Propagate contribution to hierarchy */
@@ -15282,7 +15275,7 @@ int sched_group_set_idle(struct task_group *tg, long idle)
1528215275

1528315276
for_each_possible_cpu(i) {
1528415277
struct rq *rq = cpu_rq(i);
15285-
struct sched_entity *se = tg->se[i];
15278+
struct sched_entity *se = tg_se(tg, i);
1528615279
struct cfs_rq *grp_cfs_rq = tg->cfs_rq[i];
1528715280
bool was_idle = cfs_rq_is_idle(grp_cfs_rq);
1528815281
long idle_task_delta;

kernel/sched/sched.h

Lines changed: 26 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -484,8 +484,6 @@ struct task_group {
484484
#endif
485485

486486
#ifdef CONFIG_FAIR_GROUP_SCHED
487-
/* schedulable entities of this group on each CPU */
488-
struct sched_entity **se;
489487
/* runqueue "owned" by this group on each CPU */
490488
struct cfs_rq **cfs_rq;
491489
unsigned long shares;
@@ -934,7 +932,8 @@ struct dl_rq {
934932
};
935933

936934
#ifdef CONFIG_FAIR_GROUP_SCHED
937-
935+
/* Check whether a task group is root tg */
936+
#define is_root_task_group(tg) ((tg) == &root_task_group)
938937
/* An entity is a task if it doesn't "own" a runqueue */
939938
#define entity_is_task(se) (!se->my_q)
940939

@@ -2304,6 +2303,28 @@ struct cfs_tg_state {
23042303
struct sched_entity se;
23052304
struct sched_statistics stats;
23062305
} __no_randomize_layout;
2306+
2307+
static inline struct sched_entity *tg_se(struct task_group *tg, int cpu)
2308+
{
2309+
struct cfs_tg_state *state;
2310+
2311+
if (is_root_task_group(tg))
2312+
return NULL;
2313+
2314+
state = container_of(tg->cfs_rq[cpu], struct cfs_tg_state, cfs_rq);
2315+
return &state->se;
2316+
}
2317+
2318+
static inline struct sched_entity *cfs_rq_se(struct cfs_rq *cfs_rq)
2319+
{
2320+
struct cfs_tg_state *state;
2321+
2322+
if (is_root_task_group(cfs_rq->tg))
2323+
return NULL;
2324+
2325+
state = container_of(cfs_rq, struct cfs_tg_state, cfs_rq);
2326+
return &state->se;
2327+
}
23072328
#endif
23082329

23092330
/* Change a task's cfs_rq and parent entity if it moves across CPUs/groups */
@@ -2316,8 +2337,8 @@ static inline void set_task_rq(struct task_struct *p, unsigned int cpu)
23162337
#ifdef CONFIG_FAIR_GROUP_SCHED
23172338
set_task_rq_fair(&p->se, p->se.cfs_rq, tg->cfs_rq[cpu]);
23182339
p->se.cfs_rq = tg->cfs_rq[cpu];
2319-
p->se.parent = tg->se[cpu];
2320-
p->se.depth = tg->se[cpu] ? tg->se[cpu]->depth + 1 : 0;
2340+
p->se.parent = tg_se(tg, cpu);
2341+
p->se.depth = p->se.parent ? p->se.parent->depth + 1 : 0;
23212342
#endif
23222343

23232344
#ifdef CONFIG_RT_GROUP_SCHED

0 commit comments

Comments
 (0)