Unverified Commit 4b2cfbda authored by Christian Brauner's avatar Christian Brauner
Browse files

nfs: port block device access to files 

Link: https://lore.kernel.org/r/20240123-vfs-bdev-file-v2-24-adbd023e19cc@kernel.org


Reviewed-by: default avatarJan Kara <jack@suse.cz>
Signed-off-by: default avatarChristian Brauner <brauner@kernel.org>
parent ac4e78bd

fs/nfs/blocklayout/blocklayout.h

+1 −1
Original line number Diff line number Diff line
@@ -108,7 +108,7 @@ struct pnfs_block_dev { 
	struct pnfs_block_dev		*children;

	u64				chunk_size;



	struct bdev_handle		*bdev_handle;

	struct file			*bdev_file;

	u64				disk_offset;



	u64				pr_key;

fs/nfs/blocklayout/dev.c

+34 −34
Original line number Diff line number Diff line
@@ -25,17 +25,17 @@ bl_free_device(struct pnfs_block_dev *dev) 
	} else {

		if (dev->pr_registered) {

			const struct pr_ops *ops =

				dev->bdev_handle->bdev->bd_disk->fops->pr_ops;

				file_bdev(dev->bdev_file)->bd_disk->fops->pr_ops;

			int error;



			error = ops->pr_register(dev->bdev_handle->bdev,

			error = ops->pr_register(file_bdev(dev->bdev_file),

				dev->pr_key, 0, false);

			if (error)

				pr_err("failed to unregister PR key.\n");

		}



		if (dev->bdev_handle)

			bdev_release(dev->bdev_handle);

		if (dev->bdev_file)

			fput(dev->bdev_file);

	}

}
@@ -169,7 +169,7 @@ static bool bl_map_simple(struct pnfs_block_dev *dev, u64 offset, 
	map->start = dev->start;

	map->len = dev->len;

	map->disk_offset = dev->disk_offset;

	map->bdev = dev->bdev_handle->bdev;

	map->bdev = file_bdev(dev->bdev_file);

	return true;

}
@@ -236,26 +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 *v = &volumes[idx];

	struct bdev_handle *bdev_handle;

	struct file *bdev_file;

	dev_t dev;



	dev = bl_resolve_deviceid(server, v, gfp_mask);

	if (!dev)

		return -EIO;



	bdev_handle = bdev_open_by_dev(dev, BLK_OPEN_READ | BLK_OPEN_WRITE,

	bdev_file = bdev_file_open_by_dev(dev, BLK_OPEN_READ | BLK_OPEN_WRITE,

				       NULL, NULL);

	if (IS_ERR(bdev_handle)) {

	if (IS_ERR(bdev_file)) {

		printk(KERN_WARNING "pNFS: failed to open device %d:%d (%ld)\n",

			MAJOR(dev), MINOR(dev), PTR_ERR(bdev_handle));

		return PTR_ERR(bdev_handle);

			MAJOR(dev), MINOR(dev), PTR_ERR(bdev_file));

		return PTR_ERR(bdev_file);

	}

	d->bdev_handle = bdev_handle;

	d->len = bdev_nr_bytes(bdev_handle->bdev);

	d->bdev_file = bdev_file;

	d->len = bdev_nr_bytes(file_bdev(bdev_file));

	d->map = bl_map_simple;



	printk(KERN_INFO "pNFS: using block device %s\n",

		bdev_handle->bdev->bd_disk->disk_name);

		file_bdev(bdev_file)->bd_disk->disk_name);

	return 0;

}
@@ -300,10 +300,10 @@ bl_validate_designator(struct pnfs_block_volume *v) 
	}

}



static struct bdev_handle *

static struct file *

bl_open_path(struct pnfs_block_volume *v, const char *prefix)

{

	struct bdev_handle *bdev_handle;

	struct file *bdev_file;

	const char *devname;



	devname = kasprintf(GFP_KERNEL, "/dev/disk/by-id/%s%*phN",
@@ -311,15 +311,15 @@ bl_open_path(struct pnfs_block_volume *v, const char *prefix) 
	if (!devname)

		return ERR_PTR(-ENOMEM);



	bdev_handle = bdev_open_by_path(devname, BLK_OPEN_READ | BLK_OPEN_WRITE,

	bdev_file = bdev_file_open_by_path(devname, BLK_OPEN_READ | BLK_OPEN_WRITE,

					NULL, NULL);

	if (IS_ERR(bdev_handle)) {

	if (IS_ERR(bdev_file)) {

		pr_warn("pNFS: failed to open device %s (%ld)\n",

			devname, PTR_ERR(bdev_handle));

			devname, PTR_ERR(bdev_file));

	}



	kfree(devname);

	return bdev_handle;

	return bdev_file;

}



static int
@@ -327,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 *v = &volumes[idx];

	struct bdev_handle *bdev_handle;

	struct file *bdev_file;

	const struct pr_ops *ops;

	int error;
@@ -340,14 +340,14 @@ bl_parse_scsi(struct nfs_server *server, struct pnfs_block_dev *d, 
	 * On other distributions like Debian, the default SCSI by-id path will

	 * point to the dm-multipath device if one exists.

	 */

	bdev_handle = bl_open_path(v, "dm-uuid-mpath-0x");

	if (IS_ERR(bdev_handle))

		bdev_handle = bl_open_path(v, "wwn-0x");

	if (IS_ERR(bdev_handle))

		return PTR_ERR(bdev_handle);

	d->bdev_handle = bdev_handle;



	d->len = bdev_nr_bytes(d->bdev_handle->bdev);

	bdev_file = bl_open_path(v, "dm-uuid-mpath-0x");

	if (IS_ERR(bdev_file))

		bdev_file = bl_open_path(v, "wwn-0x");

	if (IS_ERR(bdev_file))

		return PTR_ERR(bdev_file);

	d->bdev_file = bdev_file;



	d->len = bdev_nr_bytes(file_bdev(d->bdev_file));

	d->map = bl_map_simple;

	d->pr_key = v->scsi.pr_key;
@@ -355,20 +355,20 @@ bl_parse_scsi(struct nfs_server *server, struct pnfs_block_dev *d, 
		return -ENODEV;



	pr_info("pNFS: using block device %s (reservation key 0x%llx)\n",

		d->bdev_handle->bdev->bd_disk->disk_name, d->pr_key);

		file_bdev(d->bdev_file)->bd_disk->disk_name, d->pr_key);



	ops = d->bdev_handle->bdev->bd_disk->fops->pr_ops;

	ops = file_bdev(d->bdev_file)->bd_disk->fops->pr_ops;

	if (!ops) {

		pr_err("pNFS: block device %s does not support reservations.",

				d->bdev_handle->bdev->bd_disk->disk_name);

				file_bdev(d->bdev_file)->bd_disk->disk_name);

		error = -EINVAL;

		goto out_blkdev_put;

	}



	error = ops->pr_register(d->bdev_handle->bdev, 0, d->pr_key, true);

	error = ops->pr_register(file_bdev(d->bdev_file), 0, d->pr_key, true);

	if (error) {

		pr_err("pNFS: failed to register key for block device %s.",

				d->bdev_handle->bdev->bd_disk->disk_name);

				file_bdev(d->bdev_file)->bd_disk->disk_name);

		goto out_blkdev_put;

	}
@@ -376,7 +376,7 @@ bl_parse_scsi(struct nfs_server *server, struct pnfs_block_dev *d, 
	return 0;



out_blkdev_put:

	bdev_release(d->bdev_handle);

	fput(d->bdev_file);

	return error;

}