Commit 3fe5d9fb authored by Jan Kara's avatar Jan Kara Committed by Christian Brauner

nfs/blocklayout: Convert to use bdev_open_by_dev/path()

Convert block device handling to use bdev_open_by_dev/path() and pass
the handle around.

CC: linux-nfs@vger.kernel.org
CC: Trond Myklebust <trond.myklebust@hammerspace.com>
CC: Anna Schumaker <anna@kernel.org>
Acked-by: default avatarChristoph Hellwig <hch@lst.de>
Reviewed-by: default avatarChristian Brauner <brauner@kernel.org>
Signed-off-by: default avatarJan Kara <jack@suse.cz>
Link: https://lore.kernel.org/r/20230927093442.25915-25-jack@suse.czSigned-off-by: default avatarChristian Brauner <brauner@kernel.org>
parent 898c57f4
...@@ -108,7 +108,7 @@ struct pnfs_block_dev { ...@@ -108,7 +108,7 @@ struct pnfs_block_dev {
struct pnfs_block_dev *children; struct pnfs_block_dev *children;
u64 chunk_size; u64 chunk_size;
struct block_device *bdev; struct bdev_handle *bdev_handle;
u64 disk_offset; u64 disk_offset;
u64 pr_key; u64 pr_key;
......
...@@ -25,17 +25,17 @@ bl_free_device(struct pnfs_block_dev *dev) ...@@ -25,17 +25,17 @@ bl_free_device(struct pnfs_block_dev *dev)
} else { } else {
if (dev->pr_registered) { if (dev->pr_registered) {
const struct pr_ops *ops = const struct pr_ops *ops =
dev->bdev->bd_disk->fops->pr_ops; dev->bdev_handle->bdev->bd_disk->fops->pr_ops;
int error; int error;
error = ops->pr_register(dev->bdev, dev->pr_key, 0, error = ops->pr_register(dev->bdev_handle->bdev,
false); dev->pr_key, 0, false);
if (error) if (error)
pr_err("failed to unregister PR key.\n"); pr_err("failed to unregister PR key.\n");
} }
if (dev->bdev) if (dev->bdev_handle)
blkdev_put(dev->bdev, NULL); bdev_release(dev->bdev_handle);
} }
} }
...@@ -169,7 +169,7 @@ static bool bl_map_simple(struct pnfs_block_dev *dev, u64 offset, ...@@ -169,7 +169,7 @@ static bool bl_map_simple(struct pnfs_block_dev *dev, u64 offset,
map->start = dev->start; map->start = dev->start;
map->len = dev->len; map->len = dev->len;
map->disk_offset = dev->disk_offset; map->disk_offset = dev->disk_offset;
map->bdev = dev->bdev; map->bdev = dev->bdev_handle->bdev;
return true; return true;
} }
...@@ -236,28 +236,26 @@ bl_parse_simple(struct nfs_server *server, struct pnfs_block_dev *d, ...@@ -236,28 +236,26 @@ bl_parse_simple(struct nfs_server *server, struct pnfs_block_dev *d,
struct pnfs_block_volume *volumes, int idx, gfp_t gfp_mask) struct pnfs_block_volume *volumes, int idx, gfp_t gfp_mask)
{ {
struct pnfs_block_volume *v = &volumes[idx]; struct pnfs_block_volume *v = &volumes[idx];
struct block_device *bdev; struct bdev_handle *bdev_handle;
dev_t dev; dev_t dev;
dev = bl_resolve_deviceid(server, v, gfp_mask); dev = bl_resolve_deviceid(server, v, gfp_mask);
if (!dev) if (!dev)
return -EIO; return -EIO;
bdev = blkdev_get_by_dev(dev, BLK_OPEN_READ | BLK_OPEN_WRITE, NULL, bdev_handle = bdev_open_by_dev(dev, BLK_OPEN_READ | BLK_OPEN_WRITE,
NULL); NULL, NULL);
if (IS_ERR(bdev)) { if (IS_ERR(bdev_handle)) {
printk(KERN_WARNING "pNFS: failed to open device %d:%d (%ld)\n", printk(KERN_WARNING "pNFS: failed to open device %d:%d (%ld)\n",
MAJOR(dev), MINOR(dev), PTR_ERR(bdev)); MAJOR(dev), MINOR(dev), PTR_ERR(bdev_handle));
return PTR_ERR(bdev); return PTR_ERR(bdev_handle);
} }
d->bdev = bdev; d->bdev_handle = bdev_handle;
d->len = bdev_nr_bytes(bdev_handle->bdev);
d->len = bdev_nr_bytes(d->bdev);
d->map = bl_map_simple; d->map = bl_map_simple;
printk(KERN_INFO "pNFS: using block device %s\n", printk(KERN_INFO "pNFS: using block device %s\n",
d->bdev->bd_disk->disk_name); bdev_handle->bdev->bd_disk->disk_name);
return 0; return 0;
} }
...@@ -302,10 +300,10 @@ bl_validate_designator(struct pnfs_block_volume *v) ...@@ -302,10 +300,10 @@ bl_validate_designator(struct pnfs_block_volume *v)
} }
} }
static struct block_device * static struct bdev_handle *
bl_open_path(struct pnfs_block_volume *v, const char *prefix) bl_open_path(struct pnfs_block_volume *v, const char *prefix)
{ {
struct block_device *bdev; struct bdev_handle *bdev_handle;
const char *devname; const char *devname;
devname = kasprintf(GFP_KERNEL, "/dev/disk/by-id/%s%*phN", devname = kasprintf(GFP_KERNEL, "/dev/disk/by-id/%s%*phN",
...@@ -313,15 +311,15 @@ bl_open_path(struct pnfs_block_volume *v, const char *prefix) ...@@ -313,15 +311,15 @@ bl_open_path(struct pnfs_block_volume *v, const char *prefix)
if (!devname) if (!devname)
return ERR_PTR(-ENOMEM); return ERR_PTR(-ENOMEM);
bdev = blkdev_get_by_path(devname, BLK_OPEN_READ | BLK_OPEN_WRITE, NULL, bdev_handle = bdev_open_by_path(devname, BLK_OPEN_READ | BLK_OPEN_WRITE,
NULL); NULL, NULL);
if (IS_ERR(bdev)) { if (IS_ERR(bdev_handle)) {
pr_warn("pNFS: failed to open device %s (%ld)\n", pr_warn("pNFS: failed to open device %s (%ld)\n",
devname, PTR_ERR(bdev)); devname, PTR_ERR(bdev_handle));
} }
kfree(devname); kfree(devname);
return bdev; return bdev_handle;
} }
static int static int
...@@ -329,7 +327,7 @@ bl_parse_scsi(struct nfs_server *server, struct pnfs_block_dev *d, ...@@ -329,7 +327,7 @@ bl_parse_scsi(struct nfs_server *server, struct pnfs_block_dev *d,
struct pnfs_block_volume *volumes, int idx, gfp_t gfp_mask) struct pnfs_block_volume *volumes, int idx, gfp_t gfp_mask)
{ {
struct pnfs_block_volume *v = &volumes[idx]; struct pnfs_block_volume *v = &volumes[idx];
struct block_device *bdev; struct bdev_handle *bdev_handle;
const struct pr_ops *ops; const struct pr_ops *ops;
int error; int error;
...@@ -342,32 +340,32 @@ bl_parse_scsi(struct nfs_server *server, struct pnfs_block_dev *d, ...@@ -342,32 +340,32 @@ bl_parse_scsi(struct nfs_server *server, struct pnfs_block_dev *d,
* On other distributions like Debian, the default SCSI by-id path will * On other distributions like Debian, the default SCSI by-id path will
* point to the dm-multipath device if one exists. * point to the dm-multipath device if one exists.
*/ */
bdev = bl_open_path(v, "dm-uuid-mpath-0x"); bdev_handle = bl_open_path(v, "dm-uuid-mpath-0x");
if (IS_ERR(bdev)) if (IS_ERR(bdev_handle))
bdev = bl_open_path(v, "wwn-0x"); bdev_handle = bl_open_path(v, "wwn-0x");
if (IS_ERR(bdev)) if (IS_ERR(bdev_handle))
return PTR_ERR(bdev); return PTR_ERR(bdev_handle);
d->bdev = bdev; d->bdev_handle = bdev_handle;
d->len = bdev_nr_bytes(d->bdev); d->len = bdev_nr_bytes(d->bdev_handle->bdev);
d->map = bl_map_simple; d->map = bl_map_simple;
d->pr_key = v->scsi.pr_key; d->pr_key = v->scsi.pr_key;
pr_info("pNFS: using block device %s (reservation key 0x%llx)\n", pr_info("pNFS: using block device %s (reservation key 0x%llx)\n",
d->bdev->bd_disk->disk_name, d->pr_key); d->bdev_handle->bdev->bd_disk->disk_name, d->pr_key);
ops = d->bdev->bd_disk->fops->pr_ops; ops = d->bdev_handle->bdev->bd_disk->fops->pr_ops;
if (!ops) { if (!ops) {
pr_err("pNFS: block device %s does not support reservations.", pr_err("pNFS: block device %s does not support reservations.",
d->bdev->bd_disk->disk_name); d->bdev_handle->bdev->bd_disk->disk_name);
error = -EINVAL; error = -EINVAL;
goto out_blkdev_put; goto out_blkdev_put;
} }
error = ops->pr_register(d->bdev, 0, d->pr_key, true); error = ops->pr_register(d->bdev_handle->bdev, 0, d->pr_key, true);
if (error) { if (error) {
pr_err("pNFS: failed to register key for block device %s.", pr_err("pNFS: failed to register key for block device %s.",
d->bdev->bd_disk->disk_name); d->bdev_handle->bdev->bd_disk->disk_name);
goto out_blkdev_put; goto out_blkdev_put;
} }
...@@ -375,7 +373,7 @@ bl_parse_scsi(struct nfs_server *server, struct pnfs_block_dev *d, ...@@ -375,7 +373,7 @@ bl_parse_scsi(struct nfs_server *server, struct pnfs_block_dev *d,
return 0; return 0;
out_blkdev_put: out_blkdev_put:
blkdev_put(d->bdev, NULL); bdev_release(d->bdev_handle);
return error; return error;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment