diff mbox series

btrfs: Derive compression type from extent map during reads

Message ID 20220426134734.dxxdrf2hutbmimtc@fiona (mailing list archive)
State New, archived
Headers show
Series btrfs: Derive compression type from extent map during reads | expand

Commit Message

Goldwyn Rodrigues April 26, 2022, 1:47 p.m. UTC
Derive the compression type from extent map as opposed to the bio flags
passed. This makes it more precise and not reliant on function
parameters.

Signed-off-by: Goldwyn Rodrigues <rgoldwyn@suse.com>

Comments

Nikolay Borisov April 27, 2022, 9:06 a.m. UTC | #1
On 26.04.22 г. 16:47 ч., Goldwyn Rodrigues wrote:
> Derive the compression type from extent map as opposed to the bio flags
> passed. This makes it more precise and not reliant on function
> parameters.
> 
> Signed-off-by: Goldwyn Rodrigues <rgoldwyn@suse.com>

This patch also makes extent_compress_type unused so it can be removed. 
Also extent_set_compress_type also becomes redundant and can be removed.

Reviewed-by: Nikolay Borisov <nborisov@suse.com>


<snip>
David Sterba April 27, 2022, 8:24 p.m. UTC | #2
On Wed, Apr 27, 2022 at 12:06:37PM +0300, Nikolay Borisov wrote:
> 
> 
> On 26.04.22 г. 16:47 ч., Goldwyn Rodrigues wrote:
> > Derive the compression type from extent map as opposed to the bio flags
> > passed. This makes it more precise and not reliant on function
> > parameters.
> > 
> > Signed-off-by: Goldwyn Rodrigues <rgoldwyn@suse.com>
> 
> This patch also makes extent_compress_type unused so it can be removed. 
> Also extent_set_compress_type also becomes redundant and can be removed.

I have a cleanup patch removing extent_set_compress_type so I'll rebase
it on top of that patch.
David Sterba April 28, 2022, 4:42 p.m. UTC | #3
On Tue, Apr 26, 2022 at 08:47:34AM -0500, Goldwyn Rodrigues wrote:
> Derive the compression type from extent map as opposed to the bio flags
> passed. This makes it more precise and not reliant on function
> parameters.
> 
> Signed-off-by: Goldwyn Rodrigues <rgoldwyn@suse.com>

Added to misc-next, thanks.
diff mbox series

Patch

diff --git a/fs/btrfs/compression.c b/fs/btrfs/compression.c
index 19bf36d8ffea..f14255cb4ed7 100644
--- a/fs/btrfs/compression.c
+++ b/fs/btrfs/compression.c
@@ -803,7 +803,7 @@  static noinline int add_ra_bio_pages(struct inode *inode,
  * bio we were passed and then call the bio end_io calls
  */
 blk_status_t btrfs_submit_compressed_read(struct inode *inode, struct bio *bio,
-				 int mirror_num, unsigned long bio_flags)
+				 int mirror_num)
 {
 	struct btrfs_fs_info *fs_info = btrfs_sb(inode->i_sb);
 	struct extent_map_tree *em_tree;
@@ -855,14 +855,14 @@  blk_status_t btrfs_submit_compressed_read(struct inode *inode, struct bio *bio,
 	em_len = em->len;
 	em_start = em->start;
 
-	free_extent_map(em);
-	em = NULL;
-
 	cb->len = bio->bi_iter.bi_size;
 	cb->compressed_len = compressed_len;
-	cb->compress_type = extent_compress_type(bio_flags);
+	cb->compress_type = em->compress_type;
 	cb->orig_bio = bio;
 
+	free_extent_map(em);
+	em = NULL;
+
 	nr_pages = DIV_ROUND_UP(compressed_len, PAGE_SIZE);
 	cb->compressed_pages = kcalloc(nr_pages, sizeof(struct page *),
 				       GFP_NOFS);
diff --git a/fs/btrfs/compression.h b/fs/btrfs/compression.h
index ac5b20731d2a..26d80df0b42e 100644
--- a/fs/btrfs/compression.h
+++ b/fs/btrfs/compression.h
@@ -103,7 +103,7 @@  blk_status_t btrfs_submit_compressed_write(struct btrfs_inode *inode, u64 start,
 				  struct cgroup_subsys_state *blkcg_css,
 				  bool writeback);
 blk_status_t btrfs_submit_compressed_read(struct inode *inode, struct bio *bio,
-				 int mirror_num, unsigned long bio_flags);
+				 int mirror_num);
 
 unsigned int btrfs_compress_str2level(unsigned int type, const char *str);
 
diff --git a/fs/btrfs/inode.c b/fs/btrfs/inode.c
index 5082b9c70f8c..4dfc02fbbad5 100644
--- a/fs/btrfs/inode.c
+++ b/fs/btrfs/inode.c
@@ -2547,8 +2547,7 @@  blk_status_t btrfs_submit_data_bio(struct inode *inode, struct bio *bio,
 			 * here.
 			 */
 			ret = btrfs_submit_compressed_read(inode, bio,
-							   mirror_num,
-							   bio_flags);
+							   mirror_num);
 			goto out_no_endio;
 		} else {
 			/*