make prioritizers use checker_timeout, if set
authorBenjamin Marzinski <bmarzins@redhat.com>
Mon, 30 Jun 2014 05:14:02 +0000 (00:14 -0500)
committerChristophe Varoqui <christophe.varoqui@opensvc.com>
Thu, 24 Jul 2014 08:49:06 +0000 (10:49 +0200)
The multipath prioritizers can get stuck issuing scsi commands that
don't return quickly, just like the checkers. So if checker_timeout
is set, the prioritizers should should it for their cmd timeouts as
well.

Signed-off-by: Benjamin Marzinski <bmarzins@redhat.com>
libmultipath/prio.c
libmultipath/prio.h
libmultipath/prioritizers/alua_rtpg.c
libmultipath/prioritizers/emc.c
libmultipath/prioritizers/hds.c
libmultipath/prioritizers/hp_sw.c
libmultipath/prioritizers/ontap.c
libmultipath/prioritizers/rdac.c
multipath.conf.annotated
multipath/multipath.conf.5

index 05a8cf1..6ee0b9c 100644 (file)
 
 static LIST_HEAD(prioritizers);
 
+unsigned int get_prio_timeout(unsigned int default_timeout)
+{
+       if (conf->checker_timeout)
+               return conf->checker_timeout * 1000;
+       return default_timeout;
+}
+
 int init_prio (void)
 {
        if (!add_prio(DEFAULT_PRIO))
index 4eeb216..495688f 100644 (file)
@@ -51,6 +51,7 @@ struct prio {
        int (*getprio)(struct path *, char *);
 };
 
+unsigned int get_prio_timeout(unsigned int default_timeout);
 int init_prio (void);
 void cleanup_prio (void);
 struct prio * add_prio (char *);
index 981ba06..6d04fc1 100644 (file)
@@ -21,6 +21,7 @@
 #define __user
 #include <scsi/sg.h>
 
+#include "../prio.h"
 #include "alua_rtpg.h"
 
 #define SENSE_BUFF_LEN  32
@@ -134,7 +135,7 @@ do_inquiry(int fd, int evpd, unsigned int codepage, void *resp, int resplen)
        hdr.dxfer_len           = resplen;
        hdr.sbp                 = sense;
        hdr.mx_sb_len           = sizeof(sense);
-       hdr.timeout             = DEF_TIMEOUT;
+       hdr.timeout             = get_prio_timeout(DEF_TIMEOUT);
 
        if (ioctl(fd, SG_IO, &hdr) < 0) {
                PRINT_DEBUG("do_inquiry: IOCTL failed!\n");
@@ -253,7 +254,7 @@ do_rtpg(int fd, void* resp, long resplen)
        hdr.dxfer_len           = resplen;
        hdr.mx_sb_len           = sizeof(sense);
        hdr.sbp                 = sense;
-       hdr.timeout             = DEF_TIMEOUT;
+       hdr.timeout             = get_prio_timeout(DEF_TIMEOUT);
 
        if (ioctl(fd, SG_IO, &hdr) < 0)
                return -RTPG_RTPG_FAILED;
index 91b3d90..e49809c 100644 (file)
@@ -31,7 +31,7 @@ int emc_clariion_prio(const char *dev, int fd)
        io_hdr.dxferp = sense_buffer;
        io_hdr.cmdp = inqCmdBlk;
        io_hdr.sbp = sb;
-       io_hdr.timeout = 60000;
+       io_hdr.timeout = get_prio_timeout(60000);
        io_hdr.pack_id = 0;
        if (ioctl(fd, SG_IO, &io_hdr) < 0) {
                pp_emc_log(0, "sending query command failed");
index f748707..8043b5b 100644 (file)
@@ -114,7 +114,7 @@ int hds_modular_prio (const char *dev, int fd)
        io_hdr.dxferp = inqBuff;
        io_hdr.cmdp = inqCmdBlk;
        io_hdr.sbp = sense_buffer;
-       io_hdr.timeout = 2000;  /* TimeOut = 2 seconds */
+       io_hdr.timeout = get_prio_timeout(2000); /* TimeOut = 2 seconds */
 
        if (ioctl (fd, SG_IO, &io_hdr) < 0) {
                pp_hds_log(0, "SG_IO error");
index c24baad..4950cf7 100644 (file)
@@ -46,7 +46,7 @@ int hp_sw_prio(const char *dev, int fd)
        io_hdr.dxfer_direction = SG_DXFER_NONE;
        io_hdr.cmdp = turCmdBlk;
        io_hdr.sbp = sb;
-       io_hdr.timeout = 60000;
+       io_hdr.timeout = get_prio_timeout(60000);
        io_hdr.pack_id = 0;
  retry:
        if (ioctl(fd, SG_IO, &io_hdr) < 0) {
index 026d45d..5e82a17 100644 (file)
@@ -89,7 +89,7 @@ static int send_gva(const char *dev, int fd, unsigned char pg,
        io_hdr.dxferp = results;
        io_hdr.cmdp = cdb;
        io_hdr.sbp = sb;
-       io_hdr.timeout = SG_TIMEOUT;
+       io_hdr.timeout = get_prio_timeout(SG_TIMEOUT);
        io_hdr.pack_id = 0;
        if (ioctl(fd, SG_IO, &io_hdr) < 0) {
                pp_ontap_log(0, "SG_IO ioctl failed, errno=%d", errno);
@@ -141,7 +141,7 @@ static int get_proxy(const char *dev, int fd)
        io_hdr.dxferp = results;
        io_hdr.cmdp = cdb;
        io_hdr.sbp = sb;
-       io_hdr.timeout = SG_TIMEOUT;
+       io_hdr.timeout = get_prio_timeout(SG_TIMEOUT);
        io_hdr.pack_id = 0;
        if (ioctl(fd, SG_IO, &io_hdr) < 0) {
                pp_ontap_log(0, "ioctl sending inquiry command failed, "
index 2bf1443..a210055 100644 (file)
@@ -31,7 +31,7 @@ int rdac_prio(const char *dev, int fd)
        io_hdr.dxferp = sense_buffer;
        io_hdr.cmdp = inqCmdBlk;
        io_hdr.sbp = sb;
-       io_hdr.timeout = 60000;
+       io_hdr.timeout = get_prio_timeout(60000);
        io_hdr.pack_id = 0;
        if (ioctl(fd, SG_IO, &io_hdr) < 0) {
                pp_rdac_log(0, "sending inquiry command failed");
index 235e130..f158746 100644 (file)
 #      #
 #      # name    : checker_timeout
 #      # scope   : multipath & multipathd
-#      # desc    : The timeout to use for path checkers that issue scsi
-#      #           commands with an explicit timeout, in seconds.
+#      # desc    : The timeout to use for path checkers and prioritizers
+#      #           that issue scsi commands with an explicit timeout, in
+#      #           seconds.
 #      # values  : n > 0
 #      # default : taken from /sys/block/sd<x>/device/timeout
 #      checker_timeout 60
index 1a904e9..195e663 100644 (file)
@@ -330,8 +330,8 @@ maximum number of open fds is taken from the calling process. It is usually
 if that number is greated than 1024.
 .TP
 .B checker_timeout
-Specify the timeout to user for path checkers that issue scsi commands with an
-explicit timeout, in seconds; default taken from
+Specify the timeout to use for path checkers and prioritizers that issue scsi
+commands with an explicit timeout, in seconds; default taken from
 .I /sys/block/sd<x>/device/timeout
 .TP
 .B fast_io_fail_tmo