^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 1) // SPDX-License-Identifier: GPL-2.0-or-later
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 2) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 3) * RDMA Network Block Driver
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 4) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 5) * Copyright (c) 2014 - 2018 ProfitBricks GmbH. All rights reserved.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 6) * Copyright (c) 2018 - 2019 1&1 IONOS Cloud GmbH. All rights reserved.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 7) * Copyright (c) 2019 - 2020 1&1 IONOS SE. All rights reserved.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 8) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 9) #undef pr_fmt
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 10) #define pr_fmt(fmt) KBUILD_MODNAME " L" __stringify(__LINE__) ": " fmt
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 11)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 12) #include "rnbd-srv-dev.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 13) #include "rnbd-log.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 14)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 15) struct rnbd_dev *rnbd_dev_open(const char *path, fmode_t flags,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 16) struct bio_set *bs)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 17) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 18) struct rnbd_dev *dev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 19) int ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 20)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 21) dev = kzalloc(sizeof(*dev), GFP_KERNEL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 22) if (!dev)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 23) return ERR_PTR(-ENOMEM);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 24)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 25) dev->blk_open_flags = flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 26) dev->bdev = blkdev_get_by_path(path, flags, THIS_MODULE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 27) ret = PTR_ERR_OR_ZERO(dev->bdev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 28) if (ret)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 29) goto err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 30)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 31) dev->blk_open_flags = flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 32) bdevname(dev->bdev, dev->name);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 33) dev->ibd_bio_set = bs;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 34)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 35) return dev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 36)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 37) err:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 38) kfree(dev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 39) return ERR_PTR(ret);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 40) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 41)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 42) void rnbd_dev_close(struct rnbd_dev *dev)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 43) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 44) blkdev_put(dev->bdev, dev->blk_open_flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 45) kfree(dev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 46) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 47)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 48) void rnbd_dev_bi_end_io(struct bio *bio)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 49) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 50) struct rnbd_dev_blk_io *io = bio->bi_private;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 51)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 52) rnbd_endio(io->priv, blk_status_to_errno(bio->bi_status));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 53) bio_put(bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 54) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 55)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 56) /**
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 57) * rnbd_bio_map_kern - map kernel address into bio
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 58) * @data: pointer to buffer to map
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 59) * @bs: bio_set to use.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 60) * @len: length in bytes
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 61) * @gfp_mask: allocation flags for bio allocation
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 62) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 63) * Map the kernel address into a bio suitable for io to a block
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 64) * device. Returns an error pointer in case of error.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 65) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 66) struct bio *rnbd_bio_map_kern(void *data, struct bio_set *bs,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 67) unsigned int len, gfp_t gfp_mask)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 68) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 69) unsigned long kaddr = (unsigned long)data;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 70) unsigned long end = (kaddr + len + PAGE_SIZE - 1) >> PAGE_SHIFT;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 71) unsigned long start = kaddr >> PAGE_SHIFT;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 72) const int nr_pages = end - start;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 73) int offset, i;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 74) struct bio *bio;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 75)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 76) bio = bio_alloc_bioset(gfp_mask, nr_pages, bs);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 77) if (!bio)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 78) return ERR_PTR(-ENOMEM);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 79)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 80) offset = offset_in_page(kaddr);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 81) for (i = 0; i < nr_pages; i++) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 82) unsigned int bytes = PAGE_SIZE - offset;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 83)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 84) if (len <= 0)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 85) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 86)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 87) if (bytes > len)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 88) bytes = len;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 89)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 90) if (bio_add_page(bio, virt_to_page(data), bytes,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 91) offset) < bytes) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 92) /* we don't support partial mappings */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 93) bio_put(bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 94) return ERR_PTR(-EINVAL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 95) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 96)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 97) data += bytes;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 98) len -= bytes;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 99) offset = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 100) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 101)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 102) return bio;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 103) }