Commit d8530de5 authored by Christoph Hellwig's avatar Christoph Hellwig Committed by Christian Brauner

block: call into the file system for bdev_mark_dead

Combine the newly merged bdev_mark_dead helper with the existing
mark_dead holder operation so that all operations that invalidate
a device that is dead or being removed now go through the holder
ops.  This allows file systems to explicitly shutdown either ASAP
(for a surprise removal) or after writing back data (for an orderly
removal), and do so not only for the main device.
Signed-off-by: default avatarChristoph Hellwig <hch@lst.de>
Reviewed-by: default avatarJosef Bacik <josef@toxicpanda.com>
Message-Id: <20230811100828.1897174-15-hch@lst.de>
Signed-off-by: default avatarChristian Brauner <brauner@kernel.org>
parent 560e20e4
...@@ -968,31 +968,19 @@ EXPORT_SYMBOL(lookup_bdev); ...@@ -968,31 +968,19 @@ EXPORT_SYMBOL(lookup_bdev);
* to %true the device or media is already gone, if not we are preparing for an * to %true the device or media is already gone, if not we are preparing for an
* orderly removal. * orderly removal.
* *
* This syncs out all dirty data and writes back inodes and then invalidates any * This calls into the file system, which then typicall syncs out all dirty data
* cached data in the inodes on the file system, the inodes themselves and the * and writes back inodes and then invalidates any cached data in the inodes on
* block device mapping. * the file system. In addition we also invalidate the block device mapping.
*/ */
void bdev_mark_dead(struct block_device *bdev, bool surprise) void bdev_mark_dead(struct block_device *bdev, bool surprise)
{ {
struct super_block *sb = get_super(bdev); mutex_lock(&bdev->bd_holder_lock);
int res = 0; if (bdev->bd_holder_ops && bdev->bd_holder_ops->mark_dead)
bdev->bd_holder_ops->mark_dead(bdev, surprise);
else
sync_blockdev(bdev);
mutex_unlock(&bdev->bd_holder_lock);
if (sb) {
if (!surprise)
sync_filesystem(sb);
/*
* no need to lock the super, get_super holds the
* read mutex so the filesystem cannot go away
* under us (->put_super runs with the write lock
* hold).
*/
shrink_dcache_sb(sb);
res = invalidate_inodes(sb, true);
drop_super(sb);
} else {
if (!surprise)
sync_blockdev(bdev);
}
invalidate_bdev(bdev); invalidate_bdev(bdev);
} }
#ifdef CONFIG_DASD_MODULE #ifdef CONFIG_DASD_MODULE
......
...@@ -554,7 +554,7 @@ int __must_check device_add_disk(struct device *parent, struct gendisk *disk, ...@@ -554,7 +554,7 @@ int __must_check device_add_disk(struct device *parent, struct gendisk *disk,
} }
EXPORT_SYMBOL(device_add_disk); EXPORT_SYMBOL(device_add_disk);
static void blk_report_disk_dead(struct gendisk *disk) static void blk_report_disk_dead(struct gendisk *disk, bool surprise)
{ {
struct block_device *bdev; struct block_device *bdev;
unsigned long idx; unsigned long idx;
...@@ -565,10 +565,7 @@ static void blk_report_disk_dead(struct gendisk *disk) ...@@ -565,10 +565,7 @@ static void blk_report_disk_dead(struct gendisk *disk)
continue; continue;
rcu_read_unlock(); rcu_read_unlock();
mutex_lock(&bdev->bd_holder_lock); bdev_mark_dead(bdev, surprise);
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); put_device(&bdev->bd_device);
rcu_read_lock(); rcu_read_lock();
...@@ -576,14 +573,7 @@ static void blk_report_disk_dead(struct gendisk *disk) ...@@ -576,14 +573,7 @@ static void blk_report_disk_dead(struct gendisk *disk)
rcu_read_unlock(); rcu_read_unlock();
} }
/** static void __blk_mark_disk_dead(struct gendisk *disk)
* blk_mark_disk_dead - mark a disk as dead
* @disk: disk to mark as dead
*
* Mark as disk as dead (e.g. surprise removed) and don't accept any new I/O
* to this disk.
*/
void blk_mark_disk_dead(struct gendisk *disk)
{ {
/* /*
* Fail any new I/O. * Fail any new I/O.
...@@ -603,8 +593,19 @@ void blk_mark_disk_dead(struct gendisk *disk) ...@@ -603,8 +593,19 @@ void blk_mark_disk_dead(struct gendisk *disk)
* Prevent new I/O from crossing bio_queue_enter(). * Prevent new I/O from crossing bio_queue_enter().
*/ */
blk_queue_start_drain(disk->queue); blk_queue_start_drain(disk->queue);
}
blk_report_disk_dead(disk); /**
* blk_mark_disk_dead - mark a disk as dead
* @disk: disk to mark as dead
*
* Mark as disk as dead (e.g. surprise removed) and don't accept any new I/O
* to this disk.
*/
void blk_mark_disk_dead(struct gendisk *disk)
{
__blk_mark_disk_dead(disk);
blk_report_disk_dead(disk, true);
} }
EXPORT_SYMBOL_GPL(blk_mark_disk_dead); EXPORT_SYMBOL_GPL(blk_mark_disk_dead);
...@@ -641,17 +642,20 @@ void del_gendisk(struct gendisk *disk) ...@@ -641,17 +642,20 @@ void del_gendisk(struct gendisk *disk)
disk_del_events(disk); disk_del_events(disk);
/* /*
* Prevent new openers by unlinked the bdev inode, and write out * Prevent new openers by unlinked the bdev inode.
* dirty data before marking the disk dead and stopping all I/O.
*/ */
mutex_lock(&disk->open_mutex); mutex_lock(&disk->open_mutex);
xa_for_each(&disk->part_tbl, idx, part) { xa_for_each(&disk->part_tbl, idx, part)
remove_inode_hash(part->bd_inode); remove_inode_hash(part->bd_inode);
bdev_mark_dead(part, false);
}
mutex_unlock(&disk->open_mutex); mutex_unlock(&disk->open_mutex);
blk_mark_disk_dead(disk); /*
* Tell the file system to write back all dirty data and shut down if
* it hasn't been notified earlier.
*/
if (!test_bit(GD_DEAD, &disk->state))
blk_report_disk_dead(disk, false);
__blk_mark_disk_dead(disk);
/* /*
* Drop all partitions now that the disk is marked dead. * Drop all partitions now that the disk is marked dead.
......
...@@ -1228,7 +1228,7 @@ static bool lock_active_super(struct super_block *sb) ...@@ -1228,7 +1228,7 @@ static bool lock_active_super(struct super_block *sb)
return true; return true;
} }
static void fs_mark_dead(struct block_device *bdev) static void fs_bdev_mark_dead(struct block_device *bdev, bool surprise)
{ {
struct super_block *sb = bdev->bd_holder; struct super_block *sb = bdev->bd_holder;
...@@ -1238,6 +1238,10 @@ static void fs_mark_dead(struct block_device *bdev) ...@@ -1238,6 +1238,10 @@ static void fs_mark_dead(struct block_device *bdev)
if (!lock_active_super(sb)) if (!lock_active_super(sb))
return; return;
if (!surprise)
sync_filesystem(sb);
shrink_dcache_sb(sb);
invalidate_inodes(sb, true);
if (sb->s_op->shutdown) if (sb->s_op->shutdown)
sb->s_op->shutdown(sb); sb->s_op->shutdown(sb);
...@@ -1245,7 +1249,7 @@ static void fs_mark_dead(struct block_device *bdev) ...@@ -1245,7 +1249,7 @@ static void fs_mark_dead(struct block_device *bdev)
} }
const struct blk_holder_ops fs_holder_ops = { const struct blk_holder_ops fs_holder_ops = {
.mark_dead = fs_mark_dead, .mark_dead = fs_bdev_mark_dead,
}; };
EXPORT_SYMBOL_GPL(fs_holder_ops); EXPORT_SYMBOL_GPL(fs_holder_ops);
......
...@@ -1461,7 +1461,7 @@ void blkdev_show(struct seq_file *seqf, off_t offset); ...@@ -1461,7 +1461,7 @@ void blkdev_show(struct seq_file *seqf, off_t offset);
#endif #endif
struct blk_holder_ops { struct blk_holder_ops {
void (*mark_dead)(struct block_device *bdev); void (*mark_dead)(struct block_device *bdev, bool surprise);
}; };
extern const struct blk_holder_ops fs_holder_ops; extern const struct blk_holder_ops fs_holder_ops;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment