test/api/test.c

/*
 * Copyright (C) 2001-2004 Sistina Software, Inc. All rights reserved.
 * Copyright (C) 2004-2011 Red Hat, Inc. All rights reserved.
 *
 * This file is part of LVM2.
 *
 * This copyrighted material is made available to anyone wishing to use,
 * modify, copy, or redistribute it subject to the terms and conditions
 * of the GNU Lesser General Public License v.2.1.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program; if not, write to the Free Software Foundation,
 * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 */

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <ctype.h>

#include "configure.h"
#include "lvm2app.h"

#ifdef READLINE_SUPPORT
#include <readline/readline.h>

#define MAX_ARGS 64

static int lvm_split(char *str, int *argc, char **argv, int max)
{
	char *b = str, *e;
	*argc = 0;

	while (*b) {
		while (*b && isspace(*b))
			b++;

		if ((!*b) || ((*argc == 0)&&(*b == '#')))
			break;

		e = b;
		while (*e && !isspace(*e))
			e++;

		argv[(*argc)++] = b;
		if (!*e)
			break;
		*e++ = '\0';
		b = e;
		if (*argc == max)
			break;
	}

	return *argc;
}

static void _show_help(void)
{
	printf("'lv_activate vgname lvname: "
	       "Activate an LV\n");
	printf("'lv_deactivate vgname lvname: "
	       "Deactivate an LV\n");
	printf("'vg_remove_lv vgname lvname': "
	       "Remove a LV\n");
	printf("'vg_create_lv_linear vgname lvname size_in_bytes': "
	       "Create a linear LV\n");
	printf("'scan_vgs': "
	       "Scan the system for LVM metadata\n");
	printf("'list_vg_names': "
	       "List the names of the VGs that exist in the system\n");
	printf("'list_vg_ids': "
	       "List the uuids of the VGs that exist in the system\n");
	printf("'vg_list_pvs vgname': "
	       "List the PVs that exist in VG vgname\n");
	printf("'pv_list_pvsegs pvname': "
	       "List the PV segments that exist in PV pvname\n");
	printf("'vg_list_lvs vgname': "
	       "List the LVs that exist in VG vgname\n");
	printf("'lv_list_lvsegs vgname lvname': "
	       "List the LV segments that exist in LV vgname/lvname\n");
	printf("'vgs_open': "
	       "List the VGs that are currently open\n");
	printf("'vgs': "
	       "List all VGs known to the system\n");
	printf("'vg_extend vgname device: "
	       "Issue a lvm_vg_extend() API call on VG 'vgname'\n");
	printf("'vg_reduce vgname device: "
	       "Issue a lvm_vg_reduce() API call on VG 'vgname'\n");
	printf("'vg_open vgname ['r' | 'w']': "
	       "Issue a lvm_vg_open() API call on VG 'vgname'\n");
	printf("'vg_close vgname': "
	       "Issue a lvm_vg_close() API call on VG 'vgname'\n");
	printf("'vg_create vgname: "
	       "Issue a lvm_vg_create() to create VG 'vgname'\n");
	printf("'vg_remove vgname: "
	       "Issue a lvm_vg_remove() to remove VG 'vgname'\n");
	printf("'config_reload': "
	       "Issue a lvm_config_reload() API to reload LVM config\n");
	printf("'config_override' device: "
	       "Issue a lvm_config_override() with accept device filter\n");
	printf("'vg_get_tags vgname': "
	       "List the tags of a VG\n");
	printf("'lv_get_property vgname lvname property_name': "
	       "Display the value of LV property\n");
	printf("'vg_get_property vgname property_name': "
	       "Display the value of VG property\n");
	printf("'pv_get_property pvname property_name': "
	       "Display the value of PV property\n");
	printf("'vg_set_property vgname property_name': "
	       "Set the value of VG property\n");
	printf("'lv_get_tags vgname lvname': "
	       "List the tags of a LV\n");
	printf("'vg_{add|remove}_tag vgname tag': "
	       "Add/remove a tag from a VG\n");
	printf("'lv_{add|remove}_tag vgname lvname tag': "
	       "Add/remove a tag from a LV\n");
	printf("'vgname_from_devname device': "
	       "Lookup a vgname from a device name\n");
	printf("'vgname_from_pvid pvid': "
	       "Lookup a vgname from a pvid\n");
	printf("'lv_from_uuid vgname lvuuid': "
	       "Lookup an LV from an LV uuid\n");
	printf("'lv_from_name vgname lvname': "
	       "Lookup an LV from an LV name\n");
	printf("'pv_from_uuid vgname pvuuid': "
	       "Lookup an LV from an LV uuid\n");
	printf("'pv_from_name vgname pvname': "
	       "Lookup an LV from an LV name\n");
	printf("'quit': exit the program\n");
}

