---
libmultipath/configure.c | 18 +++------------
libmultipath/devmapper.c | 55 +++++++++++++++++++++++++++++++++++++++++------
libmultipath/devmapper.h | 3 +-
3 files changed, 55 insertions(+), 21 deletions(-)
Index: multipath-tools-130222/libmultipath/configure.c
===================================================================
--- multipath-tools-130222.orig/libmultipath/configure.c
+++ multipath-tools-130222/libmultipath/configure.c
@@ -616,7 +616,6 @@ extern int
domap (struct multipath * mpp, char * params)
{
int r = 0;
- uint16_t udev_flags = ((mpp->force_udev_reload)? 0 : MPATH_UDEV_RELOAD_FLAG) | ((mpp->skip_kpartx == SKIP_KPARTX_ON)? MPATH_UDEV_NO_KPARTX_FLAG : 0) | ((mpp->nr_active)? 0 : MPATH_UDEV_NO_PATHS_FLAG);
/*
* last chance to quit before touching the devmaps
@@ -660,17 +659,11 @@ domap (struct multipath * mpp, char * pa
break;
case ACT_RELOAD:
- r = dm_addmap_reload(mpp, params);
- if (r)
- r = dm_simplecmd_noflush(DM_DEVICE_RESUME, mpp->alias,
- udev_flags);
+ r = dm_addmap_reload(mpp, params, 0);
break;
case ACT_RESIZE:
- r = dm_addmap_reload(mpp, params);
- if (r)
- r = dm_simplecmd_flush(DM_DEVICE_RESUME, mpp->alias, 1,
- udev_flags);
+ r = dm_addmap_reload(mpp, params, 1);
break;
case ACT_RENAME:
@@ -679,11 +672,8 @@ domap (struct multipath * mpp, char * pa
case ACT_RENAME2:
r = dm_rename(mpp->alias_old, mpp->alias, mpp->skip_kpartx);
- if (r) {
- r = dm_addmap_reload(mpp, params);
- if (r)
- r = dm_simplecmd_noflush(DM_DEVICE_RESUME, mpp->alias, udev_flags);
- }
+ if (r)
+ r = dm_addmap_reload(mpp, params, 0);
break;
default:
Index: multipath-tools-130222/libmultipath/devmapper.c
===================================================================
--- multipath-tools-130222.orig/libmultipath/devmapper.c
+++ multipath-tools-130222/libmultipath/devmapper.c
@@ -356,15 +356,33 @@ dm_addmap_create (struct multipath *mpp,
#define ADDMAP_RO 1
extern int
-dm_addmap_reload (struct multipath *mpp, char *params) {
+dm_addmap_reload (struct multipath *mpp, char *params, int flush) {
+ int r = 0;
+ uint16_t udev_flags = ((mpp->force_udev_reload)?
+ 0 : MPATH_UDEV_RELOAD_FLAG) |
+ ((mpp->skip_kpartx == SKIP_KPARTX_ON)?
+ MPATH_UDEV_NO_KPARTX_FLAG : 0) |
+ ((mpp->nr_active)? 0 : MPATH_UDEV_NO_PATHS_FLAG);
+
sysfs_set_max_sectors_kb(mpp, 1);
- if (!mpp->force_readonly) {
- if (dm_addmap(DM_DEVICE_RELOAD, TGT_MPATH, mpp, params, 0, ADDMAP_RW, SKIP_KPARTX_OFF))
- return 1;
- if (errno != EROFS)
+ if (!mpp->force_readonly)
+ r = dm_addmap(DM_DEVICE_RELOAD, TGT_MPATH, mpp, params, 0,
+ ADDMAP_RW, SKIP_KPARTX_OFF);
+ if (!r) {
+ if (!mpp->force_readonly && errno != EROFS)
return 0;
+ r = dm_addmap(DM_DEVICE_RELOAD, TGT_MPATH, mpp, params, 0,
+ ADDMAP_RO, SKIP_KPARTX_OFF);
}
- return dm_addmap(DM_DEVICE_RELOAD, TGT_MPATH, mpp, params, 0, ADDMAP_RO, SKIP_KPARTX_OFF);
+ if (r)
+ r = dm_simplecmd(DM_DEVICE_RESUME, mpp->alias, !flush,
+ 1, udev_flags, 0);
+ if (r)
+ return r;
+ if (dm_is_suspended(mpp->alias))
+ dm_simplecmd(DM_DEVICE_RESUME, mpp->alias, !flush, 1,
+ udev_flags, 0);
+ return 0;
}
extern int
@@ -613,6 +631,31 @@ dm_is_mpath(const char * name)
out:
dm_task_destroy(dmt);
return r;
+}
+
+int
+dm_is_suspended(const char *mapname)
+{
+ int r = -1;
+ struct dm_task *dmt;
+ struct dm_info info;
+
+ if (!(dmt = dm_task_create(DM_DEVICE_INFO)))
+ return r;
+
+ if (!dm_task_set_name(dmt, mapname))
+ goto out;
+
+ if (!dm_task_run(dmt))
+ goto out;
+
+ if (!dm_task_get_info(dmt, &info) || !info.exists)
+ goto out;
+
+ r = info.suspended;
+out:
+ dm_task_destroy(dmt);
+ return r;
}
static int
Index: multipath-tools-130222/libmultipath/devmapper.h
===================================================================
--- multipath-tools-130222.orig/libmultipath/devmapper.h
+++ multipath-tools-130222/libmultipath/devmapper.h
@@ -30,7 +30,7 @@ int dm_drv_version (unsigned int * versi
int dm_simplecmd_flush (int, const char *, int, uint16_t);
int dm_simplecmd_noflush (int, const char *, uint16_t);
int dm_addmap_create (struct multipath *mpp, char *params);
-int dm_addmap_reload (struct multipath *mpp, char *params);
+int dm_addmap_reload (struct multipath *mpp, char *params, int flush);
int dm_map_present (const char *);
int dm_get_map(const char *, unsigned long long *, char *);
int dm_get_status(char *, char *);
@@ -51,6 +51,7 @@ int dm_switchgroup(char * mapname, int i
int dm_enablegroup(char * mapname, int index);
int dm_disablegroup(char * mapname, int index);
int dm_get_maps (vector mp);
+int dm_is_suspended(const char *mapname);
int dm_geteventnr (char *name);
int dm_get_major (char *name);
int dm_get_minor (char *name);