dm zoned: select reclaim zone based on device index

per-device reclaim should select zones on that device only.

Signed-off-by: Hannes Reinecke <hare@suse.de>
Reviewed-by: Damien Le Moal <damien.lemoal@wdc.com>
Signed-off-by: Mike Snitzer <snitzer@redhat.com>
This commit is contained in:
Hannes Reinecke 2020-06-02 13:09:54 +02:00 committed by Mike Snitzer
parent 22c1ef66c4
commit 69875d443b
4 changed files with 27 additions and 32 deletions

View file

@ -1938,7 +1938,7 @@ static void dmz_wait_for_reclaim(struct dmz_metadata *zmd, struct dm_zone *zone)
* Select a cache or random write zone for reclaim. * Select a cache or random write zone for reclaim.
*/ */
static struct dm_zone *dmz_get_rnd_zone_for_reclaim(struct dmz_metadata *zmd, static struct dm_zone *dmz_get_rnd_zone_for_reclaim(struct dmz_metadata *zmd,
bool idle) unsigned int idx, bool idle)
{ {
struct dm_zone *dzone = NULL; struct dm_zone *dzone = NULL;
struct dm_zone *zone; struct dm_zone *zone;
@ -1948,24 +1948,17 @@ static struct dm_zone *dmz_get_rnd_zone_for_reclaim(struct dmz_metadata *zmd,
if (zmd->nr_cache) { if (zmd->nr_cache) {
zone_list = &zmd->map_cache_list; zone_list = &zmd->map_cache_list;
/* Try to relaim random zones, too, when idle */ /* Try to relaim random zones, too, when idle */
if (idle && list_empty(zone_list)) { if (idle && list_empty(zone_list))
int i; zone_list = &zmd->dev[idx].map_rnd_list;
} else
for (i = 1; i < zmd->nr_devs; i++) { zone_list = &zmd->dev[idx].map_rnd_list;
zone_list = &zmd->dev[i].map_rnd_list;
if (!list_empty(zone_list))
break;
}
}
} else {
/* Otherwise the random zones are on the first disk */
zone_list = &zmd->dev[0].map_rnd_list;
}
list_for_each_entry(zone, zone_list, link) { list_for_each_entry(zone, zone_list, link) {
if (dmz_is_buf(zone)) if (dmz_is_buf(zone)) {
dzone = zone->bzone; dzone = zone->bzone;
else if (dzone->dev->dev_idx != idx)
continue;
} else
dzone = zone; dzone = zone;
if (dmz_lock_zone_reclaim(dzone)) if (dmz_lock_zone_reclaim(dzone))
return dzone; return dzone;
@ -1977,20 +1970,16 @@ static struct dm_zone *dmz_get_rnd_zone_for_reclaim(struct dmz_metadata *zmd,
/* /*
* Select a buffered sequential zone for reclaim. * Select a buffered sequential zone for reclaim.
*/ */
static struct dm_zone *dmz_get_seq_zone_for_reclaim(struct dmz_metadata *zmd) static struct dm_zone *dmz_get_seq_zone_for_reclaim(struct dmz_metadata *zmd,
unsigned int idx)
{ {
struct dm_zone *zone; struct dm_zone *zone;
int i;
for (i = 0; i < zmd->nr_devs; i++) { list_for_each_entry(zone, &zmd->dev[idx].map_seq_list, link) {
struct dmz_dev *dev = &zmd->dev[i]; if (!zone->bzone)
continue;
list_for_each_entry(zone, &dev->map_seq_list, link) { if (dmz_lock_zone_reclaim(zone))
if (!zone->bzone) return zone;
continue;
if (dmz_lock_zone_reclaim(zone))
return zone;
}
} }
return NULL; return NULL;
@ -1999,7 +1988,8 @@ static struct dm_zone *dmz_get_seq_zone_for_reclaim(struct dmz_metadata *zmd)
/* /*
* Select a zone for reclaim. * Select a zone for reclaim.
*/ */
struct dm_zone *dmz_get_zone_for_reclaim(struct dmz_metadata *zmd, bool idle) struct dm_zone *dmz_get_zone_for_reclaim(struct dmz_metadata *zmd,
unsigned int dev_idx, bool idle)
{ {
struct dm_zone *zone; struct dm_zone *zone;
@ -2013,9 +2003,9 @@ struct dm_zone *dmz_get_zone_for_reclaim(struct dmz_metadata *zmd, bool idle)
*/ */
dmz_lock_map(zmd); dmz_lock_map(zmd);
if (list_empty(&zmd->reserved_seq_zones_list)) if (list_empty(&zmd->reserved_seq_zones_list))
zone = dmz_get_seq_zone_for_reclaim(zmd); zone = dmz_get_seq_zone_for_reclaim(zmd, dev_idx);
else else
zone = dmz_get_rnd_zone_for_reclaim(zmd, idle); zone = dmz_get_rnd_zone_for_reclaim(zmd, dev_idx, idle);
dmz_unlock_map(zmd); dmz_unlock_map(zmd);
return zone; return zone;

View file

@ -370,7 +370,8 @@ static int dmz_do_reclaim(struct dmz_reclaim *zrc)
int ret; int ret;
/* Get a data zone */ /* Get a data zone */
dzone = dmz_get_zone_for_reclaim(zmd, dmz_target_idle(zrc)); dzone = dmz_get_zone_for_reclaim(zmd, zrc->dev_idx,
dmz_target_idle(zrc));
if (!dzone) { if (!dzone) {
DMDEBUG("(%s/%u): No zone found to reclaim", DMDEBUG("(%s/%u): No zone found to reclaim",
dmz_metadata_label(zmd), zrc->dev_idx); dmz_metadata_label(zmd), zrc->dev_idx);

View file

@ -738,6 +738,7 @@ static int dmz_get_zoned_device(struct dm_target *ti, char *path,
dev = &dmz->dev[idx]; dev = &dmz->dev[idx];
} }
dev->bdev = bdev; dev->bdev = bdev;
dev->dev_idx = idx;
(void)bdevname(dev->bdev, dev->name); (void)bdevname(dev->bdev, dev->name);
dev->capacity = i_size_read(bdev->bd_inode) >> SECTOR_SHIFT; dev->capacity = i_size_read(bdev->bd_inode) >> SECTOR_SHIFT;

View file

@ -61,6 +61,8 @@ struct dmz_dev {
sector_t capacity; sector_t capacity;
unsigned int dev_idx;
unsigned int nr_zones; unsigned int nr_zones;
unsigned int zone_offset; unsigned int zone_offset;
@ -243,7 +245,8 @@ static inline void dmz_activate_zone(struct dm_zone *zone)
int dmz_lock_zone_reclaim(struct dm_zone *zone); int dmz_lock_zone_reclaim(struct dm_zone *zone);
void dmz_unlock_zone_reclaim(struct dm_zone *zone); void dmz_unlock_zone_reclaim(struct dm_zone *zone);
struct dm_zone *dmz_get_zone_for_reclaim(struct dmz_metadata *zmd, bool idle); struct dm_zone *dmz_get_zone_for_reclaim(struct dmz_metadata *zmd,
unsigned int dev_idx, bool idle);
struct dm_zone *dmz_get_chunk_mapping(struct dmz_metadata *zmd, struct dm_zone *dmz_get_chunk_mapping(struct dmz_metadata *zmd,
unsigned int chunk, int op); unsigned int chunk, int op);