提交 561d9c71 编写于 作者: J Johannes Weiner 提交者: Joseph Qi

sched: loadavg: consolidate LOAD_INT, LOAD_FRAC, CALC_LOAD

commit 8508cf3ffad4defa202b303e5b6379efc4cd9054 upstream.

There are several definitions of those functions/macros in places that
mess with fixed-point load averages.  Provide an official version.

[akpm@linux-foundation.org: fix missed conversion in block/blk-iolatency.c]
Link: http://lkml.kernel.org/r/20180828172258.3185-5-hannes@cmpxchg.orgSigned-off-by: NJohannes Weiner <hannes@cmpxchg.org>
Acked-by: NPeter Zijlstra (Intel) <peterz@infradead.org>
Tested-by: NSuren Baghdasaryan <surenb@google.com>
Tested-by: NDaniel Drake <drake@endlessm.com>
Cc: Christopher Lameter <cl@linux.com>
Cc: Ingo Molnar <mingo@redhat.com>
Cc: Johannes Weiner <jweiner@fb.com>
Cc: Mike Galbraith <efault@gmx.de>
Cc: Peter Enderborg <peter.enderborg@sony.com>
Cc: Randy Dunlap <rdunlap@infradead.org>
Cc: Shakeel Butt <shakeelb@google.com>
Cc: Tejun Heo <tj@kernel.org>
Cc: Vinayak Menon <vinmenon@codeaurora.org>
Signed-off-by: NAndrew Morton <akpm@linux-foundation.org>
Signed-off-by: NLinus Torvalds <torvalds@linux-foundation.org>
[Joseph: use stat.mean instead of stat->rqs.mean to solve conflict]
Signed-off-by: NJoseph Qi <joseph.qi@linux.alibaba.com>
Acked-by: NCaspar Zhang <caspar@linux.alibaba.com>

Conflicts:
    block/blk-iolatency.c
