提交 3feeb894 编写于 作者: A Alex Elder

rbd: return snap name from rbd_add_parse_args()

This is the first of two patches aimed at isolating the code that
sets the mapping information into a single spot.
Signed-off-by: NAlex Elder <elder@inktank.com>
Reviewed-by: NJosh Durgin <josh.durgin@inktank.com>
上级 99c1f08f
...@@ -2477,14 +2477,16 @@ static inline char *dup_token(const char **buf, size_t *lenp) ...@@ -2477,14 +2477,16 @@ static inline char *dup_token(const char **buf, size_t *lenp)
} }
/* /*
* This fills in the pool_name, image_name, image_name_len, snap_name, * This fills in the pool_name, image_name, image_name_len, rbd_dev,
* rbd_dev, rbd_md_name, and name fields of the given rbd_dev, based * rbd_md_name, and name fields of the given rbd_dev, based on the
* on the list of monitor addresses and other options provided via * list of monitor addresses and other options provided via
* /sys/bus/rbd/add. * /sys/bus/rbd/add. Returns a pointer to a dynamically-allocated
* copy of the snapshot name to map if successful, or a
* pointer-coded error otherwise.
* *
* Note: rbd_dev is assumed to have been initially zero-filled. * Note: rbd_dev is assumed to have been initially zero-filled.
*/ */
static int rbd_add_parse_args(struct rbd_device *rbd_dev, static char *rbd_add_parse_args(struct rbd_device *rbd_dev,
const char *buf, const char *buf,
const char **mon_addrs, const char **mon_addrs,
size_t *mon_addrs_size, size_t *mon_addrs_size,
...@@ -2492,13 +2494,14 @@ static int rbd_add_parse_args(struct rbd_device *rbd_dev, ...@@ -2492,13 +2494,14 @@ static int rbd_add_parse_args(struct rbd_device *rbd_dev,
size_t options_size) size_t options_size)
{ {
size_t len; size_t len;
int ret; char *err_ptr = ERR_PTR(-EINVAL);
char *snap_name;
/* The first four tokens are required */ /* The first four tokens are required */
len = next_token(&buf); len = next_token(&buf);
if (!len) if (!len)
return -EINVAL; return err_ptr;
*mon_addrs_size = len + 1; *mon_addrs_size = len + 1;
*mon_addrs = buf; *mon_addrs = buf;
...@@ -2506,9 +2509,9 @@ static int rbd_add_parse_args(struct rbd_device *rbd_dev, ...@@ -2506,9 +2509,9 @@ static int rbd_add_parse_args(struct rbd_device *rbd_dev,
len = copy_token(&buf, options, options_size); len = copy_token(&buf, options, options_size);
if (!len || len >= options_size) if (!len || len >= options_size)
return -EINVAL; return err_ptr;
ret = -ENOMEM; err_ptr = ERR_PTR(-ENOMEM);
rbd_dev->pool_name = dup_token(&buf, NULL); rbd_dev->pool_name = dup_token(&buf, NULL);
if (!rbd_dev->pool_name) if (!rbd_dev->pool_name)
goto out_err; goto out_err;
...@@ -2526,26 +2529,21 @@ static int rbd_add_parse_args(struct rbd_device *rbd_dev, ...@@ -2526,26 +2529,21 @@ static int rbd_add_parse_args(struct rbd_device *rbd_dev,
goto out_err; goto out_err;
sprintf(rbd_dev->header_name, "%s%s", rbd_dev->image_name, RBD_SUFFIX); sprintf(rbd_dev->header_name, "%s%s", rbd_dev->image_name, RBD_SUFFIX);
/* /* Snapshot name is optional */
* The snapshot name is optional. If none is is supplied, len = next_token(&buf);
* we use the default value.
*/
rbd_dev->mapping.snap_name = dup_token(&buf, &len);
if (!rbd_dev->mapping.snap_name)
goto out_err;
if (!len) { if (!len) {
/* Replace the empty name with the default */ buf = RBD_SNAP_HEAD_NAME; /* No snapshot supplied */
kfree(rbd_dev->mapping.snap_name); len = sizeof (RBD_SNAP_HEAD_NAME) - 1;
rbd_dev->mapping.snap_name }
= kmalloc(sizeof (RBD_SNAP_HEAD_NAME), GFP_KERNEL); snap_name = kmalloc(len + 1, GFP_KERNEL);
if (!rbd_dev->mapping.snap_name) if (!snap_name)
goto out_err; goto out_err;
memcpy(snap_name, buf, len);
*(snap_name + len) = '\0';
memcpy(rbd_dev->mapping.snap_name, RBD_SNAP_HEAD_NAME, dout(" SNAP_NAME is <%s>, len is %zd\n", snap_name, len);
sizeof (RBD_SNAP_HEAD_NAME));
}
return 0; return snap_name;
out_err: out_err:
kfree(rbd_dev->header_name); kfree(rbd_dev->header_name);
...@@ -2556,7 +2554,7 @@ static int rbd_add_parse_args(struct rbd_device *rbd_dev, ...@@ -2556,7 +2554,7 @@ static int rbd_add_parse_args(struct rbd_device *rbd_dev,
kfree(rbd_dev->pool_name); kfree(rbd_dev->pool_name);
rbd_dev->pool_name = NULL; rbd_dev->pool_name = NULL;
return ret; return err_ptr;
} }
static ssize_t rbd_add(struct bus_type *bus, static ssize_t rbd_add(struct bus_type *bus,
...@@ -2569,6 +2567,7 @@ static ssize_t rbd_add(struct bus_type *bus, ...@@ -2569,6 +2567,7 @@ static ssize_t rbd_add(struct bus_type *bus,
size_t mon_addrs_size = 0; size_t mon_addrs_size = 0;
struct ceph_osd_client *osdc; struct ceph_osd_client *osdc;
int rc = -ENOMEM; int rc = -ENOMEM;
char *snap_name;
if (!try_module_get(THIS_MODULE)) if (!try_module_get(THIS_MODULE))
return -ENODEV; return -ENODEV;
...@@ -2595,10 +2594,13 @@ static ssize_t rbd_add(struct bus_type *bus, ...@@ -2595,10 +2594,13 @@ static ssize_t rbd_add(struct bus_type *bus,
sprintf(rbd_dev->name, "%s%d", RBD_DRV_NAME, rbd_dev->dev_id); sprintf(rbd_dev->name, "%s%d", RBD_DRV_NAME, rbd_dev->dev_id);
/* parse add command */ /* parse add command */
rc = rbd_add_parse_args(rbd_dev, buf, &mon_addrs, &mon_addrs_size, snap_name = rbd_add_parse_args(rbd_dev, buf,
options, count); &mon_addrs, &mon_addrs_size, options, count);
if (rc) if (IS_ERR(snap_name)) {
rc = PTR_ERR(snap_name);
goto err_put_id; goto err_put_id;
}
rbd_dev->mapping.snap_name = snap_name;
rc = rbd_get_client(rbd_dev, mon_addrs, mon_addrs_size - 1, options); rc = rbd_get_client(rbd_dev, mon_addrs, mon_addrs_size - 1, options);
if (rc < 0) if (rc < 0)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册