btrfs: reduce arguments for decompress_bio ops
authorAnand Jain <anand.jain@oracle.com>
Fri, 26 May 2017 07:44:59 +0000 (15:44 +0800)
committerDavid Sterba <dsterba@suse.com>
Mon, 19 Jun 2017 16:26:00 +0000 (18:26 +0200)
struct compressed_bio pointer can be used instead.

Signed-off-by: Anand Jain <anand.jain@oracle.com>
Reviewed-by: Nikolay Borisov <nborisov@suse.com>
Signed-off-by: David Sterba <dsterba@suse.com>
fs/btrfs/compression.c
fs/btrfs/compression.h
fs/btrfs/lzo.c
fs/btrfs/zlib.c

index ce57fea2a66f281f346aa919a5cc99690164bac4..ba511dd454d573553a21e5274551daeeef7c9249 100644 (file)
 #include "extent_io.h"
 #include "extent_map.h"
 
-struct compressed_bio {
-       /* number of bios pending for this compressed extent */
-       refcount_t pending_bios;
-
-       /* the pages with the compressed data on them */
-       struct page **compressed_pages;
-
-       /* inode that owns this data */
-       struct inode *inode;
-
-       /* starting offset in the inode for our pages */
-       u64 start;
-
-       /* number of bytes in the inode we're working on */
-       unsigned long len;
-
-       /* number of bytes on disk */
-       unsigned long compressed_len;
-
-       /* the compression algorithm for this bio */
-       int compress_type;
-
-       /* number of compressed pages in the array */
-       unsigned long nr_pages;
-
-       /* IO errors */
-       int errors;
-       int mirror_num;
-
-       /* for reads, this is the bio we are copying the data into */
-       struct bio *orig_bio;
-
-       /*
-        * the start of a variable length array of checksums only
-        * used by reads
-        */
-       u32 sums;
-};
-
 static int btrfs_decompress_bio(struct compressed_bio *cb);
 
 static inline int compressed_bio_size(struct btrfs_fs_info *fs_info,
@@ -963,12 +924,9 @@ static int btrfs_decompress_bio(struct compressed_bio *cb)
        int type = cb->compress_type;
 
        workspace = find_workspace(type);
-
-       ret = btrfs_compress_op[type - 1]->decompress_bio(workspace,
-                       cb->compressed_pages, cb->start, cb->orig_bio,
-                       cb->compressed_len);
-
+       ret = btrfs_compress_op[type - 1]->decompress_bio(workspace, cb);
        free_workspace(type, workspace);
+
        return ret;
 }
 
index 39ec43ab8df1b72bf9a7cc57b0a90ea4e5fb8602..89bcf975efb8b29dbacad15f260c084766966417 100644 (file)
 /* Maximum size of data before compression */
 #define BTRFS_MAX_UNCOMPRESSED         (SZ_128K)
 
+struct compressed_bio {
+       /* number of bios pending for this compressed extent */
+       refcount_t pending_bios;
+
+       /* the pages with the compressed data on them */
+       struct page **compressed_pages;
+
+       /* inode that owns this data */
+       struct inode *inode;
+
+       /* starting offset in the inode for our pages */
+       u64 start;
+
+       /* number of bytes in the inode we're working on */
+       unsigned long len;
+
+       /* number of bytes on disk */
+       unsigned long compressed_len;
+
+       /* the compression algorithm for this bio */
+       int compress_type;
+
+       /* number of compressed pages in the array */
+       unsigned long nr_pages;
+
+       /* IO errors */
+       int errors;
+       int mirror_num;
+
+       /* for reads, this is the bio we are copying the data into */
+       struct bio *orig_bio;
+
+       /*
+        * the start of a variable length array of checksums only
+        * used by reads
+        */
+       u32 sums;
+};
+
 void btrfs_init_compress(void);
 void btrfs_exit_compress(void);
 
@@ -78,10 +117,7 @@ struct btrfs_compress_op {
                              unsigned long *total_out);
 
        int (*decompress_bio)(struct list_head *workspace,
-                                struct page **pages_in,
-                                u64 disk_start,
-                                struct bio *orig_bio,
-                                size_t srclen);
+                               struct compressed_bio *cb);
 
        int (*decompress)(struct list_head *workspace,
                          unsigned char *data_in,
index f48c8c14dc144b63a5e4d1d8c355106649614bba..5995563ca56f41911ccb70ede429a9df17423bea 100644 (file)
@@ -25,6 +25,7 @@
 #include <linux/pagemap.h>
 #include <linux/bio.h>
 #include <linux/lzo.h>
+#include <linux/refcount.h>
 #include "compression.h"
 
 #define LZO_LEN        4
@@ -254,16 +255,13 @@ out:
        return ret;
 }
 
-static int lzo_decompress_bio(struct list_head *ws,
-                                struct page **pages_in,
-                                u64 disk_start,
-                                struct bio *orig_bio,
-                                size_t srclen)
+static int lzo_decompress_bio(struct list_head *ws, struct compressed_bio *cb)
 {
        struct workspace *workspace = list_entry(ws, struct workspace, list);
        int ret = 0, ret2;
        char *data_in;
        unsigned long page_in_index = 0;
+       size_t srclen = cb->compressed_len;
        unsigned long total_pages_in = DIV_ROUND_UP(srclen, PAGE_SIZE);
        unsigned long buf_start;
        unsigned long buf_offset = 0;
@@ -278,6 +276,9 @@ static int lzo_decompress_bio(struct list_head *ws,
        unsigned long tot_len;
        char *buf;
        bool may_late_unmap, need_unmap;
+       struct page **pages_in = cb->compressed_pages;
+       u64 disk_start = cb->start;
+       struct bio *orig_bio = cb->orig_bio;
 
        data_in = kmap(pages_in[0]);
        tot_len = read_compress_length(data_in);
index 135b10823c6dbd1d20171234d5db60961aff1377..d5446e18bb5929978da9f107c45059864c2e28aa 100644 (file)
@@ -30,6 +30,7 @@
 #include <linux/sched.h>
 #include <linux/pagemap.h>
 #include <linux/bio.h>
+#include <linux/refcount.h>
 #include "compression.h"
 
 struct workspace {
@@ -211,10 +212,7 @@ out:
        return ret;
 }
 
-static int zlib_decompress_bio(struct list_head *ws, struct page **pages_in,
-                                 u64 disk_start,
-                                 struct bio *orig_bio,
-                                 size_t srclen)
+static int zlib_decompress_bio(struct list_head *ws, struct compressed_bio *cb)
 {
        struct workspace *workspace = list_entry(ws, struct workspace, list);
        int ret = 0, ret2;
@@ -222,8 +220,12 @@ static int zlib_decompress_bio(struct list_head *ws, struct page **pages_in,
        char *data_in;
        size_t total_out = 0;
        unsigned long page_in_index = 0;
+       size_t srclen = cb->compressed_len;
        unsigned long total_pages_in = DIV_ROUND_UP(srclen, PAGE_SIZE);
        unsigned long buf_start;
+       struct page **pages_in = cb->compressed_pages;
+       u64 disk_start = cb->start;
+       struct bio *orig_bio = cb->orig_bio;
 
        data_in = kmap(pages_in[page_in_index]);
        workspace->strm.next_in = data_in;