Commit 41f38c2b authored by Alex Elder's avatar Alex Elder

rbd: remove snapshots on error in rbd_add()

If rbd_dev_snaps_update() has ever been called for an rbd device
structure there could be snapshot structures on its snaps list.
In rbd_add(), this function is called but a subsequent error
path neglected to clean up any of these snapshots.

Add a call to rbd_remove_all_snaps() in the appropriate spot to
remedy this.  Change a couple of error labels to be a little
clearer while there.

Drop the leading underscores from the function name; there's nothing
special about that function that they might signify.  As suggested
in review, the leading underscores in __rbd_remove_snap_dev() have
been removed as well.
Signed-off-by: default avatarAlex Elder <elder@inktank.com>
Reviewed-by: default avatarJosh Durgin <josh.durgin@inktank.com>
parent f7760dad
...@@ -228,7 +228,7 @@ static int rbd_dev_snaps_update(struct rbd_device *rbd_dev); ...@@ -228,7 +228,7 @@ static int rbd_dev_snaps_update(struct rbd_device *rbd_dev);
static int rbd_dev_snaps_register(struct rbd_device *rbd_dev); static int rbd_dev_snaps_register(struct rbd_device *rbd_dev);
static void rbd_dev_release(struct device *dev); static void rbd_dev_release(struct device *dev);
static void __rbd_remove_snap_dev(struct rbd_snap *snap); static void rbd_remove_snap_dev(struct rbd_snap *snap);
static ssize_t rbd_add(struct bus_type *bus, const char *buf, static ssize_t rbd_add(struct bus_type *bus, const char *buf,
size_t count); size_t count);
...@@ -1787,13 +1787,13 @@ static int rbd_read_header(struct rbd_device *rbd_dev, ...@@ -1787,13 +1787,13 @@ static int rbd_read_header(struct rbd_device *rbd_dev,
return ret; return ret;
} }
static void __rbd_remove_all_snaps(struct rbd_device *rbd_dev) static void rbd_remove_all_snaps(struct rbd_device *rbd_dev)
{ {
struct rbd_snap *snap; struct rbd_snap *snap;
struct rbd_snap *next; struct rbd_snap *next;
list_for_each_entry_safe(snap, next, &rbd_dev->snaps, node) list_for_each_entry_safe(snap, next, &rbd_dev->snaps, node)
__rbd_remove_snap_dev(snap); rbd_remove_snap_dev(snap);
} }
static void rbd_update_mapping_size(struct rbd_device *rbd_dev) static void rbd_update_mapping_size(struct rbd_device *rbd_dev)
...@@ -2146,7 +2146,7 @@ static bool rbd_snap_registered(struct rbd_snap *snap) ...@@ -2146,7 +2146,7 @@ static bool rbd_snap_registered(struct rbd_snap *snap)
return ret; return ret;
} }
static void __rbd_remove_snap_dev(struct rbd_snap *snap) static void rbd_remove_snap_dev(struct rbd_snap *snap)
{ {
list_del(&snap->node); list_del(&snap->node);
if (device_is_registered(&snap->dev)) if (device_is_registered(&snap->dev))
...@@ -2569,7 +2569,7 @@ static int rbd_dev_snaps_update(struct rbd_device *rbd_dev) ...@@ -2569,7 +2569,7 @@ static int rbd_dev_snaps_update(struct rbd_device *rbd_dev)
if (rbd_dev->mapping.snap_id == snap->id) if (rbd_dev->mapping.snap_id == snap->id)
rbd_dev->mapping.snap_exists = false; rbd_dev->mapping.snap_exists = false;
__rbd_remove_snap_dev(snap); rbd_remove_snap_dev(snap);
dout("%ssnap id %llu has been removed\n", dout("%ssnap id %llu has been removed\n",
rbd_dev->mapping.snap_id == snap->id ? rbd_dev->mapping.snap_id == snap->id ?
"mapped " : "", "mapped " : "",
...@@ -3179,11 +3179,11 @@ static ssize_t rbd_add(struct bus_type *bus, ...@@ -3179,11 +3179,11 @@ static ssize_t rbd_add(struct bus_type *bus,
/* no need to lock here, as rbd_dev is not registered yet */ /* no need to lock here, as rbd_dev is not registered yet */
rc = rbd_dev_snaps_update(rbd_dev); rc = rbd_dev_snaps_update(rbd_dev);
if (rc) if (rc)
goto err_out_header; goto err_out_probe;
rc = rbd_dev_set_mapping(rbd_dev, snap_name); rc = rbd_dev_set_mapping(rbd_dev, snap_name);
if (rc) if (rc)
goto err_out_header; goto err_out_snaps;
/* generate unique id: find highest unique id, add one */ /* generate unique id: find highest unique id, add one */
rbd_dev_id_get(rbd_dev); rbd_dev_id_get(rbd_dev);
...@@ -3247,7 +3247,9 @@ static ssize_t rbd_add(struct bus_type *bus, ...@@ -3247,7 +3247,9 @@ static ssize_t rbd_add(struct bus_type *bus,
unregister_blkdev(rbd_dev->major, rbd_dev->name); unregister_blkdev(rbd_dev->major, rbd_dev->name);
err_out_id: err_out_id:
rbd_dev_id_put(rbd_dev); rbd_dev_id_put(rbd_dev);
err_out_header: err_out_snaps:
rbd_remove_all_snaps(rbd_dev);
err_out_probe:
rbd_header_free(&rbd_dev->header); rbd_header_free(&rbd_dev->header);
err_out_client: err_out_client:
kfree(rbd_dev->header_name); kfree(rbd_dev->header_name);
...@@ -3345,7 +3347,7 @@ static ssize_t rbd_remove(struct bus_type *bus, ...@@ -3345,7 +3347,7 @@ static ssize_t rbd_remove(struct bus_type *bus,
goto done; goto done;
} }
__rbd_remove_all_snaps(rbd_dev); rbd_remove_all_snaps(rbd_dev);
rbd_bus_del_dev(rbd_dev); rbd_bus_del_dev(rbd_dev);
done: done:
......
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