|
@@ -399,6 +399,9 @@ static void replenish_dl_entity(struct sched_dl_entity *dl_se,
|
|
dl_se->runtime = pi_se->dl_runtime;
|
|
dl_se->runtime = pi_se->dl_runtime;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ if (dl_se->dl_yielded && dl_se->runtime > 0)
|
|
|
|
+ dl_se->runtime = 0;
|
|
|
|
+
|
|
/*
|
|
/*
|
|
* We keep moving the deadline away until we get some
|
|
* We keep moving the deadline away until we get some
|
|
* available runtime for the entity. This ensures correct
|
|
* available runtime for the entity. This ensures correct
|
|
@@ -735,8 +738,11 @@ static void update_curr_dl(struct rq *rq)
|
|
* approach need further study.
|
|
* approach need further study.
|
|
*/
|
|
*/
|
|
delta_exec = rq_clock_task(rq) - curr->se.exec_start;
|
|
delta_exec = rq_clock_task(rq) - curr->se.exec_start;
|
|
- if (unlikely((s64)delta_exec <= 0))
|
|
|
|
|
|
+ if (unlikely((s64)delta_exec <= 0)) {
|
|
|
|
+ if (unlikely(dl_se->dl_yielded))
|
|
|
|
+ goto throttle;
|
|
return;
|
|
return;
|
|
|
|
+ }
|
|
|
|
|
|
schedstat_set(curr->se.statistics.exec_max,
|
|
schedstat_set(curr->se.statistics.exec_max,
|
|
max(curr->se.statistics.exec_max, delta_exec));
|
|
max(curr->se.statistics.exec_max, delta_exec));
|
|
@@ -749,8 +755,10 @@ static void update_curr_dl(struct rq *rq)
|
|
|
|
|
|
sched_rt_avg_update(rq, delta_exec);
|
|
sched_rt_avg_update(rq, delta_exec);
|
|
|
|
|
|
- dl_se->runtime -= dl_se->dl_yielded ? 0 : delta_exec;
|
|
|
|
- if (dl_runtime_exceeded(dl_se)) {
|
|
|
|
|
|
+ dl_se->runtime -= delta_exec;
|
|
|
|
+
|
|
|
|
+throttle:
|
|
|
|
+ if (dl_runtime_exceeded(dl_se) || dl_se->dl_yielded) {
|
|
dl_se->dl_throttled = 1;
|
|
dl_se->dl_throttled = 1;
|
|
__dequeue_task_dl(rq, curr, 0);
|
|
__dequeue_task_dl(rq, curr, 0);
|
|
if (unlikely(dl_se->dl_boosted || !start_dl_timer(curr)))
|
|
if (unlikely(dl_se->dl_boosted || !start_dl_timer(curr)))
|
|
@@ -994,18 +1002,14 @@ static void dequeue_task_dl(struct rq *rq, struct task_struct *p, int flags)
|
|
*/
|
|
*/
|
|
static void yield_task_dl(struct rq *rq)
|
|
static void yield_task_dl(struct rq *rq)
|
|
{
|
|
{
|
|
- struct task_struct *p = rq->curr;
|
|
|
|
-
|
|
|
|
/*
|
|
/*
|
|
* We make the task go to sleep until its current deadline by
|
|
* We make the task go to sleep until its current deadline by
|
|
* forcing its runtime to zero. This way, update_curr_dl() stops
|
|
* forcing its runtime to zero. This way, update_curr_dl() stops
|
|
* it and the bandwidth timer will wake it up and will give it
|
|
* it and the bandwidth timer will wake it up and will give it
|
|
* new scheduling parameters (thanks to dl_yielded=1).
|
|
* new scheduling parameters (thanks to dl_yielded=1).
|
|
*/
|
|
*/
|
|
- if (p->dl.runtime > 0) {
|
|
|
|
- rq->curr->dl.dl_yielded = 1;
|
|
|
|
- p->dl.runtime = 0;
|
|
|
|
- }
|
|
|
|
|
|
+ rq->curr->dl.dl_yielded = 1;
|
|
|
|
+
|
|
update_rq_clock(rq);
|
|
update_rq_clock(rq);
|
|
update_curr_dl(rq);
|
|
update_curr_dl(rq);
|
|
/*
|
|
/*
|