Blame SOURCES/0131-libmultipath-keep-renames-from-stopping-other-multip.patch

108c2a
From 0000000000000000000000000000000000000000 Mon Sep 17 00:00:00 2001
108c2a
From: Benjamin Marzinski <bmarzins@redhat.com>
108c2a
Date: Tue, 31 Jan 2023 12:00:31 -0600
108c2a
Subject: [PATCH] libmultipath: keep renames from stopping other multipath
108c2a
 actions
108c2a
108c2a
If select_action() is called and a multipath device needs to be renamed,
108c2a
the code currently checks if force_reload is set, and if so, does the
108c2a
reload after the rename.  But if force_reload isn't set, only the rename
108c2a
happens, regardless of what other actions are needed. This can happen if
108c2a
multipathd starts up and a device needs both a reload and a rename.
108c2a
108c2a
Make multipath check for resize, reload, and switch pathgroup along with
108c2a
rename, and do both if necessary.
108c2a
108c2a
Signed-off-by: Benjamin Marzinski <bmarzins@redhat.com>
108c2a
---
108c2a
 libmultipath/configure.c | 92 +++++++++++++++++++++-------------------
108c2a
 libmultipath/configure.h |  4 +-
108c2a
 2 files changed, 51 insertions(+), 45 deletions(-)
108c2a
108c2a
diff --git a/libmultipath/configure.c b/libmultipath/configure.c
108c2a
index 303d2380..65a0b208 100644
108c2a
--- a/libmultipath/configure.c
108c2a
+++ b/libmultipath/configure.c
108c2a
@@ -690,6 +690,7 @@ select_action (struct multipath * mpp, vector curmp, int force_reload)
108c2a
 	struct multipath * cmpp_by_name;
108c2a
 	char * mpp_feat, * cmpp_feat;
108c2a
 
108c2a
+	mpp->action = ACT_NOTHING;
108c2a
 	cmpp = find_mp_by_wwid(curmp, mpp->wwid);
108c2a
 	cmpp_by_name = find_mp_by_alias(curmp, mpp->alias);
108c2a
 
108c2a
@@ -712,14 +713,8 @@ select_action (struct multipath * mpp, vector curmp, int force_reload)
108c2a
 			mpp->alias);
108c2a
 		strlcpy(mpp->alias_old, cmpp->alias, WWID_SIZE);
108c2a
 		mpp->action = ACT_RENAME;
108c2a
-		if (force_reload) {
108c2a
-			mpp->force_udev_reload = 1;
108c2a
-			mpp->action = ACT_FORCERENAME;
108c2a
-		}
108c2a
-		return;
108c2a
-	}
108c2a
-
108c2a
-	if (cmpp != cmpp_by_name) {
108c2a
+		/* don't return here. Check for other needed actions */
108c2a
+	} else if (cmpp != cmpp_by_name) {
108c2a
 		condlog(2, "%s: unable to rename %s to %s (%s is used by %s)",
108c2a
 			mpp->wwid, cmpp->alias, mpp->alias,
108c2a
 			mpp->alias, cmpp_by_name->wwid);
108c2a
@@ -727,12 +722,13 @@ select_action (struct multipath * mpp, vector curmp, int force_reload)
108c2a
 		FREE(mpp->alias);
108c2a
 		mpp->alias = STRDUP(cmpp->alias);
108c2a
 		mpp->action = ACT_IMPOSSIBLE;
108c2a
-		return;
108c2a
+		/* don't return here. Check for other needed actions */
108c2a
 	}
108c2a
 
