Commit 1132e56e authored by Coly Li's avatar Coly Li Committed by Jens Axboe

bcache: add set_uuid in struct cache_set

This patch adds a separated set_uuid[16] in struct cache_set, to store
the uuid of the cache set. This is the preparation to remove the
embedded struct cache_sb from struct cache_set.
Signed-off-by: default avatarColy Li <colyli@suse.de>
Reviewed-by: default avatarHannes Reinecke <hare@suse.de>
Signed-off-by: default avatarJens Axboe <axboe@kernel.dk>
parent 08fdb2cd
...@@ -668,6 +668,7 @@ struct cache_set { ...@@ -668,6 +668,7 @@ struct cache_set {
struct mutex verify_lock; struct mutex verify_lock;
#endif #endif
uint8_t set_uuid[16];
unsigned int nr_uuids; unsigned int nr_uuids;
struct uuid_entry *uuids; struct uuid_entry *uuids;
BKEY_PADDED(uuid_bucket); BKEY_PADDED(uuid_bucket);
......
...@@ -238,7 +238,7 @@ void bch_debug_init_cache_set(struct cache_set *c) ...@@ -238,7 +238,7 @@ void bch_debug_init_cache_set(struct cache_set *c)
if (!IS_ERR_OR_NULL(bcache_debug)) { if (!IS_ERR_OR_NULL(bcache_debug)) {
char name[50]; char name[50];
snprintf(name, 50, "bcache-%pU", c->sb.set_uuid); snprintf(name, 50, "bcache-%pU", c->set_uuid);
c->debug = debugfs_create_file(name, 0400, bcache_debug, c, c->debug = debugfs_create_file(name, 0400, bcache_debug, c,
&cache_set_debug_ops); &cache_set_debug_ops);
} }
......
...@@ -1189,8 +1189,8 @@ int bch_cached_dev_attach(struct cached_dev *dc, struct cache_set *c, ...@@ -1189,8 +1189,8 @@ int bch_cached_dev_attach(struct cached_dev *dc, struct cache_set *c,
struct cached_dev *exist_dc, *t; struct cached_dev *exist_dc, *t;
int ret = 0; int ret = 0;
if ((set_uuid && memcmp(set_uuid, c->sb.set_uuid, 16)) || if ((set_uuid && memcmp(set_uuid, c->set_uuid, 16)) ||
(!set_uuid && memcmp(dc->sb.set_uuid, c->sb.set_uuid, 16))) (!set_uuid && memcmp(dc->sb.set_uuid, c->set_uuid, 16)))
return -ENOENT; return -ENOENT;
if (dc->disk.c) { if (dc->disk.c) {
...@@ -1262,7 +1262,7 @@ int bch_cached_dev_attach(struct cached_dev *dc, struct cache_set *c, ...@@ -1262,7 +1262,7 @@ int bch_cached_dev_attach(struct cached_dev *dc, struct cache_set *c,
u->first_reg = u->last_reg = rtime; u->first_reg = u->last_reg = rtime;
bch_uuid_write(c); bch_uuid_write(c);
memcpy(dc->sb.set_uuid, c->sb.set_uuid, 16); memcpy(dc->sb.set_uuid, c->set_uuid, 16);
SET_BDEV_STATE(&dc->sb, BDEV_STATE_CLEAN); SET_BDEV_STATE(&dc->sb, BDEV_STATE_CLEAN);
bch_write_bdev_super(dc, &cl); bch_write_bdev_super(dc, &cl);
...@@ -1324,7 +1324,7 @@ int bch_cached_dev_attach(struct cached_dev *dc, struct cache_set *c, ...@@ -1324,7 +1324,7 @@ int bch_cached_dev_attach(struct cached_dev *dc, struct cache_set *c,
pr_info("Caching %s as %s on set %pU\n", pr_info("Caching %s as %s on set %pU\n",
dc->backing_dev_name, dc->backing_dev_name,
dc->disk.disk->disk_name, dc->disk.disk->disk_name,
dc->disk.c->sb.set_uuid); dc->disk.c->set_uuid);
return 0; return 0;
} }
...@@ -1631,7 +1631,7 @@ bool bch_cache_set_error(struct cache_set *c, const char *fmt, ...) ...@@ -1631,7 +1631,7 @@ bool bch_cache_set_error(struct cache_set *c, const char *fmt, ...)
vaf.va = &args; vaf.va = &args;
pr_err("error on %pU: %pV, disabling caching\n", pr_err("error on %pU: %pV, disabling caching\n",
c->sb.set_uuid, &vaf); c->set_uuid, &vaf);
va_end(args); va_end(args);
...@@ -1684,7 +1684,7 @@ static void cache_set_free(struct closure *cl) ...@@ -1684,7 +1684,7 @@ static void cache_set_free(struct closure *cl)
list_del(&c->list); list_del(&c->list);
mutex_unlock(&bch_register_lock); mutex_unlock(&bch_register_lock);
pr_info("Cache set %pU unregistered\n", c->sb.set_uuid); pr_info("Cache set %pU unregistered\n", c->set_uuid);
wake_up(&unregister_wait); wake_up(&unregister_wait);
closure_debug_destroy(&c->cl); closure_debug_destroy(&c->cl);
...@@ -1754,7 +1754,7 @@ static void conditional_stop_bcache_device(struct cache_set *c, ...@@ -1754,7 +1754,7 @@ static void conditional_stop_bcache_device(struct cache_set *c,
{ {
if (dc->stop_when_cache_set_failed == BCH_CACHED_DEV_STOP_ALWAYS) { if (dc->stop_when_cache_set_failed == BCH_CACHED_DEV_STOP_ALWAYS) {
pr_warn("stop_when_cache_set_failed of %s is \"always\", stop it for failed cache set %pU.\n", pr_warn("stop_when_cache_set_failed of %s is \"always\", stop it for failed cache set %pU.\n",
d->disk->disk_name, c->sb.set_uuid); d->disk->disk_name, c->set_uuid);
bcache_device_stop(d); bcache_device_stop(d);
} else if (atomic_read(&dc->has_dirty)) { } else if (atomic_read(&dc->has_dirty)) {
/* /*
...@@ -1861,7 +1861,7 @@ struct cache_set *bch_cache_set_alloc(struct cache_sb *sb) ...@@ -1861,7 +1861,7 @@ struct cache_set *bch_cache_set_alloc(struct cache_sb *sb)
bch_cache_accounting_init(&c->accounting, &c->cl); bch_cache_accounting_init(&c->accounting, &c->cl);
memcpy(c->sb.set_uuid, sb->set_uuid, 16); memcpy(c->set_uuid, sb->set_uuid, 16);
c->sb.block_size = sb->block_size; c->sb.block_size = sb->block_size;
c->sb.bucket_size = sb->bucket_size; c->sb.bucket_size = sb->bucket_size;
c->sb.nr_in_set = sb->nr_in_set; c->sb.nr_in_set = sb->nr_in_set;
...@@ -2144,7 +2144,7 @@ static const char *register_cache_set(struct cache *ca) ...@@ -2144,7 +2144,7 @@ static const char *register_cache_set(struct cache *ca)
struct cache_set *c; struct cache_set *c;
list_for_each_entry(c, &bch_cache_sets, list) list_for_each_entry(c, &bch_cache_sets, list)
if (!memcmp(c->sb.set_uuid, ca->sb.set_uuid, 16)) { if (!memcmp(c->set_uuid, ca->sb.set_uuid, 16)) {
if (c->cache) if (c->cache)
return "duplicate cache set member"; return "duplicate cache set member";
...@@ -2162,7 +2162,7 @@ static const char *register_cache_set(struct cache *ca) ...@@ -2162,7 +2162,7 @@ static const char *register_cache_set(struct cache *ca)
return err; return err;
err = "error creating kobject"; err = "error creating kobject";
if (kobject_add(&c->kobj, bcache_kobj, "%pU", c->sb.set_uuid) || if (kobject_add(&c->kobj, bcache_kobj, "%pU", c->set_uuid) ||
kobject_add(&c->internal, &c->kobj, "internal")) kobject_add(&c->internal, &c->kobj, "internal"))
goto err; goto err;
...@@ -2187,7 +2187,7 @@ static const char *register_cache_set(struct cache *ca) ...@@ -2187,7 +2187,7 @@ static const char *register_cache_set(struct cache *ca)
*/ */
if (ca->sb.seq > c->sb.seq || c->sb.seq == 0) { if (ca->sb.seq > c->sb.seq || c->sb.seq == 0) {
c->sb.version = ca->sb.version; c->sb.version = ca->sb.version;
memcpy(c->sb.set_uuid, ca->sb.set_uuid, 16); memcpy(c->set_uuid, ca->sb.set_uuid, 16);
c->sb.flags = ca->sb.flags; c->sb.flags = ca->sb.flags;
c->sb.seq = ca->sb.seq; c->sb.seq = ca->sb.seq;
pr_debug("set version = %llu\n", c->sb.version); pr_debug("set version = %llu\n", c->sb.version);
...@@ -2702,7 +2702,7 @@ static ssize_t bch_pending_bdevs_cleanup(struct kobject *k, ...@@ -2702,7 +2702,7 @@ static ssize_t bch_pending_bdevs_cleanup(struct kobject *k,
list_for_each_entry_safe(pdev, tpdev, &pending_devs, list) { list_for_each_entry_safe(pdev, tpdev, &pending_devs, list) {
list_for_each_entry_safe(c, tc, &bch_cache_sets, list) { list_for_each_entry_safe(c, tc, &bch_cache_sets, list) {
char *pdev_set_uuid = pdev->dc->sb.set_uuid; char *pdev_set_uuid = pdev->dc->sb.set_uuid;
char *set_uuid = c->sb.uuid; char *set_uuid = c->set_uuid;
if (!memcmp(pdev_set_uuid, set_uuid, 16)) { if (!memcmp(pdev_set_uuid, set_uuid, 16)) {
list_del(&pdev->list); list_del(&pdev->list);
......
...@@ -164,7 +164,7 @@ TRACE_EVENT(bcache_write, ...@@ -164,7 +164,7 @@ TRACE_EVENT(bcache_write,
), ),
TP_fast_assign( TP_fast_assign(
memcpy(__entry->uuid, c->sb.set_uuid, 16); memcpy(__entry->uuid, c->set_uuid, 16);
__entry->inode = inode; __entry->inode = inode;
__entry->sector = bio->bi_iter.bi_sector; __entry->sector = bio->bi_iter.bi_sector;
__entry->nr_sector = bio->bi_iter.bi_size >> 9; __entry->nr_sector = bio->bi_iter.bi_size >> 9;
...@@ -200,7 +200,7 @@ DECLARE_EVENT_CLASS(cache_set, ...@@ -200,7 +200,7 @@ DECLARE_EVENT_CLASS(cache_set,
), ),
TP_fast_assign( TP_fast_assign(
memcpy(__entry->uuid, c->sb.set_uuid, 16); memcpy(__entry->uuid, c->set_uuid, 16);
), ),
TP_printk("%pU", __entry->uuid) TP_printk("%pU", __entry->uuid)
......
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