From dfe213f8049b941ff1d5894c4b518198de8fdf40 Mon Sep 17 00:00:00 2001 From: Dave Wysochanski Date: Mon, 27 Jul 2009 17:44:29 +0000 Subject: [PATCH] Add lvm_vg_reduce to liblvm2app Extend lvm_vg_write to remove pvs removed in lvm_vg_reduce. The lvm volume_group internal structure removed_pvs is used for that. The list is empty afterwards. Add new test for vg->pvs emptyness to lvm_vg_write to prevent to write empty vgs. This is needed because of lvm_vg_reduce and lv_vg_create, which creates empty vgs. Signed-off-by: Thomas Woerner Acked-by: Dave Wysochanski Author: Dave Wysochanski --- liblvm/.exported_symbols | 1 + liblvm/lvm.h | 18 ++++++++++++++++++ liblvm/lvm_vg.c | 35 +++++++++++++++++++++++++++++++++++ 3 files changed, 54 insertions(+) diff --git a/liblvm/.exported_symbols b/liblvm/.exported_symbols index 991142304..68edb870e 100644 --- a/liblvm/.exported_symbols +++ b/liblvm/.exported_symbols @@ -21,6 +21,7 @@ lvm_lv_is_active lvm_lv_is_suspended lvm_vg_create lvm_vg_extend +lvm_vg_reduce lvm_vg_set_extent_size lvm_vg_write lvm_vg_open diff --git a/liblvm/lvm.h b/liblvm/lvm.h index 73ba6d947..1247d44b6 100644 --- a/liblvm/lvm.h +++ b/liblvm/lvm.h @@ -330,6 +330,24 @@ int lvm_vg_close(vg_t *vg); */ int lvm_vg_extend(vg_t *vg, const char *device); +/** + * Reduce a VG by removing an unused device. + * + * This API requires calling lvm_vg_write to commit the change to disk. + * After successfully removing a device, use lvm_vg_write to commit the new VG + * to disk. Upon failure, retry the operation or release the VG handle with + * lvm_vg_close. + * + * \param vg + * VG handle obtained from lvm_vg_create or lvm_vg_open. + * + * \param device + * Name of device to remove from VG. + * + * \return 0 (success) or -1 (failure). + */ +int lvm_vg_reduce(vg_t *vg, const char *device); + /** * Set the extent size of a VG. * diff --git a/liblvm/lvm_vg.c b/liblvm/lvm_vg.c index cd2ef46c2..b83e31c97 100644 --- a/liblvm/lvm_vg.c +++ b/liblvm/lvm_vg.c @@ -68,6 +68,16 @@ int lvm_vg_extend(vg_t *vg, const char *device) return 0; } +int lvm_vg_reduce(vg_t *vg, const char *device) +{ + if (vg_read_error(vg)) + return -1; + + if (!vg_reduce(vg, (char *)device)) + return -1; + return 0; +} + int lvm_vg_set_extent_size(vg_t *vg, uint32_t new_size) { if (vg_read_error(vg)) @@ -80,15 +90,40 @@ int lvm_vg_set_extent_size(vg_t *vg, uint32_t new_size) int lvm_vg_write(vg_t *vg) { + struct pv_list *pvl; + if (vg_read_error(vg)) return -1; + if (dm_list_empty(&vg->pvs)) { + log_error("Volume group %s does not contain any " + "physical volumes.\n", vg->name); + return -1; + } + + if (! dm_list_empty(&vg->removed_pvs)) { + if (!lock_vol(vg->cmd, VG_ORPHANS, LCK_VG_WRITE)) { + log_error("Can't get lock for orphan PVs"); + return 0; + } + } + if (!archive(vg)) return -1; /* Store VG on disk(s) */ if (!vg_write(vg) || !vg_commit(vg)) return -1; + + if (! dm_list_empty(&vg->removed_pvs)) { + dm_list_iterate_items(pvl, &vg->removed_pvs) { + pv_write_orphan(vg->cmd, pvl->pv); + /* FIXME: do pvremove / label_remove()? */ + } + dm_list_init(&vg->removed_pvs); + unlock_vg(vg->cmd, VG_ORPHANS); + } + return 0; } -- 2.43.5