108c2a
 	if (cmpp->size != mpp->size) {
108c2a
 		mpp->force_udev_reload = 1;
108c2a
-		mpp->action = ACT_RESIZE;
108c2a
+		mpp->action = mpp->action == ACT_RENAME ? ACT_RESIZE_RENAME :
108c2a
+			      ACT_RESIZE;
108c2a
 		condlog(3, "%s: set ACT_RESIZE (size change)",
108c2a
 			mpp->alias);
108c2a
 		return;
108c2a
@@ -740,7 +736,8 @@ select_action (struct multipath * mpp, vector curmp, int force_reload)
108c2a
 
108c2a
 	if (force_reload) {
108c2a
 		mpp->force_udev_reload = 1;
108c2a
-		mpp->action = ACT_RELOAD;
108c2a
+		mpp->action = mpp->action == ACT_RENAME ? ACT_RELOAD_RENAME :
108c2a
+			      ACT_RELOAD;
108c2a
 		condlog(3, "%s: set ACT_RELOAD (forced by user)",
108c2a
 			mpp->alias);
108c2a
 		return;
108c2a
@@ -749,7 +746,8 @@ select_action (struct multipath * mpp, vector curmp, int force_reload)
108c2a
 	if (mpp->no_path_retry != NO_PATH_RETRY_UNDEF &&
108c2a
 	    !!strstr(mpp->features, "queue_if_no_path") !=
108c2a
 	    !!strstr(cmpp->features, "queue_if_no_path")) {
108c2a
-		mpp->action =  ACT_RELOAD;
108c2a
+		mpp->action = mpp->action == ACT_RENAME ? ACT_RELOAD_RENAME :
108c2a
+			      ACT_RELOAD;
108c2a
 		condlog(3, "%s: set ACT_RELOAD (no_path_retry change)",
108c2a
 			mpp->alias);
108c2a
 		return;
108c2a
@@ -759,7 +757,8 @@ select_action (struct multipath * mpp, vector curmp, int force_reload)
108c2a
 	    (strlen(cmpp->hwhandler) != strlen(mpp->hwhandler) ||
108c2a
 	     strncmp(cmpp->hwhandler, mpp->hwhandler,
108c2a
 		    strlen(mpp->hwhandler)))) {
108c2a
-		mpp->action = ACT_RELOAD;
108c2a
+		mpp->action = mpp->action == ACT_RENAME ? ACT_RELOAD_RENAME :
108c2a
+			      ACT_RELOAD;
108c2a
 		condlog(3, "%s: set ACT_RELOAD (hwhandler change)",
108c2a
 			mpp->alias);
108c2a
 		return;
108c2a
@@ -769,7 +768,8 @@ select_action (struct multipath * mpp, vector curmp, int force_reload)
108c2a
 	    !!strstr(mpp->features, "retain_attached_hw_handler") !=
108c2a
 	    !!strstr(cmpp->features, "retain_attached_hw_handler") &&
108c2a
 	    get_linux_version_code() < KERNEL_VERSION(4, 3, 0)) {
108c2a
-		mpp->action = ACT_RELOAD;
108c2a
+		mpp->action = mpp->action == ACT_RENAME ? ACT_RELOAD_RENAME :
108c2a
+			      ACT_RELOAD;
108c2a
 		condlog(3, "%s: set ACT_RELOAD (retain_hwhandler change)",
108c2a
 			mpp->alias);
108c2a
 		return;
108c2a
@@ -783,9 +783,13 @@ select_action (struct multipath * mpp, vector curmp, int force_reload)
108c2a
 		remove_feature(&cmpp_feat, "queue_if_no_path");
108c2a
 		remove_feature(&cmpp_feat, "retain_attached_hw_handler");
108c2a
 		if (strncmp(mpp_feat, cmpp_feat, PARAMS_SIZE)) {
108c2a
-			mpp->action =  ACT_RELOAD;
108c2a
+			mpp->action = mpp->action == ACT_RENAME ?
108c2a
+				      ACT_RELOAD_RENAME : ACT_RELOAD;
108c2a
 			condlog(3, "%s: set ACT_RELOAD (features change)",
108c2a
 				mpp->alias);
108c2a
+			FREE(cmpp_feat);
108c2a
+			FREE(mpp_feat);
108c2a
+			return;
108c2a
 		}
108c2a
 	}
108c2a
 	FREE(cmpp_feat);
108c2a
@@ -793,44 +797,49 @@ select_action (struct multipath * mpp, vector curmp, int force_reload)
108c2a
 
108c2a
 	if (!cmpp->selector || strncmp(cmpp->selector, mpp->selector,
108c2a
 		    strlen(mpp->selector))) {
108c2a
-		mpp->action = ACT_RELOAD;
108c2a
+		mpp->action = mpp->action == ACT_RENAME ? ACT_RELOAD_RENAME :
108c2a
+			      ACT_RELOAD;
108c2a
 		condlog(3, "%s: set ACT_RELOAD (selector change)",
108c2a
 			mpp->alias);
108c2a
 		return;
108c2a
 	}
108c2a
 	if (cmpp->minio != mpp->minio) {
108c2a
-		mpp->action = ACT_RELOAD;
108c2a
+		mpp->action = mpp->action == ACT_RENAME ? ACT_RELOAD_RENAME :
108c2a
+			      ACT_RELOAD;
108c2a
 		condlog(3, "%s: set ACT_RELOAD (minio change, %u->%u)",
108c2a
 			mpp->alias, cmpp->minio, mpp->minio);
108c2a
 		return;
108c2a
 	}
108c2a
 	if (!cmpp->pg || VECTOR_SIZE(cmpp->pg) != VECTOR_SIZE(mpp->pg)) {
108c2a
-		mpp->action = ACT_RELOAD;
108c2a
+		mpp->action = mpp->action == ACT_RENAME ? ACT_RELOAD_RENAME :
108c2a
+			      ACT_RELOAD;
108c2a
 		condlog(3, "%s: set ACT_RELOAD (path group number change)",
108c2a
 			mpp->alias);
108c2a
 		return;
108c2a
 	}
108c2a
 	if (pgcmp(mpp, cmpp)) {
108c2a
-		mpp->action = ACT_RELOAD;
108c2a
+		mpp->action = mpp->action == ACT_RENAME ? ACT_RELOAD_RENAME :
108c2a
+			      ACT_RELOAD;
108c2a
 		condlog(3, "%s: set ACT_RELOAD (path group topology change)",
108c2a
 			mpp->alias);
108c2a
 		return;
108c2a
 	}
108c2a
 	if (cmpp->nextpg != mpp->bestpg) {
108c2a
-		mpp->action = ACT_SWITCHPG;
108c2a
+		mpp->action = mpp->action == ACT_RENAME ? ACT_SWITCHPG_RENAME :
108c2a
+			      ACT_SWITCHPG;
108c2a
 		condlog(3, "%s: set ACT_SWITCHPG (next path group change)",
108c2a
 			mpp->alias);
108c2a
 		return;
108c2a
 	}
108c2a
 	if (!is_mpp_known_to_udev(cmpp)) {
108c2a
-		mpp->action = ACT_RELOAD;
108c2a
+		mpp->action = mpp->action == ACT_RENAME ? ACT_SWITCHPG_RENAME :
108c2a
+			      ACT_SWITCHPG;
108c2a
 		condlog(3, "%s: set ACT_RELOAD (udev device not initialized)",
108c2a
 			mpp->alias);
108c2a
 		return;
108c2a
 	}
108c2a
-	mpp->action = ACT_NOTHING;
108c2a
-	condlog(3, "%s: set ACT_NOTHING (map unchanged)",
108c2a
-		mpp->alias);
108c2a
+	if (mpp->action == ACT_NOTHING)
108c2a
+		condlog(3, "%s: set ACT_NOTHING (map unchanged)", mpp->alias);
108c2a
 	return;
108c2a
 }
108c2a
 
108c2a
@@ -924,6 +933,17 @@ int domap(struct multipath *mpp, char *params, int is_daemon)
108c2a
 		mpp->action = ACT_RELOAD;
108c2a
 	}
