JakeHillion/scx-upstream
1
0
Fork 0
mirror of https://github.com/sched-ext/scx.git synced 2024-11-28 13:40:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

rusty: Add lookup_pcpu_ctx() helper

Browse Source 
Getting rid of more boilerplate

Signed-off-by: David Vernet <void@manifault.com>
This commit is contained in:
David Vernet 2024-04-11 19:27:38 -05:00
parent 885a9fd7da
commit e032ee7cc0
No known key found for this signature in database
GPG Key ID: 59E4B86965C4F364
1 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
scheds/rust/scx_rusty/src/bpf/main.bpf.c
View File

@ -160,6 +160,17 @@ static struct task_ctx *lookup_task_ctx(struct task_struct *p)
}
}
static struct pcpu_ctx *lookup_pcpu_ctx(s32 cpu)
{
struct pcpu_ctx *pcpuc;
pcpuc = MEMBER_VPTR(pcpu_ctx, [cpu]);
if (!pcpuc)
scx_bpf_error("Failed to lookup pcpu ctx for %d", cpu);
return pcpuc;
}
static inline u32 weight_to_bucket_idx(u32 weight)
{
/* Weight is calculated linearly, and is within range of [1, 10000] */
@ -882,7 +893,7 @@ static u32 dom_rr_next(s32 cpu)
struct pcpu_ctx *pcpuc;
u32 idx, *dom_id;
pcpuc = MEMBER_VPTR(pcpu_ctx, [cpu]);
pcpuc = lookup_pcpu_ctx(cpu);
if (!pcpuc || !pcpuc->nr_node_doms)
return 0;
@ -926,11 +937,9 @@ void BPF_STRUCT_OPS(rusty_dispatch, s32 cpu, struct task_struct *prev)
if (!greedy_threshold)
return;
pcpuc = MEMBER_VPTR(pcpu_ctx, [cpu]);
if (!pcpuc) {
scx_bpf_error("Failed to get PCPU context");
pcpuc = lookup_pcpu_ctx(cpu);
if (!pcpuc)
return;
}
node_doms = pcpuc->nr_node_doms;
/* try to steal a task from domains on the current NUMA node */
@ -1359,13 +1368,11 @@ static s32 initialize_cpu(s32 cpu)
struct bpf_cpumask *cpumask;
struct dom_ctx *domc;
int i, j = 0;
struct pcpu_ctx *pcpuc = MEMBER_VPTR(pcpu_ctx, [cpu]);
struct pcpu_ctx *pcpuc = lookup_pcpu_ctx(cpu);
u32 *dom_nodes;
if (!pcpuc) {
scx_bpf_error("Failed to lookup pcpu ctx %d", cpu);
if (!pcpuc)
return -ENOENT;
}
pcpuc->dom_rr_cur = cpu;
bpf_for(i, 0, nr_doms) {