diff options
-rw-r--r-- | fs/fs-writeback.c | 16 | ||||
-rw-r--r-- | include/trace/events/writeback.h | 5 |
2 files changed, 11 insertions, 10 deletions
diff --git a/fs/fs-writeback.c b/fs/fs-writeback.c index 6401cd76f109..c51029693600 100644 --- a/fs/fs-writeback.c +++ b/fs/fs-writeback.c | |||
@@ -251,7 +251,7 @@ static bool inode_dirtied_after(struct inode *inode, unsigned long t) | |||
251 | */ | 251 | */ |
252 | static int move_expired_inodes(struct list_head *delaying_queue, | 252 | static int move_expired_inodes(struct list_head *delaying_queue, |
253 | struct list_head *dispatch_queue, | 253 | struct list_head *dispatch_queue, |
254 | unsigned long *older_than_this) | 254 | struct wb_writeback_work *work) |
255 | { | 255 | { |
256 | LIST_HEAD(tmp); | 256 | LIST_HEAD(tmp); |
257 | struct list_head *pos, *node; | 257 | struct list_head *pos, *node; |
@@ -262,8 +262,8 @@ static int move_expired_inodes(struct list_head *delaying_queue, | |||
262 | 262 | ||
263 | while (!list_empty(delaying_queue)) { | 263 | while (!list_empty(delaying_queue)) { |
264 | inode = wb_inode(delaying_queue->prev); | 264 | inode = wb_inode(delaying_queue->prev); |
265 | if (older_than_this && | 265 | if (work->older_than_this && |
266 | inode_dirtied_after(inode, *older_than_this)) | 266 | inode_dirtied_after(inode, *work->older_than_this)) |
267 | break; | 267 | break; |
268 | if (sb && sb != inode->i_sb) | 268 | if (sb && sb != inode->i_sb) |
269 | do_sb_sort = 1; | 269 | do_sb_sort = 1; |
@@ -302,13 +302,13 @@ out: | |||
302 | * | | 302 | * | |
303 | * +--> dequeue for IO | 303 | * +--> dequeue for IO |
304 | */ | 304 | */ |
305 | static void queue_io(struct bdi_writeback *wb, unsigned long *older_than_this) | 305 | static void queue_io(struct bdi_writeback *wb, struct wb_writeback_work *work) |
306 | { | 306 | { |
307 | int moved; | 307 | int moved; |
308 | assert_spin_locked(&wb->list_lock); | 308 | assert_spin_locked(&wb->list_lock); |
309 | list_splice_init(&wb->b_more_io, &wb->b_io); | 309 | list_splice_init(&wb->b_more_io, &wb->b_io); |
310 | moved = move_expired_inodes(&wb->b_dirty, &wb->b_io, older_than_this); | 310 | moved = move_expired_inodes(&wb->b_dirty, &wb->b_io, work); |
311 | trace_writeback_queue_io(wb, older_than_this, moved); | 311 | trace_writeback_queue_io(wb, work, moved); |
312 | } | 312 | } |
313 | 313 | ||
314 | static int write_inode(struct inode *inode, struct writeback_control *wbc) | 314 | static int write_inode(struct inode *inode, struct writeback_control *wbc) |
@@ -651,7 +651,7 @@ long writeback_inodes_wb(struct bdi_writeback *wb, long nr_pages) | |||
651 | 651 | ||
652 | spin_lock(&wb->list_lock); | 652 | spin_lock(&wb->list_lock); |
653 | if (list_empty(&wb->b_io)) | 653 | if (list_empty(&wb->b_io)) |
654 | queue_io(wb, NULL); | 654 | queue_io(wb, &work); |
655 | __writeback_inodes_wb(wb, &work); | 655 | __writeback_inodes_wb(wb, &work); |
656 | spin_unlock(&wb->list_lock); | 656 | spin_unlock(&wb->list_lock); |
657 | 657 | ||
@@ -745,7 +745,7 @@ static long wb_writeback(struct bdi_writeback *wb, | |||
745 | 745 | ||
746 | trace_writeback_start(wb->bdi, work); | 746 | trace_writeback_start(wb->bdi, work); |
747 | if (list_empty(&wb->b_io)) | 747 | if (list_empty(&wb->b_io)) |
748 | queue_io(wb, work->older_than_this); | 748 | queue_io(wb, work); |
749 | if (work->sb) | 749 | if (work->sb) |
750 | progress = writeback_sb_inodes(work->sb, wb, work); | 750 | progress = writeback_sb_inodes(work->sb, wb, work); |
751 | else | 751 | else |
diff --git a/include/trace/events/writeback.h b/include/trace/events/writeback.h index 0ce9f06f58c2..1261db3916cc 100644 --- a/include/trace/events/writeback.h +++ b/include/trace/events/writeback.h | |||
@@ -157,9 +157,9 @@ DEFINE_WBC_EVENT(wbc_writepage); | |||
157 | 157 | ||
158 | TRACE_EVENT(writeback_queue_io, | 158 | TRACE_EVENT(writeback_queue_io, |
159 | TP_PROTO(struct bdi_writeback *wb, | 159 | TP_PROTO(struct bdi_writeback *wb, |
160 | unsigned long *older_than_this, | 160 | struct wb_writeback_work *work, |
161 | int moved), | 161 | int moved), |
162 | TP_ARGS(wb, older_than_this, moved), | 162 | TP_ARGS(wb, work, moved), |
163 | TP_STRUCT__entry( | 163 | TP_STRUCT__entry( |
164 | __array(char, name, 32) | 164 | __array(char, name, 32) |
165 | __field(unsigned long, older) | 165 | __field(unsigned long, older) |
@@ -167,6 +167,7 @@ TRACE_EVENT(writeback_queue_io, | |||
167 | __field(int, moved) | 167 | __field(int, moved) |
168 | ), | 168 | ), |
169 | TP_fast_assign( | 169 | TP_fast_assign( |
170 | unsigned long *older_than_this = work->older_than_this; | ||
170 | strncpy(__entry->name, dev_name(wb->bdi->dev), 32); | 171 | strncpy(__entry->name, dev_name(wb->bdi->dev), 32); |
171 | __entry->older = older_than_this ? *older_than_this : 0; | 172 | __entry->older = older_than_this ? *older_than_this : 0; |
172 | __entry->age = older_than_this ? | 173 | __entry->age = older_than_this ? |