108c2a
 
108c2a
+	if (mpp->action == ACT_RENAME || mpp->action == ACT_SWITCHPG_RENAME ||
108c2a
+	    mpp->action == ACT_RELOAD_RENAME ||
108c2a
+	    mpp->action == ACT_RESIZE_RENAME) {
108c2a
+		conf = get_multipath_config();
108c2a
+		pthread_cleanup_push(put_multipath_config, conf);
108c2a
+		r = dm_rename(mpp->alias_old, mpp->alias,
108c2a
+			      conf->partition_delim, mpp->skip_kpartx);
108c2a
+		pthread_cleanup_pop(1);
108c2a
+		if (r == DOMAP_FAIL)
108c2a
+			return r;
108c2a
+	}
108c2a
 	switch (mpp->action) {
108c2a
 	case ACT_REJECT:
108c2a
 	case ACT_NOTHING:
108c2a
@@ -931,6 +951,7 @@ int domap(struct multipath *mpp, char *params, int is_daemon)
108c2a
 		return DOMAP_EXIST;
108c2a
 
108c2a
 	case ACT_SWITCHPG:
108c2a
+	case ACT_SWITCHPG_RENAME:
108c2a
 		dm_switchgroup(mpp->alias, mpp->bestpg);
108c2a
 		/*
108c2a
 		 * we may have avoided reinstating paths because there where in
108c2a
@@ -957,6 +978,7 @@ int domap(struct multipath *mpp, char *params, int is_daemon)
108c2a
 		break;
108c2a
 
108c2a
 	case ACT_RELOAD:
108c2a
+	case ACT_RELOAD_RENAME:
108c2a
 		sysfs_set_max_sectors_kb(mpp, 1);
108c2a
 		if (mpp->ghost_delay_tick > 0 && pathcount(mpp, PATH_UP))
108c2a
 			mpp->ghost_delay_tick = 0;
108c2a
@@ -964,6 +986,7 @@ int domap(struct multipath *mpp, char *params, int is_daemon)
108c2a
 		break;
108c2a
 
108c2a
 	case ACT_RESIZE:
108c2a
+	case ACT_RESIZE_RENAME:
108c2a
 		sysfs_set_max_sectors_kb(mpp, 1);
108c2a
 		if (mpp->ghost_delay_tick > 0 && pathcount(mpp, PATH_UP))
108c2a
 			mpp->ghost_delay_tick = 0;
108c2a
@@ -971,29 +994,10 @@ int domap(struct multipath *mpp, char *params, int is_daemon)
108c2a
 		break;
108c2a
 
108c2a
 	case ACT_RENAME:
108c2a
-		conf = get_multipath_config();
108c2a
-		pthread_cleanup_push(put_multipath_config, conf);
108c2a
-		r = dm_rename(mpp->alias_old, mpp->alias,
108c2a
-			      conf->partition_delim, mpp->skip_kpartx);
108c2a
-		pthread_cleanup_pop(1);
108c2a
-		break;
108c2a
-
108c2a
-	case ACT_FORCERENAME:
108c2a
-		conf = get_multipath_config();
108c2a
-		pthread_cleanup_push(put_multipath_config, conf);
108c2a
-		r = dm_rename(mpp->alias_old, mpp->alias,
108c2a
-			      conf->partition_delim, mpp->skip_kpartx);
108c2a
-		pthread_cleanup_pop(1);
108c2a
-		if (r) {
108c2a
-			sysfs_set_max_sectors_kb(mpp, 1);
108c2a
-			if (mpp->ghost_delay_tick > 0 &&
108c2a
-			    pathcount(mpp, PATH_UP))
108c2a
-				mpp->ghost_delay_tick = 0;
108c2a
-			r = dm_addmap_reload(mpp, params, 0);
108c2a
-		}
108c2a
 		break;
108c2a
 
108c2a
 	default:
108c2a
+		r = DOMAP_FAIL;
108c2a
 		break;
108c2a
 	}
108c2a
 
108c2a
diff --git a/libmultipath/configure.h b/libmultipath/configure.h
108c2a
index 5cf08d45..1a93f49d 100644
108c2a
--- a/libmultipath/configure.h
108c2a
+++ b/libmultipath/configure.h
108c2a
@@ -18,9 +18,11 @@ enum actions {
108c2a
 	ACT_RENAME,
108c2a
 	ACT_CREATE,
108c2a
 	ACT_RESIZE,
108c2a
-	ACT_FORCERENAME,
108c2a
+	ACT_RELOAD_RENAME,
108c2a
 	ACT_DRY_RUN,
108c2a
 	ACT_IMPOSSIBLE,
108c2a
+	ACT_RESIZE_RENAME,
108c2a
+	ACT_SWITCHPG_RENAME,
108c2a
 };
108c2a
 
108c2a
 /*