Commit 1415f402 authored by Yu Kuai's avatar Yu Kuai Committed by Song Liu

md/md-bitmap: merge md_bitmap_end_sync() into bitmap_operations

So that the implementation won't be exposed, and it'll be possible
to invent a new bitmap by replacing bitmap_operations.

Also change the parameter from bitmap to mddev, to avoid access
bitmap outside md-bitmap.c as much as possible.
Signed-off-by: default avatarYu Kuai <yukuai3@huawei.com>
Link: https://lore.kernel.org/r/20240826074452.1490072-28-yukuai1@huaweicloud.comSigned-off-by: default avatarSong Liu <song@kernel.org>
parent 9be669bd
...@@ -1665,12 +1665,11 @@ static void __bitmap_end_sync(struct bitmap *bitmap, sector_t offset, ...@@ -1665,12 +1665,11 @@ static void __bitmap_end_sync(struct bitmap *bitmap, sector_t offset,
spin_unlock_irqrestore(&bitmap->counts.lock, flags); spin_unlock_irqrestore(&bitmap->counts.lock, flags);
} }
void md_bitmap_end_sync(struct bitmap *bitmap, sector_t offset, static void bitmap_end_sync(struct mddev *mddev, sector_t offset,
sector_t *blocks) sector_t *blocks)
{ {
__bitmap_end_sync(bitmap, offset, blocks, true); __bitmap_end_sync(mddev->bitmap, offset, blocks, true);
} }
EXPORT_SYMBOL(md_bitmap_end_sync);
void md_bitmap_close_sync(struct bitmap *bitmap) void md_bitmap_close_sync(struct bitmap *bitmap)
{ {
...@@ -2745,6 +2744,7 @@ static struct bitmap_operations bitmap_ops = { ...@@ -2745,6 +2744,7 @@ static struct bitmap_operations bitmap_ops = {
.startwrite = bitmap_startwrite, .startwrite = bitmap_startwrite,
.endwrite = bitmap_endwrite, .endwrite = bitmap_endwrite,
.start_sync = bitmap_start_sync, .start_sync = bitmap_start_sync,
.end_sync = bitmap_end_sync,
.update_sb = bitmap_update_sb, .update_sb = bitmap_update_sb,
.get_stats = bitmap_get_stats, .get_stats = bitmap_get_stats,
......
...@@ -261,6 +261,7 @@ struct bitmap_operations { ...@@ -261,6 +261,7 @@ struct bitmap_operations {
unsigned long sectors, bool success, bool behind); unsigned long sectors, bool success, bool behind);
bool (*start_sync)(struct mddev *mddev, sector_t offset, bool (*start_sync)(struct mddev *mddev, sector_t offset,
sector_t *blocks, bool degraded); sector_t *blocks, bool degraded);
void (*end_sync)(struct mddev *mddev, sector_t offset, sector_t *blocks);
void (*update_sb)(struct bitmap *bitmap); void (*update_sb)(struct bitmap *bitmap);
int (*get_stats)(struct bitmap *bitmap, struct md_bitmap_stats *stats); int (*get_stats)(struct bitmap *bitmap, struct md_bitmap_stats *stats);
...@@ -270,8 +271,6 @@ struct bitmap_operations { ...@@ -270,8 +271,6 @@ struct bitmap_operations {
void mddev_set_bitmap_ops(struct mddev *mddev); void mddev_set_bitmap_ops(struct mddev *mddev);
/* these are exported */ /* these are exported */
void md_bitmap_end_sync(struct bitmap *bitmap, sector_t offset,
sector_t *blocks);
void md_bitmap_close_sync(struct bitmap *bitmap); void md_bitmap_close_sync(struct bitmap *bitmap);
void md_bitmap_cond_end_sync(struct bitmap *bitmap, sector_t sector, bool force); void md_bitmap_cond_end_sync(struct bitmap *bitmap, sector_t sector, bool force);
void md_bitmap_sync_with_cluster(struct mddev *mddev, void md_bitmap_sync_with_cluster(struct mddev *mddev,
......
...@@ -2026,7 +2026,7 @@ static void abort_sync_write(struct mddev *mddev, struct r1bio *r1_bio) ...@@ -2026,7 +2026,7 @@ static void abort_sync_write(struct mddev *mddev, struct r1bio *r1_bio)
/* make sure these bits don't get cleared. */ /* make sure these bits don't get cleared. */
do { do {
md_bitmap_end_sync(mddev->bitmap, s, &sync_blocks); mddev->bitmap_ops->end_sync(mddev, s, &sync_blocks);
s += sync_blocks; s += sync_blocks;
sectors_to_go -= sync_blocks; sectors_to_go -= sync_blocks;
} while (sectors_to_go > 0); } while (sectors_to_go > 0);
...@@ -2772,7 +2772,7 @@ static sector_t raid1_sync_request(struct mddev *mddev, sector_t sector_nr, ...@@ -2772,7 +2772,7 @@ static sector_t raid1_sync_request(struct mddev *mddev, sector_t sector_nr,
* We can find the current addess in mddev->curr_resync * We can find the current addess in mddev->curr_resync
*/ */
if (mddev->curr_resync < max_sector) /* aborted */ if (mddev->curr_resync < max_sector) /* aborted */
md_bitmap_end_sync(mddev->bitmap, mddev->curr_resync, mddev->bitmap_ops->end_sync(mddev, mddev->curr_resync,
&sync_blocks); &sync_blocks);
else /* completed sync */ else /* completed sync */
conf->fullsync = 0; conf->fullsync = 0;
......
...@@ -3194,12 +3194,14 @@ static sector_t raid10_sync_request(struct mddev *mddev, sector_t sector_nr, ...@@ -3194,12 +3194,14 @@ static sector_t raid10_sync_request(struct mddev *mddev, sector_t sector_nr,
if (mddev->curr_resync < max_sector) { /* aborted */ if (mddev->curr_resync < max_sector) { /* aborted */
if (test_bit(MD_RECOVERY_SYNC, &mddev->recovery)) if (test_bit(MD_RECOVERY_SYNC, &mddev->recovery))
md_bitmap_end_sync(mddev->bitmap, mddev->curr_resync, mddev->bitmap_ops->end_sync(mddev,
mddev->curr_resync,
&sync_blocks); &sync_blocks);
else for (i = 0; i < conf->geo.raid_disks; i++) { else for (i = 0; i < conf->geo.raid_disks; i++) {
sector_t sect = sector_t sect =
raid10_find_virt(conf, mddev->curr_resync, i); raid10_find_virt(conf, mddev->curr_resync, i);
md_bitmap_end_sync(mddev->bitmap, sect,
mddev->bitmap_ops->end_sync(mddev, sect,
&sync_blocks); &sync_blocks);
} }
} else { } else {
......
...@@ -6497,7 +6497,7 @@ static inline sector_t raid5_sync_request(struct mddev *mddev, sector_t sector_n ...@@ -6497,7 +6497,7 @@ static inline sector_t raid5_sync_request(struct mddev *mddev, sector_t sector_n
} }
if (mddev->curr_resync < max_sector) /* aborted */ if (mddev->curr_resync < max_sector) /* aborted */
md_bitmap_end_sync(mddev->bitmap, mddev->curr_resync, mddev->bitmap_ops->end_sync(mddev, mddev->curr_resync,
&sync_blocks); &sync_blocks);
else /* completed sync */ else /* completed sync */
conf->fullsync = 0; conf->fullsync = 0;
......
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