aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAndrea Righi <righi.andrea@gmail.com>2008-07-27 18:48:12 -0400
committerLinus Torvalds <torvalds@linux-foundation.org>2008-07-27 19:12:28 -0400
commit940389b8afad6495211614c13eb91ef7001773ec (patch)
tree92c581cc9dc7a067899a6a28e382e4099dfe8ead
parent837b41b5de356aa67abb2cadb5eef3efc7776f91 (diff)
task IO accounting: move all IO statistics in struct task_io_accounting
Simplify the code of include/linux/task_io_accounting.h. It is also more reasonable to have all the task i/o-related statistics in a single struct (task_io_accounting). Signed-off-by: Andrea Righi <righi.andrea@gmail.com> Signed-off-by: Oleg Nesterov <oleg@tv-sign.ru> Signed-off-by: Linus Torvalds <torvalds@linux-foundation.org>
-rw-r--r--fs/proc/base.c10
-rw-r--r--include/linux/sched.h12
-rw-r--r--include/linux/task_io_accounting.h17
-rw-r--r--include/linux/task_io_accounting_ops.h48
-rw-r--r--kernel/tsacct.c14
5 files changed, 44 insertions, 57 deletions
diff --git a/fs/proc/base.c b/fs/proc/base.c
index 3d94906c7aa..01ed610f9b8 100644
--- a/fs/proc/base.c
+++ b/fs/proc/base.c
@@ -2403,7 +2403,7 @@ static int proc_base_fill_cache(struct file *filp, void *dirent,
2403#ifdef CONFIG_TASK_IO_ACCOUNTING 2403#ifdef CONFIG_TASK_IO_ACCOUNTING
2404static int do_io_accounting(struct task_struct *task, char *buffer, int whole) 2404static int do_io_accounting(struct task_struct *task, char *buffer, int whole)
2405{ 2405{
2406 struct proc_io_accounting acct = task->ioac; 2406 struct task_io_accounting acct = task->ioac;
2407 unsigned long flags; 2407 unsigned long flags;
2408 2408
2409 if (whole && lock_task_sighand(task, &flags)) { 2409 if (whole && lock_task_sighand(task, &flags)) {
@@ -2423,10 +2423,10 @@ static int do_io_accounting(struct task_struct *task, char *buffer, int whole)
2423 "read_bytes: %llu\n" 2423 "read_bytes: %llu\n"
2424 "write_bytes: %llu\n" 2424 "write_bytes: %llu\n"
2425 "cancelled_write_bytes: %llu\n", 2425 "cancelled_write_bytes: %llu\n",
2426 acct.chr.rchar, acct.chr.wchar, 2426 acct.rchar, acct.wchar,
2427 acct.chr.syscr, acct.chr.syscw, 2427 acct.syscr, acct.syscw,
2428 acct.blk.read_bytes, acct.blk.write_bytes, 2428 acct.read_bytes, acct.write_bytes,
2429 acct.blk.cancelled_write_bytes); 2429 acct.cancelled_write_bytes);
2430} 2430}
2431 2431
2432static int proc_tid_io_accounting(struct task_struct *task, char *buffer) 2432static int proc_tid_io_accounting(struct task_struct *task, char *buffer)
diff --git a/include/linux/sched.h b/include/linux/sched.h
index 034c1ca6b33..5270d449ff9 100644
--- a/include/linux/sched.h
+++ b/include/linux/sched.h
@@ -505,7 +505,7 @@ struct signal_struct {
505 unsigned long nvcsw, nivcsw, cnvcsw, cnivcsw; 505 unsigned long nvcsw, nivcsw, cnvcsw, cnivcsw;
506 unsigned long min_flt, maj_flt, cmin_flt, cmaj_flt; 506 unsigned long min_flt, maj_flt, cmin_flt, cmaj_flt;
507 unsigned long inblock, oublock, cinblock, coublock; 507 unsigned long inblock, oublock, cinblock, coublock;
508 struct proc_io_accounting ioac; 508 struct task_io_accounting ioac;
509 509
510 /* 510 /*
511 * Cumulative ns of scheduled CPU time for dead threads in the 511 * Cumulative ns of scheduled CPU time for dead threads in the
@@ -1253,7 +1253,7 @@ struct task_struct {
1253 1253
1254 unsigned long ptrace_message; 1254 unsigned long ptrace_message;
1255 siginfo_t *last_siginfo; /* For ptrace use. */ 1255 siginfo_t *last_siginfo; /* For ptrace use. */
1256 struct proc_io_accounting ioac; 1256 struct task_io_accounting ioac;
1257#if defined(CONFIG_TASK_XACCT) 1257#if defined(CONFIG_TASK_XACCT)
1258 u64 acct_rss_mem1; /* accumulated rss usage */ 1258 u64 acct_rss_mem1; /* accumulated rss usage */
1259 u64 acct_vm_mem1; /* accumulated virtual memory usage */ 1259 u64 acct_vm_mem1; /* accumulated virtual memory usage */
@@ -2183,22 +2183,22 @@ extern long sched_group_rt_period(struct task_group *tg);
2183#ifdef CONFIG_TASK_XACCT 2183#ifdef CONFIG_TASK_XACCT
2184static inline void add_rchar(struct task_struct *tsk, ssize_t amt) 2184static inline void add_rchar(struct task_struct *tsk, ssize_t amt)
2185{ 2185{
2186 tsk->ioac.chr.rchar += amt; 2186 tsk->ioac.rchar += amt;
2187} 2187}
2188 2188
2189static inline void add_wchar(struct task_struct *tsk, ssize_t amt) 2189static inline void add_wchar(struct task_struct *tsk, ssize_t amt)
2190{ 2190{
2191 tsk->ioac.chr.wchar += amt; 2191 tsk->ioac.wchar += amt;
2192} 2192}
2193 2193
2194static inline void inc_syscr(struct task_struct *tsk) 2194static inline void inc_syscr(struct task_struct *tsk)
2195{ 2195{
2196 tsk->ioac.chr.syscr++; 2196 tsk->ioac.syscr++;
2197} 2197}
2198 2198
2199static inline void inc_syscw(struct task_struct *tsk) 2199static inline void inc_syscw(struct task_struct *tsk)
2200{ 2200{
2201 tsk->ioac.chr.syscw++; 2201 tsk->ioac.syscw++;
2202} 2202}
2203#else 2203#else
2204static inline void add_rchar(struct task_struct *tsk, ssize_t amt) 2204static inline void add_rchar(struct task_struct *tsk, ssize_t amt)
diff --git a/include/linux/task_io_accounting.h b/include/linux/task_io_accounting.h
index 165390f8b93..5e88afc9a2f 100644
--- a/include/linux/task_io_accounting.h
+++ b/include/linux/task_io_accounting.h
@@ -1,5 +1,5 @@
1/* 1/*
2 * proc_io_accounting: a structure which is used for recording a single task's 2 * task_io_accounting: a structure which is used for recording a single task's
3 * IO statistics. 3 * IO statistics.
4 * 4 *
5 * Don't include this header file directly - it is designed to be dragged in via 5 * Don't include this header file directly - it is designed to be dragged in via
@@ -8,8 +8,8 @@
8 * Blame akpm@osdl.org for all this. 8 * Blame akpm@osdl.org for all this.
9 */ 9 */
10 10
11struct task_io_accounting {
11#ifdef CONFIG_TASK_XACCT 12#ifdef CONFIG_TASK_XACCT
12struct task_chr_io_accounting {
13 /* bytes read */ 13 /* bytes read */
14 u64 rchar; 14 u64 rchar;
15 /* bytes written */ 15 /* bytes written */
@@ -18,14 +18,9 @@ struct task_chr_io_accounting {
18 u64 syscr; 18 u64 syscr;
19 /* # of write syscalls */ 19 /* # of write syscalls */
20 u64 syscw; 20 u64 syscw;
21};
22#else /* CONFIG_TASK_XACCT */
23struct task_chr_io_accounting {
24};
25#endif /* CONFIG_TASK_XACCT */ 21#endif /* CONFIG_TASK_XACCT */
26 22
27#ifdef CONFIG_TASK_IO_ACCOUNTING 23#ifdef CONFIG_TASK_IO_ACCOUNTING
28struct task_io_accounting {
29 /* 24 /*
30 * The number of bytes which this task has caused to be read from 25 * The number of bytes which this task has caused to be read from
31 * storage. 26 * storage.
@@ -46,13 +41,5 @@ struct task_io_accounting {
46 * information loss in doing that. 41 * information loss in doing that.
47 */ 42 */
48 u64 cancelled_write_bytes; 43 u64 cancelled_write_bytes;
49};
50#else /* CONFIG_TASK_IO_ACCOUNTING */
51struct task_io_accounting {
52};
53#endif /* CONFIG_TASK_IO_ACCOUNTING */ 44#endif /* CONFIG_TASK_IO_ACCOUNTING */
54
55struct proc_io_accounting {
56 struct task_chr_io_accounting chr;
57 struct task_io_accounting blk;
58}; 45};
diff --git a/include/linux/task_io_accounting_ops.h b/include/linux/task_io_accounting_ops.h
index e6f958ebe97..4d090f9ee60 100644
--- a/include/linux/task_io_accounting_ops.h
+++ b/include/linux/task_io_accounting_ops.h
@@ -9,7 +9,7 @@
9#ifdef CONFIG_TASK_IO_ACCOUNTING 9#ifdef CONFIG_TASK_IO_ACCOUNTING
10static inline void task_io_account_read(size_t bytes) 10static inline void task_io_account_read(size_t bytes)
11{ 11{
12 current->ioac.blk.read_bytes += bytes; 12 current->ioac.read_bytes += bytes;
13} 13}
14 14
15/* 15/*
@@ -18,12 +18,12 @@ static inline void task_io_account_read(size_t bytes)
18 */ 18 */
19static inline unsigned long task_io_get_inblock(const struct task_struct *p) 19static inline unsigned long task_io_get_inblock(const struct task_struct *p)
20{ 20{
21 return p->ioac.blk.read_bytes >> 9; 21 return p->ioac.read_bytes >> 9;
22} 22}
23 23
24static inline void task_io_account_write(size_t bytes) 24static inline void task_io_account_write(size_t bytes)
25{ 25{
26 current->ioac.blk.write_bytes += bytes; 26 current->ioac.write_bytes += bytes;
27} 27}
28 28
29/* 29/*
@@ -32,25 +32,25 @@ static inline void task_io_account_write(size_t bytes)
32 */ 32 */
33static inline unsigned long task_io_get_oublock(const struct task_struct *p) 33static inline unsigned long task_io_get_oublock(const struct task_struct *p)
34{ 34{
35 return p->ioac.blk.write_bytes >> 9; 35 return p->ioac.write_bytes >> 9;
36} 36}
37 37
38static inline void task_io_account_cancelled_write(size_t bytes) 38static inline void task_io_account_cancelled_write(size_t bytes)
39{ 39{
40 current->ioac.blk.cancelled_write_bytes += bytes; 40 current->ioac.cancelled_write_bytes += bytes;
41} 41}
42 42
43static inline void task_io_accounting_init(struct proc_io_accounting *ioac) 43static inline void task_io_accounting_init(struct task_io_accounting *ioac)
44{ 44{
45 memset(ioac, 0, sizeof(*ioac)); 45 memset(ioac, 0, sizeof(*ioac));
46} 46}
47 47
48static inline void task_blk_io_accounting_add(struct proc_io_accounting *dst, 48static inline void task_blk_io_accounting_add(struct task_io_accounting *dst,
49 struct proc_io_accounting *src) 49 struct task_io_accounting *src)
50{ 50{
51 dst->blk.read_bytes += src->blk.read_bytes; 51 dst->read_bytes += src->read_bytes;
52 dst->blk.write_bytes += src->blk.write_bytes; 52 dst->write_bytes += src->write_bytes;
53 dst->blk.cancelled_write_bytes += src->blk.cancelled_write_bytes; 53 dst->cancelled_write_bytes += src->cancelled_write_bytes;
54} 54}
55 55
56#else 56#else
@@ -77,35 +77,35 @@ static inline void task_io_account_cancelled_write(size_t bytes)
77{ 77{
78} 78}
79 79
80static inline void task_io_accounting_init(struct proc_io_accounting *ioac) 80static inline void task_io_accounting_init(struct task_io_accounting *ioac)
81{ 81{
82} 82}
83 83
84static inline void task_blk_io_accounting_add(struct proc_io_accounting *dst, 84static inline void task_blk_io_accounting_add(struct task_io_accounting *dst,
85 struct proc_io_accounting *src) 85 struct task_io_accounting *src)
86{ 86{
87} 87}
88 88
89#endif /* CONFIG_TASK_IO_ACCOUNTING */ 89#endif /* CONFIG_TASK_IO_ACCOUNTING */
90 90
91#ifdef CONFIG_TASK_XACCT 91#ifdef CONFIG_TASK_XACCT
92static inline void task_chr_io_accounting_add(struct proc_io_accounting *dst, 92static inline void task_chr_io_accounting_add(struct task_io_accounting *dst,
93 struct proc_io_accounting *src) 93 struct task_io_accounting *src)
94{ 94{
95 dst->chr.rchar += src->chr.rchar; 95 dst->rchar += src->rchar;
96 dst->chr.wchar += src->chr.wchar; 96 dst->wchar += src->wchar;
97 dst->chr.syscr += src->chr.syscr; 97 dst->syscr += src->syscr;
98 dst->chr.syscw += src->chr.syscw; 98 dst->syscw += src->syscw;
99} 99}
100#else 100#else
101static inline void task_chr_io_accounting_add(struct proc_io_accounting *dst, 101static inline void task_chr_io_accounting_add(struct task_io_accounting *dst,
102 struct proc_io_accounting *src) 102 struct task_io_accounting *src)
103{ 103{
104} 104}
105#endif /* CONFIG_TASK_XACCT */ 105#endif /* CONFIG_TASK_XACCT */
106 106
107static inline void task_io_accounting_add(struct proc_io_accounting *dst, 107static inline void task_io_accounting_add(struct task_io_accounting *dst,
108 struct proc_io_accounting *src) 108 struct task_io_accounting *src)
109{ 109{
110 task_chr_io_accounting_add(dst, src); 110 task_chr_io_accounting_add(dst, src);
111 task_blk_io_accounting_add(dst, src); 111 task_blk_io_accounting_add(dst, src);
diff --git a/kernel/tsacct.c b/kernel/tsacct.c
index f9cd2561689..8ebcd8532df 100644
--- a/kernel/tsacct.c
+++ b/kernel/tsacct.c
@@ -94,14 +94,14 @@ void xacct_add_tsk(struct taskstats *stats, struct task_struct *p)
94 stats->hiwater_vm = mm->hiwater_vm * PAGE_SIZE / KB; 94 stats->hiwater_vm = mm->hiwater_vm * PAGE_SIZE / KB;
95 mmput(mm); 95 mmput(mm);
96 } 96 }
97 stats->read_char = p->ioac.chr.rchar; 97 stats->read_char = p->ioac.rchar;
98 stats->write_char = p->ioac.chr.wchar; 98 stats->write_char = p->ioac.wchar;
99 stats->read_syscalls = p->ioac.chr.syscr; 99 stats->read_syscalls = p->ioac.syscr;
100 stats->write_syscalls = p->ioac.chr.syscw; 100 stats->write_syscalls = p->ioac.syscw;
101#ifdef CONFIG_TASK_IO_ACCOUNTING 101#ifdef CONFIG_TASK_IO_ACCOUNTING
102 stats->read_bytes = p->ioac.blk.read_bytes; 102 stats->read_bytes = p->ioac.read_bytes;
103 stats->write_bytes = p->ioac.blk.write_bytes; 103 stats->write_bytes = p->ioac.write_bytes;
104 stats->cancelled_write_bytes = p->ioac.blk.cancelled_write_bytes; 104 stats->cancelled_write_bytes = p->ioac.cancelled_write_bytes;
105#else 105#else
106 stats->read_bytes = 0; 106 stats->read_bytes = 0;
107 stats->write_bytes = 0; 107 stats->write_bytes = 0;