static struct dm_hash_table *_vgid_hash = NULL;
static struct dm_hash_table *_vgname_hash = NULL;
static struct dm_hash_table *_pvname_hash = NULL;
static struct dm_hash_table *_lvname_hash = NULL;

static void _hash_destroy_single(struct dm_hash_table **htable)
{
	if (htable && *htable) {
		dm_hash_destroy(*htable);
		*htable = NULL;
	}
}

static void _hash_destroy(void)
{
	_hash_destroy_single(&_vgname_hash);
	_hash_destroy_single(&_vgid_hash);
	_hash_destroy_single(&_pvname_hash);
	_hash_destroy_single(&_lvname_hash);
}

static int _hash_create(void)
{
	if (!(_vgname_hash = dm_hash_create(128)))
		return 0;
	if (!(_pvname_hash = dm_hash_create(128))) {
		_hash_destroy_single(&_vgname_hash);
		return 0;
	}
	if (!(_lvname_hash = dm_hash_create(128))) {
		_hash_destroy_single(&_vgname_hash);
		_hash_destroy_single(&_pvname_hash);
		return 0;
	}
	if (!(_vgid_hash = dm_hash_create(128))) {
		_hash_destroy_single(&_vgname_hash);
		_hash_destroy_single(&_pvname_hash);
		_hash_destroy_single(&_lvname_hash);
		return 0;
	}
	return 1;
}

/* FIXME: this should be per vg */
static lv_t _lookup_lv_by_name(const char *name)
{
	lv_t lv;

	if (!name) {
		printf ("Invalid LV name\n");
		return NULL;
	}
	if (!(lv = dm_hash_lookup(_lvname_hash, name))) {
		printf ("Can't find %s in LVs - run vg_create_lv first\n",
			name);
		return NULL;
	}
	return lv;
}

static vg_t _lookup_vg_by_name(char **argv, int argc)
{
	vg_t vg;

	if (argc < 2) {
		printf ("Please enter vg_name\n");
		return NULL;
	}
	if (!(vg = dm_hash_lookup(_vgid_hash, argv[1])) &&
	    !(vg = dm_hash_lookup(_vgname_hash, argv[1]))) {
		printf ("Can't find %s in open VGs - run vg_open first\n",
			argv[1]);
		return NULL;
	}
	return vg;
}

static pv_t _lookup_pv_by_name(const char *name)
{
	pv_t pv;

	if (!(pv = dm_hash_lookup(_pvname_hash, name))) {
		printf ("Can't find %s in open PVs - run vg_open first\n",
			name);
		return NULL;
	}
	return pv;
}

static void _add_lvs_to_lvname_hash(struct dm_list *lvs)
{
	struct lvm_lv_list *lvl;
	dm_list_iterate_items(lvl, lvs) {
		/* Concatenate VG name with LV name */
		dm_hash_insert(_lvname_hash, lvm_lv_get_name(lvl->lv), lvl->lv);
	}
}

static void _add_pvs_to_pvname_hash(struct dm_list *pvs)
{
	struct lvm_pv_list *pvl;
	dm_list_iterate_items(pvl, pvs) {
		dm_hash_insert(_pvname_hash, lvm_pv_get_name(pvl->pv), pvl->pv);
	}
}

static void _remove_device_from_pvname_hash(struct dm_list *pvs, const char *name)
{
	struct lvm_pv_list *pvl;
	dm_list_iterate_items(pvl, pvs) {
		if (!strncmp(lvm_pv_get_name(pvl->pv), name, strlen(name)))
			dm_hash_remove(_pvname_hash, name);
	}
}
static void _add_device_to_pvname_hash(struct dm_list *pvs, const char *name)
{
	struct lvm_pv_list *pvl;
	dm_list_iterate_items(pvl, pvs) {
		if (!strncmp(lvm_pv_get_name(pvl->pv), name, strlen(name)))
			dm_hash_insert(_pvname_hash, name, pvl->pv);
	}
}

