dm zoned: remove 'dev' argument from reclaim
[sfrench/cifs-2.6.git] / drivers / md / dm-zoned-reclaim.c
index 5daede0daf923f3546db1eef04ee8ed52bc83c27..3c8847d49e5a29bd9da8cd198e70a57fb8764cfa 100644 (file)
@@ -13,7 +13,6 @@
 
 struct dmz_reclaim {
        struct dmz_metadata     *metadata;
-       struct dmz_dev          *dev;
 
        struct delayed_work     work;
        struct workqueue_struct *wq;
@@ -59,6 +58,7 @@ static int dmz_reclaim_align_wp(struct dmz_reclaim *zrc, struct dm_zone *zone,
                                sector_t block)
 {
        struct dmz_metadata *zmd = zrc->metadata;
+       struct dmz_dev *dev = dmz_zone_to_dev(zmd, zone);
        sector_t wp_block = zone->wp_block;
        unsigned int nr_blocks;
        int ret;
@@ -74,15 +74,15 @@ static int dmz_reclaim_align_wp(struct dmz_reclaim *zrc, struct dm_zone *zone,
         * pointer and the requested position.
         */
        nr_blocks = block - wp_block;
-       ret = blkdev_issue_zeroout(zrc->dev->bdev,
+       ret = blkdev_issue_zeroout(dev->bdev,
                                   dmz_start_sect(zmd, zone) + dmz_blk2sect(wp_block),
                                   dmz_blk2sect(nr_blocks), GFP_NOIO, 0);
        if (ret) {
-               dmz_dev_err(zrc->dev,
+               dmz_dev_err(dev,
                            "Align zone %u wp %llu to %llu (wp+%u) blocks failed %d",
                            zone->id, (unsigned long long)wp_block,
                            (unsigned long long)block, nr_blocks, ret);
-               dmz_check_bdev(zrc->dev);
+               dmz_check_bdev(dev);
                return ret;
        }
 
@@ -116,7 +116,7 @@ static int dmz_reclaim_copy(struct dmz_reclaim *zrc,
                            struct dm_zone *src_zone, struct dm_zone *dst_zone)
 {
        struct dmz_metadata *zmd = zrc->metadata;
-       struct dmz_dev *dev = zrc->dev;
+       struct dmz_dev *src_dev, *dst_dev;
        struct dm_io_region src, dst;
        sector_t block = 0, end_block;
        sector_t nr_blocks;
@@ -130,13 +130,17 @@ static int dmz_reclaim_copy(struct dmz_reclaim *zrc,
        else
                end_block = dmz_zone_nr_blocks(zmd);
        src_zone_block = dmz_start_block(zmd, src_zone);
+       src_dev = dmz_zone_to_dev(zmd, src_zone);
        dst_zone_block = dmz_start_block(zmd, dst_zone);
+       dst_dev = dmz_zone_to_dev(zmd, dst_zone);
 
        if (dmz_is_seq(dst_zone))
                set_bit(DM_KCOPYD_WRITE_SEQ, &flags);
 
        while (block < end_block) {
-               if (dev->flags & DMZ_BDEV_DYING)
+               if (src_dev->flags & DMZ_BDEV_DYING)
+                       return -EIO;
+               if (dst_dev->flags & DMZ_BDEV_DYING)
                        return -EIO;
 
                /* Get a valid region from the source zone */
@@ -156,11 +160,11 @@ static int dmz_reclaim_copy(struct dmz_reclaim *zrc,
                                return ret;
                }
 
-               src.bdev = dev->bdev;
+               src.bdev = src_dev->bdev;
                src.sector = dmz_blk2sect(src_zone_block + block);
                src.count = dmz_blk2sect(nr_blocks);
 
-               dst.bdev = dev->bdev;
+               dst.bdev = dst_dev->bdev;
                dst.sector = dmz_blk2sect(dst_zone_block + block);
                dst.count = src.count;
 
@@ -194,10 +198,10 @@ static int dmz_reclaim_buf(struct dmz_reclaim *zrc, struct dm_zone *dzone)
        struct dmz_metadata *zmd = zrc->metadata;
        int ret;
 
-       dmz_dev_debug(zrc->dev,
-                     "Chunk %u, move buf zone %u (weight %u) to data zone %u (weight %u)",
-                     dzone->chunk, bzone->id, dmz_weight(bzone),
-                     dzone->id, dmz_weight(dzone));
+       DMDEBUG("(%s): Chunk %u, move buf zone %u (weight %u) to data zone %u (weight %u)",
+               dmz_metadata_label(zmd),
+               dzone->chunk, bzone->id, dmz_weight(bzone),
+               dzone->id, dmz_weight(dzone));
 
        /* Flush data zone into the buffer zone */
        ret = dmz_reclaim_copy(zrc, bzone, dzone);
@@ -233,10 +237,10 @@ static int dmz_reclaim_seq_data(struct dmz_reclaim *zrc, struct dm_zone *dzone)
        struct dmz_metadata *zmd = zrc->metadata;
        int ret = 0;
 
-       dmz_dev_debug(zrc->dev,
-                     "Chunk %u, move data zone %u (weight %u) to buf zone %u (weight %u)",
-                     chunk, dzone->id, dmz_weight(dzone),
-                     bzone->id, dmz_weight(bzone));
+       DMDEBUG("(%s): Chunk %u, move data zone %u (weight %u) to buf zone %u (weight %u)",
+               dmz_metadata_label(zmd),
+               chunk, dzone->id, dmz_weight(dzone),
+               bzone->id, dmz_weight(bzone));
 
        /* Flush data zone into the buffer zone */
        ret = dmz_reclaim_copy(zrc, dzone, bzone);
@@ -285,9 +289,9 @@ static int dmz_reclaim_rnd_data(struct dmz_reclaim *zrc, struct dm_zone *dzone)
        if (!szone)
                return -ENOSPC;
 
-       dmz_dev_debug(zrc->dev,
-                     "Chunk %u, move rnd zone %u (weight %u) to seq zone %u",
-                     chunk, dzone->id, dmz_weight(dzone), szone->id);
+       DMDEBUG("(%s): Chunk %u, move rnd zone %u (weight %u) to seq zone %u",
+               dmz_metadata_label(zmd),
+               chunk, dzone->id, dmz_weight(dzone), szone->id);
 
        /* Flush the random data zone into the sequential zone */
        ret = dmz_reclaim_copy(zrc, dzone, szone);
@@ -352,7 +356,6 @@ static int dmz_do_reclaim(struct dmz_reclaim *zrc)
                return PTR_ERR(dzone);
 
        start = jiffies;
-
        if (dmz_is_rnd(dzone)) {
                if (!dmz_weight(dzone)) {
                        /* Empty zone */
@@ -400,14 +403,14 @@ out:
 
        ret = dmz_flush_metadata(zrc->metadata);
        if (ret) {
-               dmz_dev_debug(zrc->dev,
-                             "Metadata flush for zone %u failed, err %d\n",
-                             rzone->id, ret);
+               DMDEBUG("(%s): Metadata flush for zone %u failed, err %d\n",
+                       dmz_metadata_label(zmd), rzone->id, ret);
                return ret;
        }
 
-       dmz_dev_debug(zrc->dev, "Reclaimed zone %u in %u ms",
-                     rzone->id, jiffies_to_msecs(jiffies - start));
+       DMDEBUG("(%s): Reclaimed zone %u in %u ms",
+               dmz_metadata_label(zmd),
+               rzone->id, jiffies_to_msecs(jiffies - start));
        return 0;
 }
 
@@ -500,7 +503,7 @@ static void dmz_reclaim_work(struct work_struct *work)
 /*
  * Initialize reclaim.
  */
-int dmz_ctr_reclaim(struct dmz_dev *dev, struct dmz_metadata *zmd,
+int dmz_ctr_reclaim(struct dmz_metadata *zmd,
                    struct dmz_reclaim **reclaim)
 {
        struct dmz_reclaim *zrc;
@@ -510,7 +513,6 @@ int dmz_ctr_reclaim(struct dmz_dev *dev, struct dmz_metadata *zmd,
        if (!zrc)
                return -ENOMEM;
 
-       zrc->dev = dev;
        zrc->metadata = zmd;
        zrc->atime = jiffies;