mirror of
https://github.com/torvalds/linux.git
synced 2026-10-25 08:16:03 +01:00
sched: Add sched_ext hooks for proxy execution
Proxy execution splits the scheduling context (the donor) from the execution context (the lock owner). sched_ext needs to observe that split at three points in __schedule(): - whether a blocked EXT task can be retained on the runqueue as a donor, - when a donor's scheduling context starts driving a lock owner, - after proxy resolution, when deferred reenqueue work that was blocked by an active proxy relationship can be retried. Introduce scx_allow_proxy_exec(), scx_proxy_donor_start() and scx_proxy_reenqueue_retry(), and add their call sites in __schedule(). The implementations are empty here and are filled in by the sched_ext changes that follow, so that all the sched core changes needed by proxy execution stay together in the preparatory patches. SCHED_PROXY_EXEC still depends on !SCHED_CLASS_EXT, so the new hooks are inert: they are compiled out with CONFIG_SCHED_CLASS_EXT=n and unreachable otherwise. This is a preparatory change to support proxy execution with sched_ext. No functional change. Signed-off-by: Andrea Righi <arighi@nvidia.com> Signed-off-by: Peter Zijlstra (Intel) <peterz@infradead.org> Link: https://patch.msgid.link/20260922165445.943315-6-arighi@nvidia.com
This commit is contained in:
parent
57c75e3ae3
commit
be100c7717
|
|
@ -7243,13 +7243,12 @@ static void __sched notrace __schedule(int sched_mode)
|
|||
}
|
||||
} else if (!preempt && prev_state) {
|
||||
/*
|
||||
* We pass task_is_blocked() as the should_block arg
|
||||
* in order to keep mutex-blocked tasks on the runqueue
|
||||
* for slection with proxy-exec (without proxy-exec
|
||||
* task_is_blocked() will always be false).
|
||||
* Keep mutex-blocked tasks on the runqueue for proxy execution
|
||||
* only when their scheduling class allows it. Without proxy
|
||||
* execution, task_is_blocked() always returns false.
|
||||
*/
|
||||
try_to_block_task(rq, prev, &prev_state,
|
||||
!task_is_blocked(prev));
|
||||
!task_is_blocked(prev) || !scx_allow_proxy_exec(prev));
|
||||
switch_count = &prev->nvcsw;
|
||||
}
|
||||
|
||||
|
|
@ -7270,6 +7269,7 @@ static void __sched notrace __schedule(int sched_mode)
|
|||
}
|
||||
if (next == rq->idle) {
|
||||
zap_balance_callbacks(rq);
|
||||
scx_proxy_reenqueue_retry(rq, next);
|
||||
goto keep_resched;
|
||||
}
|
||||
}
|
||||
|
|
@ -7290,6 +7290,8 @@ static void __sched notrace __schedule(int sched_mode)
|
|||
donor->sched_class->put_prev_task(rq, donor, donor);
|
||||
donor->sched_class->set_next_task(rq, donor, SNT_PICK);
|
||||
}
|
||||
scx_proxy_donor_start(rq);
|
||||
scx_proxy_reenqueue_retry(rq, next);
|
||||
} else {
|
||||
rq_set_donor(rq, next);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -24,6 +24,11 @@
|
|||
|
||||
DEFINE_RAW_SPINLOCK(scx_sched_lock);
|
||||
|
||||
bool scx_allow_proxy_exec(const struct task_struct *p)
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
/*
|
||||
* NOTE: sched_ext is in the process of growing multiple scheduler support and
|
||||
* scx_root usage is in a transitional state. Naked dereferences are safe if the
|
||||
|
|
@ -1079,6 +1084,10 @@ static void schedule_deferred_locked(struct rq *rq)
|
|||
schedule_deferred(rq);
|
||||
}
|
||||
|
||||
void scx_proxy_reenqueue_retry(struct rq *rq, struct task_struct *next)
|
||||
{
|
||||
}
|
||||
|
||||
void schedule_dsq_reenq(struct scx_sched *sch, struct scx_dispatch_q *dsq,
|
||||
u64 reenq_flags, struct rq *locked_rq)
|
||||
{
|
||||
|
|
@ -3065,6 +3074,10 @@ static void set_next_task_scx(struct rq *rq, struct task_struct *p, enum snt_e t
|
|||
}
|
||||
}
|
||||
|
||||
void scx_proxy_donor_start(struct rq *rq)
|
||||
{
|
||||
}
|
||||
|
||||
static enum scx_cpu_preempt_reason
|
||||
preempt_reason_from_class(const struct sched_class *class)
|
||||
{
|
||||
|
|
|
|||
|
|
@ -20,6 +20,9 @@ void scx_rq_deactivate(struct rq *rq);
|
|||
int scx_check_setscheduler(struct task_struct *p, int policy);
|
||||
bool task_should_scx(int policy);
|
||||
bool scx_allow_ttwu_queue(const struct task_struct *p);
|
||||
bool scx_allow_proxy_exec(const struct task_struct *p);
|
||||
void scx_proxy_donor_start(struct rq *rq);
|
||||
void scx_proxy_reenqueue_retry(struct rq *rq, struct task_struct *next);
|
||||
void init_sched_ext_class(void);
|
||||
|
||||
static inline u32 scx_cpuperf_target(s32 cpu)
|
||||
|
|
@ -54,6 +57,10 @@ static inline void scx_rq_deactivate(struct rq *rq) {}
|
|||
static inline int scx_check_setscheduler(struct task_struct *p, int policy) { return 0; }
|
||||
static inline bool task_on_scx(const struct task_struct *p) { return false; }
|
||||
static inline bool scx_allow_ttwu_queue(const struct task_struct *p) { return true; }
|
||||
static inline bool scx_allow_proxy_exec(const struct task_struct *p) { return true; }
|
||||
static inline void scx_proxy_donor_start(struct rq *rq) {}
|
||||
static inline void scx_proxy_reenqueue_retry(struct rq *rq,
|
||||
struct task_struct *next) {}
|
||||
static inline void init_sched_ext_class(void) {}
|
||||
|
||||
#endif /* CONFIG_SCHED_CLASS_EXT */
|
||||
|
|
|
|||
Loading…
Reference in New Issue
Block a user