static void _vg_reduce(char **argv, int argc, lvm_t libh)
{
	vg_t vg;
	struct dm_list *pvs;

	if (argc < 2) {
		printf ("Please enter vg_name\n");
		return;
	}
	if (!(vg = dm_hash_lookup(_vgid_hash, argv[1])) &&
	    !(vg = dm_hash_lookup(_vgname_hash, argv[1]))) {
		printf ("VG not open\n");
		return;
	}
	if (lvm_vg_reduce(vg, argv[2])) {
		printf("Error reducing %s by %s\n", argv[1], argv[2]);
		return;
	}

	printf("Success reducing vg %s by %s\n", argv[1], argv[2]);

	/*
	 * Add the device into the hashes for lookups
	 */
	pvs = lvm_vg_list_pvs(vg);
	if (pvs && !dm_list_empty(pvs))
		_remove_device_from_pvname_hash(pvs, argv[2]);
}

/* Print "Error" or "Success" depending on lvm status */
static int _lvm_status_to_pass_fail(int rc)
{
	if (rc)
		printf("Error ");
	else
		printf("Success ");
	return rc;
}
static void _config_override(char **argv, int argc, lvm_t libh)
{
	int rc;
	char tmp[64];

	if (argc < 2) {
		printf ("Please enter device\n");
		return;
	}
	snprintf(tmp, 63, "devices{filter=[\"a|%s|\", \"r|.*|\"]}", argv[1]);
	rc = lvm_config_override(libh, tmp);
	_lvm_status_to_pass_fail(rc);
	printf("overriding LVM configuration\n");
}

static void _config_reload(char **argv, int argc, lvm_t libh)
{
	int rc;
	rc = lvm_config_reload(libh);
	_lvm_status_to_pass_fail(rc);
	printf("reloading LVM configuration\n");
}

static void _vg_extend(char **argv, int argc, lvm_t libh)
{
	vg_t vg;
	struct dm_list *pvs;

	if (argc < 2) {
		printf ("Please enter vg_name\n");
		return;
	}
	if (!(vg = dm_hash_lookup(_vgid_hash, argv[1])) &&
	    !(vg = dm_hash_lookup(_vgname_hash, argv[1]))) {
		printf ("VG not open\n");
		return;
	}
	if (lvm_vg_extend(vg, argv[2])) {
		printf("Error extending %s with %s\n", argv[1], argv[2]);
		return;
	}

	printf("Success extending vg %s with %s\n", argv[1], argv[2]);

	/*
	 * Add the device into the hashes for lookups
	 */
	pvs = lvm_vg_list_pvs(vg);
	if (pvs && !dm_list_empty(pvs))
		_add_device_to_pvname_hash(pvs, argv[2]);
}

static void _vg_open(char **argv, int argc, lvm_t libh)
{
	vg_t vg;
	struct dm_list *lvs;
	struct dm_list *pvs;

	if (argc < 2) {
		printf ("Please enter vg_name\n");
		return;
	}
	if ((vg = dm_hash_lookup(_vgid_hash, argv[1])) ||
	    (vg = dm_hash_lookup(_vgname_hash, argv[1]))) {
		printf ("VG already open\n");
		return;
	}
	if (argc < 3)
		vg = lvm_vg_open(libh, argv[1], "r", 0);
	else
		vg = lvm_vg_open(libh, argv[1], argv[2], 0);
	if (!vg || !lvm_vg_get_name(vg)) {
		printf("Error opening %s\n", argv[1]);
		return;
	}

	printf("Success opening vg %s\n", argv[1]);
	dm_hash_insert(_vgname_hash, lvm_vg_get_name(vg), vg);
	dm_hash_insert(_vgid_hash, lvm_vg_get_uuid(vg), vg);

	/*
	 * Add the LVs and PVs into the hashes for lookups
	 */
	lvs = lvm_vg_list_lvs(vg);
	if (lvs && !dm_list_empty(lvs))
		_add_lvs_to_lvname_hash(lvs);
	pvs = lvm_vg_list_pvs(vg);
	if (pvs && !dm_list_empty(pvs))
		_add_pvs_to_pvname_hash(pvs);
}
/* Lookup the vg and remove it from the vgname and vgid hashes */
static vg_t _lookup_and_remove_vg(const char *vgname)
{
	vg_t vg=NULL;

	if ((vg = dm_hash_lookup(_vgname_hash, vgname))) {
		dm_hash_remove(_vgid_hash, lvm_vg_get_uuid(vg));
		dm_hash_remove(_vgname_hash, lvm_vg_get_name(vg));
	}
	if (!vg && (vg = dm_hash_lookup(_vgid_hash, vgname))) {
		dm_hash_remove(_vgid_hash, lvm_vg_get_uuid(vg));
		dm_hash_remove(_vgname_hash, lvm_vg_get_name(vg));
	}
	return vg;
}

