05150c5f57
Resolves: RHEL-54414
331 lines
12 KiB
Diff
331 lines
12 KiB
Diff
From 04aeea691fc9f509d9f73f2fcffca8669abe1906 Mon Sep 17 00:00:00 2001
|
|
From: David Teigland <teigland@redhat.com>
|
|
Date: Wed, 12 Jun 2024 15:36:45 -0500
|
|
Subject: [PATCH 7/9] lvmlockd: avoid lockd_vg for local VGs
|
|
|
|
Previously, a command would call lockd_vg() for a local VG,
|
|
which would go to lvmlockd, which would send back ENOLS,
|
|
and the command would not care when it saw the VG was local.
|
|
The pointless back-and-forth to lvmlockd for local VGs can
|
|
be avoided by checking the VG lock_type in lvmcache (which
|
|
label_scan now saves there; this wasn't the case back when
|
|
the original lockd_vg logic was added.) If the lock_type
|
|
saved during label_scan indicates a local VG, then the
|
|
lockd_vg step is skipped.
|
|
|
|
(cherry picked from commit bf60cb4da23cac2f6b721170dd0d8bfd38b16466)
|
|
---
|
|
lib/cache/lvmcache.c | 10 +++++++++
|
|
lib/cache/lvmcache.h | 2 ++
|
|
lib/locking/lvmlockd.c | 12 ++++++++---
|
|
tools/lvconvert.c | 8 ++++---
|
|
tools/polldaemon.c | 9 +++++---
|
|
tools/toollib.c | 47 +++++++++++++++++++++++++++++++++++-------
|
|
6 files changed, 71 insertions(+), 17 deletions(-)
|
|
|
|
diff --git a/lib/cache/lvmcache.c b/lib/cache/lvmcache.c
|
|
index 711a97fec..1ea4cb7db 100644
|
|
--- a/lib/cache/lvmcache.c
|
|
+++ b/lib/cache/lvmcache.c
|
|
@@ -3002,6 +3002,16 @@ int lvmcache_vg_is_foreign(struct cmd_context *cmd, const char *vgname, const ch
|
|
return ret;
|
|
}
|
|
|
|
+int lvmcache_vg_is_lockd_type(struct cmd_context *cmd, const char *vgname, const char *vgid)
|
|
+{
|
|
+ struct lvmcache_vginfo *vginfo;
|
|
+
|
|
+ if ((vginfo = lvmcache_vginfo_from_vgname(vgname, vgid)))
|
|
+ return is_lockd_type(vginfo->lock_type);
|
|
+
|
|
+ return 0;
|
|
+}
|
|
+
|
|
/*
|
|
* Example of reading four devs in sequence from the same VG:
|
|
*
|
|
diff --git a/lib/cache/lvmcache.h b/lib/cache/lvmcache.h
|
|
index eccf29eb2..760ff6ba1 100644
|
|
--- a/lib/cache/lvmcache.h
|
|
+++ b/lib/cache/lvmcache.h
|
|
@@ -179,6 +179,8 @@ void lvmcache_get_max_name_lengths(struct cmd_context *cmd,
|
|
|
|
int lvmcache_vg_is_foreign(struct cmd_context *cmd, const char *vgname, const char *vgid);
|
|
|
|
+int lvmcache_vg_is_lockd_type(struct cmd_context *cmd, const char *vgname, const char *vgid);
|
|
+
|
|
bool lvmcache_scan_mismatch(struct cmd_context *cmd, const char *vgname, const char *vgid);
|
|
|
|
int lvmcache_vginfo_has_pvid(struct lvmcache_vginfo *vginfo, const char *pvid_arg);
|
|
diff --git a/lib/locking/lvmlockd.c b/lib/locking/lvmlockd.c
|
|
index 9c24b619f..33150cb48 100644
|
|
--- a/lib/locking/lvmlockd.c
|
|
+++ b/lib/locking/lvmlockd.c
|
|
@@ -2014,9 +2014,15 @@ int lockd_global(struct cmd_context *cmd, const char *def_mode)
|
|
* this result is passed into vg_read(). After vg_read() reads the VG,
|
|
* it checks if the VG lock_type (sanlock or dlm) requires a lock to be
|
|
* held, and if so, it verifies that the lock was correctly acquired by
|
|
- * looking at lockd_state. If vg_read() sees that the VG is a local VG,
|
|
- * i.e. lock_type is not sanlock or dlm, then no lock is required, and it
|
|
- * ignores lockd_state (which would indicate no lock was found.)
|
|
+ * looking at lockd_state.
|
|
+ *
|
|
+ * If vg_read() sees that the VG is a local VG, i.e. lock_type is not
|
|
+ * sanlock or dlm, then no lock is required, and it ignores lockd_state,
|
|
+ * which would indicate no lock was found.... although a newer
|
|
+ * optimization avoids calling lockd_vg() at all for local VGs
|
|
+ * by checking the lock_type in lvmcache saved by label_scan. In extremely
|
|
+ * rare case where the lock_type changes between label_scan and vg_read,
|
|
+ * the caller will go back and repeat lockd_vg()+vg_read().
|
|
*/
|
|
|
|
int lockd_vg(struct cmd_context *cmd, const char *vg_name, const char *def_mode,
|
|
diff --git a/tools/lvconvert.c b/tools/lvconvert.c
|
|
index dd40ef4f5..4e551a949 100644
|
|
--- a/tools/lvconvert.c
|
|
+++ b/tools/lvconvert.c
|
|
@@ -5788,10 +5788,12 @@ static int _lvconvert_detach_writecache_when_clean(struct cmd_context *cmd,
|
|
struct logical_volume *lv_fast;
|
|
uint32_t lockd_state, error_flags;
|
|
uint64_t dirty;
|
|
+ int is_lockd;
|
|
int ret = 0;
|
|
|
|
idl = dm_list_item(dm_list_first(&lr->poll_idls), struct convert_poll_id_list);
|
|
id = idl->id;
|
|
+ is_lockd = lvmcache_vg_is_lockd_type(cmd, id->vg_name, NULL);
|
|
|
|
/*
|
|
* TODO: we should be able to save info about the dm device for this LV
|
|
@@ -5806,7 +5808,7 @@ static int _lvconvert_detach_writecache_when_clean(struct cmd_context *cmd,
|
|
lockd_state = 0;
|
|
error_flags = 0;
|
|
|
|
- if (!lockd_vg(cmd, id->vg_name, "ex", 0, &lockd_state)) {
|
|
+ if (is_lockd && !lockd_vg(cmd, id->vg_name, "ex", 0, &lockd_state)) {
|
|
log_error("Detaching writecache interrupted - locking VG failed.");
|
|
return 0;
|
|
}
|
|
@@ -5843,7 +5845,7 @@ static int _lvconvert_detach_writecache_when_clean(struct cmd_context *cmd,
|
|
if (!lv_writecache_is_clean(cmd, lv, &dirty)) {
|
|
unlock_and_release_vg(cmd, vg, vg->name);
|
|
|
|
- if (!lockd_vg(cmd, id->vg_name, "un", 0, &lockd_state))
|
|
+ if (is_lockd && !lockd_vg(cmd, id->vg_name, "un", 0, &lockd_state))
|
|
stack;
|
|
|
|
log_print_unless_silent("Detaching writecache cleaning %llu blocks", (unsigned long long)dirty);
|
|
@@ -5896,7 +5898,7 @@ out_release:
|
|
unlock_and_release_vg(cmd, vg, vg->name);
|
|
|
|
out_lockd:
|
|
- if (!lockd_vg(cmd, id->vg_name, "un", 0, &lockd_state))
|
|
+ if (is_lockd && !lockd_vg(cmd, id->vg_name, "un", 0, &lockd_state))
|
|
stack;
|
|
|
|
return ret;
|
|
diff --git a/tools/polldaemon.c b/tools/polldaemon.c
|
|
index 730dfbcbb..3a9211768 100644
|
|
--- a/tools/polldaemon.c
|
|
+++ b/tools/polldaemon.c
|
|
@@ -156,6 +156,7 @@ int wait_for_single_lv(struct cmd_context *cmd, struct poll_operation_id *id,
|
|
int finished = 0;
|
|
uint32_t lockd_state = 0;
|
|
uint32_t error_flags = 0;
|
|
+ int is_lockd;
|
|
int ret;
|
|
unsigned wait_before_testing = parms->wait_before_testing;
|
|
|
|
@@ -171,11 +172,13 @@ int wait_for_single_lv(struct cmd_context *cmd, struct poll_operation_id *id,
|
|
return 0;
|
|
}
|
|
|
|
+ is_lockd = lvmcache_vg_is_lockd_type(cmd, id->vg_name, NULL);
|
|
+
|
|
/*
|
|
* An ex VG lock is needed because the check can call finish_copy
|
|
* which writes the VG.
|
|
*/
|
|
- if (!lockd_vg(cmd, id->vg_name, "ex", 0, &lockd_state)) {
|
|
+ if (is_lockd && !lockd_vg(cmd, id->vg_name, "ex", 0, &lockd_state)) {
|
|
log_error("ABORTING: Can't lock VG for %s.", id->display_name);
|
|
return 0;
|
|
}
|
|
@@ -229,7 +232,7 @@ int wait_for_single_lv(struct cmd_context *cmd, struct poll_operation_id *id,
|
|
|
|
unlock_and_release_vg(cmd, vg, vg->name);
|
|
|
|
- if (!lockd_vg(cmd, id->vg_name, "un", 0, &lockd_state))
|
|
+ if (is_lockd && !lockd_vg(cmd, id->vg_name, "un", 0, &lockd_state))
|
|
stack;
|
|
|
|
wait_before_testing = 1;
|
|
@@ -240,7 +243,7 @@ int wait_for_single_lv(struct cmd_context *cmd, struct poll_operation_id *id,
|
|
out:
|
|
if (vg)
|
|
unlock_and_release_vg(cmd, vg, vg->name);
|
|
- if (!lockd_vg(cmd, id->vg_name, "un", 0, &lockd_state))
|
|
+ if (is_lockd && !lockd_vg(cmd, id->vg_name, "un", 0, &lockd_state))
|
|
stack;
|
|
|
|
return ret;
|
|
diff --git a/tools/toollib.c b/tools/toollib.c
|
|
index 080ee5429..686a5423c 100644
|
|
--- a/tools/toollib.c
|
|
+++ b/tools/toollib.c
|
|
@@ -2176,6 +2176,7 @@ static int _process_vgnameid_list(struct cmd_context *cmd, uint32_t read_flags,
|
|
int ret;
|
|
int skip;
|
|
int notfound;
|
|
+ int is_lockd;
|
|
int process_all = 0;
|
|
int do_report_ret_code = 1;
|
|
|
|
@@ -2195,6 +2196,7 @@ static int _process_vgnameid_list(struct cmd_context *cmd, uint32_t read_flags,
|
|
vg_uuid = vgnl->vgid;
|
|
skip = 0;
|
|
notfound = 0;
|
|
+ is_lockd = lvmcache_vg_is_lockd_type(cmd, vg_name, vg_uuid);
|
|
|
|
uuid[0] = '\0';
|
|
if (is_orphan_vg(vg_name)) {
|
|
@@ -2212,8 +2214,8 @@ static int _process_vgnameid_list(struct cmd_context *cmd, uint32_t read_flags,
|
|
}
|
|
|
|
log_very_verbose("Processing VG %s %s", vg_name, uuid);
|
|
-
|
|
- if (!lockd_vg(cmd, vg_name, NULL, 0, &lockd_state)) {
|
|
+do_lockd:
|
|
+ if (is_lockd && !lockd_vg(cmd, vg_name, NULL, 0, &lockd_state)) {
|
|
stack;
|
|
ret_max = ECMD_FAILED;
|
|
report_log_ret_code(ret_max);
|
|
@@ -2235,6 +2237,14 @@ static int _process_vgnameid_list(struct cmd_context *cmd, uint32_t read_flags,
|
|
if (skip || notfound)
|
|
goto endvg;
|
|
|
|
+ if (!is_lockd && vg_is_shared(vg)) {
|
|
+ /* The lock_type changed since label_scan, won't really occur in practice. */
|
|
+ log_debug("Repeat lock and read for local to shared vg");
|
|
+ unlock_and_release_vg(cmd, vg, vg_name);
|
|
+ is_lockd = 1;
|
|
+ goto do_lockd;
|
|
+ }
|
|
+
|
|
/* Process this VG? */
|
|
if ((process_all ||
|
|
(!dm_list_empty(arg_vgnames) && str_list_match_item(arg_vgnames, vg_name)) ||
|
|
@@ -2255,7 +2265,7 @@ static int _process_vgnameid_list(struct cmd_context *cmd, uint32_t read_flags,
|
|
unlock_vg(cmd, vg, vg_name);
|
|
endvg:
|
|
release_vg(vg);
|
|
- if (!lockd_vg(cmd, vg_name, "un", 0, &lockd_state))
|
|
+ if (is_lockd && !lockd_vg(cmd, vg_name, "un", 0, &lockd_state))
|
|
stack;
|
|
|
|
log_set_report_object_name_and_id(NULL, NULL);
|
|
@@ -3873,6 +3883,7 @@ static int _process_lv_vgnameid_list(struct cmd_context *cmd, uint32_t read_flag
|
|
int ret;
|
|
int skip;
|
|
int notfound;
|
|
+ int is_lockd;
|
|
int do_report_ret_code = 1;
|
|
|
|
log_set_report_object_type(LOG_REPORT_OBJECT_TYPE_VG);
|
|
@@ -3882,6 +3893,7 @@ static int _process_lv_vgnameid_list(struct cmd_context *cmd, uint32_t read_flag
|
|
vg_uuid = vgnl->vgid;
|
|
skip = 0;
|
|
notfound = 0;
|
|
+ is_lockd = lvmcache_vg_is_lockd_type(cmd, vg_name, vg_uuid);
|
|
|
|
uuid[0] = '\0';
|
|
if (vg_uuid && !id_write_format((const struct id*)vg_uuid, uuid, sizeof(uuid)))
|
|
@@ -3927,7 +3939,8 @@ static int _process_lv_vgnameid_list(struct cmd_context *cmd, uint32_t read_flag
|
|
|
|
log_very_verbose("Processing VG %s %s", vg_name, vg_uuid ? uuid : "");
|
|
|
|
- if (!lockd_vg(cmd, vg_name, NULL, 0, &lockd_state)) {
|
|
+do_lockd:
|
|
+ if (is_lockd && !lockd_vg(cmd, vg_name, NULL, 0, &lockd_state)) {
|
|
ret_max = ECMD_FAILED;
|
|
report_log_ret_code(ret_max);
|
|
continue;
|
|
@@ -3948,6 +3961,14 @@ static int _process_lv_vgnameid_list(struct cmd_context *cmd, uint32_t read_flag
|
|
if (skip || notfound)
|
|
goto endvg;
|
|
|
|
+ if (!is_lockd && vg_is_shared(vg)) {
|
|
+ /* The lock_type changed since label_scan, won't really occur in practice. */
|
|
+ log_debug("Repeat lock and read for local to shared vg");
|
|
+ unlock_and_release_vg(cmd, vg, vg_name);
|
|
+ is_lockd = 1;
|
|
+ goto do_lockd;
|
|
+ }
|
|
+
|
|
ret = process_each_lv_in_vg(cmd, vg, &lvnames, tags_arg, 0,
|
|
handle, check_single_lv, process_single_lv);
|
|
if (ret != ECMD_PROCESSED)
|
|
@@ -3959,7 +3980,7 @@ static int _process_lv_vgnameid_list(struct cmd_context *cmd, uint32_t read_flag
|
|
unlock_vg(cmd, vg, vg_name);
|
|
endvg:
|
|
release_vg(vg);
|
|
- if (!lockd_vg(cmd, vg_name, "un", 0, &lockd_state))
|
|
+ if (is_lockd && !lockd_vg(cmd, vg_name, "un", 0, &lockd_state))
|
|
stack;
|
|
log_set_report_object_name_and_id(NULL, NULL);
|
|
}
|
|
@@ -4513,6 +4534,7 @@ static int _process_pvs_in_vgs(struct cmd_context *cmd, uint32_t read_flags,
|
|
int ret;
|
|
int skip;
|
|
int notfound;
|
|
+ int is_lockd;
|
|
int do_report_ret_code = 1;
|
|
|
|
log_set_report_object_type(LOG_REPORT_OBJECT_TYPE_VG);
|
|
@@ -4522,6 +4544,7 @@ static int _process_pvs_in_vgs(struct cmd_context *cmd, uint32_t read_flags,
|
|
vg_uuid = vgnl->vgid;
|
|
skip = 0;
|
|
notfound = 0;
|
|
+ is_lockd = lvmcache_vg_is_lockd_type(cmd, vg_name, vg_uuid);
|
|
|
|
uuid[0] = '\0';
|
|
if (is_orphan_vg(vg_name)) {
|
|
@@ -4537,8 +4560,8 @@ static int _process_pvs_in_vgs(struct cmd_context *cmd, uint32_t read_flags,
|
|
ret_max = ECMD_FAILED;
|
|
goto_out;
|
|
}
|
|
-
|
|
- if (!lockd_vg(cmd, vg_name, NULL, 0, &lockd_state)) {
|
|
+do_lockd:
|
|
+ if (is_lockd && !lockd_vg(cmd, vg_name, NULL, 0, &lockd_state)) {
|
|
ret_max = ECMD_FAILED;
|
|
report_log_ret_code(ret_max);
|
|
continue;
|
|
@@ -4561,6 +4584,14 @@ static int _process_pvs_in_vgs(struct cmd_context *cmd, uint32_t read_flags,
|
|
if (notfound)
|
|
goto endvg;
|
|
|
|
+ if (vg && !is_lockd && vg_is_shared(vg)) {
|
|
+ /* The lock_type changed since label_scan, won't really occur in practice. */
|
|
+ log_debug("Repeat lock and read for local to shared vg");
|
|
+ unlock_and_release_vg(cmd, vg, vg_name);
|
|
+ is_lockd = 1;
|
|
+ goto do_lockd;
|
|
+ }
|
|
+
|
|
/*
|
|
* Don't call "continue" when skip is set, because we need to remove
|
|
* error_vg->pvs entries from devices list.
|
|
@@ -4583,7 +4614,7 @@ endvg:
|
|
if (error_vg)
|
|
unlock_and_release_vg(cmd, error_vg, vg_name);
|
|
release_vg(vg);
|
|
- if (!lockd_vg(cmd, vg_name, "un", 0, &lockd_state))
|
|
+ if (is_lockd && !lockd_vg(cmd, vg_name, "un", 0, &lockd_state))
|
|
stack;
|
|
|
|
/* Quit early when possible. */
|
|
--
|
|
2.46.0
|
|
|