shaba/lvm2
1
0
Fork 0
mirror of git://sourceware.org/git/lvm2.git synced 2025-01-03 05:18:29 +03:00
Code Releases Activity

lvresize: use process_each_vg

Browse Source 
No functional change.
This commit is contained in:
David Teigland 2015-12-01 11:01:26 -06:00
parent 5bbbd37f41
commit 67763a9bec
1 changed files with 41 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

77
tools/lvresize.c
View File

@ -163,51 +163,56 @@ static int _lvresize_params(struct cmd_context *cmd, int argc, char **argv,
return 1; return 1;
} }
int lvresize(struct cmd_context *cmd, int argc, char **argv) static int _lvresize_single(struct cmd_context *cmd, const char *vg_name,
struct volume_group *vg, struct processing_handle *handle)
{ {
struct lvresize_params lp = { 0 }; struct lvresize_params *lp = (struct lvresize_params *) handle->custom_handle;
struct volume_group *vg;
struct dm_list *pvh = NULL; struct dm_list *pvh = NULL;
struct logical_volume *lv; struct logical_volume *lv;
uint32_t lockd_state = 0; int ret = ECMD_FAILED;
int r = ECMD_FAILED;
/* Does LV exist? */
if (!(lv = find_lv(vg, lp->lv_name))) {
log_error("Logical volume %s not found in volume group %s",
lp->lv_name, lp->vg_name);
goto out;
}
if (!(pvh = lp->argc ? create_pv_list(cmd->mem, vg, lp->argc, lp->argv, 1) : &vg->pvs))
goto_out;
if (!lv_resize_prepare(cmd, lv, lp, pvh)) {
ret = EINVALID_CMD_LINE;
goto_out;
}
if (!lv_resize(cmd, lv, lp, pvh))
goto_out;
ret = ECMD_PROCESSED;
out:
return ret;
}
int lvresize(struct cmd_context *cmd, int argc, char **argv)
{
struct processing_handle *handle = NULL;
struct lvresize_params lp = { 0 };
int ret = ECMD_FAILED;
if (!_lvresize_params(cmd, argc, argv, &lp)) if (!_lvresize_params(cmd, argc, argv, &lp))
return EINVALID_CMD_LINE; return EINVALID_CMD_LINE;
if (!lockd_vg(cmd, lp.vg_name, "ex", 0, &lockd_state)) if (!(handle = init_processing_handle(cmd))) {
return_ECMD_FAILED; log_error("Failed to initialize processing handle.");
return ECMD_FAILED;
log_verbose("Finding volume group %s", lp.vg_name);
vg = vg_read_for_update(cmd, lp.vg_name, NULL, 0, lockd_state);
if (vg_read_error(vg)) {
release_vg(vg);
return_ECMD_FAILED;
} }
/* Does LV exist? */ handle->custom_handle = &lp;
if (!(lv = find_lv(vg, lp.lv_name))) {
log_error("Logical volume %s not found in volume group %s",
lp.lv_name, lp.vg_name);
goto out;
}
if (!(pvh = lp.argc ? create_pv_list(cmd->mem, vg, lp.argc, ret = process_each_vg(cmd, 0, NULL, lp.vg_name, READ_FOR_UPDATE, handle,
lp.argv, 1) : &vg->pvs)) &_lvresize_single);
goto_out;
if (!lv_resize_prepare(cmd, lv, &lp, pvh)) { destroy_processing_handle(cmd, handle);
r = EINVALID_CMD_LINE; return ret;
goto_out;
}
if (!lv_resize(cmd, lv, &lp, pvh))
goto_out;
r = ECMD_PROCESSED;
out:
unlock_and_release_vg(cmd, vg, lp.vg_name);
return r;
} }