static void _vg_write(char **argv, int argc)
{
	vg_t vg;
	int rc = 0;

	if (argc < 2) {
		printf ("Please enter vg_name\n");
		return;
	}
	vg = _lookup_vg_by_name(argv, argc);
	if (!vg) {
		printf("Can't find vg_name %s\n", argv[1]);
		return;
	}
	rc = lvm_vg_write(vg);
	_lvm_status_to_pass_fail(rc);
	printf("writing VG %s\n", lvm_vg_get_name(vg));
}

static void _vg_create(char **argv, int argc, lvm_t libh)
{
	vg_t vg;

	if (argc < 2) {
		printf ("Please enter vg_name\n");
		return;
	}
	vg = lvm_vg_create(libh, argv[1]);
	if (!vg || !lvm_vg_get_name(vg)) {
		printf("Error creating %s\n", argv[1]);
		return;
	}

	printf("Success creating vg %s\n", argv[1]);
	dm_hash_insert(_vgname_hash, lvm_vg_get_name(vg), vg);
	dm_hash_insert(_vgid_hash, lvm_vg_get_uuid(vg), vg);
}

static void _vg_remove(char **argv, int argc)
{
	vg_t vg;
	int rc = 0;

	if (argc < 2) {
		printf ("Please enter vg_name\n");
		return;
	}
	vg = _lookup_vg_by_name(argv, argc);
	if (!vg) {
		printf("Can't find vg_name %s\n", argv[1]);
		return;
	}
	rc = lvm_vg_remove(vg);
	_lvm_status_to_pass_fail(rc);
	printf("removing VG\n");
}

static void _vg_close(char **argv, int argc)
{
	vg_t vg;
	int rc = 0;

	if (argc < 2) {
		printf ("Please enter vg_name\n");
		return;
	}
	vg = _lookup_and_remove_vg(argv[1]);
	if (!vg) {
		printf("Can't find vg_name %s\n", argv[1]);
		return;
	}
	rc = lvm_vg_close(vg);
	_lvm_status_to_pass_fail(rc);
	printf("closing VG\n");
}

static void _show_one_vg(vg_t vg)
{
	printf("%s (%s): sz=%"PRIu64", free=%"PRIu64", #pv=%"PRIu64
		", seq#=%"PRIu64"\n",
		lvm_vg_get_name(vg), lvm_vg_get_uuid(vg),
		lvm_vg_get_size(vg), lvm_vg_get_free_size(vg),
		lvm_vg_get_pv_count(vg), lvm_vg_get_seqno(vg));
}

static void _print_pv(pv_t pv)
{
	if (!pv)
		return;
	printf("%s (%s): size=%"PRIu64", free=%"PRIu64
	       ", dev_size=%"PRIu64", mda_count=%"PRIu64"\n",
	       lvm_pv_get_name(pv), lvm_pv_get_uuid(pv),
	       lvm_pv_get_size(pv), lvm_pv_get_free(pv),
	       lvm_pv_get_dev_size(pv),
	       lvm_pv_get_mda_count(pv));
}

static void _print_lv(vg_t vg, lv_t lv)
{
	if (!lv)
		return;
	printf("%s/%s (%s): size=%"PRIu64", %sACTIVE / %sSUSPENDED\n",
	       lvm_vg_get_name(vg),
	       lvm_lv_get_name(lv), lvm_lv_get_uuid(lv),
	       lvm_lv_get_size(lv),
	       lvm_lv_is_active(lv) ? "" : "IN",
	       lvm_lv_is_suspended(lv) ? "" : "NOT ");
}

static void _list_open_vgs(void)
{
	dm_hash_iter(_vgid_hash, (dm_hash_iterate_fn) _show_one_vg);
}

static void _pvs_in_vg(char **argv, int argc)
{
	struct dm_list *pvs;
	struct lvm_pv_list *pvl;
	vg_t vg;

	if (!(vg = _lookup_vg_by_name(argv, argc)))
		return;
	pvs = lvm_vg_list_pvs(vg);
	if (!pvs || dm_list_empty(pvs)) {
		printf("No PVs in VG %s\n", lvm_vg_get_name(vg));
		return;
	}
	printf("PVs in VG %s:\n", lvm_vg_get_name(vg));
	dm_list_iterate_items(pvl, pvs) {
		_print_pv(pvl->pv);
	}
}

