From b6bd597d6249eb0171b024b0397d6d11838bf637 Mon Sep 17 00:00:00 2001 From: Daeyeong Lee Date: Mon, 14 May 2018 10:52:03 +0900 Subject: [PATCH] sched: ems: ontime: Use fit cpus when ontime migration. Change-Id: Icea69935638628cb8dc41d38a47a9bc4046110b0 Signed-off-by: Daeyeong Lee --- kernel/sched/ems/ontime.c | 157 ++++++++++++++++++++------------------ 1 file changed, 82 insertions(+), 75 deletions(-) diff --git a/kernel/sched/ems/ontime.c b/kernel/sched/ems/ontime.c index 2e30c831adaa..e10fc9e47b2d 100644 --- a/kernel/sched/ems/ontime.c +++ b/kernel/sched/ems/ontime.c @@ -180,8 +180,7 @@ ontime_select_target_cpu(struct cpumask *dst_cpus, const struct cpumask *mask) extern struct sched_entity *__pick_next_entity(struct sched_entity *se); static struct task_struct * -ontime_pick_heavy_task(struct sched_entity *se, struct cpumask *dst_cpus, - int *boost_migration) +ontime_pick_heavy_task(struct sched_entity *se, int *boost_migration) { struct task_struct *heaviest_task = NULL; struct task_struct *p; @@ -220,8 +219,7 @@ ontime_pick_heavy_task(struct sched_entity *se, struct cpumask *dst_cpus, if (ontime_load_avg(p) < get_up_threshold(task_cpu(p))) goto next_entity; - if (ontime_load_avg(p) > max_util_avg && - cpumask_intersects(dst_cpus, tsk_cpus_allowed(p))) { + if (ontime_load_avg(p) > max_util_avg) { heaviest_task = p; max_util_avg = ontime_load_avg(p); *boost_migration = 0; @@ -381,97 +379,106 @@ static DEFINE_SPINLOCK(om_lock); void ontime_migration(void) { - struct ontime_cond *curr, *next = NULL; int cpu; if (!spin_trylock(&om_lock)) return; - list_for_each_entry(curr, &cond_list, list) { - next = list_next_entry(curr, list); - if (!next) + for_each_possible_cpu(cpu) { + unsigned long flags; + struct rq *rq = cpu_rq(cpu); + struct sched_entity *se; + struct task_struct *p; + struct ontime_env *env = &per_cpu(ontime_env, cpu); + struct cpumask fit_cpus; + int boost_migration = 0; + int dst_cpu; + + /* Task in big cores don't be ontime migrated. */ + if (cpumask_test_cpu(cpu, cpu_coregroup_mask(MAX_CAPACITY_CPU))) break; - for_each_cpu_and(cpu, &curr->cpus, cpu_active_mask) { - unsigned long flags; - struct rq *rq = cpu_rq(cpu); - struct sched_entity *se; - struct task_struct *p; - struct ontime_env *env = &per_cpu(ontime_env, cpu); - int dst_cpu; - int boost_migration = 0; - - raw_spin_lock_irqsave(&rq->lock, flags); - - /* - * Ontime migration is not performed when active balance - * is in progress. - */ - if (rq->active_balance) { - raw_spin_unlock_irqrestore(&rq->lock, flags); - continue; - } + raw_spin_lock_irqsave(&rq->lock, flags); - /* - * No need to migration if source cpu does not have cfs - * tasks. - */ - if (!rq->cfs.curr) { - raw_spin_unlock_irqrestore(&rq->lock, flags); - continue; - } + /* + * Ontime migration is not performed when active balance + * is in progress. + */ + if (rq->active_balance) { + raw_spin_unlock_irqrestore(&rq->lock, flags); + continue; + } - /* Find task entity if entity is cfs_rq. */ - se = rq->cfs.curr; - if (entity_is_cfs_rq(se)) { - struct cfs_rq *cfs_rq = se->my_q; + /* + * No need to migration if source cpu does not have cfs + * tasks. + */ + if (!rq->cfs.curr) { + raw_spin_unlock_irqrestore(&rq->lock, flags); + continue; + } - while (cfs_rq) { - se = cfs_rq->curr; - cfs_rq = se->my_q; - } - } + /* Find task entity if entity is cfs_rq. */ + se = rq->cfs.curr; + if (entity_is_cfs_rq(se)) { + struct cfs_rq *cfs_rq = se->my_q; - /* - * Select cpu to migrate the task to. Return negative number - * if there is no idle cpu in sg. - */ - dst_cpu = ontime_select_target_cpu(&next->cpus, cpu_active_mask); - if (dst_cpu < 0) { - raw_spin_unlock_irqrestore(&rq->lock, flags); - continue; + while (cfs_rq) { + se = cfs_rq->curr; + cfs_rq = se->my_q; } + } - /* - * Pick task to be migrated. Return NULL if there is no - * heavy task in rq. - */ - p = ontime_pick_heavy_task(se, &next->cpus, &boost_migration); - if (!p) { - raw_spin_unlock_irqrestore(&rq->lock, flags); - continue; - } + /* + * Pick task to be migrated. Return NULL if there is no + * heavy task in rq. + */ + p = ontime_pick_heavy_task(se, &boost_migration); + if (!p) { + raw_spin_unlock_irqrestore(&rq->lock, flags); + continue; + } + + /* + * If fit_cpus is smaller than current coregroup, + * don't need to ontime migration. + */ + ontime_select_fit_cpus(p, &fit_cpus); + if (capacity_orig_of(cpu) >= + capacity_orig_of(cpumask_first(&fit_cpus))) { + raw_spin_unlock_irqrestore(&rq->lock, flags); + continue; + } - ontime_of(p)->migrating = 1; - get_task_struct(p); + /* + * Select cpu to migrate the task to. Return negative number + * if there is no idle cpu in sg. + */ + dst_cpu = ontime_select_target_cpu(&fit_cpus, cpu_active_mask); + if (!cpu_selected(dst_cpu)) { + raw_spin_unlock_irqrestore(&rq->lock, flags); + continue; + } - /* Set environment data */ - env->dst_cpu = dst_cpu; - env->src_rq = rq; - env->target_task = p; - env->boost_migration = boost_migration; + ontime_of(p)->migrating = 1; + get_task_struct(p); - /* Prevent active balance to use stopper for migration */ - rq->active_balance = 1; + /* Set environment data */ + env->dst_cpu = dst_cpu; + env->src_rq = rq; + env->target_task = p; + env->boost_migration = boost_migration; - cpu_rq(dst_cpu)->ontime_migrating = 1; + /* Prevent active balance to use stopper for migration */ + rq->active_balance = 1; - raw_spin_unlock_irqrestore(&rq->lock, flags); + cpu_rq(dst_cpu)->ontime_migrating = 1; - /* Migrate task through stopper */ - stop_one_cpu_nowait(cpu, ontime_migration_cpu_stop, env, + raw_spin_unlock_irqrestore(&rq->lock, flags); + + /* Migrate task through stopper */ + stop_one_cpu_nowait(cpu, ontime_migration_cpu_stop, env, &per_cpu(ontime_migration_work, cpu)); - } } spin_unlock(&om_lock); -- 2.20.1