null_blk_zoned.c 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
  1. // SPDX-License-Identifier: GPL-2.0
  2. #include <linux/vmalloc.h>
  3. #include "null_blk.h"
  4. /* zone_size in MBs to sectors. */
  5. #define ZONE_SIZE_SHIFT 11
  6. static inline unsigned int null_zone_no(struct nullb_device *dev, sector_t sect)
  7. {
  8. return sect >> ilog2(dev->zone_size_sects);
  9. }
  10. int null_zone_init(struct nullb_device *dev)
  11. {
  12. sector_t dev_size = (sector_t)dev->size * 1024 * 1024;
  13. sector_t sector = 0;
  14. unsigned int i;
  15. if (!is_power_of_2(dev->zone_size)) {
  16. pr_err("null_blk: zone_size must be power-of-two\n");
  17. return -EINVAL;
  18. }
  19. dev->zone_size_sects = dev->zone_size << ZONE_SIZE_SHIFT;
  20. dev->nr_zones = dev_size >>
  21. (SECTOR_SHIFT + ilog2(dev->zone_size_sects));
  22. dev->zones = kvmalloc_array(dev->nr_zones, sizeof(struct blk_zone),
  23. GFP_KERNEL | __GFP_ZERO);
  24. if (!dev->zones)
  25. return -ENOMEM;
  26. for (i = 0; i < dev->nr_zones; i++) {
  27. struct blk_zone *zone = &dev->zones[i];
  28. zone->start = zone->wp = sector;
  29. zone->len = dev->zone_size_sects;
  30. zone->type = BLK_ZONE_TYPE_SEQWRITE_REQ;
  31. zone->cond = BLK_ZONE_COND_EMPTY;
  32. sector += dev->zone_size_sects;
  33. }
  34. return 0;
  35. }
  36. void null_zone_exit(struct nullb_device *dev)
  37. {
  38. kvfree(dev->zones);
  39. }
  40. int null_zone_report(struct gendisk *disk, sector_t sector,
  41. struct blk_zone *zones, unsigned int *nr_zones,
  42. gfp_t gfp_mask)
  43. {
  44. struct nullb *nullb = disk->private_data;
  45. struct nullb_device *dev = nullb->dev;
  46. unsigned int zno, nrz = 0;
  47. if (!dev->zoned)
  48. /* Not a zoned null device */
  49. return -EOPNOTSUPP;
  50. zno = null_zone_no(dev, sector);
  51. if (zno < dev->nr_zones) {
  52. nrz = min_t(unsigned int, *nr_zones, dev->nr_zones - zno);
  53. memcpy(zones, &dev->zones[zno], nrz * sizeof(struct blk_zone));
  54. }
  55. *nr_zones = nrz;
  56. return 0;
  57. }
  58. void null_zone_write(struct nullb_cmd *cmd, sector_t sector,
  59. unsigned int nr_sectors)
  60. {
  61. struct nullb_device *dev = cmd->nq->dev;
  62. unsigned int zno = null_zone_no(dev, sector);
  63. struct blk_zone *zone = &dev->zones[zno];
  64. switch (zone->cond) {
  65. case BLK_ZONE_COND_FULL:
  66. /* Cannot write to a full zone */
  67. cmd->error = BLK_STS_IOERR;
  68. break;
  69. case BLK_ZONE_COND_EMPTY:
  70. case BLK_ZONE_COND_IMP_OPEN:
  71. /* Writes must be at the write pointer position */
  72. if (sector != zone->wp) {
  73. cmd->error = BLK_STS_IOERR;
  74. break;
  75. }
  76. if (zone->cond == BLK_ZONE_COND_EMPTY)
  77. zone->cond = BLK_ZONE_COND_IMP_OPEN;
  78. zone->wp += nr_sectors;
  79. if (zone->wp == zone->start + zone->len)
  80. zone->cond = BLK_ZONE_COND_FULL;
  81. break;
  82. default:
  83. /* Invalid zone condition */
  84. cmd->error = BLK_STS_IOERR;
  85. break;
  86. }
  87. }
  88. void null_zone_reset(struct nullb_cmd *cmd, sector_t sector)
  89. {
  90. struct nullb_device *dev = cmd->nq->dev;
  91. unsigned int zno = null_zone_no(dev, sector);
  92. struct blk_zone *zone = &dev->zones[zno];
  93. zone->cond = BLK_ZONE_COND_EMPTY;
  94. zone->wp = zone->start;
  95. }