static void _print_property_value(const char *name,
				  struct lvm_property_value v)
{
	if (!v.is_valid)
		printf("%s = INVALID\n", name);
	else if (v.is_string)
		printf("%s = %s\n", name, v.value.string);
	else
		printf("%s = %"PRIu64"\n", name, v.value.integer);
}

static void _pvsegs_in_pv(char **argv, int argc)
{
	struct dm_list *pvsegs;
	struct lvm_pvseg_list *pvl;
	pv_t pv;

	if (!(pv = _lookup_pv_by_name(argv[1])))
		return;
	pvsegs = lvm_pv_list_pvsegs(pv);
	if (!pvsegs || dm_list_empty(pvsegs)) {
		printf("No PV segments in pv %s\n", argv[1]);
		return;
	}
	printf("PV segments in pv %s:\n", argv[1]);
	dm_list_iterate_items(pvl, pvsegs) {
		struct lvm_property_value v;
		v = lvm_pvseg_get_property(pvl->pvseg, "pvseg_start");
		_print_property_value("pvseg_start", v);
		v = lvm_pvseg_get_property(pvl->pvseg, "pvseg_size");
		_print_property_value("pvseg_size", v);
	}
}

static void _scan_vgs(lvm_t libh)
{
	lvm_scan(libh);
}

static void _list_vg_names(lvm_t libh)
{
	struct dm_list *list;
	struct lvm_str_list *strl;

	list = lvm_list_vg_names(libh);
	printf("VG names:\n");
	dm_list_iterate_items(strl, list) {
		printf("%s\n", strl->str);
	}
}

static void _list_vg_ids(lvm_t libh)
{
	struct dm_list *list;
	struct lvm_str_list *strl;

	list = lvm_list_vg_uuids(libh);
	printf("VG uuids:\n");
	dm_list_iterate_items(strl, list) {
		printf("%s\n", strl->str);
	}
}

static void _display_tags(struct dm_list *list)
{
	struct lvm_str_list *strl;
	if (dm_list_empty(list)) {
		printf("No tags exist\n");
		return;
	} else if (!list) {
		printf("Error obtaining tags\n");
		return;
	}
	dm_list_iterate_items(strl, list) {
		printf("%s\n", strl->str);
	}
}

static void _vg_get_tags(char **argv, int argc)
{
	vg_t vg;

	if (!(vg = _lookup_vg_by_name(argv, argc)))
		return;
	printf("VG tags:\n");
	_display_tags(lvm_vg_get_tags(vg));
}

static void _vg_tag(char **argv, int argc, int add)
{
	vg_t vg;

	if (argc < 3) {
		printf("Please enter vgname, tag\n");
		return;
	}
	if (!(vg = _lookup_vg_by_name(argv, argc)))
		return;
	if (add && lvm_vg_add_tag(vg, argv[2]))
		printf("Error ");
	else if (!add && lvm_vg_remove_tag(vg, argv[2])){
		printf("Error ");
	} else {
		printf("Success ");
	}
	printf("%s tag %s to VG %s\n",
	       add ? "adding":"removing", argv[2], argv[1]);
}

static void _pv_get_property(char **argv, int argc)
{
	pv_t pv;
	struct lvm_property_value v;

	if (argc < 3) {
		printf("Please enter pvname, field_id\n");
		return;
	}
	if (!(pv = _lookup_pv_by_name(argv[1])))
		return;
	v = lvm_pv_get_property(pv, argv[2]);
	_print_property_value(argv[2], v);
}

static void _vg_get_property(char **argv, int argc)
{
	vg_t vg;
	struct lvm_property_value v;

	if (argc < 3) {
		printf("Please enter vgname, field_id\n");
		return;
	}
	if (!(vg = _lookup_vg_by_name(argv, argc)))
		return;
	v =  lvm_vg_get_property(vg, argv[2]);
	_print_property_value(argv[2], v);
}

static void _lv_get_property(char **argv, int argc)
{
	lv_t lv;
	struct lvm_property_value v;

	if (argc < 4) {
		printf("Please enter vgname, lvname, field_id\n");
		return;
	}
	if (!(lv = _lookup_lv_by_name(argv[2])))
		return;
	v = lvm_lv_get_property(lv, argv[3]);
	_print_property_value(argv[3], v);
}

