lkml.org 
[lkml]   [2015]   [May]   [12]   [last100]   RSS Feed
Views: [wrap][no wrap]   [headers]  [forward] 
 
Messages in this thread
    Patch in this message
    /
    From
    Subject[PATCH v3 2/4] sched/deadline: Check to push the task away after its affinity was changed
    Date
    From: Xunlei Pang <pang.xunlei@linaro.org>

    (Sync up the same behaviour as that of RT.)

    We may suffer from extra dl overload rq due to the affinity,
    so when the affinity of any runnable dl task is changed, we
    should check to trigger balancing, otherwise it will cause
    some unnecessary delayed real-time response. Unfortunately,
    current DL global scheduler does nothing about this.

    This patch modified set_cpus_allowed_dl(), if the target task
    is runnable but not running and not throttled, it tries to push
    it away once it got migratable.

    The patch also solves a problem about move_queued_task() called
    in set_cpus_allowed_ptr():
    When a smaller deadline value dl task got migrated due to its curr
    cpu isn't in the new affinity mask, after move_queued_task() it
    will miss the chance of pushing away, because check_preempt_curr()
    called by move_queued_task() doens't set the "need resched flag"
    for smaller deadline value tasks.

    Signed-off-by: Xunlei Pang <pang.xunlei@linaro.org>
    ---
    kernel/sched/deadline.c | 19 ++++++++++++++++---
    1 file changed, 16 insertions(+), 3 deletions(-)

    diff --git a/kernel/sched/deadline.c b/kernel/sched/deadline.c
    index 3baffb2..968612b 100644
    --- a/kernel/sched/deadline.c
    +++ b/kernel/sched/deadline.c
    @@ -1615,11 +1615,12 @@ static bool set_cpus_allowed_dl(struct task_struct *p,
    weight = cpumask_weight(new_mask);

    /*
    - * Only update if the process changes its state from whether it
    - * can migrate or not.
    + * Skip updating the migration stuff if the process doesn't change
    + * its migrate state, but still need to check if it can be pushed
    + * away due to its new affinity.
    */
    if ((p->nr_cpus_allowed > 1) == (weight > 1))
    - return false;
    + goto check_push;

    /*
    * The process used to be able to migrate OR it can now migrate
    @@ -1637,6 +1638,18 @@ static bool set_cpus_allowed_dl(struct task_struct *p,

    update_dl_migration(&rq->dl);

    +check_push:
    + if (weight > 1 &&
    + !task_running(rq, p) &&
    + !test_tsk_need_resched(rq->curr) &&
    + !cpumask_subset(new_mask, &p->cpus_allowed)) {
    + /* Update new affinity and try to push. */
    + cpumask_copy(&p->cpus_allowed, new_mask);
    + p->nr_cpus_allowed = weight;
    + push_dl_tasks(rq);
    + return true;
    + }
    +
    return false;
    }

    --
    1.9.1



    \
     
     \ /
      Last update: 2015-05-12 17:21    [W:3.213 / U:0.284 seconds]
    ©2003-2020 Jasper Spaans|hosted at Digital Ocean and TransIP|Read the blog|Advertise on this site