mirror of
git://sourceware.org/git/lvm2.git
synced 2024-12-21 13:34:40 +03:00
a7c45ddc59
Previously, a command sent lvmetad new VG metadata in vg_commit().
In vg_commit(), devices are suspended, so any memory allocation
done by the command while sending to lvmetad, or by lvmetad while
updating its cache could deadlock if memory reclaim was triggered.
Now lvmetad is updated in unlock_vg(), after devices are resumed.
The new method for updating VG metadata in lvmetad is in two phases:
1. In vg_write(), before devices are suspended, the command sends
lvmetad a short message ("set_vg_info") telling it what the new
VG seqno will be. lvmetad sees that the seqno is newer than
the seqno of its cached VG, so it sets the INVALID flag for the
cached VG. If sending the message to lvmetad fails, the command
fails before the metadata is committed and the change is not made.
If sending the message succeeds, vg_commit() is called.
2. In unlock_vg(), after devices are resumed, the command sends
lvmetad the standard vg_update message with the new metadata.
lvmetad sees that the seqno in the new metadata matches the
seqno it saved from set_vg_info, and knows it has the latest
copy, so it clears the INVALID flag for the cached VG.
If a command fails between 1 and 2 (after committing the VG on disk,
but before sending lvmetad the new metadata), the cached VG retains
the INVALID flag in lvmetad. A subsequent command will read the
cached VG from lvmetad, see the INVALID flag, ignore the cached
copy, read the VG from disk instead, update the lvmetad copy
with the latest copy from disk, (this clears the INVALID flag
in lvmetad), and use the correct VG metadata for the command.
(This INVALID mechanism already existed for use by lvmlockd.)
119 lines
3.2 KiB
C
119 lines
3.2 KiB
C
/*
|
|
* Copyright (C) 2001-2004 Sistina Software, Inc. All rights reserved.
|
|
* Copyright (C) 2004-2007 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 "tools.h"
|
|
|
|
static int _pvdisplay_single(struct cmd_context *cmd,
|
|
struct volume_group *vg,
|
|
struct physical_volume *pv,
|
|
struct processing_handle *handle __attribute__((unused)))
|
|
{
|
|
const char *pv_name = pv_dev_name(pv);
|
|
int ret = ECMD_PROCESSED;
|
|
uint64_t size;
|
|
|
|
if (is_orphan(pv))
|
|
size = pv_size(pv);
|
|
else
|
|
size = (uint64_t)(pv_pe_count(pv) - pv_pe_alloc_count(pv)) *
|
|
pv_pe_size(pv);
|
|
|
|
if (arg_is_set(cmd, short_ARG)) {
|
|
log_print("Device \"%s\" has a capacity of %s", pv_name,
|
|
display_size(cmd, size));
|
|
goto out;
|
|
}
|
|
|
|
if (pv_status(pv) & EXPORTED_VG)
|
|
log_print_unless_silent("Physical volume \"%s\" of volume group \"%s\" "
|
|
"is exported", pv_name, pv_vg_name(pv));
|
|
|
|
if (is_orphan(pv))
|
|
log_print_unless_silent("\"%s\" is a new physical volume of \"%s\"",
|
|
pv_name, display_size(cmd, size));
|
|
|
|
if (arg_is_set(cmd, colon_ARG)) {
|
|
pvdisplay_colons(pv);
|
|
goto out;
|
|
}
|
|
|
|
pvdisplay_full(cmd, pv, NULL);
|
|
|
|
if (arg_is_set(cmd, maps_ARG))
|
|
pvdisplay_segments(pv);
|
|
|
|
out:
|
|
return ret;
|
|
}
|
|
|
|
int pvdisplay(struct cmd_context *cmd, int argc, char **argv)
|
|
{
|
|
int lock_global = 0;
|
|
int ret;
|
|
|
|
if (arg_is_set(cmd, columns_ARG)) {
|
|
if (arg_is_set(cmd, colon_ARG) || arg_is_set(cmd, maps_ARG) ||
|
|
arg_is_set(cmd, short_ARG)) {
|
|
log_error("Incompatible options selected");
|
|
return EINVALID_CMD_LINE;
|
|
}
|
|
return pvs(cmd, argc, argv);
|
|
}
|
|
|
|
if (arg_is_set(cmd, aligned_ARG) ||
|
|
arg_is_set(cmd, all_ARG) ||
|
|
arg_is_set(cmd, binary_ARG) ||
|
|
arg_is_set(cmd, noheadings_ARG) ||
|
|
arg_is_set(cmd, options_ARG) ||
|
|
arg_is_set(cmd, separator_ARG) ||
|
|
arg_is_set(cmd, sort_ARG) ||
|
|
arg_is_set(cmd, unbuffered_ARG)) {
|
|
log_error("Incompatible options selected");
|
|
return EINVALID_CMD_LINE;
|
|
}
|
|
|
|
if (arg_is_set(cmd, colon_ARG) && arg_is_set(cmd, maps_ARG)) {
|
|
log_error("Option -c not allowed with option -m");
|
|
return EINVALID_CMD_LINE;
|
|
}
|
|
|
|
if (arg_is_set(cmd, colon_ARG) && arg_is_set(cmd, short_ARG)) {
|
|
log_error("Option -c is not allowed with option -s");
|
|
return EINVALID_CMD_LINE;
|
|
}
|
|
|
|
/*
|
|
* If the lock_type is LCK_VG_READ (used only in reporting commands),
|
|
* we lock VG_GLOBAL to enable use of metadata cache.
|
|
* This can pause alongide pvscan or vgscan process for a while.
|
|
*/
|
|
if (!lvmetad_used()) {
|
|
lock_global = 1;
|
|
if (!lock_vol(cmd, VG_GLOBAL, LCK_VG_READ, NULL)) {
|
|
log_error("Unable to obtain global lock.");
|
|
return ECMD_FAILED;
|
|
}
|
|
}
|
|
|
|
ret = process_each_pv(cmd, argc, argv, NULL,
|
|
arg_is_set(cmd, all_ARG), 0,
|
|
NULL, _pvdisplay_single);
|
|
|
|
if (lock_global)
|
|
unlock_vg(cmd, NULL, VG_GLOBAL);
|
|
|
|
return ret;
|
|
}
|