]> www.infradead.org Git - users/hch/block.git/commitdiff
block: add a mark_dead holder operation
authorChristoph Hellwig <hch@lst.de>
Fri, 5 May 2023 13:05:18 +0000 (09:05 -0400)
committerChristoph Hellwig <hch@lst.de>
Fri, 5 May 2023 13:59:36 +0000 (09:59 -0400)
Add a mark_dead method to blk_holder_ops that is called from blk_mark_disk_dead
to notify the holder that the block device it is using has been marked dead.

Signed-off-by: Christoph Hellwig <hch@lst.de>
block/genhd.c
include/linux/blkdev.h

index d1c673b967c254cbc99bd9dfe4d52676686cbbad..af97a4ef1e926ce78eb3df2028a9ab4ec172896b 100644 (file)
@@ -575,6 +575,28 @@ out_exit_elevator:
 }
 EXPORT_SYMBOL(device_add_disk);
 
+static void blk_report_disk_dead(struct gendisk *disk)
+{
+       struct block_device *bdev;
+       unsigned long idx;
+
+       rcu_read_lock();
+       xa_for_each(&disk->part_tbl, idx, bdev) {
+               if (!kobject_get_unless_zero(&bdev->bd_device.kobj))
+                       continue;
+               rcu_read_unlock();
+
+               mutex_lock(&bdev->bd_holder_lock);
+               if (bdev->bd_holder_ops && bdev->bd_holder_ops->mark_dead)
+                       bdev->bd_holder_ops->mark_dead(bdev);
+               mutex_unlock(&bdev->bd_holder_lock);
+
+               put_device(&bdev->bd_device);
+               rcu_read_lock();
+       }
+       rcu_read_unlock();
+}
+
 /**
  * blk_mark_disk_dead - mark a disk as dead
  * @disk: disk to mark as dead
@@ -602,6 +624,8 @@ void blk_mark_disk_dead(struct gendisk *disk)
         * Prevent new I/O from crossing bio_queue_enter().
         */
        blk_queue_start_drain(disk->queue);
+
+       blk_report_disk_dead(disk);
 }
 EXPORT_SYMBOL_GPL(blk_mark_disk_dead);
 
index 3f41f8c9b103cfd46a2aea8aa53a404d34016443..9706bec2be16a544e0206f52513e2a6e6151d9bc 100644 (file)
@@ -1469,6 +1469,7 @@ void blkdev_show(struct seq_file *seqf, off_t offset);
 #endif
 
 struct blk_holder_ops {
+       void (*mark_dead)(struct block_device *bdev);
 };
 
 struct block_device *blkdev_get_by_dev(dev_t dev, fmode_t mode, void *holder,