diff options
Diffstat (limited to 'fs/btrfs/ordered-data.c')
| -rw-r--r-- | fs/btrfs/ordered-data.c | 93 |
1 files changed, 4 insertions, 89 deletions
diff --git a/fs/btrfs/ordered-data.c b/fs/btrfs/ordered-data.c index b5d6d24726b0..897fba835f89 100644 --- a/fs/btrfs/ordered-data.c +++ b/fs/btrfs/ordered-data.c | |||
| @@ -458,7 +458,7 @@ void btrfs_start_ordered_extent(struct inode *inode, | |||
| 458 | * start IO on any dirty ones so the wait doesn't stall waiting | 458 | * start IO on any dirty ones so the wait doesn't stall waiting |
| 459 | * for pdflush to find them | 459 | * for pdflush to find them |
| 460 | */ | 460 | */ |
| 461 | btrfs_fdatawrite_range(inode->i_mapping, start, end, WB_SYNC_ALL); | 461 | filemap_fdatawrite_range(inode->i_mapping, start, end); |
| 462 | if (wait) { | 462 | if (wait) { |
| 463 | wait_event(entry->wait, test_bit(BTRFS_ORDERED_COMPLETE, | 463 | wait_event(entry->wait, test_bit(BTRFS_ORDERED_COMPLETE, |
| 464 | &entry->flags)); | 464 | &entry->flags)); |
| @@ -488,17 +488,15 @@ again: | |||
| 488 | /* start IO across the range first to instantiate any delalloc | 488 | /* start IO across the range first to instantiate any delalloc |
| 489 | * extents | 489 | * extents |
| 490 | */ | 490 | */ |
| 491 | btrfs_fdatawrite_range(inode->i_mapping, start, orig_end, WB_SYNC_ALL); | 491 | filemap_fdatawrite_range(inode->i_mapping, start, orig_end); |
| 492 | 492 | ||
| 493 | /* The compression code will leave pages locked but return from | 493 | /* The compression code will leave pages locked but return from |
| 494 | * writepage without setting the page writeback. Starting again | 494 | * writepage without setting the page writeback. Starting again |
| 495 | * with WB_SYNC_ALL will end up waiting for the IO to actually start. | 495 | * with WB_SYNC_ALL will end up waiting for the IO to actually start. |
| 496 | */ | 496 | */ |
| 497 | btrfs_fdatawrite_range(inode->i_mapping, start, orig_end, WB_SYNC_ALL); | 497 | filemap_fdatawrite_range(inode->i_mapping, start, orig_end); |
| 498 | 498 | ||
| 499 | btrfs_wait_on_page_writeback_range(inode->i_mapping, | 499 | filemap_fdatawait_range(inode->i_mapping, start, orig_end); |
| 500 | start >> PAGE_CACHE_SHIFT, | ||
| 501 | orig_end >> PAGE_CACHE_SHIFT); | ||
| 502 | 500 | ||
| 503 | end = orig_end; | 501 | end = orig_end; |
| 504 | found = 0; | 502 | found = 0; |
| @@ -716,89 +714,6 @@ out: | |||
| 716 | } | 714 | } |
| 717 | 715 | ||
| 718 | 716 | ||
| 719 | /** | ||
| 720 | * taken from mm/filemap.c because it isn't exported | ||
| 721 | * | ||
| 722 | * __filemap_fdatawrite_range - start writeback on mapping dirty pages in range | ||
| 723 | * @mapping: address space structure to write | ||
| 724 | * @start: offset in bytes where the range starts | ||
| 725 | * @end: offset in bytes where the range ends (inclusive) | ||
| 726 | * @sync_mode: enable synchronous operation | ||
| 727 | * | ||
| 728 | * Start writeback against all of a mapping's dirty pages that lie | ||
| 729 | * within the byte offsets <start, end> inclusive. | ||
| 730 | * | ||
| 731 | * If sync_mode is WB_SYNC_ALL then this is a "data integrity" operation, as | ||
| 732 | * opposed to a regular memory cleansing writeback. The difference between | ||
| 733 | * these two operations is that if a dirty page/buffer is encountered, it must | ||
| 734 | * be waited upon, and not just skipped over. | ||
| 735 | */ | ||
| 736 | int btrfs_fdatawrite_range(struct address_space *mapping, loff_t start, | ||
| 737 | loff_t end, int sync_mode) | ||
| 738 | { | ||
| 739 | struct writeback_control wbc = { | ||
| 740 | .sync_mode = sync_mode, | ||
| 741 | .nr_to_write = mapping->nrpages * 2, | ||
| 742 | .range_start = start, | ||
| 743 | .range_end = end, | ||
| 744 | }; | ||
| 745 | return btrfs_writepages(mapping, &wbc); | ||
| 746 | } | ||
| 747 | |||
| 748 | /** | ||
| 749 | * taken from mm/filemap.c because it isn't exported | ||
| 750 | * | ||
| 751 | * wait_on_page_writeback_range - wait for writeback to complete | ||
| 752 | * @mapping: target address_space | ||
| 753 | * @start: beginning page index | ||
| 754 | * @end: ending page index | ||
| 755 | * | ||
| 756 | * Wait for writeback to complete against pages indexed by start->end | ||
| 757 | * inclusive | ||
| 758 | */ | ||
| 759 | int btrfs_wait_on_page_writeback_range(struct address_space *mapping, | ||
| 760 | pgoff_t start, pgoff_t end) | ||
| 761 | { | ||
| 762 | struct pagevec pvec; | ||
| 763 | int nr_pages; | ||
| 764 | int ret = 0; | ||
| 765 | pgoff_t index; | ||
| 766 | |||
| 767 | if (end < start) | ||
| 768 | return 0; | ||
| 769 | |||
| 770 | pagevec_init(&pvec, 0); | ||
| 771 | index = start; | ||
| 772 | while ((index <= end) && | ||
| 773 | (nr_pages = pagevec_lookup_tag(&pvec, mapping, &index, | ||
| 774 | PAGECACHE_TAG_WRITEBACK, | ||
| 775 | min(end - index, (pgoff_t)PAGEVEC_SIZE-1) + 1)) != 0) { | ||
| 776 | unsigned i; | ||
| 777 | |||
| 778 | for (i = 0; i < nr_pages; i++) { | ||
| 779 | struct page *page = pvec.pages[i]; | ||
| 780 | |||
| 781 | /* until radix tree lookup accepts end_index */ | ||
| 782 | if (page->index > end) | ||
| 783 | continue; | ||
| 784 | |||
| 785 | wait_on_page_writeback(page); | ||
| 786 | if (PageError(page)) | ||
| 787 | ret = -EIO; | ||
| 788 | } | ||
| 789 | pagevec_release(&pvec); | ||
| 790 | cond_resched(); | ||
| 791 | } | ||
| 792 | |||
| 793 | /* Check for outstanding write errors */ | ||
| 794 | if (test_and_clear_bit(AS_ENOSPC, &mapping->flags)) | ||
| 795 | ret = -ENOSPC; | ||
| 796 | if (test_and_clear_bit(AS_EIO, &mapping->flags)) | ||
| 797 | ret = -EIO; | ||
| 798 | |||
| 799 | return ret; | ||
| 800 | } | ||
| 801 | |||
| 802 | /* | 717 | /* |
| 803 | * add a given inode to the list of inodes that must be fully on | 718 | * add a given inode to the list of inodes that must be fully on |
| 804 | * disk before a transaction commit finishes. | 719 | * disk before a transaction commit finishes. |
