* [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
@ 2009-05-05 3:18 Chandra Seetharaman
2009-05-15 3:10 ` Chandra Seetharaman
0 siblings, 1 reply; 18+ messages in thread
From: Chandra Seetharaman @ 2009-05-05 3:18 UTC (permalink / raw)
To: dm-devel; +Cc: Nikanth Karthikesan
This is a modified patch of what Nikanth submitted a while back
(http://patchwork.kernel.org/patch/8067/) to make the delay variable a
configurable attribute.
This applies on top the patch I sent few days back to send multiple
activates on pg_init()
(http://www.kernel.org/pub/linux/kernel/people/agk/patches/2.6/editing/dm-mpath-call-activate-fn-for-each-path-in-pg_init.patch)
This applies cleanly on 2.6.30-rc4 and tested there.
-------------------------
From: Chandra Seetharaman <sekharan@us.ibm.com>
SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
immediately and SCSI_DH_RETRY in cases where it is better to retry
after some delay.
Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
SCSI_DH_RETRY. This patch adds a user configurable attribute
pg_init_delay_secs which specifies the number of seconds to delay
before retrying scsi_dh_activate, when it returned SCSI_DH_RETRY.
Default for this attribute is set to 2 seconds.
Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
Signed-off-by: Chandra Seetharaman <sekharan@us.ibm.com>
---
drivers/md/dm-mpath.c | 41 ++++++++++++++++++++++++++++++++---------
include/scsi/scsi_dh.h | 4 ++++
2 files changed, 36 insertions(+), 9 deletions(-)
Index: linux-2.6.30-rc4/drivers/md/dm-mpath.c
===================================================================
--- linux-2.6.30-rc4.orig/drivers/md/dm-mpath.c
+++ linux-2.6.30-rc4/drivers/md/dm-mpath.c
@@ -35,7 +35,7 @@ struct pgpath {
struct dm_path path;
struct work_struct deactivate_path;
- struct work_struct activate_path;
+ struct delayed_work activate_path;
};
#define path_to_pgpath(__pgp) container_of((__pgp), struct pgpath, path)
@@ -69,6 +69,7 @@ struct multipath {
struct list_head priority_groups;
unsigned pg_init_required; /* pg_init needs calling? */
unsigned pg_init_in_progress; /* Only one pg_init allowed at once */
+ unsigned pg_init_delay; /* To delay or not to delay */
unsigned nr_valid_paths; /* Total number of usable paths */
struct pgpath *current_pgpath;
@@ -81,6 +82,7 @@ struct multipath {
unsigned saved_queue_if_no_path;/* Saved state during suspension */
unsigned pg_init_retries; /* Number of times to retry pg_init */
unsigned pg_init_count; /* Number of times pg_init called */
+ unsigned pg_init_delay_secs; /* Delay in seconds before retry */
struct work_struct process_queued_ios;
struct bio_list queued_ios;
@@ -127,7 +129,7 @@ static struct pgpath *alloc_pgpath(void)
if (pgpath) {
pgpath->is_active = 1;
INIT_WORK(&pgpath->deactivate_path, deactivate_path);
- INIT_WORK(&pgpath->activate_path, activate_path);
+ INIT_DELAYED_WORK(&pgpath->activate_path, activate_path);
}
return pgpath;
@@ -195,6 +197,7 @@ static struct multipath *alloc_multipath
INIT_LIST_HEAD(&m->priority_groups);
spin_lock_init(&m->lock);
m->queue_io = 1;
+ m->pg_init_delay_secs = SCSI_DH_RETRY_DELAY;
INIT_WORK(&m->process_queued_ios, process_queued_ios);
INIT_WORK(&m->trigger_event, trigger_event);
m->mpio_pool = mempool_create_slab_pool(MIN_IOS, _mpio_cache);
@@ -443,9 +446,11 @@ static void process_queued_ios(struct wo
m->pg_init_count++;
m->pg_init_required = 0;
list_for_each_entry(tmp, &pgpath->pg->pgpaths, list) {
- queue_work(kmpath_handlerd, &tmp->activate_path);
+ queue_delayed_work(kmpath_handlerd, &tmp->activate_path,
+ m->pg_init_delay ? m->pg_init_delay_secs : 0);
m->pg_init_in_progress++;
}
+ m->pg_init_delay = 0;
}
out:
spin_unlock_irqrestore(&m->lock, flags);
@@ -714,8 +719,9 @@ static int parse_features(struct arg_set
const char *param_name;
static struct param _params[] = {
- {0, 3, "invalid number of feature args"},
+ {0, 5, "invalid number of feature args"},
{1, 50, "pg_init_retries must be between 1 and 50"},
+ {1, 50, "pg_init_delay_secs must be between 1 and 50"},
};
r = read_param(_params, shift(as), &argc, &ti->error);
@@ -742,6 +748,14 @@ static int parse_features(struct arg_set
continue;
}
+ if (!strnicmp(param_name, MESG_STR("pg_init_delay_secs")) &&
+ (argc >= 1)) {
+ r = read_param(_params + 1, shift(as),
+ &m->pg_init_delay_secs, &ti->error);
+ argc--;
+ continue;
+ }
+
ti->error = "Unrecognised multipath feature request";
r = -EINVAL;
} while (argc && !r);
@@ -919,7 +933,7 @@ static int reinstate_path(struct pgpath
queue_work(kmultipathd, &m->process_queued_ios);
} else if (m->hw_handler_name && (m->current_pg == pgpath->pg)) {
m->pg_init_in_progress++;
- queue_work(kmpath_handlerd, &pgpath->activate_path);
+ queue_delayed_work(kmpath_handlerd, &pgpath->activate_path, 0);
}
dm_path_uevent(DM_UEVENT_PATH_REINSTATED, m->ti,
@@ -1053,6 +1067,7 @@ static void pg_init_done(struct dm_path
struct priority_group *pg = pgpath->pg;
struct multipath *m = pg->m;
unsigned long flags;
+ unsigned int delay = 0;
/* device or driver problems */
switch (errors) {
@@ -1077,8 +1092,11 @@ static void pg_init_done(struct dm_path
*/
bypass_pg(m, pg, 1);
break;
- /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
+ /*
+ * For SCSI_DH_RETRY we wait before retrying.
+ */
case SCSI_DH_RETRY:
+ delay = 1;
case SCSI_DH_IMM_RETRY:
case SCSI_DH_RES_TEMP_UNAVAIL:
if (pg_init_limit_reached(m, pgpath))
@@ -1107,8 +1125,10 @@ static void pg_init_done(struct dm_path
}
m->pg_init_in_progress--;
- if (!m->pg_init_in_progress)
+ if (!m->pg_init_in_progress) {
+ m->pg_init_delay = delay;
queue_work(kmultipathd, &m->process_queued_ios);
+ }
spin_unlock_irqrestore(&m->lock, flags);
}
@@ -1116,7 +1136,7 @@ static void activate_path(struct work_st
{
int ret;
struct pgpath *pgpath =
- container_of(work, struct pgpath, activate_path);
+ container_of(work, struct pgpath, activate_path.work);
ret = scsi_dh_activate(bdev_get_queue(pgpath->path.dev->bdev));
pg_init_done(&pgpath->path, ret);
@@ -1252,11 +1272,14 @@ static int multipath_status(struct dm_ta
DMEMIT("2 %u %u ", m->queue_size, m->pg_init_count);
else {
DMEMIT("%u ", m->queue_if_no_path +
- (m->pg_init_retries > 0) * 2);
+ (m->pg_init_retries > 0) * 2 +
+ (m->pg_init_delay_secs != SCSI_DH_RETRY_DELAY) * 2);
if (m->queue_if_no_path)
DMEMIT("queue_if_no_path ");
if (m->pg_init_retries)
DMEMIT("pg_init_retries %u ", m->pg_init_retries);
+ if (m->pg_init_delay_secs != SCSI_DH_RETRY_DELAY)
+ DMEMIT("pg_init_delay_secs %u ", m->pg_init_delay_secs);
}
if (!m->hw_handler_name || type == STATUSTYPE_INFO)
Index: linux-2.6.29/include/scsi/scsi_dh.h
===================================================================
--- linux-2.6.29.orig/include/scsi/scsi_dh.h
+++ linux-2.6.29/include/scsi/scsi_dh.h
@@ -55,6 +55,10 @@ enum {
SCSI_DH_NOSYS,
SCSI_DH_DRIVER_MAX,
};
+
+/* Default time to wait before retry in case of SCSI_DH_RETRY */
+#define SCSI_DH_RETRY_DELAY ((HZ * 2))
+
#if defined(CONFIG_SCSI_DH) || defined(CONFIG_SCSI_DH_MODULE)
extern int scsi_dh_activate(struct request_queue *);
extern int scsi_dh_handler_exist(const char *);
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-05-05 3:18 [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY Chandra Seetharaman
@ 2009-05-15 3:10 ` Chandra Seetharaman
2009-05-15 13:38 ` Mike Christie
2009-06-09 20:54 ` Chandra Seetharaman
0 siblings, 2 replies; 18+ messages in thread
From: Chandra Seetharaman @ 2009-05-15 3:10 UTC (permalink / raw)
To: dm-devel; +Cc: Nikanth Karthikesan, Mike Christie
Resubmitting the patch with 2 changes:
1. pg_init_delay_secs was used inconsistently (jiffies and seconds).
Fixed the problem
2. Moved the #define to dm_mpath.c from scsi_dh.h
-----------------------
From: Chandra Seetharaman <sekharan@us.ibm.com>
SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
immediately and SCSI_DH_RETRY in cases where it is better to retry
after some delay.
Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
SCSI_DH_RETRY. This patch adds a user configurable attribute
pg_init_delay_secs which specifies the number of seconds to delay
before retrying scsi_dh_activate, when it returned SCSI_DH_RETRY.
Default for this attribute is set to 2 seconds.
Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
Signed-off-by: Chandra Seetharaman <sekharan@us.ibm.com>
---
drivers/md/dm-mpath.c | 44 +++++++++++++++++++++++++++++++++++---------
1 file changed, 35 insertions(+), 9 deletions(-)
Index: linux-2.6.29/drivers/md/dm-mpath.c
===================================================================
--- linux-2.6.29.orig/drivers/md/dm-mpath.c
+++ linux-2.6.29/drivers/md/dm-mpath.c
@@ -24,6 +24,7 @@
#define DM_MSG_PREFIX "multipath"
#define MESG_STR(x) x, sizeof(x)
+#define DM_PG_INIT_RETRY_DELAY 2
/* Path properties */
struct pgpath {
@@ -35,7 +36,7 @@ struct pgpath {
struct dm_path path;
struct work_struct deactivate_path;
- struct work_struct activate_path;
+ struct delayed_work activate_path;
};
#define path_to_pgpath(__pgp) container_of((__pgp), struct pgpath, path)
@@ -69,6 +70,7 @@ struct multipath {
struct list_head priority_groups;
unsigned pg_init_required; /* pg_init needs calling? */
unsigned pg_init_in_progress; /* Only one pg_init allowed at once */
+ unsigned pg_init_delay; /* To delay or not to delay */
unsigned nr_valid_paths; /* Total number of usable paths */
struct pgpath *current_pgpath;
@@ -81,6 +83,7 @@ struct multipath {
unsigned saved_queue_if_no_path;/* Saved state during suspension */
unsigned pg_init_retries; /* Number of times to retry pg_init */
unsigned pg_init_count; /* Number of times pg_init called */
+ unsigned pg_init_delay_secs; /* Delay in seconds before retry */
struct work_struct process_queued_ios;
struct bio_list queued_ios;
@@ -127,7 +130,7 @@ static struct pgpath *alloc_pgpath(void)
if (pgpath) {
pgpath->is_active = 1;
INIT_WORK(&pgpath->deactivate_path, deactivate_path);
- INIT_WORK(&pgpath->activate_path, activate_path);
+ INIT_DELAYED_WORK(&pgpath->activate_path, activate_path);
}
return pgpath;
@@ -195,6 +198,7 @@ static struct multipath *alloc_multipath
INIT_LIST_HEAD(&m->priority_groups);
spin_lock_init(&m->lock);
m->queue_io = 1;
+ m->pg_init_delay_secs = DM_PG_INIT_RETRY_DELAY;
INIT_WORK(&m->process_queued_ios, process_queued_ios);
INIT_WORK(&m->trigger_event, trigger_event);
m->mpio_pool = mempool_create_slab_pool(MIN_IOS, _mpio_cache);
@@ -443,9 +447,12 @@ static void process_queued_ios(struct wo
m->pg_init_count++;
m->pg_init_required = 0;
list_for_each_entry(tmp, &pgpath->pg->pgpaths, list) {
- queue_work(kmpath_handlerd, &tmp->activate_path);
+ queue_delayed_work(kmpath_handlerd, &tmp->activate_path,
+ m->pg_init_delay ?
+ m->pg_init_delay_secs * HZ : 0);
m->pg_init_in_progress++;
}
+ m->pg_init_delay = 0;
}
out:
spin_unlock_irqrestore(&m->lock, flags);
@@ -714,8 +721,9 @@ static int parse_features(struct arg_set
const char *param_name;
static struct param _params[] = {
- {0, 3, "invalid number of feature args"},
+ {0, 5, "invalid number of feature args"},
{1, 50, "pg_init_retries must be between 1 and 50"},
+ {1, 50, "pg_init_delay_secs must be between 1 and 50"},
};
r = read_param(_params, shift(as), &argc, &ti->error);
@@ -742,6 +750,14 @@ static int parse_features(struct arg_set
continue;
}
+ if (!strnicmp(param_name, MESG_STR("pg_init_delay_secs")) &&
+ (argc >= 1)) {
+ r = read_param(_params + 1, shift(as),
+ &m->pg_init_delay_secs, &ti->error);
+ argc--;
+ continue;
+ }
+
ti->error = "Unrecognised multipath feature request";
r = -EINVAL;
} while (argc && !r);
@@ -919,7 +935,7 @@ static int reinstate_path(struct pgpath
queue_work(kmultipathd, &m->process_queued_ios);
} else if (m->hw_handler_name && (m->current_pg == pgpath->pg)) {
m->pg_init_in_progress++;
- queue_work(kmpath_handlerd, &pgpath->activate_path);
+ queue_delayed_work(kmpath_handlerd, &pgpath->activate_path, 0);
}
dm_path_uevent(DM_UEVENT_PATH_REINSTATED, m->ti,
@@ -1053,6 +1069,7 @@ static void pg_init_done(struct dm_path
struct priority_group *pg = pgpath->pg;
struct multipath *m = pg->m;
unsigned long flags;
+ unsigned int delay = 0;
/* device or driver problems */
switch (errors) {
@@ -1077,8 +1094,11 @@ static void pg_init_done(struct dm_path
*/
bypass_pg(m, pg, 1);
break;
- /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
+ /*
+ * For SCSI_DH_RETRY we wait before retrying.
+ */
case SCSI_DH_RETRY:
+ delay = 1;
case SCSI_DH_IMM_RETRY:
case SCSI_DH_RES_TEMP_UNAVAIL:
if (pg_init_limit_reached(m, pgpath))
@@ -1107,8 +1127,10 @@ static void pg_init_done(struct dm_path
}
m->pg_init_in_progress--;
- if (!m->pg_init_in_progress)
+ if (!m->pg_init_in_progress) {
+ m->pg_init_delay = delay;
queue_work(kmultipathd, &m->process_queued_ios);
+ }
spin_unlock_irqrestore(&m->lock, flags);
}
@@ -1116,7 +1138,7 @@ static void activate_path(struct work_st
{
int ret;
struct pgpath *pgpath =
- container_of(work, struct pgpath, activate_path);
+ container_of(work, struct pgpath, activate_path.work);
ret = scsi_dh_activate(bdev_get_queue(pgpath->path.dev->bdev));
pg_init_done(&pgpath->path, ret);
@@ -1252,11 +1274,15 @@ static int multipath_status(struct dm_ta
DMEMIT("2 %u %u ", m->queue_size, m->pg_init_count);
else {
DMEMIT("%u ", m->queue_if_no_path +
- (m->pg_init_retries > 0) * 2);
+ (m->pg_init_retries > 0) * 2 +
+ (m->pg_init_delay_secs !=
+ DM_PG_INIT_RETRY_DELAY) * 2);
if (m->queue_if_no_path)
DMEMIT("queue_if_no_path ");
if (m->pg_init_retries)
DMEMIT("pg_init_retries %u ", m->pg_init_retries);
+ if (m->pg_init_delay_secs != DM_PG_INIT_RETRY_DELAY)
+ DMEMIT("pg_init_delay_secs %u ", m->pg_init_delay_secs);
}
if (!m->hw_handler_name || type == STATUSTYPE_INFO)
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-05-15 3:10 ` Chandra Seetharaman
@ 2009-05-15 13:38 ` Mike Christie
2009-06-09 20:54 ` Chandra Seetharaman
1 sibling, 0 replies; 18+ messages in thread
From: Mike Christie @ 2009-05-15 13:38 UTC (permalink / raw)
To: sekharan; +Cc: Nikanth Karthikesan, dm-devel
Chandra Seetharaman wrote:
> Resubmitting the patch with 2 changes:
> 1. pg_init_delay_secs was used inconsistently (jiffies and seconds).
> Fixed the problem
> 2. Moved the #define to dm_mpath.c from scsi_dh.h
> -----------------------
> From: Chandra Seetharaman <sekharan@us.ibm.com>
>
> SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
> immediately and SCSI_DH_RETRY in cases where it is better to retry
> after some delay.
>
> Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
> SCSI_DH_RETRY. This patch adds a user configurable attribute
> pg_init_delay_secs which specifies the number of seconds to delay
> before retrying scsi_dh_activate, when it returned SCSI_DH_RETRY.
>
> Default for this attribute is set to 2 seconds.
>
> Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
> Signed-off-by: Chandra Seetharaman <sekharan@us.ibm.com>
>
> ---
> drivers/md/dm-mpath.c | 44 +++++++++++++++++++++++++++++++++++---------
> 1 file changed, 35 insertions(+), 9 deletions(-)
>
> Index: linux-2.6.29/drivers/md/dm-mpath.c
> ===================================================================
> --- linux-2.6.29.orig/drivers/md/dm-mpath.c
> +++ linux-2.6.29/drivers/md/dm-mpath.c
> @@ -24,6 +24,7 @@
>
> #define DM_MSG_PREFIX "multipath"
> #define MESG_STR(x) x, sizeof(x)
> +#define DM_PG_INIT_RETRY_DELAY 2
>
> /* Path properties */
> struct pgpath {
> @@ -35,7 +36,7 @@ struct pgpath {
>
> struct dm_path path;
> struct work_struct deactivate_path;
> - struct work_struct activate_path;
> + struct delayed_work activate_path;
> };
>
> #define path_to_pgpath(__pgp) container_of((__pgp), struct pgpath, path)
> @@ -69,6 +70,7 @@ struct multipath {
> struct list_head priority_groups;
> unsigned pg_init_required; /* pg_init needs calling? */
> unsigned pg_init_in_progress; /* Only one pg_init allowed at once */
> + unsigned pg_init_delay; /* To delay or not to delay */
>
> unsigned nr_valid_paths; /* Total number of usable paths */
> struct pgpath *current_pgpath;
> @@ -81,6 +83,7 @@ struct multipath {
> unsigned saved_queue_if_no_path;/* Saved state during suspension */
> unsigned pg_init_retries; /* Number of times to retry pg_init */
> unsigned pg_init_count; /* Number of times pg_init called */
> + unsigned pg_init_delay_secs; /* Delay in seconds before retry */
>
> struct work_struct process_queued_ios;
> struct bio_list queued_ios;
> @@ -127,7 +130,7 @@ static struct pgpath *alloc_pgpath(void)
> if (pgpath) {
> pgpath->is_active = 1;
> INIT_WORK(&pgpath->deactivate_path, deactivate_path);
> - INIT_WORK(&pgpath->activate_path, activate_path);
> + INIT_DELAYED_WORK(&pgpath->activate_path, activate_path);
> }
>
> return pgpath;
> @@ -195,6 +198,7 @@ static struct multipath *alloc_multipath
> INIT_LIST_HEAD(&m->priority_groups);
> spin_lock_init(&m->lock);
> m->queue_io = 1;
> + m->pg_init_delay_secs = DM_PG_INIT_RETRY_DELAY;
> INIT_WORK(&m->process_queued_ios, process_queued_ios);
> INIT_WORK(&m->trigger_event, trigger_event);
> m->mpio_pool = mempool_create_slab_pool(MIN_IOS, _mpio_cache);
> @@ -443,9 +447,12 @@ static void process_queued_ios(struct wo
> m->pg_init_count++;
> m->pg_init_required = 0;
> list_for_each_entry(tmp, &pgpath->pg->pgpaths, list) {
> - queue_work(kmpath_handlerd, &tmp->activate_path);
> + queue_delayed_work(kmpath_handlerd, &tmp->activate_path,
> + m->pg_init_delay ?
> + m->pg_init_delay_secs * HZ : 0);
> m->pg_init_in_progress++;
> }
> + m->pg_init_delay = 0;
> }
> out:
> spin_unlock_irqrestore(&m->lock, flags);
> @@ -714,8 +721,9 @@ static int parse_features(struct arg_set
> const char *param_name;
>
> static struct param _params[] = {
> - {0, 3, "invalid number of feature args"},
> + {0, 5, "invalid number of feature args"},
> {1, 50, "pg_init_retries must be between 1 and 50"},
> + {1, 50, "pg_init_delay_secs must be between 1 and 50"},
> };
>
> r = read_param(_params, shift(as), &argc, &ti->error);
> @@ -742,6 +750,14 @@ static int parse_features(struct arg_set
> continue;
> }
>
> + if (!strnicmp(param_name, MESG_STR("pg_init_delay_secs")) &&
> + (argc >= 1)) {
> + r = read_param(_params + 1, shift(as),
> + &m->pg_init_delay_secs, &ti->error);
> + argc--;
> + continue;
> + }
> +
> ti->error = "Unrecognised multipath feature request";
> r = -EINVAL;
> } while (argc && !r);
> @@ -919,7 +935,7 @@ static int reinstate_path(struct pgpath
> queue_work(kmultipathd, &m->process_queued_ios);
> } else if (m->hw_handler_name && (m->current_pg == pgpath->pg)) {
> m->pg_init_in_progress++;
> - queue_work(kmpath_handlerd, &pgpath->activate_path);
> + queue_delayed_work(kmpath_handlerd, &pgpath->activate_path, 0);
> }
>
> dm_path_uevent(DM_UEVENT_PATH_REINSTATED, m->ti,
> @@ -1053,6 +1069,7 @@ static void pg_init_done(struct dm_path
> struct priority_group *pg = pgpath->pg;
> struct multipath *m = pg->m;
> unsigned long flags;
> + unsigned int delay = 0;
>
> /* device or driver problems */
> switch (errors) {
> @@ -1077,8 +1094,11 @@ static void pg_init_done(struct dm_path
> */
> bypass_pg(m, pg, 1);
> break;
> - /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
> + /*
> + * For SCSI_DH_RETRY we wait before retrying.
> + */
> case SCSI_DH_RETRY:
> + delay = 1;
> case SCSI_DH_IMM_RETRY:
> case SCSI_DH_RES_TEMP_UNAVAIL:
> if (pg_init_limit_reached(m, pgpath))
> @@ -1107,8 +1127,10 @@ static void pg_init_done(struct dm_path
> }
>
> m->pg_init_in_progress--;
> - if (!m->pg_init_in_progress)
> + if (!m->pg_init_in_progress) {
> + m->pg_init_delay = delay;
> queue_work(kmultipathd, &m->process_queued_ios);
> + }
> spin_unlock_irqrestore(&m->lock, flags);
> }
>
> @@ -1116,7 +1138,7 @@ static void activate_path(struct work_st
> {
> int ret;
> struct pgpath *pgpath =
> - container_of(work, struct pgpath, activate_path);
> + container_of(work, struct pgpath, activate_path.work);
>
> ret = scsi_dh_activate(bdev_get_queue(pgpath->path.dev->bdev));
> pg_init_done(&pgpath->path, ret);
> @@ -1252,11 +1274,15 @@ static int multipath_status(struct dm_ta
> DMEMIT("2 %u %u ", m->queue_size, m->pg_init_count);
> else {
> DMEMIT("%u ", m->queue_if_no_path +
> - (m->pg_init_retries > 0) * 2);
> + (m->pg_init_retries > 0) * 2 +
> + (m->pg_init_delay_secs !=
> + DM_PG_INIT_RETRY_DELAY) * 2);
> if (m->queue_if_no_path)
> DMEMIT("queue_if_no_path ");
> if (m->pg_init_retries)
> DMEMIT("pg_init_retries %u ", m->pg_init_retries);
> + if (m->pg_init_delay_secs != DM_PG_INIT_RETRY_DELAY)
> + DMEMIT("pg_init_delay_secs %u ", m->pg_init_delay_secs);
> }
>
> if (!m->hw_handler_name || type == STATUSTYPE_INFO)
>
>
>
Looks ok.
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-05-15 3:10 ` Chandra Seetharaman
2009-05-15 13:38 ` Mike Christie
@ 2009-06-09 20:54 ` Chandra Seetharaman
2010-11-02 19:32 ` Mike Snitzer
1 sibling, 1 reply; 18+ messages in thread
From: Chandra Seetharaman @ 2009-06-09 20:54 UTC (permalink / raw)
To: dm-devel; +Cc: Nikanth Karthikesan, Mike Christie
No functional change.
Repost with changes made to apply cleanly on top of the patch
(http://marc.info/?l=dm-devel&m=124424663327710&w=2) that changed
dm-mpath.c
-----------------
From: Chandra Seetharaman <sekharan@us.ibm.com>
SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
immediately and SCSI_DH_RETRY in cases where it is better to retry
after some delay.
Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
SCSI_DH_RETRY. This patch adds a user configurable attribute
pg_init_delay_secs which specifies the number of seconds to delay
before retrying scsi_dh_activate, when it returned SCSI_DH_RETRY.
Default for this attribute is set to 2 seconds.
Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
Signed-off-by: Chandra Seetharaman <sekharan@us.ibm.com>
--
---
drivers/md/dm-mpath.c | 43 ++++++++++++++++++++++++++++++++++---------
1 file changed, 34 insertions(+), 9 deletions(-)
Index: linux-2.6.29/drivers/md/dm-mpath.c
===================================================================
--- linux-2.6.29.orig/drivers/md/dm-mpath.c
+++ linux-2.6.29/drivers/md/dm-mpath.c
@@ -24,6 +24,7 @@
#define DM_MSG_PREFIX "multipath"
#define MESG_STR(x) x, sizeof(x)
+#define DM_PG_INIT_RETRY_DELAY 2
/* Path properties */
struct pgpath {
@@ -35,7 +36,7 @@ struct pgpath {
struct dm_path path;
struct work_struct deactivate_path;
- struct work_struct activate_path;
+ struct delayed_work activate_path;
};
#define path_to_pgpath(__pgp) container_of((__pgp), struct pgpath, path)
@@ -69,6 +70,7 @@ struct multipath {
struct list_head priority_groups;
unsigned pg_init_required; /* pg_init needs calling? */
unsigned pg_init_in_progress; /* Only one pg_init allowed at once */
+ unsigned pg_init_delay; /* To delay or not to delay */
unsigned nr_valid_paths; /* Total number of usable paths */
struct pgpath *current_pgpath;
@@ -81,6 +83,7 @@ struct multipath {
unsigned saved_queue_if_no_path;/* Saved state during suspension */
unsigned pg_init_retries; /* Number of times to retry pg_init */
unsigned pg_init_count; /* Number of times pg_init called */
+ unsigned pg_init_delay_secs; /* Delay in seconds before retry */
struct work_struct process_queued_ios;
struct bio_list queued_ios;
@@ -127,7 +130,7 @@ static struct pgpath *alloc_pgpath(void)
if (pgpath) {
pgpath->is_active = 1;
INIT_WORK(&pgpath->deactivate_path, deactivate_path);
- INIT_WORK(&pgpath->activate_path, activate_path);
+ INIT_DELAYED_WORK(&pgpath->activate_path, activate_path);
}
return pgpath;
@@ -195,6 +198,7 @@ static struct multipath *alloc_multipath
INIT_LIST_HEAD(&m->priority_groups);
spin_lock_init(&m->lock);
m->queue_io = 1;
+ m->pg_init_delay_secs = DM_PG_INIT_RETRY_DELAY;
INIT_WORK(&m->process_queued_ios, process_queued_ios);
INIT_WORK(&m->trigger_event, trigger_event);
m->mpio_pool = mempool_create_slab_pool(MIN_IOS, _mpio_cache);
@@ -443,7 +447,9 @@ static void process_queued_ios(struct wo
m->pg_init_count++;
m->pg_init_required = 0;
list_for_each_entry(tmp, &pgpath->pg->pgpaths, list) {
- if (queue_work(kmpath_handlerd, &tmp->activate_path))
+ if (queue_delayed_work(kmpath_handlerd,
+ &tmp->activate_path, m->pg_init_delay ?
+ m->pg_init_delay_secs * HZ : 0))
m->pg_init_in_progress++;
}
}
@@ -714,8 +720,9 @@ static int parse_features(struct arg_set
const char *param_name;
static struct param _params[] = {
- {0, 3, "invalid number of feature args"},
+ {0, 5, "invalid number of feature args"},
{1, 50, "pg_init_retries must be between 1 and 50"},
+ {1, 50, "pg_init_delay_secs must be between 1 and 50"},
};
r = read_param(_params, shift(as), &argc, &ti->error);
@@ -742,6 +749,14 @@ static int parse_features(struct arg_set
continue;
}
+ if (!strnicmp(param_name, MESG_STR("pg_init_delay_secs")) &&
+ (argc >= 1)) {
+ r = read_param(_params + 1, shift(as),
+ &m->pg_init_delay_secs, &ti->error);
+ argc--;
+ continue;
+ }
+
ti->error = "Unrecognised multipath feature request";
r = -EINVAL;
} while (argc && !r);
@@ -918,7 +933,7 @@ static int reinstate_path(struct pgpath
m->current_pgpath = NULL;
queue_work(kmultipathd, &m->process_queued_ios);
} else if (m->hw_handler_name && (m->current_pg == pgpath->pg)) {
- if (queue_work(kmpath_handlerd, &pgpath->activate_path))
+ if (queue_work(kmpath_handlerd, &pgpath->activate_path.work))
m->pg_init_in_progress++;
}
@@ -1053,6 +1068,7 @@ static void pg_init_done(struct dm_path
struct priority_group *pg = pgpath->pg;
struct multipath *m = pg->m;
unsigned long flags;
+ unsigned int delay = 0;
/* device or driver problems */
switch (errors) {
@@ -1077,8 +1093,11 @@ static void pg_init_done(struct dm_path
*/
bypass_pg(m, pg, 1);
break;
- /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
+ /*
+ * For SCSI_DH_RETRY we wait before retrying.
+ */
case SCSI_DH_RETRY:
+ delay = 1;
case SCSI_DH_IMM_RETRY:
case SCSI_DH_RES_TEMP_UNAVAIL:
if (pg_init_limit_reached(m, pgpath))
@@ -1107,8 +1126,10 @@ static void pg_init_done(struct dm_path
}
m->pg_init_in_progress--;
- if (!m->pg_init_in_progress)
+ if (!m->pg_init_in_progress) {
+ m->pg_init_delay = delay;
queue_work(kmultipathd, &m->process_queued_ios);
+ }
spin_unlock_irqrestore(&m->lock, flags);
}
@@ -1116,7 +1137,7 @@ static void activate_path(struct work_st
{
int ret;
struct pgpath *pgpath =
- container_of(work, struct pgpath, activate_path);
+ container_of(work, struct pgpath, activate_path.work);
ret = scsi_dh_activate(bdev_get_queue(pgpath->path.dev->bdev));
pg_init_done(&pgpath->path, ret);
@@ -1252,11 +1273,15 @@ static int multipath_status(struct dm_ta
DMEMIT("2 %u %u ", m->queue_size, m->pg_init_count);
else {
DMEMIT("%u ", m->queue_if_no_path +
- (m->pg_init_retries > 0) * 2);
+ (m->pg_init_retries > 0) * 2 +
+ (m->pg_init_delay_secs !=
+ DM_PG_INIT_RETRY_DELAY) * 2);
if (m->queue_if_no_path)
DMEMIT("queue_if_no_path ");
if (m->pg_init_retries)
DMEMIT("pg_init_retries %u ", m->pg_init_retries);
+ if (m->pg_init_delay_secs != DM_PG_INIT_RETRY_DELAY)
+ DMEMIT("pg_init_delay_secs %u ", m->pg_init_delay_secs);
}
if (!m->hw_handler_name || type == STATUSTYPE_INFO)
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-06-09 20:54 ` Chandra Seetharaman
@ 2010-11-02 19:32 ` Mike Snitzer
2010-11-02 19:56 ` Chandra Seetharaman
2010-11-02 21:02 ` Mike Christie
0 siblings, 2 replies; 18+ messages in thread
From: Mike Snitzer @ 2010-11-02 19:32 UTC (permalink / raw)
To: sekharan, device-mapper development; +Cc: Nikanth Karthikesan, Mike Christie
On Tue, Jun 09 2009 at 4:54pm -0400,
Chandra Seetharaman <sekharan@us.ibm.com> wrote:
> No functional change.
>
> Repost with changes made to apply cleanly on top of the patch
> (http://marc.info/?l=dm-devel&m=124424663327710&w=2) that changed
> dm-mpath.c
>
> -----------------
> From: Chandra Seetharaman <sekharan@us.ibm.com>
>
> SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
> immediately and SCSI_DH_RETRY in cases where it is better to retry
> after some delay.
>
> Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
> SCSI_DH_RETRY. This patch adds a user configurable attribute
> pg_init_delay_secs which specifies the number of seconds to delay
> before retrying scsi_dh_activate, when it returned SCSI_DH_RETRY.
>
> Default for this attribute is set to 2 seconds.
>
> Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
> Signed-off-by: Chandra Seetharaman <sekharan@us.ibm.com>
I'm auditing dm-devel's patchwork and would just like to confirm that
others would still like to see this go in?
Patch in question is captured here:
https://patchwork.kernel.org/patch/29088/
Mike C.,
An earlier version of this patch got your "Looks ok.":
https://patchwork.kernel.org/patch/23946/
Can I translate that to your "Acked-by:" if/when I rebase and repost?
Please advise,
Mike
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: dm mpath: delay retry activate_path on SCSI_DH_RETRY
2010-11-02 19:32 ` Mike Snitzer
@ 2010-11-02 19:56 ` Chandra Seetharaman
2010-11-02 21:02 ` Mike Christie
1 sibling, 0 replies; 18+ messages in thread
From: Chandra Seetharaman @ 2010-11-02 19:56 UTC (permalink / raw)
To: Mike Snitzer
Cc: Nikanth Karthikesan, device-mapper development, Mike Christie
Yes, I would like to see this go in.
Thanks for cleaning it up.
chandra
On Tue, 2010-11-02 at 15:32 -0400, Mike Snitzer wrote:
> On Tue, Jun 09 2009 at 4:54pm -0400,
> Chandra Seetharaman <sekharan@us.ibm.com> wrote:
>
> > No functional change.
> >
> > Repost with changes made to apply cleanly on top of the patch
> > (http://marc.info/?l=dm-devel&m=124424663327710&w=2) that changed
> > dm-mpath.c
> >
> > -----------------
> > From: Chandra Seetharaman <sekharan@us.ibm.com>
> >
> > SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
> > immediately and SCSI_DH_RETRY in cases where it is better to retry
> > after some delay.
> >
> > Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
> > SCSI_DH_RETRY. This patch adds a user configurable attribute
> > pg_init_delay_secs which specifies the number of seconds to delay
> > before retrying scsi_dh_activate, when it returned SCSI_DH_RETRY.
> >
> > Default for this attribute is set to 2 seconds.
> >
> > Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
> > Signed-off-by: Chandra Seetharaman <sekharan@us.ibm.com>
>
> I'm auditing dm-devel's patchwork and would just like to confirm that
> others would still like to see this go in?
>
> Patch in question is captured here:
> https://patchwork.kernel.org/patch/29088/
>
> Mike C.,
> An earlier version of this patch got your "Looks ok.":
> https://patchwork.kernel.org/patch/23946/
> Can I translate that to your "Acked-by:" if/when I rebase and repost?
>
> Please advise,
> Mike
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: dm mpath: delay retry activate_path on SCSI_DH_RETRY
2010-11-02 19:32 ` Mike Snitzer
2010-11-02 19:56 ` Chandra Seetharaman
@ 2010-11-02 21:02 ` Mike Christie
1 sibling, 0 replies; 18+ messages in thread
From: Mike Christie @ 2010-11-02 21:02 UTC (permalink / raw)
To: Mike Snitzer; +Cc: Nikanth Karthikesan, device-mapper development, sekharan
On 11/02/2010 02:32 PM, Mike Snitzer wrote:
> On Tue, Jun 09 2009 at 4:54pm -0400,
> Chandra Seetharaman<sekharan@us.ibm.com> wrote:
>
>> No functional change.
>>
>> Repost with changes made to apply cleanly on top of the patch
>> (http://marc.info/?l=dm-devel&m=124424663327710&w=2) that changed
>> dm-mpath.c
>>
>> -----------------
>> From: Chandra Seetharaman<sekharan@us.ibm.com>
>>
>> SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
>> immediately and SCSI_DH_RETRY in cases where it is better to retry
>> after some delay.
>>
>> Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
>> SCSI_DH_RETRY. This patch adds a user configurable attribute
>> pg_init_delay_secs which specifies the number of seconds to delay
>> before retrying scsi_dh_activate, when it returned SCSI_DH_RETRY.
>>
>> Default for this attribute is set to 2 seconds.
>>
>> Signed-off-by: Nikanth Karthikesan<knikanth@suse.de>
>> Signed-off-by: Chandra Seetharaman<sekharan@us.ibm.com>
>
> I'm auditing dm-devel's patchwork and would just like to confirm that
> others would still like to see this go in?
>
> Patch in question is captured here:
> https://patchwork.kernel.org/patch/29088/
>
> Mike C.,
> An earlier version of this patch got your "Looks ok.":
> https://patchwork.kernel.org/patch/23946/
> Can I translate that to your "Acked-by:" if/when I rebase and repost?
>
Yeah.
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-04-28 19:35 ` Chandra Seetharaman
@ 2009-04-28 22:34 ` Alasdair G Kergon
0 siblings, 0 replies; 18+ messages in thread
From: Alasdair G Kergon @ 2009-04-28 22:34 UTC (permalink / raw)
To: Chandra Seetharaman; +Cc: Nikanth Karthikesan, device-mapper development
On Tue, Apr 28, 2009 at 12:35:27PM -0700, Chandra Seetharaman wrote:
> I am working on a patch on keeping it 2 seconds and adding a parameter
> giving user/user space tool the control to change it to any number.
Either that or provide justification inline for why 2 seconds
is always a sensible value to use.
Alasdair
--
agk@redhat.com
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-04-28 6:15 [PATCH] " Nikanth Karthikesan
@ 2009-04-28 19:35 ` Chandra Seetharaman
2009-04-28 22:34 ` Alasdair G Kergon
0 siblings, 1 reply; 18+ messages in thread
From: Chandra Seetharaman @ 2009-04-28 19:35 UTC (permalink / raw)
To: Nikanth Karthikesan; +Cc: device-mapper development, Alasdair G Kergon
Nikanth,
Talked to Alasdair regarding this during yesterday's dm-devel conf call.
He mentioned that he is not convinced with "why 2 seconds", why not any
other numbers. Basically, he doesn't want another patch following this
after few days saying that we want to change it to X seconds :)
I am working on a patch on keeping it 2 seconds and adding a parameter
giving user/user space tool the control to change it to any number.
On Tue, 2009-04-28 at 11:45 +0530, Nikanth Karthikesan wrote:
> On Saturday 21 February 2009 02:41:33 Chandra Seetharaman wrote:
> > On Fri, 2009-02-20 at 10:33 +0530, Nikanth Karthikesan wrote:
> > > On Friday 20 February 2009 06:15:29 Chandra Seetharaman wrote:
> > > > On Thu, 2009-02-19 at 12:40 +0530, Nikanth Karthikesan wrote:
> > > >
> > >
> > > I missed resetting pg_init_delay to zero after using it. I have attached
> > > the corrected patch with this. This variable keeps the code
> > > cleaner(avoids taking m->lock). Also having only a boolean in struct
> > > multipath keeps it a bit smaller.
> >
> > Ok. I am fine with your justification.
> >
> > > off-topic:
> > > I think struct multipath can be shrunk even further by making various
> > > flags like pg_init_required, pg_init_in_progress, queue_io,
> > > queue_if_no_path, saved_queue_if_no_path in to a single variable.
> > > Thoughts?
> >
> > As Konrad mentioned, it is worth the cost of readability ?
> >
> >
>
> I think based on the above off-topic comment you had mistakenly marked this in
> patch-work as changes requested.
>
> > <snip>
> >
> > > SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
> > > immediately and SCSI_DH_RETRY in cases where it is better to retry
> > > after some delay.
> > >
> > > Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
> > > SCSI_DH_RETRY. This patch adds a 2 second delay before retrying to
> > > activate a device, if it returns SCSI_DH_RETRY.
> > >
> > > Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
> >
> > Acked-by: Chandra Seetharaman <sekharan@us.ibm.com>
> >
>
> All the comments received were incorporated already.
>
> Can you merge this?
>
> Thanks
> Nikanth
>
> > > ---
> > >
> > > diff --git a/drivers/md/dm-mpath.c b/drivers/md/dm-mpath.c
> > > index 095f77b..7ddf775 100644
> > > --- a/drivers/md/dm-mpath.c
> > > +++ b/drivers/md/dm-mpath.c
> > > @@ -65,12 +65,13 @@ struct multipath {
> > > spinlock_t lock;
> > >
> > > const char *hw_handler_name;
> > > - struct work_struct activate_path;
> > > + struct delayed_work activate_path;
> > > struct pgpath *pgpath_to_activate;
> > > unsigned nr_priority_groups;
> > > struct list_head priority_groups;
> > > unsigned pg_init_required; /* pg_init needs calling? */
> > > unsigned pg_init_in_progress; /* Only one pg_init allowed at once */
> > > + unsigned pg_init_delay; /* delay required before retry? */
> > >
> > > unsigned nr_valid_paths; /* Total number of usable paths */
> > > struct pgpath *current_pgpath;
> > > @@ -203,7 +204,7 @@ static struct multipath *alloc_multipath(struct
> > > dm_target *ti) m->queue_io = 1;
> > > INIT_WORK(&m->process_queued_ios, process_queued_ios);
> > > INIT_WORK(&m->trigger_event, trigger_event);
> > > - INIT_WORK(&m->activate_path, activate_path);
> > > + INIT_DELAYED_WORK(&m->activate_path, activate_path);
> > > m->mpio_pool = mempool_create_slab_pool(MIN_IOS, _mpio_cache);
> > > if (!m->mpio_pool) {
> > > kfree(m);
> > > @@ -431,6 +432,7 @@ static void process_queued_ios(struct work_struct
> > > *work) struct pgpath *pgpath = NULL;
> > > unsigned init_required = 0, must_queue = 1;
> > > unsigned long flags;
> > > + unsigned long delay = 0;
> > >
> > > spin_lock_irqsave(&m->lock, flags);
> > >
> > > @@ -452,13 +454,17 @@ static void process_queued_ios(struct work_struct
> > > *work) m->pg_init_required = 0;
> > > m->pg_init_in_progress = 1;
> > > init_required = 1;
> > > + if (m->pg_init_delay) {
> > > + delay = SCSI_DH_RETRY_DELAY;
> > > + m->pg_init_delay = 0;
> > > + }
> > > }
> > >
> > > out:
> > > spin_unlock_irqrestore(&m->lock, flags);
> > >
> > > if (init_required)
> > > - queue_work(kmpath_handlerd, &m->activate_path);
> > > + queue_delayed_work(kmpath_handlerd, &m->activate_path, delay);
> > >
> > > if (!must_queue)
> > > dispatch_queued_ios(m);
> > > @@ -1060,6 +1066,7 @@ static void pg_init_done(struct dm_path *path, int
> > > errors) struct priority_group *pg = pgpath->pg;
> > > struct multipath *m = pg->m;
> > > unsigned long flags;
> > > + unsigned delay = 0;
> > >
> > > /* device or driver problems */
> > > switch (errors) {
> > > @@ -1084,8 +1091,11 @@ static void pg_init_done(struct dm_path *path, int
> > > errors) */
> > > bypass_pg(m, pg, 1);
> > > break;
> > > - /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
> > > + /*
> > > + * For SCSI_DH_RETRY we wait before retrying.
> > > + */
> > > case SCSI_DH_RETRY:
> > > + delay = 1;
> > > case SCSI_DH_IMM_RETRY:
> > > case SCSI_DH_RES_TEMP_UNAVAIL:
> > > if (pg_init_limit_reached(m, pgpath))
> > > @@ -1112,6 +1122,7 @@ static void pg_init_done(struct dm_path *path, int
> > > errors) }
> > >
> > > m->pg_init_in_progress = 0;
> > > + m->pg_init_delay = delay;
> > > queue_work(kmultipathd, &m->process_queued_ios);
> > > spin_unlock_irqrestore(&m->lock, flags);
> > > }
> > > @@ -1120,7 +1131,7 @@ static void activate_path(struct work_struct *work)
> > > {
> > > int ret;
> > > struct multipath *m =
> > > - container_of(work, struct multipath, activate_path);
> > > + container_of(work, struct multipath, activate_path.work);
> > > struct dm_path *path;
> > > unsigned long flags;
> > >
> > > diff --git a/include/scsi/scsi_dh.h b/include/scsi/scsi_dh.h
> > > index 33efce2..f099d86 100644
> > > --- a/include/scsi/scsi_dh.h
> > > +++ b/include/scsi/scsi_dh.h
> > > @@ -55,6 +55,10 @@ enum {
> > > SCSI_DH_NOSYS,
> > > SCSI_DH_DRIVER_MAX,
> > > };
> > > +
> > > +/* Time to wait before retry in case of SCSI_DH_RETRY */
> > > +#define SCSI_DH_RETRY_DELAY ((HZ * 2))
> > > +
> > > #if defined(CONFIG_SCSI_DH) || defined(CONFIG_SCSI_DH_MODULE)
> > > extern int scsi_dh_activate(struct request_queue *);
> > > extern int scsi_dh_handler_exist(const char *);
> > > �
>
>
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
@ 2009-04-28 6:15 Nikanth Karthikesan
2009-04-28 19:35 ` Chandra Seetharaman
0 siblings, 1 reply; 18+ messages in thread
From: Nikanth Karthikesan @ 2009-04-28 6:15 UTC (permalink / raw)
To: Alasdair G Kergon; +Cc: device-mapper development, sekharan
On Saturday 21 February 2009 02:41:33 Chandra Seetharaman wrote:
> On Fri, 2009-02-20 at 10:33 +0530, Nikanth Karthikesan wrote:
> > On Friday 20 February 2009 06:15:29 Chandra Seetharaman wrote:
> > > On Thu, 2009-02-19 at 12:40 +0530, Nikanth Karthikesan wrote:
> > >
> >
> > I missed resetting pg_init_delay to zero after using it. I have attached
> > the corrected patch with this. This variable keeps the code
> > cleaner(avoids taking m->lock). Also having only a boolean in struct
> > multipath keeps it a bit smaller.
>
> Ok. I am fine with your justification.
>
> > off-topic:
> > I think struct multipath can be shrunk even further by making various
> > flags like pg_init_required, pg_init_in_progress, queue_io,
> > queue_if_no_path, saved_queue_if_no_path in to a single variable.
> > Thoughts?
>
> As Konrad mentioned, it is worth the cost of readability ?
>
>
I think based on the above off-topic comment you had mistakenly marked this in
patch-work as changes requested.
> <snip>
>
> > SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
> > immediately and SCSI_DH_RETRY in cases where it is better to retry
> > after some delay.
> >
> > Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
> > SCSI_DH_RETRY. This patch adds a 2 second delay before retrying to
> > activate a device, if it returns SCSI_DH_RETRY.
> >
> > Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
>
> Acked-by: Chandra Seetharaman <sekharan@us.ibm.com>
>
All the comments received were incorporated already.
Can you merge this?
Thanks
Nikanth
> > ---
> >
> > diff --git a/drivers/md/dm-mpath.c b/drivers/md/dm-mpath.c
> > index 095f77b..7ddf775 100644
> > --- a/drivers/md/dm-mpath.c
> > +++ b/drivers/md/dm-mpath.c
> > @@ -65,12 +65,13 @@ struct multipath {
> > spinlock_t lock;
> >
> > const char *hw_handler_name;
> > - struct work_struct activate_path;
> > + struct delayed_work activate_path;
> > struct pgpath *pgpath_to_activate;
> > unsigned nr_priority_groups;
> > struct list_head priority_groups;
> > unsigned pg_init_required; /* pg_init needs calling? */
> > unsigned pg_init_in_progress; /* Only one pg_init allowed at once */
> > + unsigned pg_init_delay; /* delay required before retry? */
> >
> > unsigned nr_valid_paths; /* Total number of usable paths */
> > struct pgpath *current_pgpath;
> > @@ -203,7 +204,7 @@ static struct multipath *alloc_multipath(struct
> > dm_target *ti) m->queue_io = 1;
> > INIT_WORK(&m->process_queued_ios, process_queued_ios);
> > INIT_WORK(&m->trigger_event, trigger_event);
> > - INIT_WORK(&m->activate_path, activate_path);
> > + INIT_DELAYED_WORK(&m->activate_path, activate_path);
> > m->mpio_pool = mempool_create_slab_pool(MIN_IOS, _mpio_cache);
> > if (!m->mpio_pool) {
> > kfree(m);
> > @@ -431,6 +432,7 @@ static void process_queued_ios(struct work_struct
> > *work) struct pgpath *pgpath = NULL;
> > unsigned init_required = 0, must_queue = 1;
> > unsigned long flags;
> > + unsigned long delay = 0;
> >
> > spin_lock_irqsave(&m->lock, flags);
> >
> > @@ -452,13 +454,17 @@ static void process_queued_ios(struct work_struct
> > *work) m->pg_init_required = 0;
> > m->pg_init_in_progress = 1;
> > init_required = 1;
> > + if (m->pg_init_delay) {
> > + delay = SCSI_DH_RETRY_DELAY;
> > + m->pg_init_delay = 0;
> > + }
> > }
> >
> > out:
> > spin_unlock_irqrestore(&m->lock, flags);
> >
> > if (init_required)
> > - queue_work(kmpath_handlerd, &m->activate_path);
> > + queue_delayed_work(kmpath_handlerd, &m->activate_path, delay);
> >
> > if (!must_queue)
> > dispatch_queued_ios(m);
> > @@ -1060,6 +1066,7 @@ static void pg_init_done(struct dm_path *path, int
> > errors) struct priority_group *pg = pgpath->pg;
> > struct multipath *m = pg->m;
> > unsigned long flags;
> > + unsigned delay = 0;
> >
> > /* device or driver problems */
> > switch (errors) {
> > @@ -1084,8 +1091,11 @@ static void pg_init_done(struct dm_path *path, int
> > errors) */
> > bypass_pg(m, pg, 1);
> > break;
> > - /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
> > + /*
> > + * For SCSI_DH_RETRY we wait before retrying.
> > + */
> > case SCSI_DH_RETRY:
> > + delay = 1;
> > case SCSI_DH_IMM_RETRY:
> > case SCSI_DH_RES_TEMP_UNAVAIL:
> > if (pg_init_limit_reached(m, pgpath))
> > @@ -1112,6 +1122,7 @@ static void pg_init_done(struct dm_path *path, int
> > errors) }
> >
> > m->pg_init_in_progress = 0;
> > + m->pg_init_delay = delay;
> > queue_work(kmultipathd, &m->process_queued_ios);
> > spin_unlock_irqrestore(&m->lock, flags);
> > }
> > @@ -1120,7 +1131,7 @@ static void activate_path(struct work_struct *work)
> > {
> > int ret;
> > struct multipath *m =
> > - container_of(work, struct multipath, activate_path);
> > + container_of(work, struct multipath, activate_path.work);
> > struct dm_path *path;
> > unsigned long flags;
> >
> > diff --git a/include/scsi/scsi_dh.h b/include/scsi/scsi_dh.h
> > index 33efce2..f099d86 100644
> > --- a/include/scsi/scsi_dh.h
> > +++ b/include/scsi/scsi_dh.h
> > @@ -55,6 +55,10 @@ enum {
> > SCSI_DH_NOSYS,
> > SCSI_DH_DRIVER_MAX,
> > };
> > +
> > +/* Time to wait before retry in case of SCSI_DH_RETRY */
> > +#define SCSI_DH_RETRY_DELAY ((HZ * 2))
> > +
> > #if defined(CONFIG_SCSI_DH) || defined(CONFIG_SCSI_DH_MODULE)
> > extern int scsi_dh_activate(struct request_queue *);
> > extern int scsi_dh_handler_exist(const char *);
> > �
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-02-20 21:11 ` Chandra Seetharaman
@ 2009-03-02 10:48 ` Nikanth Karthikesan
0 siblings, 0 replies; 18+ messages in thread
From: Nikanth Karthikesan @ 2009-03-02 10:48 UTC (permalink / raw)
To: Alasdair G Kergon; +Cc: device-mapper development, sekharan
On Saturday 21 February 2009 02:41:33 Chandra Seetharaman wrote:
> On Fri, 2009-02-20 at 10:33 +0530, Nikanth Karthikesan wrote:
> > On Friday 20 February 2009 06:15:29 Chandra Seetharaman wrote:
> > > On Thu, 2009-02-19 at 12:40 +0530, Nikanth Karthikesan wrote:
> > >
> > > <snip>
> > >
> > > > @@ -431,6 +432,7 @@ static void process_queued_ios(struct work_struct
> > > > *work) struct pgpath *pgpath = NULL;
> > > > unsigned init_required = 0, must_queue = 1;
> > > > unsigned long flags;
> > > > + unsigned long delay = 0;
> > >
> > > I do not see the reason for this variable, you can as well put the
> > > delay in pg_init_delay and use it directly (and set it to zero after
> > > using it) ?
> >
> > I missed resetting pg_init_delay to zero after using it. I have attached
> > the corrected patch with this. This variable keeps the code
> > cleaner(avoids taking m->lock). Also having only a boolean in struct
> > multipath keeps it a bit smaller.
>
> Ok. I am fine with your justification.
>
> > off-topic:
> > I think struct multipath can be shrunk even further by making various
> > flags like pg_init_required, pg_init_in_progress, queue_io,
> > queue_if_no_path, saved_queue_if_no_path in to a single variable.
> > Thoughts?
>
> As Konrad mentioned, it is worth the cost of readability ?
>
>
> <snip>
>
> > SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
> > immediately and SCSI_DH_RETRY in cases where it is better to retry
> > after some delay.
> >
> > Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
> > SCSI_DH_RETRY. This patch adds a 2 second delay before retrying to
> > activate a device, if it returns SCSI_DH_RETRY.
> >
> > Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
>
> Acked-by: Chandra Seetharaman <sekharan@us.ibm.com>
>
Hi Alasdair
Can you merge this?
Thanks
Nikanth
> > ---
> >
> > diff --git a/drivers/md/dm-mpath.c b/drivers/md/dm-mpath.c
> > index 095f77b..7ddf775 100644
> > --- a/drivers/md/dm-mpath.c
> > +++ b/drivers/md/dm-mpath.c
> > @@ -65,12 +65,13 @@ struct multipath {
> > spinlock_t lock;
> >
> > const char *hw_handler_name;
> > - struct work_struct activate_path;
> > + struct delayed_work activate_path;
> > struct pgpath *pgpath_to_activate;
> > unsigned nr_priority_groups;
> > struct list_head priority_groups;
> > unsigned pg_init_required; /* pg_init needs calling? */
> > unsigned pg_init_in_progress; /* Only one pg_init allowed at once */
> > + unsigned pg_init_delay; /* delay required before retry? */
> >
> > unsigned nr_valid_paths; /* Total number of usable paths */
> > struct pgpath *current_pgpath;
> > @@ -203,7 +204,7 @@ static struct multipath *alloc_multipath(struct
> > dm_target *ti) m->queue_io = 1;
> > INIT_WORK(&m->process_queued_ios, process_queued_ios);
> > INIT_WORK(&m->trigger_event, trigger_event);
> > - INIT_WORK(&m->activate_path, activate_path);
> > + INIT_DELAYED_WORK(&m->activate_path, activate_path);
> > m->mpio_pool = mempool_create_slab_pool(MIN_IOS, _mpio_cache);
> > if (!m->mpio_pool) {
> > kfree(m);
> > @@ -431,6 +432,7 @@ static void process_queued_ios(struct work_struct
> > *work) struct pgpath *pgpath = NULL;
> > unsigned init_required = 0, must_queue = 1;
> > unsigned long flags;
> > + unsigned long delay = 0;
> >
> > spin_lock_irqsave(&m->lock, flags);
> >
> > @@ -452,13 +454,17 @@ static void process_queued_ios(struct work_struct
> > *work) m->pg_init_required = 0;
> > m->pg_init_in_progress = 1;
> > init_required = 1;
> > + if (m->pg_init_delay) {
> > + delay = SCSI_DH_RETRY_DELAY;
> > + m->pg_init_delay = 0;
> > + }
> > }
> >
> > out:
> > spin_unlock_irqrestore(&m->lock, flags);
> >
> > if (init_required)
> > - queue_work(kmpath_handlerd, &m->activate_path);
> > + queue_delayed_work(kmpath_handlerd, &m->activate_path, delay);
> >
> > if (!must_queue)
> > dispatch_queued_ios(m);
> > @@ -1060,6 +1066,7 @@ static void pg_init_done(struct dm_path *path, int
> > errors) struct priority_group *pg = pgpath->pg;
> > struct multipath *m = pg->m;
> > unsigned long flags;
> > + unsigned delay = 0;
> >
> > /* device or driver problems */
> > switch (errors) {
> > @@ -1084,8 +1091,11 @@ static void pg_init_done(struct dm_path *path, int
> > errors) */
> > bypass_pg(m, pg, 1);
> > break;
> > - /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
> > + /*
> > + * For SCSI_DH_RETRY we wait before retrying.
> > + */
> > case SCSI_DH_RETRY:
> > + delay = 1;
> > case SCSI_DH_IMM_RETRY:
> > case SCSI_DH_RES_TEMP_UNAVAIL:
> > if (pg_init_limit_reached(m, pgpath))
> > @@ -1112,6 +1122,7 @@ static void pg_init_done(struct dm_path *path, int
> > errors) }
> >
> > m->pg_init_in_progress = 0;
> > + m->pg_init_delay = delay;
> > queue_work(kmultipathd, &m->process_queued_ios);
> > spin_unlock_irqrestore(&m->lock, flags);
> > }
> > @@ -1120,7 +1131,7 @@ static void activate_path(struct work_struct *work)
> > {
> > int ret;
> > struct multipath *m =
> > - container_of(work, struct multipath, activate_path);
> > + container_of(work, struct multipath, activate_path.work);
> > struct dm_path *path;
> > unsigned long flags;
> >
> > diff --git a/include/scsi/scsi_dh.h b/include/scsi/scsi_dh.h
> > index 33efce2..f099d86 100644
> > --- a/include/scsi/scsi_dh.h
> > +++ b/include/scsi/scsi_dh.h
> > @@ -55,6 +55,10 @@ enum {
> > SCSI_DH_NOSYS,
> > SCSI_DH_DRIVER_MAX,
> > };
> > +
> > +/* Time to wait before retry in case of SCSI_DH_RETRY */
> > +#define SCSI_DH_RETRY_DELAY ((HZ * 2))
> > +
> > #if defined(CONFIG_SCSI_DH) || defined(CONFIG_SCSI_DH_MODULE)
> > extern int scsi_dh_activate(struct request_queue *);
> > extern int scsi_dh_handler_exist(const char *);
> > �
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-02-20 5:03 ` Nikanth Karthikesan
@ 2009-02-20 21:11 ` Chandra Seetharaman
2009-03-02 10:48 ` Nikanth Karthikesan
0 siblings, 1 reply; 18+ messages in thread
From: Chandra Seetharaman @ 2009-02-20 21:11 UTC (permalink / raw)
To: Nikanth Karthikesan; +Cc: device-mapper development, Alasdair G Kergon
On Fri, 2009-02-20 at 10:33 +0530, Nikanth Karthikesan wrote:
> On Friday 20 February 2009 06:15:29 Chandra Seetharaman wrote:
> > On Thu, 2009-02-19 at 12:40 +0530, Nikanth Karthikesan wrote:
> >
> > <snip>
> >
> > > @@ -431,6 +432,7 @@ static void process_queued_ios(struct work_struct
> > > *work) struct pgpath *pgpath = NULL;
> > > unsigned init_required = 0, must_queue = 1;
> > > unsigned long flags;
> > > + unsigned long delay = 0;
> >
> > I do not see the reason for this variable, you can as well put the delay
> > in pg_init_delay and use it directly (and set it to zero after using
> > it) ?
> >
>
> I missed resetting pg_init_delay to zero after using it. I have attached the
> corrected patch with this. This variable keeps the code cleaner(avoids taking
> m->lock). Also having only a boolean in struct multipath keeps it a bit
> smaller.
Ok. I am fine with your justification.
>
> off-topic:
> I think struct multipath can be shrunk even further by making various flags
> like pg_init_required, pg_init_in_progress, queue_io, queue_if_no_path,
> saved_queue_if_no_path in to a single variable. Thoughts?
As Konrad mentioned, it is worth the cost of readability ?
<snip>
> SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
> immediately and SCSI_DH_RETRY in cases where it is better to retry
> after some delay.
>
> Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
> SCSI_DH_RETRY. This patch adds a 2 second delay before retrying to
> activate a device, if it returns SCSI_DH_RETRY.
>
> Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
Acked-by: Chandra Seetharaman <sekharan@us.ibm.com>
>
> ---
>
> diff --git a/drivers/md/dm-mpath.c b/drivers/md/dm-mpath.c
> index 095f77b..7ddf775 100644
> --- a/drivers/md/dm-mpath.c
> +++ b/drivers/md/dm-mpath.c
> @@ -65,12 +65,13 @@ struct multipath {
> spinlock_t lock;
>
> const char *hw_handler_name;
> - struct work_struct activate_path;
> + struct delayed_work activate_path;
> struct pgpath *pgpath_to_activate;
> unsigned nr_priority_groups;
> struct list_head priority_groups;
> unsigned pg_init_required; /* pg_init needs calling? */
> unsigned pg_init_in_progress; /* Only one pg_init allowed at once */
> + unsigned pg_init_delay; /* delay required before retry? */
>
> unsigned nr_valid_paths; /* Total number of usable paths */
> struct pgpath *current_pgpath;
> @@ -203,7 +204,7 @@ static struct multipath *alloc_multipath(struct dm_target *ti)
> m->queue_io = 1;
> INIT_WORK(&m->process_queued_ios, process_queued_ios);
> INIT_WORK(&m->trigger_event, trigger_event);
> - INIT_WORK(&m->activate_path, activate_path);
> + INIT_DELAYED_WORK(&m->activate_path, activate_path);
> m->mpio_pool = mempool_create_slab_pool(MIN_IOS, _mpio_cache);
> if (!m->mpio_pool) {
> kfree(m);
> @@ -431,6 +432,7 @@ static void process_queued_ios(struct work_struct *work)
> struct pgpath *pgpath = NULL;
> unsigned init_required = 0, must_queue = 1;
> unsigned long flags;
> + unsigned long delay = 0;
>
> spin_lock_irqsave(&m->lock, flags);
>
> @@ -452,13 +454,17 @@ static void process_queued_ios(struct work_struct *work)
> m->pg_init_required = 0;
> m->pg_init_in_progress = 1;
> init_required = 1;
> + if (m->pg_init_delay) {
> + delay = SCSI_DH_RETRY_DELAY;
> + m->pg_init_delay = 0;
> + }
> }
>
> out:
> spin_unlock_irqrestore(&m->lock, flags);
>
> if (init_required)
> - queue_work(kmpath_handlerd, &m->activate_path);
> + queue_delayed_work(kmpath_handlerd, &m->activate_path, delay);
>
> if (!must_queue)
> dispatch_queued_ios(m);
> @@ -1060,6 +1066,7 @@ static void pg_init_done(struct dm_path *path, int errors)
> struct priority_group *pg = pgpath->pg;
> struct multipath *m = pg->m;
> unsigned long flags;
> + unsigned delay = 0;
>
> /* device or driver problems */
> switch (errors) {
> @@ -1084,8 +1091,11 @@ static void pg_init_done(struct dm_path *path, int errors)
> */
> bypass_pg(m, pg, 1);
> break;
> - /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
> + /*
> + * For SCSI_DH_RETRY we wait before retrying.
> + */
> case SCSI_DH_RETRY:
> + delay = 1;
> case SCSI_DH_IMM_RETRY:
> case SCSI_DH_RES_TEMP_UNAVAIL:
> if (pg_init_limit_reached(m, pgpath))
> @@ -1112,6 +1122,7 @@ static void pg_init_done(struct dm_path *path, int errors)
> }
>
> m->pg_init_in_progress = 0;
> + m->pg_init_delay = delay;
> queue_work(kmultipathd, &m->process_queued_ios);
> spin_unlock_irqrestore(&m->lock, flags);
> }
> @@ -1120,7 +1131,7 @@ static void activate_path(struct work_struct *work)
> {
> int ret;
> struct multipath *m =
> - container_of(work, struct multipath, activate_path);
> + container_of(work, struct multipath, activate_path.work);
> struct dm_path *path;
> unsigned long flags;
>
> diff --git a/include/scsi/scsi_dh.h b/include/scsi/scsi_dh.h
> index 33efce2..f099d86 100644
> --- a/include/scsi/scsi_dh.h
> +++ b/include/scsi/scsi_dh.h
> @@ -55,6 +55,10 @@ enum {
> SCSI_DH_NOSYS,
> SCSI_DH_DRIVER_MAX,
> };
> +
> +/* Time to wait before retry in case of SCSI_DH_RETRY */
> +#define SCSI_DH_RETRY_DELAY ((HZ * 2))
> +
> #if defined(CONFIG_SCSI_DH) || defined(CONFIG_SCSI_DH_MODULE)
> extern int scsi_dh_activate(struct request_queue *);
> extern int scsi_dh_handler_exist(const char *);
> �
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-02-20 0:45 ` Chandra Seetharaman
@ 2009-02-20 5:03 ` Nikanth Karthikesan
2009-02-20 21:11 ` Chandra Seetharaman
0 siblings, 1 reply; 18+ messages in thread
From: Nikanth Karthikesan @ 2009-02-20 5:03 UTC (permalink / raw)
To: Alasdair G Kergon; +Cc: device-mapper development, sekharan
On Friday 20 February 2009 06:15:29 Chandra Seetharaman wrote:
> On Thu, 2009-02-19 at 12:40 +0530, Nikanth Karthikesan wrote:
>
> <snip>
>
> > @@ -431,6 +432,7 @@ static void process_queued_ios(struct work_struct
> > *work) struct pgpath *pgpath = NULL;
> > unsigned init_required = 0, must_queue = 1;
> > unsigned long flags;
> > + unsigned long delay = 0;
>
> I do not see the reason for this variable, you can as well put the delay
> in pg_init_delay and use it directly (and set it to zero after using
> it) ?
>
I missed resetting pg_init_delay to zero after using it. I have attached the
corrected patch with this. This variable keeps the code cleaner(avoids taking
m->lock). Also having only a boolean in struct multipath keeps it a bit
smaller.
off-topic:
I think struct multipath can be shrunk even further by making various flags
like pg_init_required, pg_init_in_progress, queue_io, queue_if_no_path,
saved_queue_if_no_path in to a single variable. Thoughts?
<snip>
> > @@ -1060,6 +1064,7 @@ static void pg_init_done(struct dm_path *path, int
> > errors) struct priority_group *pg = pgpath->pg;
> > struct multipath *m = pg->m;
> > unsigned long flags;
> > + unsigned delay = 0;
>
> You can get rid of this variable also and set it directly under
> SCSI_DH_RETRY.
>
pg_init_delay is protected by the m->lock. And this variable helps in keeping
the code cleaner.
<snip>
I am attaching the fixed patch(resetting pg_init_delay to zero after using
it).
Thanks
Nikanth
SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
immediately and SCSI_DH_RETRY in cases where it is better to retry
after some delay.
Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
SCSI_DH_RETRY. This patch adds a 2 second delay before retrying to
activate a device, if it returns SCSI_DH_RETRY.
Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
---
diff --git a/drivers/md/dm-mpath.c b/drivers/md/dm-mpath.c
index 095f77b..7ddf775 100644
--- a/drivers/md/dm-mpath.c
+++ b/drivers/md/dm-mpath.c
@@ -65,12 +65,13 @@ struct multipath {
spinlock_t lock;
const char *hw_handler_name;
- struct work_struct activate_path;
+ struct delayed_work activate_path;
struct pgpath *pgpath_to_activate;
unsigned nr_priority_groups;
struct list_head priority_groups;
unsigned pg_init_required; /* pg_init needs calling? */
unsigned pg_init_in_progress; /* Only one pg_init allowed at once */
+ unsigned pg_init_delay; /* delay required before retry? */
unsigned nr_valid_paths; /* Total number of usable paths */
struct pgpath *current_pgpath;
@@ -203,7 +204,7 @@ static struct multipath *alloc_multipath(struct dm_target *ti)
m->queue_io = 1;
INIT_WORK(&m->process_queued_ios, process_queued_ios);
INIT_WORK(&m->trigger_event, trigger_event);
- INIT_WORK(&m->activate_path, activate_path);
+ INIT_DELAYED_WORK(&m->activate_path, activate_path);
m->mpio_pool = mempool_create_slab_pool(MIN_IOS, _mpio_cache);
if (!m->mpio_pool) {
kfree(m);
@@ -431,6 +432,7 @@ static void process_queued_ios(struct work_struct *work)
struct pgpath *pgpath = NULL;
unsigned init_required = 0, must_queue = 1;
unsigned long flags;
+ unsigned long delay = 0;
spin_lock_irqsave(&m->lock, flags);
@@ -452,13 +454,17 @@ static void process_queued_ios(struct work_struct *work)
m->pg_init_required = 0;
m->pg_init_in_progress = 1;
init_required = 1;
+ if (m->pg_init_delay) {
+ delay = SCSI_DH_RETRY_DELAY;
+ m->pg_init_delay = 0;
+ }
}
out:
spin_unlock_irqrestore(&m->lock, flags);
if (init_required)
- queue_work(kmpath_handlerd, &m->activate_path);
+ queue_delayed_work(kmpath_handlerd, &m->activate_path, delay);
if (!must_queue)
dispatch_queued_ios(m);
@@ -1060,6 +1066,7 @@ static void pg_init_done(struct dm_path *path, int errors)
struct priority_group *pg = pgpath->pg;
struct multipath *m = pg->m;
unsigned long flags;
+ unsigned delay = 0;
/* device or driver problems */
switch (errors) {
@@ -1084,8 +1091,11 @@ static void pg_init_done(struct dm_path *path, int errors)
*/
bypass_pg(m, pg, 1);
break;
- /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
+ /*
+ * For SCSI_DH_RETRY we wait before retrying.
+ */
case SCSI_DH_RETRY:
+ delay = 1;
case SCSI_DH_IMM_RETRY:
case SCSI_DH_RES_TEMP_UNAVAIL:
if (pg_init_limit_reached(m, pgpath))
@@ -1112,6 +1122,7 @@ static void pg_init_done(struct dm_path *path, int errors)
}
m->pg_init_in_progress = 0;
+ m->pg_init_delay = delay;
queue_work(kmultipathd, &m->process_queued_ios);
spin_unlock_irqrestore(&m->lock, flags);
}
@@ -1120,7 +1131,7 @@ static void activate_path(struct work_struct *work)
{
int ret;
struct multipath *m =
- container_of(work, struct multipath, activate_path);
+ container_of(work, struct multipath, activate_path.work);
struct dm_path *path;
unsigned long flags;
diff --git a/include/scsi/scsi_dh.h b/include/scsi/scsi_dh.h
index 33efce2..f099d86 100644
--- a/include/scsi/scsi_dh.h
+++ b/include/scsi/scsi_dh.h
@@ -55,6 +55,10 @@ enum {
SCSI_DH_NOSYS,
SCSI_DH_DRIVER_MAX,
};
+
+/* Time to wait before retry in case of SCSI_DH_RETRY */
+#define SCSI_DH_RETRY_DELAY ((HZ * 2))
+
#if defined(CONFIG_SCSI_DH) || defined(CONFIG_SCSI_DH_MODULE)
extern int scsi_dh_activate(struct request_queue *);
extern int scsi_dh_handler_exist(const char *);
\0
^ permalink raw reply related [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-02-19 7:10 ` Nikanth Karthikesan
@ 2009-02-20 0:45 ` Chandra Seetharaman
2009-02-20 5:03 ` Nikanth Karthikesan
0 siblings, 1 reply; 18+ messages in thread
From: Chandra Seetharaman @ 2009-02-20 0:45 UTC (permalink / raw)
To: Nikanth Karthikesan; +Cc: device-mapper development, Alasdair G Kergon
On Thu, 2009-02-19 at 12:40 +0530, Nikanth Karthikesan wrote:
<snip>
> @@ -431,6 +432,7 @@ static void process_queued_ios(struct work_struct *work)
> struct pgpath *pgpath = NULL;
> unsigned init_required = 0, must_queue = 1;
> unsigned long flags;
> + unsigned long delay = 0;
I do not see the reason for this variable, you can as well put the delay
in pg_init_delay and use it directly (and set it to zero after using
it) ?
>
> spin_lock_irqsave(&m->lock, flags);
>
> @@ -452,13 +454,15 @@ static void process_queued_ios(struct work_struct *work)
> m->pg_init_required = 0;
> m->pg_init_in_progress = 1;
> init_required = 1;
> + if (m->pg_init_delay)
> + delay = SCSI_DH_RETRY_DELAY;
> }
>
> out:
> spin_unlock_irqrestore(&m->lock, flags);
>
> if (init_required)
> - queue_work(kmpath_handlerd, &m->activate_path);
> + queue_delayed_work(kmpath_handlerd, &m->activate_path, delay);
>
> if (!must_queue)
> dispatch_queued_ios(m);
> @@ -1060,6 +1064,7 @@ static void pg_init_done(struct dm_path *path, int errors)
> struct priority_group *pg = pgpath->pg;
> struct multipath *m = pg->m;
> unsigned long flags;
> + unsigned delay = 0;
You can get rid of this variable also and set it directly under
SCSI_DH_RETRY.
>
> /* device or driver problems */
> switch (errors) {
> @@ -1084,8 +1089,11 @@ static void pg_init_done(struct dm_path *path, int errors)
> */
> bypass_pg(m, pg, 1);
> break;
> - /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
> + /*
> + * For SCSI_DH_RETRY we wait before retrying.
> + */
> case SCSI_DH_RETRY:
> + delay = 1;
> case SCSI_DH_IMM_RETRY:
> case SCSI_DH_RES_TEMP_UNAVAIL:
> if (pg_init_limit_reached(m, pgpath))
> @@ -1112,6 +1120,7 @@ static void pg_init_done(struct dm_path *path, int errors)
> }
>
> m->pg_init_in_progress = 0;
> + m->pg_init_delay = delay;
> queue_work(kmultipathd, &m->process_queued_ios);
> spin_unlock_irqrestore(&m->lock, flags);
> }
> @@ -1120,7 +1129,7 @@ static void activate_path(struct work_struct *work)
> {
> int ret;
> struct multipath *m =
> - container_of(work, struct multipath, activate_path);
> + container_of(work, struct multipath, activate_path.work);
> struct dm_path *path;
> unsigned long flags;
>
> diff --git a/include/scsi/scsi_dh.h b/include/scsi/scsi_dh.h
> index 33efce2..f099d86 100644
> --- a/include/scsi/scsi_dh.h
> +++ b/include/scsi/scsi_dh.h
> @@ -55,6 +55,10 @@ enum {
> SCSI_DH_NOSYS,
> SCSI_DH_DRIVER_MAX,
> };
> +
> +/* Time to wait before retry in case of SCSI_DH_RETRY */
> +#define SCSI_DH_RETRY_DELAY ((HZ * 2))
> +
> #if defined(CONFIG_SCSI_DH) || defined(CONFIG_SCSI_DH_MODULE)
> extern int scsi_dh_activate(struct request_queue *);
> extern int scsi_dh_handler_exist(const char *);
>
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-02-19 2:11 ` Alasdair G Kergon
@ 2009-02-19 7:10 ` Nikanth Karthikesan
2009-02-20 0:45 ` Chandra Seetharaman
0 siblings, 1 reply; 18+ messages in thread
From: Nikanth Karthikesan @ 2009-02-19 7:10 UTC (permalink / raw)
To: Alasdair G Kergon; +Cc: device-mapper development
On Thursday 19 February 2009 07:41:18 Alasdair G Kergon wrote:
> On Tue, Feb 17, 2009 at 07:17:37PM +0530, Nikanth Karthikesan wrote:
> > Delay retry to activate_path if it returns SCSI_DH_RETRY.
>
> Please write a complete patch header if you'd like this queued for
> upstream!
>
> E.g. Why? Any cases where this will make matters worse or make no
> difference?
>
Sorry for the terse changelog.
> > + unsigned long pg_init_jiffy; /* To delay retry if SCSI_DH_RETRY */
> > +#define SCSI_DH_RETRY_DELAY ((HZ * 2))
>
> Why that particular value?
There is no specific reason. Just picked 2 seconds based on the TODO comment,
"For SCSI_DH_RETRY we should wait a couple seconds".
> Please move it into a header file with an explanation of what it does.
>
done.
Attached is the patch with comments from you and Chandra incorporated.
Thanks
Nikanth
SCSI Device Handlers return SCSI_DH_IMM_RETRY if we could retry
immediately and SCSI_DH_RETRY in cases where it is better to retry
after some delay.
Currently we retry immediately irrespective of SCSI_DH_IMM_RETRY and
SCSI_DH_RETRY. This patch adds a 2 second delay before retrying to
activate a device, if it returns SCSI_DH_RETRY.
Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
---
diff --git a/drivers/md/dm-mpath.c b/drivers/md/dm-mpath.c
index 095f77b..6fd76f1 100644
--- a/drivers/md/dm-mpath.c
+++ b/drivers/md/dm-mpath.c
@@ -65,12 +65,13 @@ struct multipath {
spinlock_t lock;
const char *hw_handler_name;
- struct work_struct activate_path;
+ struct delayed_work activate_path;
struct pgpath *pgpath_to_activate;
unsigned nr_priority_groups;
struct list_head priority_groups;
unsigned pg_init_required; /* pg_init needs calling? */
unsigned pg_init_in_progress; /* Only one pg_init allowed at once */
+ unsigned pg_init_delay; /* delay required before retry? */
unsigned nr_valid_paths; /* Total number of usable paths */
struct pgpath *current_pgpath;
@@ -203,7 +204,7 @@ static struct multipath *alloc_multipath(struct dm_target *ti)
m->queue_io = 1;
INIT_WORK(&m->process_queued_ios, process_queued_ios);
INIT_WORK(&m->trigger_event, trigger_event);
- INIT_WORK(&m->activate_path, activate_path);
+ INIT_DELAYED_WORK(&m->activate_path, activate_path);
m->mpio_pool = mempool_create_slab_pool(MIN_IOS, _mpio_cache);
if (!m->mpio_pool) {
kfree(m);
@@ -431,6 +432,7 @@ static void process_queued_ios(struct work_struct *work)
struct pgpath *pgpath = NULL;
unsigned init_required = 0, must_queue = 1;
unsigned long flags;
+ unsigned long delay = 0;
spin_lock_irqsave(&m->lock, flags);
@@ -452,13 +454,15 @@ static void process_queued_ios(struct work_struct *work)
m->pg_init_required = 0;
m->pg_init_in_progress = 1;
init_required = 1;
+ if (m->pg_init_delay)
+ delay = SCSI_DH_RETRY_DELAY;
}
out:
spin_unlock_irqrestore(&m->lock, flags);
if (init_required)
- queue_work(kmpath_handlerd, &m->activate_path);
+ queue_delayed_work(kmpath_handlerd, &m->activate_path, delay);
if (!must_queue)
dispatch_queued_ios(m);
@@ -1060,6 +1064,7 @@ static void pg_init_done(struct dm_path *path, int errors)
struct priority_group *pg = pgpath->pg;
struct multipath *m = pg->m;
unsigned long flags;
+ unsigned delay = 0;
/* device or driver problems */
switch (errors) {
@@ -1084,8 +1089,11 @@ static void pg_init_done(struct dm_path *path, int errors)
*/
bypass_pg(m, pg, 1);
break;
- /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
+ /*
+ * For SCSI_DH_RETRY we wait before retrying.
+ */
case SCSI_DH_RETRY:
+ delay = 1;
case SCSI_DH_IMM_RETRY:
case SCSI_DH_RES_TEMP_UNAVAIL:
if (pg_init_limit_reached(m, pgpath))
@@ -1112,6 +1120,7 @@ static void pg_init_done(struct dm_path *path, int errors)
}
m->pg_init_in_progress = 0;
+ m->pg_init_delay = delay;
queue_work(kmultipathd, &m->process_queued_ios);
spin_unlock_irqrestore(&m->lock, flags);
}
@@ -1120,7 +1129,7 @@ static void activate_path(struct work_struct *work)
{
int ret;
struct multipath *m =
- container_of(work, struct multipath, activate_path);
+ container_of(work, struct multipath, activate_path.work);
struct dm_path *path;
unsigned long flags;
diff --git a/include/scsi/scsi_dh.h b/include/scsi/scsi_dh.h
index 33efce2..f099d86 100644
--- a/include/scsi/scsi_dh.h
+++ b/include/scsi/scsi_dh.h
@@ -55,6 +55,10 @@ enum {
SCSI_DH_NOSYS,
SCSI_DH_DRIVER_MAX,
};
+
+/* Time to wait before retry in case of SCSI_DH_RETRY */
+#define SCSI_DH_RETRY_DELAY ((HZ * 2))
+
#if defined(CONFIG_SCSI_DH) || defined(CONFIG_SCSI_DH_MODULE)
extern int scsi_dh_activate(struct request_queue *);
extern int scsi_dh_handler_exist(const char *);
^ permalink raw reply related [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-02-17 13:47 Nikanth Karthikesan
2009-02-19 1:55 ` Chandra Seetharaman
@ 2009-02-19 2:11 ` Alasdair G Kergon
2009-02-19 7:10 ` Nikanth Karthikesan
1 sibling, 1 reply; 18+ messages in thread
From: Alasdair G Kergon @ 2009-02-19 2:11 UTC (permalink / raw)
To: Nikanth Karthikesan; +Cc: device-mapper development
On Tue, Feb 17, 2009 at 07:17:37PM +0530, Nikanth Karthikesan wrote:
> Delay retry to activate_path if it returns SCSI_DH_RETRY.
Please write a complete patch header if you'd like this queued for upstream!
E.g. Why? Any cases where this will make matters worse or make no difference?
> + unsigned long pg_init_jiffy; /* To delay retry if SCSI_DH_RETRY */
> +#define SCSI_DH_RETRY_DELAY ((HZ * 2))
Why that particular value?
Please move it into a header file with an explanation of what it does.
Alasdair
--
agk@redhat.com
^ permalink raw reply [flat|nested] 18+ messages in thread
* Re: [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
2009-02-17 13:47 Nikanth Karthikesan
@ 2009-02-19 1:55 ` Chandra Seetharaman
2009-02-19 2:11 ` Alasdair G Kergon
1 sibling, 0 replies; 18+ messages in thread
From: Chandra Seetharaman @ 2009-02-19 1:55 UTC (permalink / raw)
To: device-mapper development; +Cc: Alasdair G Kergon
Hi Nikanth,
Thanks for the patch.
Please see my comment below.
chandra
On Tue, 2009-02-17 at 19:17 +0530, Nikanth Karthikesan wrote:
> Delay retry to activate_path if it returns SCSI_DH_RETRY.
>
> Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
>
> ---
>
> diff --git a/drivers/md/dm-mpath.c b/drivers/md/dm-mpath.c
> index 095f77b..af54632 100644
> --- a/drivers/md/dm-mpath.c
> +++ b/drivers/md/dm-mpath.c
> @@ -65,12 +65,14 @@ struct multipath {
> spinlock_t lock;
>
> const char *hw_handler_name;
> - struct work_struct activate_path;
> + struct delayed_work activate_path;
> struct pgpath *pgpath_to_activate;
> unsigned nr_priority_groups;
> struct list_head priority_groups;
> unsigned pg_init_required; /* pg_init needs calling? */
> unsigned pg_init_in_progress; /* Only one pg_init allowed at once */
> + unsigned long pg_init_jiffy; /* To delay retry if SCSI_DH_RETRY */
> +#define SCSI_DH_RETRY_DELAY ((HZ * 2))
>
> unsigned nr_valid_paths; /* Total number of usable paths */
> struct pgpath *current_pgpath;
> @@ -203,7 +205,7 @@ static struct multipath *alloc_multipath(struct dm_target *ti)
> m->queue_io = 1;
> INIT_WORK(&m->process_queued_ios, process_queued_ios);
> INIT_WORK(&m->trigger_event, trigger_event);
> - INIT_WORK(&m->activate_path, activate_path);
> + INIT_DELAYED_WORK(&m->activate_path, activate_path);
> m->mpio_pool = mempool_create_slab_pool(MIN_IOS, _mpio_cache);
> if (!m->mpio_pool) {
> kfree(m);
> @@ -431,6 +433,8 @@ static void process_queued_ios(struct work_struct *work)
> struct pgpath *pgpath = NULL;
> unsigned init_required = 0, must_queue = 1;
> unsigned long flags;
> + unsigned long delay = 0;
> + unsigned long now;
>
> spin_lock_irqsave(&m->lock, flags);
>
> @@ -452,13 +456,20 @@ static void process_queued_ios(struct work_struct *work)
> m->pg_init_required = 0;
> m->pg_init_in_progress = 1;
> init_required = 1;
> + /* Delay retry due to SCSI_DH_RETRY */
> + if (m->pg_init_jiffy) {
> + now = jiffies;
> + if (time_after(now, m->pg_init_jiffy))
> + delay = now - m->pg_init_jiffy;
I think the logic is reversed. Acc to linux/jiffies.h, "time_after(a,b)
returns true if time a is after time b",
We want it other way around, don't we ?
IMO, we need _not_ be so critical of the time. We could just set a flag
in pg_init_done and use 2 seconds in queue_delayed_work().
> + m->pg_init_jiffy = 0;
> + }
> }
>
> out:
> spin_unlock_irqrestore(&m->lock, flags);
>
> if (init_required)
> - queue_work(kmpath_handlerd, &m->activate_path);
> + queue_delayed_work(kmpath_handlerd, &m->activate_path, delay);
>
> if (!must_queue)
> dispatch_queued_ios(m);
> @@ -1060,6 +1071,7 @@ static void pg_init_done(struct dm_path *path, int errors)
> struct priority_group *pg = pgpath->pg;
> struct multipath *m = pg->m;
> unsigned long flags;
> + bool delay = false;
>
> /* device or driver problems */
> switch (errors) {
> @@ -1084,8 +1096,11 @@ static void pg_init_done(struct dm_path *path, int errors)
> */
> bypass_pg(m, pg, 1);
> break;
> - /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
> + /*
> + * For SCSI_DH_RETRY we wait for a couple seconds.
> + */
> case SCSI_DH_RETRY:
> + delay = true;
> case SCSI_DH_IMM_RETRY:
> case SCSI_DH_RES_TEMP_UNAVAIL:
> if (pg_init_limit_reached(m, pgpath))
> @@ -1112,6 +1127,10 @@ static void pg_init_done(struct dm_path *path, int errors)
> }
>
> m->pg_init_in_progress = 0;
> + if (delay)
> + m->pg_init_jiffy = jiffies + SCSI_DH_RETRY_DELAY;
> + else
> + m->pg_init_jiffy = 0;
> queue_work(kmultipathd, &m->process_queued_ios);
> spin_unlock_irqrestore(&m->lock, flags);
> }
> @@ -1120,7 +1139,7 @@ static void activate_path(struct work_struct *work)
> {
> int ret;
> struct multipath *m =
> - container_of(work, struct multipath, activate_path);
> + container_of(work, struct multipath, activate_path.work);
> struct dm_path *path;
> unsigned long flags;
>
>
> --
> dm-devel mailing list
> dm-devel@redhat.com
> https://www.redhat.com/mailman/listinfo/dm-devel
^ permalink raw reply [flat|nested] 18+ messages in thread
* [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY
@ 2009-02-17 13:47 Nikanth Karthikesan
2009-02-19 1:55 ` Chandra Seetharaman
2009-02-19 2:11 ` Alasdair G Kergon
0 siblings, 2 replies; 18+ messages in thread
From: Nikanth Karthikesan @ 2009-02-17 13:47 UTC (permalink / raw)
To: Alasdair G Kergon; +Cc: device-mapper development
Delay retry to activate_path if it returns SCSI_DH_RETRY.
Signed-off-by: Nikanth Karthikesan <knikanth@suse.de>
---
diff --git a/drivers/md/dm-mpath.c b/drivers/md/dm-mpath.c
index 095f77b..af54632 100644
--- a/drivers/md/dm-mpath.c
+++ b/drivers/md/dm-mpath.c
@@ -65,12 +65,14 @@ struct multipath {
spinlock_t lock;
const char *hw_handler_name;
- struct work_struct activate_path;
+ struct delayed_work activate_path;
struct pgpath *pgpath_to_activate;
unsigned nr_priority_groups;
struct list_head priority_groups;
unsigned pg_init_required; /* pg_init needs calling? */
unsigned pg_init_in_progress; /* Only one pg_init allowed at once */
+ unsigned long pg_init_jiffy; /* To delay retry if SCSI_DH_RETRY */
+#define SCSI_DH_RETRY_DELAY ((HZ * 2))
unsigned nr_valid_paths; /* Total number of usable paths */
struct pgpath *current_pgpath;
@@ -203,7 +205,7 @@ static struct multipath *alloc_multipath(struct dm_target *ti)
m->queue_io = 1;
INIT_WORK(&m->process_queued_ios, process_queued_ios);
INIT_WORK(&m->trigger_event, trigger_event);
- INIT_WORK(&m->activate_path, activate_path);
+ INIT_DELAYED_WORK(&m->activate_path, activate_path);
m->mpio_pool = mempool_create_slab_pool(MIN_IOS, _mpio_cache);
if (!m->mpio_pool) {
kfree(m);
@@ -431,6 +433,8 @@ static void process_queued_ios(struct work_struct *work)
struct pgpath *pgpath = NULL;
unsigned init_required = 0, must_queue = 1;
unsigned long flags;
+ unsigned long delay = 0;
+ unsigned long now;
spin_lock_irqsave(&m->lock, flags);
@@ -452,13 +456,20 @@ static void process_queued_ios(struct work_struct *work)
m->pg_init_required = 0;
m->pg_init_in_progress = 1;
init_required = 1;
+ /* Delay retry due to SCSI_DH_RETRY */
+ if (m->pg_init_jiffy) {
+ now = jiffies;
+ if (time_after(now, m->pg_init_jiffy))
+ delay = now - m->pg_init_jiffy;
+ m->pg_init_jiffy = 0;
+ }
}
out:
spin_unlock_irqrestore(&m->lock, flags);
if (init_required)
- queue_work(kmpath_handlerd, &m->activate_path);
+ queue_delayed_work(kmpath_handlerd, &m->activate_path, delay);
if (!must_queue)
dispatch_queued_ios(m);
@@ -1060,6 +1071,7 @@ static void pg_init_done(struct dm_path *path, int errors)
struct priority_group *pg = pgpath->pg;
struct multipath *m = pg->m;
unsigned long flags;
+ bool delay = false;
/* device or driver problems */
switch (errors) {
@@ -1084,8 +1096,11 @@ static void pg_init_done(struct dm_path *path, int errors)
*/
bypass_pg(m, pg, 1);
break;
- /* TODO: For SCSI_DH_RETRY we should wait a couple seconds */
+ /*
+ * For SCSI_DH_RETRY we wait for a couple seconds.
+ */
case SCSI_DH_RETRY:
+ delay = true;
case SCSI_DH_IMM_RETRY:
case SCSI_DH_RES_TEMP_UNAVAIL:
if (pg_init_limit_reached(m, pgpath))
@@ -1112,6 +1127,10 @@ static void pg_init_done(struct dm_path *path, int errors)
}
m->pg_init_in_progress = 0;
+ if (delay)
+ m->pg_init_jiffy = jiffies + SCSI_DH_RETRY_DELAY;
+ else
+ m->pg_init_jiffy = 0;
queue_work(kmultipathd, &m->process_queued_ios);
spin_unlock_irqrestore(&m->lock, flags);
}
@@ -1120,7 +1139,7 @@ static void activate_path(struct work_struct *work)
{
int ret;
struct multipath *m =
- container_of(work, struct multipath, activate_path);
+ container_of(work, struct multipath, activate_path.work);
struct dm_path *path;
unsigned long flags;
^ permalink raw reply related [flat|nested] 18+ messages in thread
end of thread, other threads:[~2010-11-02 21:02 UTC | newest]
Thread overview: 18+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2009-05-05 3:18 [PATCH] dm mpath: delay retry activate_path on SCSI_DH_RETRY Chandra Seetharaman
2009-05-15 3:10 ` Chandra Seetharaman
2009-05-15 13:38 ` Mike Christie
2009-06-09 20:54 ` Chandra Seetharaman
2010-11-02 19:32 ` Mike Snitzer
2010-11-02 19:56 ` Chandra Seetharaman
2010-11-02 21:02 ` Mike Christie
-- strict thread matches above, loose matches on Subject: below --
2009-04-28 6:15 [PATCH] " Nikanth Karthikesan
2009-04-28 19:35 ` Chandra Seetharaman
2009-04-28 22:34 ` Alasdair G Kergon
2009-02-17 13:47 Nikanth Karthikesan
2009-02-19 1:55 ` Chandra Seetharaman
2009-02-19 2:11 ` Alasdair G Kergon
2009-02-19 7:10 ` Nikanth Karthikesan
2009-02-20 0:45 ` Chandra Seetharaman
2009-02-20 5:03 ` Nikanth Karthikesan
2009-02-20 21:11 ` Chandra Seetharaman
2009-03-02 10:48 ` Nikanth Karthikesan
This is an external index of several public inboxes,
see mirroring instructions on how to clone and mirror
all data and code used by this external index.