static void _vg_set_property(char **argv, int argc)
{
	vg_t vg;
	struct lvm_property_value value;
	int rc;

	if (argc < 4) {
		printf("Please enter vgname, field_id, value\n");
		return;
	}
	if (!(vg = _lookup_vg_by_name(argv, argc)))
		return;
	value = lvm_vg_get_property(vg, argv[2]);
	if (!value.is_valid) {
		printf("Error obtaining property value\n");
		return;
	}
	if (value.is_string)
		value.value.string = argv[3];
	else
		value.value.integer = atoi(argv[3]);
	rc = lvm_vg_set_property(vg, argv[2], &value);
	if (rc)
		printf("Error ");
	else
		printf("Success ");
	printf("setting value of property %s in VG %s\n",
	       argv[2], argv[1]);
}

static void _lv_get_tags(char **argv, int argc)
{
	lv_t lv;

	if (argc < 3) {
		printf("Please enter vgname, lvname\n");
		return;
	}
	if (!(lv = _lookup_lv_by_name(argv[2])))
		return;
	printf("LV tags:\n");
	_display_tags(lvm_lv_get_tags(lv));
}

static void _lv_tag(char **argv, int argc, int add)
{
	lv_t lv;

	if (argc < 3) {
		printf("Please enter vgname, lvname\n");
		return;
	}
	if (!(lv = _lookup_lv_by_name(argv[2])))
		return;
	if (add && lvm_lv_add_tag(lv, argv[3]))
		printf("Error ");
	else if (!add && lvm_lv_remove_tag(lv, argv[3])){
		printf("Error ");
	} else {
		printf("Success ");
	}
	printf("%s tag %s to LV %s\n",
	       add ? "adding":"removing", argv[3], argv[2]);
}

static void _lv_from_uuid(char **argv, int argc)
{
	vg_t vg;

	if (argc < 3) {
		printf("Please enter vgname, lv_uuid\n");
		return;
	}
	if (!(vg = _lookup_vg_by_name(argv, argc)))
		return;
	_print_lv(vg, lvm_lv_from_uuid(vg, argv[2]));
}

static void _lv_from_name(char **argv, int argc)
{
	vg_t vg;

	if (argc < 3) {
		printf("Please enter vgname, lv_uuid\n");
		return;
	}
	if (!(vg = _lookup_vg_by_name(argv, argc)))
		return;
	_print_lv(vg, lvm_lv_from_name(vg, argv[2]));
}

static void _pv_from_uuid(char **argv, int argc)
{
	vg_t vg;

	if (argc < 3) {
		printf("Please enter vgname, pv_uuid\n");
		return;
	}
	if (!(vg = _lookup_vg_by_name(argv, argc)))
		return;
	_print_pv(lvm_pv_from_uuid(vg, argv[2]));
}

static void _pv_from_name(char **argv, int argc)
{
	vg_t vg;

	if (argc < 3) {
		printf("Please enter vgname, pv_uuid\n");
		return;
	}
	if (!(vg = _lookup_vg_by_name(argv, argc)))
		return;
	_print_pv(lvm_pv_from_name(vg, argv[2]));
}

static void _vgname_from_pvid(char **argv, int argc, lvm_t libh)
{
	const char *vgname;

	if (argc < 1) {
		printf("Please enter pvid\n");
		return;
	}
	if (!(vgname = lvm_vgname_from_pvid(libh, argv[1]))) {
		printf("Error ");
	} else {
		printf("Success ");
	}
	printf("looking up vgname=%s from PVID=%s\n",
	       vgname, argv[1]);
}
static void _vgname_from_devname(char **argv, int argc, lvm_t libh)
{
	const char *vgname;

	if (argc < 1) {
		printf("Please enter device\n");
		return;
	}
	if (!(vgname = lvm_vgname_from_device(libh, argv[1]))) {
		printf("Error ");
	} else {
		printf("Success ");
	}
	printf("looking up vgname=%s from device name=%s\n",
	       vgname, argv[1]);
}
static void _lvs_in_vg(char **argv, int argc)
{
	struct dm_list *lvs;
	struct lvm_lv_list *lvl;
	vg_t vg;

	if (!(vg = _lookup_vg_by_name(argv, argc)))
		return;
	lvs = lvm_vg_list_lvs(vg);
	if (!lvs || dm_list_empty(lvs)) {
		printf("No LVs in VG %s\n", lvm_vg_get_name(vg));
		return;
	}
	printf("LVs in VG %s:\n", lvm_vg_get_name(vg));
	dm_list_iterate_items(lvl, lvs) {
		_print_lv(vg, lvl->lv);
	}
}

