diff options
Diffstat (limited to 'fs/btrfs/compression.c')
| -rw-r--r-- | fs/btrfs/compression.c | 42 |
1 files changed, 21 insertions, 21 deletions
diff --git a/fs/btrfs/compression.c b/fs/btrfs/compression.c index 369d5068ac7a..bfe42b03eaf9 100644 --- a/fs/btrfs/compression.c +++ b/fs/btrfs/compression.c | |||
| @@ -333,7 +333,7 @@ int btrfs_submit_compressed_write(struct inode *inode, u64 start, | |||
| 333 | struct compressed_bio *cb; | 333 | struct compressed_bio *cb; |
| 334 | unsigned long bytes_left; | 334 | unsigned long bytes_left; |
| 335 | struct extent_io_tree *io_tree = &BTRFS_I(inode)->io_tree; | 335 | struct extent_io_tree *io_tree = &BTRFS_I(inode)->io_tree; |
| 336 | int page_index = 0; | 336 | int pg_index = 0; |
| 337 | struct page *page; | 337 | struct page *page; |
| 338 | u64 first_byte = disk_start; | 338 | u64 first_byte = disk_start; |
| 339 | struct block_device *bdev; | 339 | struct block_device *bdev; |
| @@ -367,8 +367,8 @@ int btrfs_submit_compressed_write(struct inode *inode, u64 start, | |||
| 367 | 367 | ||
| 368 | /* create and submit bios for the compressed pages */ | 368 | /* create and submit bios for the compressed pages */ |
| 369 | bytes_left = compressed_len; | 369 | bytes_left = compressed_len; |
| 370 | for (page_index = 0; page_index < cb->nr_pages; page_index++) { | 370 | for (pg_index = 0; pg_index < cb->nr_pages; pg_index++) { |
| 371 | page = compressed_pages[page_index]; | 371 | page = compressed_pages[pg_index]; |
| 372 | page->mapping = inode->i_mapping; | 372 | page->mapping = inode->i_mapping; |
| 373 | if (bio->bi_size) | 373 | if (bio->bi_size) |
| 374 | ret = io_tree->ops->merge_bio_hook(page, 0, | 374 | ret = io_tree->ops->merge_bio_hook(page, 0, |
| @@ -433,7 +433,7 @@ static noinline int add_ra_bio_pages(struct inode *inode, | |||
| 433 | struct compressed_bio *cb) | 433 | struct compressed_bio *cb) |
| 434 | { | 434 | { |
| 435 | unsigned long end_index; | 435 | unsigned long end_index; |
| 436 | unsigned long page_index; | 436 | unsigned long pg_index; |
| 437 | u64 last_offset; | 437 | u64 last_offset; |
| 438 | u64 isize = i_size_read(inode); | 438 | u64 isize = i_size_read(inode); |
| 439 | int ret; | 439 | int ret; |
| @@ -457,13 +457,13 @@ static noinline int add_ra_bio_pages(struct inode *inode, | |||
| 457 | end_index = (i_size_read(inode) - 1) >> PAGE_CACHE_SHIFT; | 457 | end_index = (i_size_read(inode) - 1) >> PAGE_CACHE_SHIFT; |
| 458 | 458 | ||
| 459 | while (last_offset < compressed_end) { | 459 | while (last_offset < compressed_end) { |
| 460 | page_index = last_offset >> PAGE_CACHE_SHIFT; | 460 | pg_index = last_offset >> PAGE_CACHE_SHIFT; |
| 461 | 461 | ||
| 462 | if (page_index > end_index) | 462 | if (pg_index > end_index) |
| 463 | break; | 463 | break; |
| 464 | 464 | ||
| 465 | rcu_read_lock(); | 465 | rcu_read_lock(); |
| 466 | page = radix_tree_lookup(&mapping->page_tree, page_index); | 466 | page = radix_tree_lookup(&mapping->page_tree, pg_index); |
| 467 | rcu_read_unlock(); | 467 | rcu_read_unlock(); |
| 468 | if (page) { | 468 | if (page) { |
| 469 | misses++; | 469 | misses++; |
| @@ -477,7 +477,7 @@ static noinline int add_ra_bio_pages(struct inode *inode, | |||
| 477 | if (!page) | 477 | if (!page) |
| 478 | break; | 478 | break; |
| 479 | 479 | ||
| 480 | if (add_to_page_cache_lru(page, mapping, page_index, | 480 | if (add_to_page_cache_lru(page, mapping, pg_index, |
| 481 | GFP_NOFS)) { | 481 | GFP_NOFS)) { |
| 482 | page_cache_release(page); | 482 | page_cache_release(page); |
| 483 | goto next; | 483 | goto next; |
| @@ -561,7 +561,7 @@ int btrfs_submit_compressed_read(struct inode *inode, struct bio *bio, | |||
| 561 | unsigned long uncompressed_len = bio->bi_vcnt * PAGE_CACHE_SIZE; | 561 | unsigned long uncompressed_len = bio->bi_vcnt * PAGE_CACHE_SIZE; |
| 562 | unsigned long compressed_len; | 562 | unsigned long compressed_len; |
| 563 | unsigned long nr_pages; | 563 | unsigned long nr_pages; |
| 564 | unsigned long page_index; | 564 | unsigned long pg_index; |
| 565 | struct page *page; | 565 | struct page *page; |
| 566 | struct block_device *bdev; | 566 | struct block_device *bdev; |
| 567 | struct bio *comp_bio; | 567 | struct bio *comp_bio; |
| @@ -614,10 +614,10 @@ int btrfs_submit_compressed_read(struct inode *inode, struct bio *bio, | |||
| 614 | 614 | ||
| 615 | bdev = BTRFS_I(inode)->root->fs_info->fs_devices->latest_bdev; | 615 | bdev = BTRFS_I(inode)->root->fs_info->fs_devices->latest_bdev; |
| 616 | 616 | ||
| 617 | for (page_index = 0; page_index < nr_pages; page_index++) { | 617 | for (pg_index = 0; pg_index < nr_pages; pg_index++) { |
| 618 | cb->compressed_pages[page_index] = alloc_page(GFP_NOFS | | 618 | cb->compressed_pages[pg_index] = alloc_page(GFP_NOFS | |
| 619 | __GFP_HIGHMEM); | 619 | __GFP_HIGHMEM); |
| 620 | if (!cb->compressed_pages[page_index]) | 620 | if (!cb->compressed_pages[pg_index]) |
| 621 | goto fail2; | 621 | goto fail2; |
| 622 | } | 622 | } |
| 623 | cb->nr_pages = nr_pages; | 623 | cb->nr_pages = nr_pages; |
| @@ -635,8 +635,8 @@ int btrfs_submit_compressed_read(struct inode *inode, struct bio *bio, | |||
| 635 | comp_bio->bi_end_io = end_compressed_bio_read; | 635 | comp_bio->bi_end_io = end_compressed_bio_read; |
| 636 | atomic_inc(&cb->pending_bios); | 636 | atomic_inc(&cb->pending_bios); |
| 637 | 637 | ||
| 638 | for (page_index = 0; page_index < nr_pages; page_index++) { | 638 | for (pg_index = 0; pg_index < nr_pages; pg_index++) { |
| 639 | page = cb->compressed_pages[page_index]; | 639 | page = cb->compressed_pages[pg_index]; |
| 640 | page->mapping = inode->i_mapping; | 640 | page->mapping = inode->i_mapping; |
| 641 | page->index = em_start >> PAGE_CACHE_SHIFT; | 641 | page->index = em_start >> PAGE_CACHE_SHIFT; |
| 642 | 642 | ||
| @@ -703,8 +703,8 @@ int btrfs_submit_compressed_read(struct inode *inode, struct bio *bio, | |||
| 703 | return 0; | 703 | return 0; |
| 704 | 704 | ||
| 705 | fail2: | 705 | fail2: |
| 706 | for (page_index = 0; page_index < nr_pages; page_index++) | 706 | for (pg_index = 0; pg_index < nr_pages; pg_index++) |
| 707 | free_page((unsigned long)cb->compressed_pages[page_index]); | 707 | free_page((unsigned long)cb->compressed_pages[pg_index]); |
| 708 | 708 | ||
| 709 | kfree(cb->compressed_pages); | 709 | kfree(cb->compressed_pages); |
| 710 | fail1: | 710 | fail1: |
| @@ -946,7 +946,7 @@ void btrfs_exit_compress(void) | |||
| 946 | int btrfs_decompress_buf2page(char *buf, unsigned long buf_start, | 946 | int btrfs_decompress_buf2page(char *buf, unsigned long buf_start, |
| 947 | unsigned long total_out, u64 disk_start, | 947 | unsigned long total_out, u64 disk_start, |
| 948 | struct bio_vec *bvec, int vcnt, | 948 | struct bio_vec *bvec, int vcnt, |
| 949 | unsigned long *page_index, | 949 | unsigned long *pg_index, |
| 950 | unsigned long *pg_offset) | 950 | unsigned long *pg_offset) |
| 951 | { | 951 | { |
| 952 | unsigned long buf_offset; | 952 | unsigned long buf_offset; |
| @@ -955,7 +955,7 @@ int btrfs_decompress_buf2page(char *buf, unsigned long buf_start, | |||
| 955 | unsigned long working_bytes = total_out - buf_start; | 955 | unsigned long working_bytes = total_out - buf_start; |
| 956 | unsigned long bytes; | 956 | unsigned long bytes; |
| 957 | char *kaddr; | 957 | char *kaddr; |
| 958 | struct page *page_out = bvec[*page_index].bv_page; | 958 | struct page *page_out = bvec[*pg_index].bv_page; |
| 959 | 959 | ||
| 960 | /* | 960 | /* |
| 961 | * start byte is the first byte of the page we're currently | 961 | * start byte is the first byte of the page we're currently |
| @@ -996,11 +996,11 @@ int btrfs_decompress_buf2page(char *buf, unsigned long buf_start, | |||
| 996 | 996 | ||
| 997 | /* check if we need to pick another page */ | 997 | /* check if we need to pick another page */ |
| 998 | if (*pg_offset == PAGE_CACHE_SIZE) { | 998 | if (*pg_offset == PAGE_CACHE_SIZE) { |
| 999 | (*page_index)++; | 999 | (*pg_index)++; |
| 1000 | if (*page_index >= vcnt) | 1000 | if (*pg_index >= vcnt) |
| 1001 | return 0; | 1001 | return 0; |
| 1002 | 1002 | ||
| 1003 | page_out = bvec[*page_index].bv_page; | 1003 | page_out = bvec[*pg_index].bv_page; |
| 1004 | *pg_offset = 0; | 1004 | *pg_offset = 0; |
| 1005 | start_byte = page_offset(page_out) - disk_start; | 1005 | start_byte = page_offset(page_out) - disk_start; |
| 1006 | 1006 | ||