上级 4b7c32ef
...@@ -49,7 +49,7 @@ static int calc_freq(struct spu_gov_info_struct *info) ...@@ -49,7 +49,7 @@ static int calc_freq(struct spu_gov_info_struct *info)
cpu = info->policy->cpu; cpu = info->policy->cpu;
busy_spus = atomic_read(&cbe_spu_info[cpu_to_node(cpu)].busy_spus); busy_spus = atomic_read(&cbe_spu_info[cpu_to_node(cpu)].busy_spus);
CALC_LOAD(info->busy_spus, EXP, busy_spus * FIXED_1); info->busy_spus = calc_load(info->busy_spus, EXP, busy_spus * FIXED_1);
pr_debug("cpu %d: busy_spus=%d, info->busy_spus=%ld\n", pr_debug("cpu %d: busy_spus=%d, info->busy_spus=%ld\n",
cpu, busy_spus, info->busy_spus); cpu, busy_spus, info->busy_spus);
......
...@@ -987,9 +987,9 @@ static void spu_calc_load(void) ...@@ -987,9 +987,9 @@ static void spu_calc_load(void)
unsigned long active_tasks; /* fixed-point */ unsigned long active_tasks; /* fixed-point */
active_tasks = count_active_contexts() * FIXED_1; active_tasks = count_active_contexts() * FIXED_1;
CALC_LOAD(spu_avenrun[0], EXP_1, active_tasks); spu_avenrun[0] = calc_load(spu_avenrun[0], EXP_1, active_tasks);
CALC_LOAD(spu_avenrun[1], EXP_5, active_tasks); spu_avenrun[1] = calc_load(spu_avenrun[1], EXP_5, active_tasks);
CALC_LOAD(spu_avenrun[2], EXP_15, active_tasks); spu_avenrun[2] = calc_load(spu_avenrun[2], EXP_15, active_tasks);
} }
static void spusched_wake(struct timer_list *unused) static void spusched_wake(struct timer_list *unused)
...@@ -1071,9 +1071,6 @@ void spuctx_switch_state(struct spu_context *ctx, ...@@ -1071,9 +1071,6 @@ void spuctx_switch_state(struct spu_context *ctx,
} }
} }
#define LOAD_INT(x) ((x) >> FSHIFT)
#define LOAD_FRAC(x) LOAD_INT(((x) & (FIXED_1-1)) * 100)
static int show_spu_loadavg(struct seq_file *s, void *private) static int show_spu_loadavg(struct seq_file *s, void *private)
{ {
int a, b, c; int a, b, c;
......
...@@ -25,10 +25,6 @@ ...@@ -25,10 +25,6 @@
#include "appldata.h" #include "appldata.h"
#define LOAD_INT(x) ((x) >> FSHIFT)
#define LOAD_FRAC(x) LOAD_INT(((x) & (FIXED_1-1)) * 100)
/* /*
* OS data * OS data
* *
......
...@@ -141,7 +141,7 @@ struct iolatency_grp { ...@@ -141,7 +141,7 @@ struct iolatency_grp {
#define BLKIOLATENCY_MAX_WIN_SIZE NSEC_PER_SEC #define BLKIOLATENCY_MAX_WIN_SIZE NSEC_PER_SEC
/* /*
* These are the constants used to fake the fixed-point moving average * These are the constants used to fake the fixed-point moving average
* calculation just like load average. The call to CALC_LOAD folds * calculation just like load average. The call to calc_load() folds
* (FIXED_1 (2048) - exp_factor) * new_sample into lat_avg. The sampling * (FIXED_1 (2048) - exp_factor) * new_sample into lat_avg. The sampling
* window size is bucketed to try to approximately calculate average * window size is bucketed to try to approximately calculate average
* latency such that 1/exp (decay rate) is [1 min, 2.5 min) when windows * latency such that 1/exp (decay rate) is [1 min, 2.5 min) when windows
...@@ -505,7 +505,7 @@ static void iolatency_check_latencies(struct iolatency_grp *iolat, u64 now) ...@@ -505,7 +505,7 @@ static void iolatency_check_latencies(struct iolatency_grp *iolat, u64 now)
lat_info = &parent->child_lat; lat_info = &parent->child_lat;
/* /*
* CALC_LOAD takes in a number stored in fixed point representation. * calc_load() takes in a number stored in fixed point representation.
* Because we are using this for IO time in ns, the values stored * Because we are using this for IO time in ns, the values stored
* are significantly larger than the FIXED_1 denominator (2048). * are significantly larger than the FIXED_1 denominator (2048).
* Therefore, rounding errors in the calculation are negligible and * Therefore, rounding errors in the calculation are negligible and
...@@ -514,7 +514,9 @@ static void iolatency_check_latencies(struct iolatency_grp *iolat, u64 now) ...@@ -514,7 +514,9 @@ static void iolatency_check_latencies(struct iolatency_grp *iolat, u64 now)
exp_idx = min_t(int, BLKIOLATENCY_NR_EXP_FACTORS - 1, exp_idx = min_t(int, BLKIOLATENCY_NR_EXP_FACTORS - 1,
div64_u64(iolat->cur_win_nsec, div64_u64(iolat->cur_win_nsec,
BLKIOLATENCY_EXP_BUCKET_SIZE)); BLKIOLATENCY_EXP_BUCKET_SIZE));
CALC_LOAD(iolat->lat_avg, iolatency_exp_factors[exp_idx], stat.mean); iolat->lat_avg = calc_load(iolat->lat_avg,
iolatency_exp_factors[exp_idx],
stat.mean);
/* Everything is ok and we don't need to adjust the scale. */ /* Everything is ok and we don't need to adjust the scale. */
if (stat.mean <= iolat->min_lat_nsec && if (stat.mean <= iolat->min_lat_nsec &&
......
...@@ -131,10 +131,6 @@ struct menu_device { ...@@ -131,10 +131,6 @@ struct menu_device {
int interval_ptr; int interval_ptr;
}; };
#define LOAD_INT(x) ((x) >> FSHIFT)
#define LOAD_FRAC(x) LOAD_INT(((x) & (FIXED_1-1)) * 100)
static inline int get_loadavg(unsigned long load) static inline int get_loadavg(unsigned long load)
{ {
return LOAD_INT(load) * 10 + LOAD_FRAC(load) / 10; return LOAD_INT(load) * 10 + LOAD_FRAC(load) / 10;
......
...@@ -10,9 +10,6 @@ ...@@ -10,9 +10,6 @@
#include <linux/seqlock.h> #include <linux/seqlock.h>
#include <linux/time.h> #include <linux/time.h>
#define LOAD_INT(x) ((x) >> FSHIFT)
#define LOAD_FRAC(x) LOAD_INT(((x) & (FIXED_1-1)) * 100)
static int loadavg_proc_show(struct seq_file *m, void *v) static int loadavg_proc_show(struct seq_file *m, void *v)
{ {
unsigned long avnrun[3]; unsigned long avnrun[3];
......
...@@ -22,10 +22,23 @@ extern void get_avenrun(unsigned long *loads, unsigned long offset, int shift); ...@@ -22,10 +22,23 @@ extern void get_avenrun(unsigned long *loads, unsigned long offset, int shift);
#define EXP_5 2014 /* 1/exp(5sec/5min) */ #define EXP_5 2014 /* 1/exp(5sec/5min) */
#define EXP_15 2037 /* 1/exp(5sec/15min) */ #define EXP_15 2037 /* 1/exp(5sec/15min) */
#define CALC_LOAD(load,exp,n) \ /*
load *= exp; \ * a1 = a0 * e + a * (1 - e)
load += n*(FIXED_1-exp); \ */
load >>= FSHIFT; static inline unsigned long
calc_load(unsigned long load, unsigned long exp, unsigned long active)
{
unsigned long newload;
newload = load * exp + active * (FIXED_1 - exp);
if (active >= load)
newload += FIXED_1-1;
return newload / FIXED_1;
}
#define LOAD_INT(x) ((x) >> FSHIFT)
#define LOAD_FRAC(x) LOAD_INT(((x) & (FIXED_1-1)) * 100)
extern void calc_global_load(unsigned long ticks); extern void calc_global_load(unsigned long ticks);
......
...@@ -2556,16 +2556,11 @@ static int kdb_summary(int argc, const char **argv) ...@@ -2556,16 +2556,11 @@ static int kdb_summary(int argc, const char **argv)
} }
kdb_printf("%02ld:%02ld\n", val.uptime/(60*60), (val.uptime/60)%60); kdb_printf("%02ld:%02ld\n", val.uptime/(60*60), (val.uptime/60)%60);
/* lifted from fs/proc/proc_misc.c::loadavg_read_proc() */
#define LOAD_INT(x) ((x) >> FSHIFT)
#define LOAD_FRAC(x) LOAD_INT(((x) & (FIXED_1-1)) * 100)
kdb_printf("load avg %ld.%02ld %ld.%02ld %ld.%02ld\n", kdb_printf("load avg %ld.%02ld %ld.%02ld %ld.%02ld\n",
LOAD_INT(val.loads[0]), LOAD_FRAC(val.loads[0]), LOAD_INT(val.loads[0]), LOAD_FRAC(val.loads[0]),
LOAD_INT(val.loads[1]), LOAD_FRAC(val.loads[1]), LOAD_INT(val.loads[1]), LOAD_FRAC(val.loads[1]),
LOAD_INT(val.loads[2]), LOAD_FRAC(val.loads[2])); LOAD_INT(val.loads[2]), LOAD_FRAC(val.loads[2]));
#undef LOAD_INT
#undef LOAD_FRAC
/* Display in kilobytes */ /* Display in kilobytes */
#define K(x) ((x) << (PAGE_SHIFT - 10)) #define K(x) ((x) << (PAGE_SHIFT - 10))
kdb_printf("\nMemTotal: %8lu kB\nMemFree: %8lu kB\n" kdb_printf("\nMemTotal: %8lu kB\nMemFree: %8lu kB\n"
......
...@@ -91,21 +91,6 @@ long calc_load_fold_active(struct rq *this_rq, long adjust) ...@@ -91,21 +91,6 @@ long calc_load_fold_active(struct rq *this_rq, long adjust)
return delta; return delta;
} }
/*
* a1 = a0 * e + a * (1 - e)
*/
static unsigned long
calc_load(unsigned long load, unsigned long exp, unsigned long active)
{
unsigned long newload;
newload = load * exp + active * (FIXED_1 - exp);
if (active >= load)
newload += FIXED_1-1;
return newload / FIXED_1;
}
#ifdef CONFIG_NO_HZ_COMMON #ifdef CONFIG_NO_HZ_COMMON
/* /*
* Handle NO_HZ for the global load-average. * Handle NO_HZ for the global load-average.
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册