static void _lvsegs_in_lv(char **argv, int argc)
{
	struct dm_list *lvsegs;
	struct lvm_lvseg_list *lvl;
	lv_t lv;

	if (!(lv = _lookup_lv_by_name(argv[2])))
		return;
	lvsegs = lvm_lv_list_lvsegs(lv);
	if (!lvsegs || dm_list_empty(lvsegs)) {
		printf("No LV segments in lv %s\n", lvm_lv_get_name(lv));
		return;
	}
	printf("LV segments in lv %s:\n", lvm_lv_get_name(lv));
	dm_list_iterate_items(lvl, lvsegs) {
		struct lvm_property_value v;
		v = lvm_lvseg_get_property(lvl->lvseg, "segtype");
		_print_property_value("segtype", v);
		v = lvm_lvseg_get_property(lvl->lvseg, "seg_start_pe");
		_print_property_value("seg_start_pe", v);
		v = lvm_lvseg_get_property(lvl->lvseg, "seg_size");
		_print_property_value("seg_size", v);
		v = lvm_lvseg_get_property(lvl->lvseg, "devices");
		_print_property_value("devices", v);
		v = lvm_lvseg_get_property(lvl->lvseg, "seg_pe_ranges");
		_print_property_value("seg_pe_ranges", v);
	}
}

static void _lv_deactivate(char **argv, int argc)
{
	lv_t lv;
	int rc=0;

	if (argc < 3) {
		printf("Please enter vgname, lvname\n");
		return;
	}
	if (!(lv = _lookup_lv_by_name(argv[2])))
		return;
	rc = lvm_lv_deactivate(lv);
	_lvm_status_to_pass_fail(rc);
	printf("De-activating LV %s in VG %s\n",
		argv[2], argv[1]);
}
static void _lv_activate(char **argv, int argc)
{
	lv_t lv;
	int rc=0;

	if (argc < 3) {
		printf("Please enter vgname, lvname\n");
		return;
	}
	if (!(lv = _lookup_lv_by_name(argv[2])))
		return;
	rc = lvm_lv_activate(lv);
	_lvm_status_to_pass_fail(rc);
	printf("activating LV %s in VG %s\n",
		argv[2], argv[1]);
}

static void _vg_remove_lv(char **argv, int argc)
{
	lv_t lv;

	if (argc < 3) {
		printf("Please enter vgname, lvname\n");
		return;
	}
	if (!(lv = _lookup_lv_by_name(argv[2])))
		return;
	if (lvm_vg_remove_lv(lv))
		printf("Error ");
	else {
		printf("Success ");
		dm_hash_remove(_lvname_hash, argv[2]);
	}
	printf("removing LV %s in VG %s\n",
		argv[2], argv[1]);
}

static void _vg_create_lv_linear(char **argv, int argc)
{
	vg_t vg;
	lv_t lv;

	if (argc < 4) {
		printf("Please enter vgname, lvname, and size\n");
		return;
	}
	if (!(vg = _lookup_vg_by_name(argv, argc)))
		return;
	lv = lvm_vg_create_lv_linear(vg, argv[2], atol(argv[3]));
	if (!lv)
		printf("Error ");
	else {
		printf("Success ");
		dm_hash_insert(_lvname_hash, argv[2], lv);
	}
	printf("creating LV %s in VG %s\n",
		argv[2], argv[1]);
}

