diff options
Diffstat (limited to 'mm')
-rw-r--r-- | mm/page-writeback.c | 39 | ||||
-rw-r--r-- | mm/swapfile.c | 9 |
2 files changed, 26 insertions, 22 deletions
diff --git a/mm/page-writeback.c b/mm/page-writeback.c index 0b19943ecf8b..d0f2b3765f8d 100644 --- a/mm/page-writeback.c +++ b/mm/page-writeback.c | |||
@@ -683,10 +683,6 @@ void throttle_vm_writeout(gfp_t gfp_mask) | |||
683 | } | 683 | } |
684 | } | 684 | } |
685 | 685 | ||
686 | static void laptop_timer_fn(unsigned long unused); | ||
687 | |||
688 | static DEFINE_TIMER(laptop_mode_wb_timer, laptop_timer_fn, 0, 0); | ||
689 | |||
690 | /* | 686 | /* |
691 | * sysctl handler for /proc/sys/vm/dirty_writeback_centisecs | 687 | * sysctl handler for /proc/sys/vm/dirty_writeback_centisecs |
692 | */ | 688 | */ |
@@ -697,21 +693,19 @@ int dirty_writeback_centisecs_handler(ctl_table *table, int write, | |||
697 | return 0; | 693 | return 0; |
698 | } | 694 | } |
699 | 695 | ||
700 | static void do_laptop_sync(struct work_struct *work) | 696 | void laptop_mode_timer_fn(unsigned long data) |
701 | { | 697 | { |
702 | wakeup_flusher_threads(0); | 698 | struct request_queue *q = (struct request_queue *)data; |
703 | kfree(work); | 699 | int nr_pages = global_page_state(NR_FILE_DIRTY) + |
704 | } | 700 | global_page_state(NR_UNSTABLE_NFS); |
705 | 701 | ||
706 | static void laptop_timer_fn(unsigned long unused) | 702 | /* |
707 | { | 703 | * We want to write everything out, not just down to the dirty |
708 | struct work_struct *work; | 704 | * threshold |
705 | */ | ||
709 | 706 | ||
710 | work = kmalloc(sizeof(*work), GFP_ATOMIC); | 707 | if (bdi_has_dirty_io(&q->backing_dev_info)) |
711 | if (work) { | 708 | bdi_start_writeback(&q->backing_dev_info, NULL, nr_pages); |
712 | INIT_WORK(work, do_laptop_sync); | ||
713 | schedule_work(work); | ||
714 | } | ||
715 | } | 709 | } |
716 | 710 | ||
717 | /* | 711 | /* |
@@ -719,9 +713,9 @@ static void laptop_timer_fn(unsigned long unused) | |||
719 | * of all dirty data a few seconds from now. If the flush is already scheduled | 713 | * of all dirty data a few seconds from now. If the flush is already scheduled |
720 | * then push it back - the user is still using the disk. | 714 | * then push it back - the user is still using the disk. |
721 | */ | 715 | */ |
722 | void laptop_io_completion(void) | 716 | void laptop_io_completion(struct backing_dev_info *info) |
723 | { | 717 | { |
724 | mod_timer(&laptop_mode_wb_timer, jiffies + laptop_mode); | 718 | mod_timer(&info->laptop_mode_wb_timer, jiffies + laptop_mode); |
725 | } | 719 | } |
726 | 720 | ||
727 | /* | 721 | /* |
@@ -731,7 +725,14 @@ void laptop_io_completion(void) | |||
731 | */ | 725 | */ |
732 | void laptop_sync_completion(void) | 726 | void laptop_sync_completion(void) |
733 | { | 727 | { |
734 | del_timer(&laptop_mode_wb_timer); | 728 | struct backing_dev_info *bdi; |
729 | |||
730 | rcu_read_lock(); | ||
731 | |||
732 | list_for_each_entry_rcu(bdi, &bdi_list, bdi_list) | ||
733 | del_timer(&bdi->laptop_mode_wb_timer); | ||
734 | |||
735 | rcu_read_unlock(); | ||
735 | } | 736 | } |
736 | 737 | ||
737 | /* | 738 | /* |
diff --git a/mm/swapfile.c b/mm/swapfile.c index 6cd0a8f90dc7..eb086e0f4dcc 100644 --- a/mm/swapfile.c +++ b/mm/swapfile.c | |||
@@ -139,7 +139,8 @@ static int discard_swap(struct swap_info_struct *si) | |||
139 | nr_blocks = ((sector_t)se->nr_pages - 1) << (PAGE_SHIFT - 9); | 139 | nr_blocks = ((sector_t)se->nr_pages - 1) << (PAGE_SHIFT - 9); |
140 | if (nr_blocks) { | 140 | if (nr_blocks) { |
141 | err = blkdev_issue_discard(si->bdev, start_block, | 141 | err = blkdev_issue_discard(si->bdev, start_block, |
142 | nr_blocks, GFP_KERNEL, DISCARD_FL_BARRIER); | 142 | nr_blocks, GFP_KERNEL, |
143 | BLKDEV_IFL_WAIT | BLKDEV_IFL_BARRIER); | ||
143 | if (err) | 144 | if (err) |
144 | return err; | 145 | return err; |
145 | cond_resched(); | 146 | cond_resched(); |
@@ -150,7 +151,8 @@ static int discard_swap(struct swap_info_struct *si) | |||
150 | nr_blocks = (sector_t)se->nr_pages << (PAGE_SHIFT - 9); | 151 | nr_blocks = (sector_t)se->nr_pages << (PAGE_SHIFT - 9); |
151 | 152 | ||
152 | err = blkdev_issue_discard(si->bdev, start_block, | 153 | err = blkdev_issue_discard(si->bdev, start_block, |
153 | nr_blocks, GFP_KERNEL, DISCARD_FL_BARRIER); | 154 | nr_blocks, GFP_KERNEL, |
155 | BLKDEV_IFL_WAIT | BLKDEV_IFL_BARRIER); | ||
154 | if (err) | 156 | if (err) |
155 | break; | 157 | break; |
156 | 158 | ||
@@ -189,7 +191,8 @@ static void discard_swap_cluster(struct swap_info_struct *si, | |||
189 | start_block <<= PAGE_SHIFT - 9; | 191 | start_block <<= PAGE_SHIFT - 9; |
190 | nr_blocks <<= PAGE_SHIFT - 9; | 192 | nr_blocks <<= PAGE_SHIFT - 9; |
191 | if (blkdev_issue_discard(si->bdev, start_block, | 193 | if (blkdev_issue_discard(si->bdev, start_block, |
192 | nr_blocks, GFP_NOIO, DISCARD_FL_BARRIER)) | 194 | nr_blocks, GFP_NOIO, BLKDEV_IFL_WAIT | |
195 | BLKDEV_IFL_BARRIER)) | ||
193 | break; | 196 | break; |
194 | } | 197 | } |
195 | 198 | ||