sched: Fix SCHED_HRTICK bug leading to late preemption of tasks
PATCH 1/1 sched: Fix SCHED_HRTICK bug leading to late preemption of tasks
From: Srivatsa Vaddagiri <[email protected]>
SCHED_HRTICK feature is useful to preempt SCHED_FAIR tasks on-the-dot (just when they would have exceeded their ideal_runtime). It makes use of a per-cpu hrtimer resource and hence alarming that hrtimer should be based on total SCHED_FAIR tasks a cpu has across its various cfs_rqs, rather than being based on number of tasks in a particular cfs_rq (as implemented currently). As a result, with current code, its possible for a running task (which is the sole task in its cfs_rq) to be preempted much after its ideal_runtime has elapsed, resulting in increased latency for tasks in other cfs_rq on same cpu.
Fix this by alarming sched hrtimer based on total number of SCHED_FAIR tasks a CPU has across its various cfs_rqs.
---
joonwoop: Do we also need to update or remove if-statement inside hrtick_update()?
I guess not because hrtick_update() doesn't want to start hrtick when cfs_rq has large number of nr_running where slice is longer than sched_latency.
kernel/sched/fair.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
kernel/sched/fair.c +1 -1
@@ -4458,7 +4458,7 @@ static void hrtick_start_fair(struct rq *rq, struct task_struct *p)WARN_ON (task_rq (p) != rq); -if (cfs_rq->nr_running >1 ) { +if (rq->cfs.h_nr_running >1 ) {u64 slice =sched_slice (cfs_rq, se);u64 ran = se->sum_exec_runtime - se->prev_sum_exec_runtime;s64 delta = slice - ran;
Signature · 2 lines
The Qualcomm Innovation Center, Inc. is a member of the Code Aurora Forum, hosted by The Linux Foundation
2016-09-17 9:28 GMT+08:00 Joonwoo Park <[email protected]>:
Quoted 9 lines
From: Srivatsa Vaddagiri <[email protected]>
SCHED_HRTICKfeature is useful to preemptSCHED_FAIRtasks on-the-dot (just when they would have exceeded theirideal_runtime). It makes use of a per-cpu hrtimer resource and hence alarming that hrtimer should be based on totalSCHED_FAIRtasks a cpu has across its variouscfs_rqs, rather than being based on number of tasks in a particularcfs_rq(as implemented currently). As a result, with current code, its possible for a running task (which is the sole task in itscfs_rq) to be preempted
not be preempted much, right?
Quoted 38 lines
much after its
ideal_runtimehas elapsed, resulting in increased latency for tasks in othercfs_rqon same cpu.Fix this by alarming sched hrtimer based on total number of
SCHED_FAIRtasks a CPU has across its variouscfs_rqs.Cc Ingo Molnar <[email protected]>Cc Peter Zijlstra <[email protected]>Signed-off-by Srivatsa Vaddagiri <[email protected]>Signed-off-by Joonwoo Park <[email protected]>---
joonwoop: Do we also need to update or remove if-statement inside
hrtick_update()?
I guess not becausehrtick_update()doesn't want to start hrtick whencfs_rqhas large number ofnr_runningwhere slice is longer thansched_latency.kernel/sched/fair.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)kernel/sched/fair.c +1
-2@@ -4458,7 +4458,7 @@ static void hrtick_start_fair(struct rq *rq, struct task_struct *p)WARN_ON (task_rq (p) != rq); -if (cfs_rq->nr_running >1 ) { +if (rq->cfs.h_nr_running >1 ) {u64 slice =sched_slice (cfs_rq, se);u64 ran = se->sum_exec_runtime - se->prev_sum_exec_runtime;s64 delta = slice - ran; --The Qualcomm Innovation Center, Inc. is a member of the Code Aurora Forum, hosted by The Linux Foundation
Quoted 11 lines · Wanpeng Li
2016-09-17 9:28 GMT+08:00 Joonwoo Park <[email protected]>:
Quoted 9 lines
From: Srivatsa Vaddagiri <[email protected]>
SCHED_HRTICKfeature is useful to preemptSCHED_FAIRtasks on-the-dot (just when they would have exceeded theirideal_runtime). It makes use of a per-cpu hrtimer resource and hence alarming that hrtimer should be based on totalSCHED_FAIRtasks a cpu has across its variouscfs_rqs, rather than being based on number of tasks in a particularcfs_rq(as implemented currently). As a result, with current code, its possible for a running task (which is the sole task in itscfs_rq) to be preempted
Quoted 1 line
not be preempted much, right?
I don't think so....
By saying 'to be preempted much after its ideal_runtime has elapsed' I wanted to describe the current suboptimal behaviour.
Thanks,
Joonwoo
Quoted 39 lines
Quoted 39 lines
much after its
ideal_runtimehas elapsed, resulting in increased latency for tasks in othercfs_rqon same cpu.Fix this by alarming sched hrtimer based on total number of
SCHED_FAIRtasks a CPU has across its variouscfs_rqs.Cc Ingo Molnar <[email protected]>Cc Peter Zijlstra <[email protected]>Signed-off-by Srivatsa Vaddagiri <[email protected]>Signed-off-by Joonwoo Park <[email protected]>---
joonwoop: Do we also need to update or remove if-statement inside
hrtick_update()?
I guess not becausehrtick_update()doesn't want to start hrtick whencfs_rqhas large number ofnr_runningwhere slice is longer thansched_latency.kernel/sched/fair.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)kernel/sched/fair.c +1
-2@@ -4458,7 +4458,7 @@ static void hrtick_start_fair(struct rq *rq, struct task_struct *p)WARN_ON (task_rq (p) != rq); -if (cfs_rq->nr_running >1 ) { +if (rq->cfs.h_nr_running >1 ) {u64 slice =sched_slice (cfs_rq, se);u64 ran = se->sum_exec_runtime - se->prev_sum_exec_runtime;s64 delta = slice - ran; --The Qualcomm Innovation Center, Inc. is a member of the Code Aurora Forum, hosted by The Linux Foundation
2016-09-20 2:08 GMT+08:00 Joonwoo Park <[email protected]>:
Quoted 12 lines · Wanpeng Li
Quoted 11 lines
2016-09-17 9:28 GMT+08:00 Joonwoo Park <[email protected]>:
Quoted 9 lines
From: Srivatsa Vaddagiri <[email protected]>
SCHED_HRTICKfeature is useful to preemptSCHED_FAIRtasks on-the-dot (just when they would have exceeded theirideal_runtime). It makes use of a per-cpu hrtimer resource and hence alarming that hrtimer should be based on totalSCHED_FAIRtasks a cpu has across its variouscfs_rqs, rather than being based on number of tasks in a particularcfs_rq(as implemented currently). As a result, with current code, its possible for a running task (which is the sole task in itscfs_rq) to be preempted
Quoted 5 lines
Quoted 1 line
not be preempted much, right?
I don't think so....
By saying 'to be preempted much after itsideal_runtimehas elapsed' I wanted to describe the current suboptimal behaviour.
I also described the current suboptimal behaviour. A running task (which is the sole task in its cfs_rq) as the test case 2 you mentioned in another reply is preempted after 10ms since the scheduler tick, however, it will be preempted after 1.5ms since the hrtick fire in test case 1. That's what I mean "not be preempted much for test case 2".
Regards,
Wanpeng Li
Peter Zijlstra
maintainerQuoted 3 lines · Joonwoo Park
From: Srivatsa Vaddagiri <[email protected]>
SCHED_HRTICKfeature is useful to preemptSCHED_FAIRtasks on-the-dot
Right, but I always found the overhead of the thing too high to be really useful.
How come you're using this?
Quoted 5 lines
joonwoop: Do we also need to update or remove if-statement inside
hrtick_update()?I guess not because
hrtick_update()doesn't want to start hrtick whencfs_rqhas large number ofnr_runningwhere slice is longer thansched_latency.
Right, you want that to match with whatever sched_slice() does.
kernel/sched/fair.c static void hrtick_start_fair(struct rq *rq, struct task_struct *p) · line 4464
Quoted 10 lines
+++
b/kernel/sched/fair.ckernel/sched/fair.c +1
-1@@ -4458,7 +4458,7 @@ static void hrtick_start_fair(struct rq *rq, struct task_struct *p)WARN_ON (task_rq (p) != rq); -if (cfs_rq->nr_running >1 ) { +if (rq->cfs.h_nr_running >1 ) {u64 slice =sched_slice (cfs_rq, se);u64 ran = se->sum_exec_runtime - se->prev_sum_exec_runtime;s64 delta = slice - ran;
Yeah, that looks right. I don't think I've ever tried hrtick with cgroups enabled...
Quoted 9 lines · Peter Zijlstra
Quoted 3 lines · Joonwoo Park
From: Srivatsa Vaddagiri <[email protected]>
SCHED_HRTICKfeature is useful to preemptSCHED_FAIRtasks on-the-dotRight, but I always found the overhead of the thing too high to be really useful.
How come you're using this?
This patch was in our internal tree for decades so I unfortunately cannot find actual usecase or history.
But I guess it was about excessive latency when there are number of CPU bound tasks running on a CPU but on different cfs_rqs and CONFIG_HZ = 100.
See how I recreated :
* run 4 cpu hogs on the same cgroup [1] :
dd-960 [000] d..3 110.651060: sched_switch: prev_comm=dd prev_pid=960 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=959 next_prio=120 dd-959 [000] d..3 110.652566: sched_switch: prev_comm=dd prev_pid=959 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=961 next_prio=120 dd-961 [000] d..3 110.654072: sched_switch: prev_comm=dd prev_pid=961 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=962 next_prio=120 dd-962 [000] d..3 110.655578: sched_switch: prev_comm=dd prev_pid=962 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=960 next_prio=120
preempt every 1.5ms slice by hrtick.
* run 4 CPU hogs on 4 different cgroups [2] :
dd-964 [000] d..3 24.169873: sched_switch: prev_comm=dd prev_pid=964 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=966 next_prio=120 dd-966 [000] d..3 24.179873: sched_switch: prev_comm=dd prev_pid=966 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=965 next_prio=120 dd-965 [000] d..3 24.189873: sched_switch: prev_comm=dd prev_pid=965 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=967 next_prio=120 dd-967 [000] d..3 24.199873: sched_switch: prev_comm=dd prev_pid=967 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=964 next_prio=120
preempt every 10ms by scheduler tick so that all tasks suffers from 40ms preemption latency.
[1] :
dd if=/dev/zero of=/dev/zero &
dd if=/dev/zero of=/dev/zero &
dd if=/dev/zero of=/dev/zero &
dd if=/dev/zero of=/dev/zero &
[2] :
mount -t cgroup -o cpu cpu /sys/fs/cgroup
mkdir /sys/fs/cgroup/grp1
mkdir /sys/fs/cgroup/grp2
mkdir /sys/fs/cgroup/grp3
mkdir /sys/fs/cgroup/grp4
dd if=/dev/zero of=/dev/zero &
echo $! > /sys/fs/cgroup/grp1/tasks
dd if=/dev/zero of=/dev/zero &
echo $! > /sys/fs/cgroup/grp2/tasks
dd if=/dev/zero of=/dev/zero &
echo $! > /sys/fs/cgroup/grp3/tasks
dd if=/dev/zero of=/dev/zero &
echo $! > /sys/fs/cgroup/grp4/tasks
I could confirm this patch makes the latter behaves as same as the former in terms of preemption latency.
Quoted 9 lines
Quoted 7 lines
joonwoop: Do we also need to update or remove if-statement inside
hrtick_update()?I guess not because
hrtick_update()doesn't want to start hrtick whencfs_rqhas large number ofnr_runningwhere slice is longer thansched_latency.Right, you want that to match with whatever
sched_slice()does.
Cool. Thank you!
Thanks,
Joonwoo
Quoted 14 lines
kernel/sched/fair.c static void hrtick_start_fair(struct rq *rq, struct task_struct *p) · line 4464
Quoted 11 lines
+++
b/kernel/sched/fair.ckernel/sched/fair.c +1
-1@@ -4458,7 +4458,7 @@ static void hrtick_start_fair(struct rq *rq, struct task_struct *p)WARN_ON (task_rq (p) != rq); -if (cfs_rq->nr_running >1 ) { +if (rq->cfs.h_nr_running >1 ) {u64 slice =sched_slice (cfs_rq, se);u64 ran = se->sum_exec_runtime - se->prev_sum_exec_runtime;s64 delta = slice - ran;Yeah, that looks right. I don't think I've ever tried hrtick with cgroups enabled...
Quoted 26 lines · Joonwoo Park
Quoted 9 lines · Peter Zijlstra
Quoted 3 lines · Joonwoo Park
From: Srivatsa Vaddagiri <[email protected]>
SCHED_HRTICKfeature is useful to preemptSCHED_FAIRtasks on-the-dotRight, but I always found the overhead of the thing too high to be really useful.
How come you're using this?
This patch was in our internal tree for decades so I unfortunately cannot find actual usecase or history.
But I guess it was about excessive latency when there are number of CPU bound tasks running on a CPU but on differentcfs_rqsandCONFIG_HZ= 100.See how I recreated :
* run 4 cpu hogs on the same cgroup [1] :
dd-960 [000] d..3 110.651060: sched_switch: prev_comm=dd prev_pid=960 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=959 next_prio=120 dd-959 [000] d..3 110.652566: sched_switch: prev_comm=dd prev_pid=959 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=961 next_prio=120 dd-961 [000] d..3 110.654072: sched_switch: prev_comm=dd prev_pid=961 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=962 next_prio=120 dd-962 [000] d..3 110.655578: sched_switch: prev_comm=dd prev_pid=962 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=960 next_prio=120preempt every 1.5ms slice by hrtick.
* run 4 CPU hogs on 4 different cgroups [2] :
Quoted 8 lines
dd-964 [000] d..3 24.169873: sched_switch: prev_comm=dd prev_pid=964 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=966 next_prio=120 dd-966 [000] d..3 24.179873: sched_switch: prev_comm=dd prev_pid=966 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=965 next_prio=120 dd-965 [000] d..3 24.189873: sched_switch: prev_comm=dd prev_pid=965 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=967 next_prio=120 dd-967 [000] d..3 24.199873: sched_switch: prev_comm=dd prev_pid=967 prev_prio=120 prev_state=R+ ==> next_comm=dd next_pid=964 next_prio=120preempt every 10ms by scheduler tick so that all tasks suffers from 40ms preemption latency.
[1] :
dd if=/dev/zero of=/dev/zero &
Ugh.. of=/dev/null instead.
Quoted 50 lines
dd if=/dev/zero of=/dev/zero &
dd if=/dev/zero of=/dev/zero &
dd if=/dev/zero of=/dev/zero &[2] :
mount -t cgroup -o cpu cpu/sys/fs/cgroup
mkdir/sys/fs/cgroup/grp1
mkdir/sys/fs/cgroup/grp2
mkdir/sys/fs/cgroup/grp3
mkdir/sys/fs/cgroup/grp4
dd if=/dev/zero of=/dev/zero &
echo $! >/sys/fs/cgroup/grp1/tasks
dd if=/dev/zero of=/dev/zero &
echo $! >/sys/fs/cgroup/grp2/tasks
dd if=/dev/zero of=/dev/zero &
echo $! >/sys/fs/cgroup/grp3/tasks
dd if=/dev/zero of=/dev/zero &
echo $! >/sys/fs/cgroup/grp4/tasksI could confirm this patch makes the latter behaves as same as the former in terms of preemption latency.
Quoted 9 lines
Quoted 7 lines
joonwoop: Do we also need to update or remove if-statement inside
hrtick_update()?I guess not because
hrtick_update()doesn't want to start hrtick whencfs_rqhas large number ofnr_runningwhere slice is longer thansched_latency.Right, you want that to match with whatever
sched_slice()does.Cool. Thank you!
Thanks,
JoonwooQuoted 14 lines
kernel/sched/fair.c static void hrtick_start_fair(struct rq *rq, struct task_struct *p) · line 4464
Quoted 11 lines
+++
b/kernel/sched/fair.ckernel/sched/fair.c +1
-1@@ -4458,7 +4458,7 @@ static void hrtick_start_fair(struct rq *rq, struct task_struct *p)WARN_ON (task_rq (p) != rq); -if (cfs_rq->nr_running >1 ) { +if (rq->cfs.h_nr_running >1 ) {u64 slice =sched_slice (cfs_rq, se);u64 ran = se->sum_exec_runtime - se->prev_sum_exec_runtime;s64 delta = slice - ran;Yeah, that looks right. I don't think I've ever tried hrtick with cgroups enabled...
tip-bot for Srivatsa Vaddagiri
merge bot[tip:sched/core] sched/fair: Fix SCHED_HRTICK bug leading to late preemption of tasks
In reply to Joonwoo Parksched/fair: Fix SCHED_HRTICK bug leading to late preemption of tasks
Commit-ID: 8bf46a39be910937d4c9e8d999a7438a7ae1a75b Gitweb: http://git.kernel.org/tip/8bf46a39be910937d4c9e8d999a7438a7ae1a75b Author: Srivatsa Vaddagiri <[email protected]> AuthorDate: Fri, 16 Sep 2016 18:28:51 -0700 Committer: Ingo Molnar <[email protected]> CommitDate: Thu, 22 Sep 2016 15:20:18 +0200
sched/fair: Fix SCHED_HRTICK bug leading to late preemption of tasks
SCHED_HRTICK feature is useful to preempt SCHED_FAIR tasks on-the-dot (just when they would have exceeded their ideal_runtime).
It makes use of a per-CPU hrtimer resource and hence arming that hrtimer should be based on total SCHED_FAIR tasks a CPU has across its various cfs_rqs, rather than being based on number of tasks in a particular cfs_rq (as implemented currently).
As a result, with current code, its possible for a running task (which is the sole task in its cfs_rq) to be preempted much after its ideal_runtime has elapsed, resulting in increased latency for tasks in other cfs_rq on same CPU.
Fix this by arming sched hrtimer based on total number of SCHED_FAIR tasks a CPU has across its various cfs_rqs.
--- kernel/sched/fair.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
kernel/sched/fair.c +1 -1
@@ -4469,7 +4469,7 @@ static void hrtick_start_fair(struct rq *rq, struct task_struct *p)WARN_ON (task_rq (p) != rq); -if (cfs_rq->nr_running >1 ) { +if (rq->cfs.h_nr_running >1 ) {u64 slice =sched_slice (cfs_rq, se);u64 ran = se->sum_exec_runtime - se->prev_sum_exec_runtime;s64 delta = slice - ran;