mirror of
git://sourceware.org/git/lvm2.git
synced 2024-12-21 13:34:40 +03:00
Refactor metadata.[ch] into pv.[ch] for pv functions.
The metadata.[ch] files are very large. This patch makes a first attempt at separating out pv functions and data, particularly related to the reporting fields calculations. More code could be moved here but for now I'm stopping at reporting functions 'get' / 'set' functions.
This commit is contained in:
Dave Wysochanski
parent
81f0124a58
commit
f42b708eae
@ -33,6 +33,7 @@
|
|||||||
@top_srcdir@/lib/metadata/lv_alloc.h
|
@top_srcdir@/lib/metadata/lv_alloc.h
|
||||||
@top_srcdir@/lib/metadata/metadata.h
|
@top_srcdir@/lib/metadata/metadata.h
|
||||||
@top_srcdir@/lib/metadata/metadata-exported.h
|
@top_srcdir@/lib/metadata/metadata-exported.h
|
||||||
|
@top_srcdir@/lib/metadata/pv.h
|
||||||
@top_srcdir@/lib/metadata/pv_alloc.h
|
@top_srcdir@/lib/metadata/pv_alloc.h
|
||||||
@top_srcdir@/lib/metadata/segtype.h
|
@top_srcdir@/lib/metadata/segtype.h
|
||||||
@top_srcdir@/lib/metadata/vg.h
|
@top_srcdir@/lib/metadata/vg.h
|
||||||
|
|||||||
@ -77,6 +77,7 @@ SOURCES =\
|
|||||||
metadata/merge.c \
|
metadata/merge.c \
|
||||||
metadata/metadata.c \
|
metadata/metadata.c \
|
||||||
metadata/mirror.c \
|
metadata/mirror.c \
|
||||||
|
metadata/pv.c \
|
||||||
metadata/pv_manip.c \
|
metadata/pv_manip.c \
|
||||||
metadata/pv_map.c \
|
metadata/pv_map.c \
|
||||||
metadata/replicator_manip.c \
|
metadata/replicator_manip.c \
|
||||||
|
|||||||
@ -22,6 +22,7 @@
|
|||||||
#define _LVM_METADATA_EXPORTED_H
|
#define _LVM_METADATA_EXPORTED_H
|
||||||
|
|
||||||
#include "uuid.h"
|
#include "uuid.h"
|
||||||
|
#include "pv.h"
|
||||||
#include "vg.h"
|
#include "vg.h"
|
||||||
|
|
||||||
#define MAX_STRIPES 128U
|
#define MAX_STRIPES 128U
|
||||||
@ -175,39 +176,6 @@ struct pv_segment {
|
|||||||
|
|
||||||
#define pvseg_is_allocated(pvseg) ((pvseg)->lvseg)
|
#define pvseg_is_allocated(pvseg) ((pvseg)->lvseg)
|
||||||
|
|
||||||
struct physical_volume {
|
|
||||||
struct id id;
|
|
||||||
struct device *dev;
|
|
||||||
const struct format_type *fmt;
|
|
||||||
|
|
||||||
/*
|
|
||||||
* vg_name and vgid are used before the parent VG struct exists.
|
|
||||||
* FIXME: Investigate removal/substitution with 'vg' fields.
|
|
||||||
*/
|
|
||||||
const char *vg_name;
|
|
||||||
struct id vgid;
|
|
||||||
|
|
||||||
/*
|
|
||||||
* 'vg' is set and maintained when the PV belongs to a 'pvs'
|
|
||||||
* list in a parent VG struct.
|
|
||||||
*/
|
|
||||||
struct volume_group *vg;
|
|
||||||
|
|
||||||
uint64_t status;
|
|
||||||
uint64_t size;
|
|
||||||
|
|
||||||
/* physical extents */
|
|
||||||
uint32_t pe_size;
|
|
||||||
uint64_t pe_start;
|
|
||||||
uint32_t pe_count;
|
|
||||||
uint32_t pe_alloc_count;
|
|
||||||
unsigned long pe_align;
|
|
||||||
unsigned long pe_align_offset;
|
|
||||||
|
|
||||||
struct dm_list segments; /* Ordered pv_segments covering complete PV */
|
|
||||||
struct dm_list tags;
|
|
||||||
};
|
|
||||||
|
|
||||||
struct format_instance {
|
struct format_instance {
|
||||||
const struct format_type *fmt;
|
const struct format_type *fmt;
|
||||||
/*
|
/*
|
||||||
@ -419,7 +387,6 @@ int scan_vgs_for_pvs(struct cmd_context *cmd);
|
|||||||
|
|
||||||
int pv_write(struct cmd_context *cmd, struct physical_volume *pv,
|
int pv_write(struct cmd_context *cmd, struct physical_volume *pv,
|
||||||
struct dm_list *mdas, int64_t label_sector);
|
struct dm_list *mdas, int64_t label_sector);
|
||||||
int is_pv(struct physical_volume *pv);
|
|
||||||
int move_pv(struct volume_group *vg_from, struct volume_group *vg_to,
|
int move_pv(struct volume_group *vg_from, struct volume_group *vg_to,
|
||||||
const char *pv_name);
|
const char *pv_name);
|
||||||
int move_pvs_used_by_lv(struct volume_group *vg_from,
|
int move_pvs_used_by_lv(struct volume_group *vg_from,
|
||||||
@ -427,8 +394,6 @@ int move_pvs_used_by_lv(struct volume_group *vg_from,
|
|||||||
const char *lv_name);
|
const char *lv_name);
|
||||||
int is_global_vg(const char *vg_name);
|
int is_global_vg(const char *vg_name);
|
||||||
int is_orphan_vg(const char *vg_name);
|
int is_orphan_vg(const char *vg_name);
|
||||||
int is_orphan(const struct physical_volume *pv);
|
|
||||||
int is_missing_pv(const struct physical_volume *pv);
|
|
||||||
int vg_missing_pv_count(const struct volume_group *vg);
|
int vg_missing_pv_count(const struct volume_group *vg);
|
||||||
int vgs_are_compatible(struct cmd_context *cmd,
|
int vgs_are_compatible(struct cmd_context *cmd,
|
||||||
struct volume_group *vg_from,
|
struct volume_group *vg_from,
|
||||||
@ -777,21 +742,6 @@ char *generate_lv_name(struct volume_group *vg, const char *format,
|
|||||||
/*
|
/*
|
||||||
* Begin skeleton for external LVM library
|
* Begin skeleton for external LVM library
|
||||||
*/
|
*/
|
||||||
struct device *pv_dev(const struct physical_volume *pv);
|
|
||||||
const char *pv_vg_name(const struct physical_volume *pv);
|
|
||||||
const char *pv_dev_name(const struct physical_volume *pv);
|
|
||||||
uint64_t pv_size(const struct physical_volume *pv);
|
|
||||||
uint64_t pv_size_field(const struct physical_volume *pv);
|
|
||||||
uint64_t pv_dev_size(const struct physical_volume *pv);
|
|
||||||
uint64_t pv_free(const struct physical_volume *pv);
|
|
||||||
uint64_t pv_status(const struct physical_volume *pv);
|
|
||||||
uint32_t pv_pe_size(const struct physical_volume *pv);
|
|
||||||
uint64_t pv_pe_start(const struct physical_volume *pv);
|
|
||||||
uint32_t pv_pe_count(const struct physical_volume *pv);
|
|
||||||
uint32_t pv_pe_alloc_count(const struct physical_volume *pv);
|
|
||||||
uint32_t pv_mda_count(const struct physical_volume *pv);
|
|
||||||
uint32_t pv_mda_used_count(const struct physical_volume *pv);
|
|
||||||
unsigned pv_mda_set_ignored(const struct physical_volume *pv, unsigned ignored);
|
|
||||||
int pv_change_metadataignore(struct physical_volume *pv, uint32_t mda_ignore);
|
int pv_change_metadataignore(struct physical_volume *pv, uint32_t mda_ignore);
|
||||||
|
|
||||||
uint64_t lv_size(const struct logical_volume *lv);
|
uint64_t lv_size(const struct logical_volume *lv);
|
||||||
|
|||||||
@ -34,12 +34,6 @@
|
|||||||
#include <math.h>
|
#include <math.h>
|
||||||
#include <sys/param.h>
|
#include <sys/param.h>
|
||||||
|
|
||||||
/*
|
|
||||||
* FIXME: Check for valid handle before dereferencing field or log error?
|
|
||||||
*/
|
|
||||||
#define pv_field(handle, field) \
|
|
||||||
(((const struct physical_volume *)(handle))->field)
|
|
||||||
|
|
||||||
static struct physical_volume *_pv_read(struct cmd_context *cmd,
|
static struct physical_volume *_pv_read(struct cmd_context *cmd,
|
||||||
struct dm_pool *pvmem,
|
struct dm_pool *pvmem,
|
||||||
const char *pv_name,
|
const char *pv_name,
|
||||||
@ -3425,29 +3419,6 @@ int is_orphan_vg(const char *vg_name)
|
|||||||
return (vg_name && !strncmp(vg_name, ORPHAN_PREFIX, sizeof(ORPHAN_PREFIX) - 1)) ? 1 : 0;
|
return (vg_name && !strncmp(vg_name, ORPHAN_PREFIX, sizeof(ORPHAN_PREFIX) - 1)) ? 1 : 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* is_orphan - Determine whether a pv is an orphan based on its vg_name
|
|
||||||
* @pv: handle to the physical volume
|
|
||||||
*/
|
|
||||||
int is_orphan(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return is_orphan_vg(pv_field(pv, vg_name));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* is_pv - Determine whether a pv is a real pv or dummy one
|
|
||||||
* @pv: handle to device
|
|
||||||
*/
|
|
||||||
int is_pv(struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return (pv_field(pv, vg_name) ? 1 : 0);
|
|
||||||
}
|
|
||||||
|
|
||||||
int is_missing_pv(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return pv_field(pv, status) & MISSING_PV ? 1 : 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Returns:
|
* Returns:
|
||||||
* 0 - fail
|
* 0 - fail
|
||||||
@ -3791,101 +3762,6 @@ uint32_t vg_lock_newname(struct cmd_context *cmd, const char *vgname)
|
|||||||
return FAILED_EXIST;
|
return FAILED_EXIST;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
|
||||||
* Gets/Sets for external LVM library
|
|
||||||
*/
|
|
||||||
struct id pv_id(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return pv_field(pv, id);
|
|
||||||
}
|
|
||||||
|
|
||||||
const struct format_type *pv_format_type(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return pv_field(pv, fmt);
|
|
||||||
}
|
|
||||||
|
|
||||||
struct id pv_vgid(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return pv_field(pv, vgid);
|
|
||||||
}
|
|
||||||
|
|
||||||
struct device *pv_dev(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return pv_field(pv, dev);
|
|
||||||
}
|
|
||||||
|
|
||||||
const char *pv_vg_name(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return pv_field(pv, vg_name);
|
|
||||||
}
|
|
||||||
|
|
||||||
const char *pv_dev_name(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return dev_name(pv_dev(pv));
|
|
||||||
}
|
|
||||||
|
|
||||||
uint64_t pv_size(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return pv_field(pv, size);
|
|
||||||
}
|
|
||||||
|
|
||||||
uint64_t pv_dev_size(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
uint64_t size;
|
|
||||||
|
|
||||||
if (!dev_get_size(pv->dev, &size))
|
|
||||||
size = 0;
|
|
||||||
return size;
|
|
||||||
}
|
|
||||||
|
|
||||||
uint64_t pv_size_field(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
uint64_t size;
|
|
||||||
|
|
||||||
if (!pv->pe_count)
|
|
||||||
size = pv->size;
|
|
||||||
else
|
|
||||||
size = (uint64_t) pv->pe_count * pv->pe_size;
|
|
||||||
return size;
|
|
||||||
}
|
|
||||||
|
|
||||||
uint64_t pv_free(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
uint64_t freespace;
|
|
||||||
|
|
||||||
if (!pv->pe_count)
|
|
||||||
freespace = pv->size;
|
|
||||||
else
|
|
||||||
freespace = (uint64_t)
|
|
||||||
(pv->pe_count - pv->pe_alloc_count) * pv->pe_size;
|
|
||||||
return freespace;
|
|
||||||
}
|
|
||||||
|
|
||||||
uint64_t pv_status(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return pv_field(pv, status);
|
|
||||||
}
|
|
||||||
|
|
||||||
uint32_t pv_pe_size(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return pv_field(pv, pe_size);
|
|
||||||
}
|
|
||||||
|
|
||||||
uint64_t pv_pe_start(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return pv_field(pv, pe_start);
|
|
||||||
}
|
|
||||||
|
|
||||||
uint32_t pv_pe_count(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return pv_field(pv, pe_count);
|
|
||||||
}
|
|
||||||
|
|
||||||
uint32_t pv_pe_alloc_count(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
return pv_field(pv, pe_alloc_count);
|
|
||||||
}
|
|
||||||
|
|
||||||
void fid_add_mda(struct format_instance *fid, struct metadata_area *mda)
|
void fid_add_mda(struct format_instance *fid, struct metadata_area *mda)
|
||||||
{
|
{
|
||||||
dm_list_add(mda_is_ignored(mda) ? &fid->metadata_areas_ignored :
|
dm_list_add(mda_is_ignored(mda) ? &fid->metadata_areas_ignored :
|
||||||
@ -3984,88 +3860,6 @@ void mda_set_ignored(struct metadata_area *mda, unsigned mda_ignored)
|
|||||||
mda->ops->mda_metadata_locn_offset ? mda->ops->mda_metadata_locn_offset(locn) : UINT64_C(0));
|
mda->ops->mda_metadata_locn_offset ? mda->ops->mda_metadata_locn_offset(locn) : UINT64_C(0));
|
||||||
}
|
}
|
||||||
|
|
||||||
uint32_t pv_mda_count(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
struct lvmcache_info *info;
|
|
||||||
|
|
||||||
info = info_from_pvid((const char *)&pv->id.uuid, 0);
|
|
||||||
return info ? dm_list_size(&info->mdas) : UINT64_C(0);
|
|
||||||
}
|
|
||||||
|
|
||||||
uint32_t pv_mda_used_count(const struct physical_volume *pv)
|
|
||||||
{
|
|
||||||
struct lvmcache_info *info;
|
|
||||||
struct metadata_area *mda;
|
|
||||||
uint32_t used_count=0;
|
|
||||||
|
|
||||||
info = info_from_pvid((const char *)&pv->id.uuid, 0);
|
|
||||||
if (!info)
|
|
||||||
return 0;
|
|
||||||
dm_list_iterate_items(mda, &info->mdas) {
|
|
||||||
if (!mda_is_ignored(mda))
|
|
||||||
used_count++;
|
|
||||||
}
|
|
||||||
return used_count;
|
|
||||||
}
|
|
||||||
|
|
||||||
unsigned pv_mda_set_ignored(const struct physical_volume *pv, unsigned mda_ignored)
|
|
||||||
{
|
|
||||||
struct lvmcache_info *info;
|
|
||||||
struct metadata_area *mda, *vg_mda, *tmda;
|
|
||||||
struct dm_list *vg_mdas_in_use, *vg_mdas_ignored;
|
|
||||||
|
|
||||||
if (!(info = info_from_pvid((const char *)&pv->id.uuid, 0)))
|
|
||||||
return_0;
|
|
||||||
|
|
||||||
if (is_orphan(pv)) {
|
|
||||||
dm_list_iterate_items(mda, &info->mdas)
|
|
||||||
mda_set_ignored(mda, mda_ignored);
|
|
||||||
return 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
* Do not allow disabling of the the last PV in a VG.
|
|
||||||
*/
|
|
||||||
if (pv_mda_used_count(pv) == vg_mda_used_count(pv->vg)) {
|
|
||||||
log_error("Cannot disable all metadata areas in volume group %s.",
|
|
||||||
pv->vg->name);
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
* Non-orphan case is more complex.
|
|
||||||
* If the PV's mdas are ignored, and we wish to un-ignore,
|
|
||||||
* we clear the bit and move them from the ignored mda list to the
|
|
||||||
* in_use list, ensuring the new state will get written to disk
|
|
||||||
* in the vg_write() path.
|
|
||||||
* If the PV's mdas are not ignored, and we are setting
|
|
||||||
* them to ignored, we set the bit but leave them on the in_use
|
|
||||||
* list, ensuring the new state will get written to disk in the
|
|
||||||
* vg_write() path.
|
|
||||||
*/
|
|
||||||
vg_mdas_in_use = &pv->vg->fid->metadata_areas_in_use;
|
|
||||||
vg_mdas_ignored = &pv->vg->fid->metadata_areas_ignored;
|
|
||||||
|
|
||||||
dm_list_iterate_items(mda, &info->mdas) {
|
|
||||||
if (mda_is_ignored(mda) && !mda_ignored)
|
|
||||||
/* Changing an ignored mda to one in_use requires moving it */
|
|
||||||
dm_list_iterate_items_safe(vg_mda, tmda, vg_mdas_ignored)
|
|
||||||
if (mda_locns_match(mda, vg_mda)) {
|
|
||||||
mda_set_ignored(vg_mda, mda_ignored);
|
|
||||||
dm_list_move(vg_mdas_in_use, &vg_mda->list);
|
|
||||||
}
|
|
||||||
|
|
||||||
dm_list_iterate_items_safe(vg_mda, tmda, vg_mdas_in_use)
|
|
||||||
if (mda_locns_match(mda, vg_mda))
|
|
||||||
/* Don't move mda: needs writing to disk. */
|
|
||||||
mda_set_ignored(vg_mda, mda_ignored);
|
|
||||||
|
|
||||||
mda_set_ignored(mda, mda_ignored);
|
|
||||||
}
|
|
||||||
|
|
||||||
return 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
int mdas_empty_or_ignored(struct dm_list *mdas)
|
int mdas_empty_or_ignored(struct dm_list *mdas)
|
||||||
{
|
{
|
||||||
struct metadata_area *mda;
|
struct metadata_area *mda;
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user