mirror of
git://sourceware.org/git/lvm2.git
synced 2025-03-10 16:58:47 +03:00
pvscan
This commit is contained in:
parent
fc4a099514
commit
b6c041d752
@ -24,6 +24,7 @@ SOURCES=\
|
|||||||
lvm.c \
|
lvm.c \
|
||||||
lvmchange.c \
|
lvmchange.c \
|
||||||
pvcreate.c \
|
pvcreate.c \
|
||||||
|
pvscan.c \
|
||||||
toollib.c \
|
toollib.c \
|
||||||
vgck.c \
|
vgck.c \
|
||||||
vgchange.c \
|
vgchange.c \
|
||||||
|
@ -31,20 +31,20 @@ int pvscan(int argc, char **argv)
|
|||||||
int pvs_found = 0;
|
int pvs_found = 0;
|
||||||
char *s1, *s2, *s3;
|
char *s1, *s2, *s3;
|
||||||
|
|
||||||
struct pv_list *pvs_list, *pvl;
|
struct list_head *pvs;
|
||||||
struct list_head *pvh;
|
struct list_head *pvh;
|
||||||
|
struct pv_list *pvl;
|
||||||
struct physical_volume *pv;
|
struct physical_volume *pv;
|
||||||
|
|
||||||
uint64_t size_total = 0;
|
uint64_t size_total = 0;
|
||||||
uint64_t size_new = 0;
|
uint64_t size_new = 0;
|
||||||
uint64_t size = 0;
|
|
||||||
|
|
||||||
int len = 0;
|
int len = 0;
|
||||||
pv_max_name_len = 0;
|
pv_max_name_len = 0;
|
||||||
vg_max_name_len = 0;
|
vg_max_name_len = 0;
|
||||||
|
|
||||||
if (arg_count(novolumegroup_ARG) && arg_count(exported_ARG)) {
|
if (arg_count(novolumegroup_ARG) && arg_count(exported_ARG)) {
|
||||||
log_error("options e and n incompatible");
|
log_error("Options -e and -n are incompatible");
|
||||||
return EINVALID_CMD_LINE;
|
return EINVALID_CMD_LINE;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -55,17 +55,17 @@ int pvscan(int argc, char **argv)
|
|||||||
|
|
||||||
log_verbose("Walking through all physical volumes");
|
log_verbose("Walking through all physical volumes");
|
||||||
|
|
||||||
if (!(pvs_list = ios->get_pvs(ios)))
|
if (!(pvs = ios->get_pvs(ios)))
|
||||||
return ECMD_FAILED;
|
return ECMD_FAILED;
|
||||||
|
|
||||||
/* eliminate exported/new if required */
|
/* eliminate exported/new if required */
|
||||||
list_for_each(pvh, &pvs_list->list) {
|
list_for_each(pvh, pvs) {
|
||||||
pvl = list_entry(pvh, struct pv_list, list);
|
pvl = list_entry(pvh, struct pv_list, list);
|
||||||
pv = &pvl->pv;
|
pv = &pvl->pv;
|
||||||
|
|
||||||
if ((arg_count(exported_ARG) && !(pv->status & STATUS_EXPORTED))
|
if ((arg_count(exported_ARG) && !(pv->status & EXPORTED_VG))
|
||||||
|| (arg_count(novolumegroup_ARG) && (pv->vg_name[0]))) {
|
|| (arg_count(novolumegroup_ARG) && (*pv->vg_name))) {
|
||||||
list_del(&pvl->list); /* Plus deallocation? */
|
list_del(&pvl->list);
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -81,20 +81,20 @@ int pvscan(int argc, char **argv)
|
|||||||
********/
|
********/
|
||||||
pvs_found++;
|
pvs_found++;
|
||||||
|
|
||||||
size = dev_get_size(pv->dev);
|
|
||||||
size_total += size;
|
|
||||||
|
|
||||||
if (pv->vg_name[0]) {
|
if (!*pv->vg_name) {
|
||||||
new_pvs_found++;
|
new_pvs_found++;
|
||||||
size_new += size;
|
size_new += pv->size;
|
||||||
}
|
size_total += pv->size;
|
||||||
|
} else
|
||||||
|
size_total += (pv->pe_count - pv->pe_allocated)
|
||||||
|
* pv->pe_size;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* find maximum pv name length */
|
/* find maximum pv name length */
|
||||||
pv_max_name_len = vg_max_name_len = 0;
|
pv_max_name_len = vg_max_name_len = 0;
|
||||||
list_for_each(pvh, &pvs_list->list) {
|
list_for_each(pvh, pvs) {
|
||||||
pvl = list_entry(pvh, struct pv_list, list);
|
pv = &list_entry(pvh, struct pv_list, list)->pv;
|
||||||
pv = &pvl->pv;
|
|
||||||
len = strlen(pv->dev->name);
|
len = strlen(pv->dev->name);
|
||||||
if (pv_max_name_len < len)
|
if (pv_max_name_len < len)
|
||||||
pv_max_name_len = len;
|
pv_max_name_len = len;
|
||||||
@ -105,19 +105,15 @@ int pvscan(int argc, char **argv)
|
|||||||
pv_max_name_len += 2;
|
pv_max_name_len += 2;
|
||||||
vg_max_name_len += 2;
|
vg_max_name_len += 2;
|
||||||
|
|
||||||
list_for_each(pvh, &pvs_list->list) {
|
list_for_each(pvh, pvs)
|
||||||
pvl = list_entry(pvh, struct pv_list, list);
|
pvscan_display_single(&list_entry(pvh, struct pv_list, list)->pv);
|
||||||
pv = &pvl->pv;
|
|
||||||
|
|
||||||
pvscan_display_single(pv);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!pvs_found) {
|
if (!pvs_found) {
|
||||||
log_print("No matching physical volumes found");
|
log_print("No matching physical volumes found");
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
log_print("total: %d [%s] / in use: %d [%s] / in no VG: %d [%s]",
|
log_print("Total: %d [%s] / in use: %d [%s] / in no VG: %d [%s]",
|
||||||
pvs_found,
|
pvs_found,
|
||||||
(s1 = display_size(size_total / 2, SIZE_SHORT)),
|
(s1 = display_size(size_total / 2, SIZE_SHORT)),
|
||||||
pvs_found - new_pvs_found,
|
pvs_found - new_pvs_found,
|
||||||
@ -150,65 +146,61 @@ void pvscan_display_single(struct physical_volume *pv)
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (arg_count(verbose_ARG) > 1) {
|
if (arg_count(verbose_ARG) > 1) {
|
||||||
pv_show(pv);
|
/* FIXME As per pv_display! Drop through for now. */
|
||||||
|
/* pv_show(pv); */
|
||||||
|
|
||||||
log_print("System Id %s", pv->exported);
|
log_print("System Id %s", pv->exported);
|
||||||
log_print("");
|
|
||||||
return;
|
/* log_print(" "); */
|
||||||
|
/* return; */
|
||||||
}
|
}
|
||||||
|
|
||||||
memset(pv_tmp_name, 0, sizeof (pv_tmp_name));
|
memset(pv_tmp_name, 0, sizeof (pv_tmp_name));
|
||||||
|
|
||||||
active_str = (pv->status & ACTIVE) ? "ACTIVE " : "inactive ";
|
active_str = (pv->status & ACTIVE) ? "ACTIVE " : "Inactive";
|
||||||
|
|
||||||
vg_name_len = strlen(pv->vg_name) - sizeof (EXPORTED) + 1;
|
vg_name_len = strlen(pv->vg_name) - sizeof (EXPORTED_TAG) + 1;
|
||||||
|
|
||||||
if (arg_count(uuid_ARG)) {
|
if (arg_count(uuid_ARG)) {
|
||||||
sprintf(pv_tmp_name,
|
sprintf(pv_tmp_name,
|
||||||
"%-*s with UUID %s",
|
"%-*s with UUID %s",
|
||||||
pv_max_name_len - 2,
|
pv_max_name_len - 2,
|
||||||
pv->dev->name, display_uuid(pv->id->uuid));
|
pv->dev->name, display_uuid(pv->id.uuid));
|
||||||
} else {
|
} else {
|
||||||
sprintf(pv_tmp_name, "%s", pv->dev.name);
|
sprintf(pv_tmp_name, "%s", pv->dev->name);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!pv->vg_name[0]) {
|
if (!*pv->vg_name) {
|
||||||
log_print("%s PV %-*s is in no VG [%s]", active_str,
|
log_print("%s PV %-*s is in no VG %-*s [%s]", active_str,
|
||||||
pv_max_name_len, pv_tmp_name,
|
pv_max_name_len, pv_tmp_name,
|
||||||
|
vg_max_name_len - 6, " ",
|
||||||
(s1 = display_size(pv->size / 2, SIZE_SHORT)));
|
(s1 = display_size(pv->size / 2, SIZE_SHORT)));
|
||||||
dbg_free(s1);
|
dbg_free(s1);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* FIXME What is pe_total now? */
|
|
||||||
if (strcmp(&pv->vg_name[vg_name_len], EXPORTED_TAG) == 0) {
|
if (strcmp(&pv->vg_name[vg_name_len], EXPORTED_TAG) == 0) {
|
||||||
strncpy(vg_name_this, pv->vg_name, vg_name_len);
|
strncpy(vg_name_this, pv->vg_name, vg_name_len);
|
||||||
log_print("%sPV %-*s is in EXPORTED VG %s [%s / %s free]",
|
log_print("%s PV %-*s is in EXPORTED VG %s [%s / %s free]",
|
||||||
active_str, pv_max_name_len, pv_tmp_name,
|
active_str, pv_max_name_len, pv_tmp_name,
|
||||||
vg_name_this, (s1 =
|
vg_name_this, (s1 =
|
||||||
display_size(pv->pe_total *
|
display_size(pv->pe_count *
|
||||||
pv->pe_size / 2,
|
pv->pe_size / 2,
|
||||||
SIZE_SHORT)),
|
SIZE_SHORT)),
|
||||||
(s2 = display_size((pv->pe_total - pv->pe_allocated)
|
(s2 = display_size((pv->pe_count - pv->pe_allocated)
|
||||||
* pv->pe_size / 2, SIZE_SHORT)));
|
* pv->pe_size / 2, SIZE_SHORT)));
|
||||||
dbg_free(s1);
|
dbg_free(s1);
|
||||||
dbg_free(s2);
|
dbg_free(s2);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!vg_check_name(pv->vg_name)) {
|
|
||||||
log_print
|
|
||||||
("%sPV %-*s is associated to an unknown VG ",
|
|
||||||
active_str, pv_max_name_len, pv_tmp_name);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
sprintf(vg_tmp_name, "%s", pv->vg_name);
|
sprintf(vg_tmp_name, "%s", pv->vg_name);
|
||||||
log_print
|
log_print
|
||||||
("%sPV %-*s of VG %-*s [%s / %s free]", active_str, pv_max_name_len,
|
("%s PV %-*s of VG %-*s [%s / %s free]", active_str, pv_max_name_len,
|
||||||
pv_tmp_name, vg_max_name_len, vg_tmp_name,
|
pv_tmp_name, vg_max_name_len, vg_tmp_name,
|
||||||
(s1 = display_size(pv->pe_total * pv->pe_size / 2, SIZE_SHORT)),
|
(s1 = display_size(pv->pe_count * pv->pe_size / 2, SIZE_SHORT)),
|
||||||
(s2 =
|
(s2 =
|
||||||
display_size((pv->pe_total - pv->pe_allocated) * pv->pe_size / 2,
|
display_size((pv->pe_count - pv->pe_allocated) * pv->pe_size / 2,
|
||||||
SIZE_SHORT)));
|
SIZE_SHORT)));
|
||||||
dbg_free(s1);
|
dbg_free(s1);
|
||||||
dbg_free(s2);
|
dbg_free(s2);
|
||||||
|
@ -33,7 +33,6 @@ int lvscan(int argc, char **argv) {return 1;}
|
|||||||
int pvchange(int argc, char **argv) {return 1;}
|
int pvchange(int argc, char **argv) {return 1;}
|
||||||
int pvdisplay(int argc, char **argv) {return 1;}
|
int pvdisplay(int argc, char **argv) {return 1;}
|
||||||
int pvdata(int argc, char **argv) {return 1;}
|
int pvdata(int argc, char **argv) {return 1;}
|
||||||
int pvscan(int argc, char **argv) {return 1;}
|
|
||||||
int vgcfgbackup(int argc, char **argv) {return 1;}
|
int vgcfgbackup(int argc, char **argv) {return 1;}
|
||||||
int vgcfgrestore(int argc, char **argv) {return 1;}
|
int vgcfgrestore(int argc, char **argv) {return 1;}
|
||||||
int vgdisplay(int argc, char **argv) {return 1;}
|
int vgdisplay(int argc, char **argv) {return 1;}
|
||||||
|
@ -79,6 +79,7 @@ static int vgchange_single(const char *vg_name)
|
|||||||
void vgchange_available(struct volume_group *vg)
|
void vgchange_available(struct volume_group *vg)
|
||||||
{
|
{
|
||||||
int lv_open;
|
int lv_open;
|
||||||
|
struct list_head *pvh;
|
||||||
int available = !strcmp(arg_str_value(available_ARG, "n"), "y");
|
int available = !strcmp(arg_str_value(available_ARG, "n"), "y");
|
||||||
|
|
||||||
/* FIXME Kernel status to override disk flags ! */
|
/* FIXME Kernel status to override disk flags ! */
|
||||||
@ -99,10 +100,17 @@ void vgchange_available(struct volume_group *vg)
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (available)
|
if (available) {
|
||||||
vg->status |= ACTIVE;
|
vg->status |= ACTIVE;
|
||||||
else
|
list_for_each(pvh, &vg->pvs)
|
||||||
|
list_entry(pvh, struct pv_list, list)->pv.status
|
||||||
|
|= ACTIVE;
|
||||||
|
} else {
|
||||||
vg->status &= ~ACTIVE;
|
vg->status &= ~ACTIVE;
|
||||||
|
list_for_each(pvh, &vg->pvs)
|
||||||
|
list_entry(pvh, struct pv_list, list)->pv.status
|
||||||
|
&= ~ACTIVE;
|
||||||
|
}
|
||||||
|
|
||||||
if (!ios->vg_write(ios, vg))
|
if (!ios->vg_write(ios, vg))
|
||||||
return;
|
return;
|
||||||
|
@ -47,9 +47,6 @@ static int vgscan_single(const char *vg_name)
|
|||||||
log_print("Found %sactive volume group %s",
|
log_print("Found %sactive volume group %s",
|
||||||
(vg->status & ACTIVE) ? "" : "in", vg_name);
|
(vg->status & ACTIVE) ? "" : "in", vg_name);
|
||||||
|
|
||||||
/* FIXME: Now try to activate any inactive logical volumes */
|
|
||||||
/* activate_lvs(vg) ? */
|
|
||||||
|
|
||||||
if (!(vg->status & ACTIVE)) {
|
if (!(vg->status & ACTIVE)) {
|
||||||
vg->status |= ACTIVE;
|
vg->status |= ACTIVE;
|
||||||
if (!(ios->vg_write(ios, vg))) {
|
if (!(ios->vg_write(ios, vg))) {
|
||||||
@ -58,9 +55,12 @@ static int vgscan_single(const char *vg_name)
|
|||||||
return ECMD_FAILED;
|
return ECMD_FAILED;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* FIXME: Create /dev/vg entries? */
|
|
||||||
log_print("Volume Group %s activated", vg_name);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/* FIXME: Creates /dev/vg */
|
||||||
|
activate_lvs_in_vg(vg);
|
||||||
|
|
||||||
|
log_print("Volume Group %s activated", vg_name);
|
||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user