static int lvmapi_test_shell(lvm_t libh)
{
	int argc;
	char *input = NULL, *args[MAX_ARGS], **argv;

	_hash_create();
	argc=0;
	while (1) {
		free(input);
		input = readline("liblvm> ");

		/* EOF */
		if (!input) {
			printf("\n");
			break;
		}

		/* empty line */
		if (!*input)
			continue;

		argv = args;

		if (lvm_split(input, &argc, argv, MAX_ARGS) == MAX_ARGS) {
			printf("Too many arguments, sorry.");
			continue;
		}

		if (!strcmp(argv[0], "lvm")) {
			argv++;
			argc--;
		}

		if (!argc)
			continue;

		if (!strcmp(argv[0], "quit") || !strcmp(argv[0], "exit")) {
			printf("Exiting.\n");
			break;
		} else if (!strcmp(argv[0], "?") || !strcmp(argv[0], "help")) {
			_show_help();
		} else if (!strcmp(argv[0], "config_reload")) {
			_config_reload(argv, argc, libh);
		} else if (!strcmp(argv[0], "config_override")) {
			_config_override(argv, argc, libh);
		} else if (!strcmp(argv[0], "vg_extend")) {
			_vg_extend(argv, argc, libh);
		} else if (!strcmp(argv[0], "vg_reduce")) {
			_vg_reduce(argv, argc, libh);
		} else if (!strcmp(argv[0], "vg_write")) {
			_vg_write(argv, argc);
		} else if (!strcmp(argv[0], "vg_open")) {
			_vg_open(argv, argc, libh);
		} else if (!strcmp(argv[0], "vg_close")) {
			_vg_close(argv, argc);
		} else if (!strcmp(argv[0], "vg_create")) {
			_vg_create(argv, argc, libh);
		} else if (!strcmp(argv[0], "vg_remove")) {
			_vg_remove(argv, argc);
		} else if (!strcmp(argv[0], "lv_activate")) {
			_lv_activate(argv, argc);
		} else if (!strcmp(argv[0], "lv_deactivate")) {
			_lv_deactivate(argv, argc);
		} else if (!strcmp(argv[0], "vg_remove_lv")) {
			_vg_remove_lv(argv, argc);
		} else if (!strcmp(argv[0], "vgs_open")) {
			_list_open_vgs();
		} else if (!strcmp(argv[0], "vg_list_pvs")) {
			_pvs_in_vg(argv, argc);
		} else if (!strcmp(argv[0], "pv_list_pvsegs")) {
			_pvsegs_in_pv(argv, argc);
		} else if (!strcmp(argv[0], "vg_list_lvs")) {
			_lvs_in_vg(argv, argc);
		} else if (!strcmp(argv[0], "lv_list_lvsegs")) {
			_lvsegs_in_lv(argv, argc);
		} else if (!strcmp(argv[0], "list_vg_names")) {
			_list_vg_names(libh);
		} else if (!strcmp(argv[0], "list_vg_ids")) {
			_list_vg_ids(libh);
		} else if (!strcmp(argv[0], "scan_vgs")) {
			_scan_vgs(libh);
		} else if (!strcmp(argv[0], "vg_create_lv_linear")) {
			_vg_create_lv_linear(argv, argc);
		} else if (!strcmp(argv[0], "vg_add_tag")) {
			_vg_tag(argv, argc, 1);
		} else if (!strcmp(argv[0], "vg_remove_tag")) {
			_vg_tag(argv, argc, 0);
		} else if (!strcmp(argv[0], "vg_get_tags")) {
			_vg_get_tags(argv, argc);
		} else if (!strcmp(argv[0], "lv_get_property")) {
			_lv_get_property(argv, argc);
		} else if (!strcmp(argv[0], "vg_get_property")) {
			_vg_get_property(argv, argc);
		} else if (!strcmp(argv[0], "pv_get_property")) {
			_pv_get_property(argv, argc);
		} else if (!strcmp(argv[0], "vg_set_property")) {
			_vg_set_property(argv, argc);
		} else if (!strcmp(argv[0], "lv_add_tag")) {
			_lv_tag(argv, argc, 1);
		} else if (!strcmp(argv[0], "lv_remove_tag")) {
			_lv_tag(argv, argc, 0);
		} else if (!strcmp(argv[0], "lv_get_tags")) {
			_lv_get_tags(argv, argc);
		} else if (!strcmp(argv[0], "vgname_from_devname")) {
			_vgname_from_devname(argv, argc, libh);
		} else if (!strcmp(argv[0], "vgname_from_pvid")) {
			_vgname_from_pvid(argv, argc, libh);
		} else if (!strcmp(argv[0], "lv_from_uuid")) {
			_lv_from_uuid(argv, argc);
		} else if (!strcmp(argv[0], "lv_from_name")) {
			_lv_from_name(argv, argc);
		} else if (!strcmp(argv[0], "pv_from_uuid")) {
			_pv_from_uuid(argv, argc);
		} else if (!strcmp(argv[0], "pv_from_name")) {
			_pv_from_name(argv, argc);
		} else {
			printf ("Unrecognized command %s\n", argv[0]);
		}
	}

	dm_hash_iter(_vgname_hash, (dm_hash_iterate_fn) lvm_vg_close);
	_hash_destroy();
	free(input);
	return 0;
}
#else /* !READLINE_SUPPORT */
static int lvmapi_test_shell(lvm_t libh)
{
	printf("Build without readline library, no interactive testing.\n");
	return 1;
}
#endif

int main (int argc, char *argv[])
{
	lvm_t libh;

	libh = lvm_init(NULL);
	if (!libh) {
		printf("Unable to open lvm library instance\n");
		return 1;
	}

	printf("Library version: %s\n", lvm_library_get_version());
	lvmapi_test_shell(libh);

	lvm_quit(libh);
	return 0;
}