dm-linear.c 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182
  1. /*
  2. * Copyright (C) 2001-2003 Sistina Software (UK) Limited.
  3. *
  4. * This file is released under the GPL.
  5. */
  6. #include "dm.h"
  7. #include <linux/module.h>
  8. #include <linux/init.h>
  9. #include <linux/blkdev.h>
  10. #include <linux/bio.h>
  11. #include <linux/slab.h>
  12. #include <linux/device-mapper.h>
  13. #define DM_MSG_PREFIX "linear"
  14. /*
  15. * Linear: maps a linear range of a device.
  16. */
  17. struct linear_c {
  18. struct dm_dev *dev;
  19. sector_t start;
  20. };
  21. /*
  22. * Construct a linear mapping: <dev_path> <offset>
  23. */
  24. static int linear_ctr(struct dm_target *ti, unsigned int argc, char **argv)
  25. {
  26. struct linear_c *lc;
  27. unsigned long long tmp;
  28. char dummy;
  29. if (argc != 2) {
  30. ti->error = "Invalid argument count";
  31. return -EINVAL;
  32. }
  33. lc = kmalloc(sizeof(*lc), GFP_KERNEL);
  34. if (lc == NULL) {
  35. ti->error = "dm-linear: Cannot allocate linear context";
  36. return -ENOMEM;
  37. }
  38. if (sscanf(argv[1], "%llu%c", &tmp, &dummy) != 1) {
  39. ti->error = "dm-linear: Invalid device sector";
  40. goto bad;
  41. }
  42. lc->start = tmp;
  43. if (dm_get_device(ti, argv[0], dm_table_get_mode(ti->table), &lc->dev)) {
  44. ti->error = "dm-linear: Device lookup failed";
  45. goto bad;
  46. }
  47. ti->num_flush_requests = 1;
  48. ti->num_discard_requests = 1;
  49. ti->private = lc;
  50. return 0;
  51. bad:
  52. kfree(lc);
  53. return -EINVAL;
  54. }
  55. static void linear_dtr(struct dm_target *ti)
  56. {
  57. struct linear_c *lc = (struct linear_c *) ti->private;
  58. dm_put_device(ti, lc->dev);
  59. kfree(lc);
  60. }
  61. static sector_t linear_map_sector(struct dm_target *ti, sector_t bi_sector)
  62. {
  63. struct linear_c *lc = ti->private;
  64. return lc->start + dm_target_offset(ti, bi_sector);
  65. }
  66. static void linear_map_bio(struct dm_target *ti, struct bio *bio)
  67. {
  68. struct linear_c *lc = ti->private;
  69. bio->bi_bdev = lc->dev->bdev;
  70. if (bio_sectors(bio))
  71. bio->bi_sector = linear_map_sector(ti, bio->bi_sector);
  72. }
  73. static int linear_map(struct dm_target *ti, struct bio *bio,
  74. union map_info *map_context)
  75. {
  76. linear_map_bio(ti, bio);
  77. return DM_MAPIO_REMAPPED;
  78. }
  79. static void linear_status(struct dm_target *ti, status_type_t type,
  80. char *result, unsigned int maxlen)
  81. {
  82. struct linear_c *lc = (struct linear_c *) ti->private;
  83. switch (type) {
  84. case STATUSTYPE_INFO:
  85. result[0] = '\0';
  86. break;
  87. case STATUSTYPE_TABLE:
  88. snprintf(result, maxlen, "%s %llu", lc->dev->name,
  89. (unsigned long long)lc->start);
  90. break;
  91. }
  92. }
  93. static int linear_ioctl(struct dm_target *ti, unsigned int cmd,
  94. unsigned long arg)
  95. {
  96. struct linear_c *lc = (struct linear_c *) ti->private;
  97. struct dm_dev *dev = lc->dev;
  98. int r = 0;
  99. /*
  100. * Only pass ioctls through if the device sizes match exactly.
  101. */
  102. if (lc->start ||
  103. ti->len != i_size_read(dev->bdev->bd_inode) >> SECTOR_SHIFT)
  104. r = scsi_verify_blk_ioctl(NULL, cmd);
  105. return r ? : __blkdev_driver_ioctl(dev->bdev, dev->mode, cmd, arg);
  106. }
  107. static int linear_merge(struct dm_target *ti, struct bvec_merge_data *bvm,
  108. struct bio_vec *biovec, int max_size)
  109. {
  110. struct linear_c *lc = ti->private;
  111. struct request_queue *q = bdev_get_queue(lc->dev->bdev);
  112. if (!q->merge_bvec_fn)
  113. return max_size;
  114. bvm->bi_bdev = lc->dev->bdev;
  115. bvm->bi_sector = linear_map_sector(ti, bvm->bi_sector);
  116. return min(max_size, q->merge_bvec_fn(q, bvm, biovec));
  117. }
  118. static int linear_iterate_devices(struct dm_target *ti,
  119. iterate_devices_callout_fn fn, void *data)
  120. {
  121. struct linear_c *lc = ti->private;
  122. return fn(ti, lc->dev, lc->start, ti->len, data);
  123. }
  124. static struct target_type linear_target = {
  125. .name = "linear",
  126. .version = {1, 1, 0},
  127. .module = THIS_MODULE,
  128. .ctr = linear_ctr,
  129. .dtr = linear_dtr,
  130. .map = linear_map,
  131. .status = linear_status,
  132. .ioctl = linear_ioctl,
  133. .merge = linear_merge,
  134. .iterate_devices = linear_iterate_devices,
  135. };
  136. int __init dm_linear_init(void)
  137. {
  138. int r = dm_register_target(&linear_target);
  139. if (r < 0)
  140. DMERR("register failed %d", r);
  141. return r;
  142. }
  143. void dm_linear_exit(void)
  144. {
  145. dm_unregister_target(&linear_target);
  146. }