aboutsummaryrefslogtreecommitdiffstats
path: root/mm/page-writeback.c
diff options
context:
space:
mode:
Diffstat (limited to 'mm/page-writeback.c')
-rw-r--r--mm/page-writeback.c9
1 files changed, 6 insertions, 3 deletions
diff --git a/mm/page-writeback.c b/mm/page-writeback.c
index 334852131588..bcdbbf6c4a85 100644
--- a/mm/page-writeback.c
+++ b/mm/page-writeback.c
@@ -553,6 +553,7 @@ static void background_writeout(unsigned long _min_pages)
553 global_page_state(NR_UNSTABLE_NFS) < background_thresh 553 global_page_state(NR_UNSTABLE_NFS) < background_thresh
554 && min_pages <= 0) 554 && min_pages <= 0)
555 break; 555 break;
556 wbc.more_io = 0;
556 wbc.encountered_congestion = 0; 557 wbc.encountered_congestion = 0;
557 wbc.nr_to_write = MAX_WRITEBACK_PAGES; 558 wbc.nr_to_write = MAX_WRITEBACK_PAGES;
558 wbc.pages_skipped = 0; 559 wbc.pages_skipped = 0;
@@ -560,8 +561,9 @@ static void background_writeout(unsigned long _min_pages)
560 min_pages -= MAX_WRITEBACK_PAGES - wbc.nr_to_write; 561 min_pages -= MAX_WRITEBACK_PAGES - wbc.nr_to_write;
561 if (wbc.nr_to_write > 0 || wbc.pages_skipped > 0) { 562 if (wbc.nr_to_write > 0 || wbc.pages_skipped > 0) {
562 /* Wrote less than expected */ 563 /* Wrote less than expected */
563 congestion_wait(WRITE, HZ/10); 564 if (wbc.encountered_congestion || wbc.more_io)
564 if (!wbc.encountered_congestion) 565 congestion_wait(WRITE, HZ/10);
566 else
565 break; 567 break;
566 } 568 }
567 } 569 }
@@ -626,11 +628,12 @@ static void wb_kupdate(unsigned long arg)
626 global_page_state(NR_UNSTABLE_NFS) + 628 global_page_state(NR_UNSTABLE_NFS) +
627 (inodes_stat.nr_inodes - inodes_stat.nr_unused); 629 (inodes_stat.nr_inodes - inodes_stat.nr_unused);
628 while (nr_to_write > 0) { 630 while (nr_to_write > 0) {
631 wbc.more_io = 0;
629 wbc.encountered_congestion = 0; 632 wbc.encountered_congestion = 0;
630 wbc.nr_to_write = MAX_WRITEBACK_PAGES; 633 wbc.nr_to_write = MAX_WRITEBACK_PAGES;
631 writeback_inodes(&wbc); 634 writeback_inodes(&wbc);
632 if (wbc.nr_to_write > 0) { 635 if (wbc.nr_to_write > 0) {
633 if (wbc.encountered_congestion) 636 if (wbc.encountered_congestion || wbc.more_io)
634 congestion_wait(WRITE, HZ/10); 637 congestion_wait(WRITE, HZ/10);
635 else 638 else
636 break; /* All the old data is written */ 639 break; /* All the old data is written */