Implement 'uxsock_timeout' keyword
authorHannes Reinecke <hare@suse.de>
Mon, 11 Aug 2014 10:49:56 +0000 (12:49 +0200)
committerChristophe Varoqui <christophe.varoqui@opensvc.com>
Sun, 29 Mar 2015 16:07:16 +0000 (18:07 +0200)
On larger systems the default CLI receive timeout of 1 second
might be too small, and the CLI commands might fail before
they can be processed. For these cases I've implemented a new
keywork 'uxsock_timeout' which can be increased to avoid these
issues.

Signed-off-by: Hannes Reinecke <hare@suse.de>
libmultipath/config.c
libmultipath/config.h
libmultipath/configure.c
libmultipath/dict.c
multipath/multipath.conf.5
multipathd/main.c

index 1007f32..c788cf6 100644 (file)
@@ -617,6 +617,7 @@ load_config (char * file, struct udev *udev)
        conf->partition_delim = NULL;
        conf->processed_main_config = 0;
        conf->find_multipaths = DEFAULT_FIND_MULTIPATHS;
+       conf->uxsock_timeout = DEFAULT_UXSOCK_TIMEOUT;
        conf->uid_attribute = set_default(DEFAULT_UID_ATTRIBUTE);
 
        /*
index eff127e..0149ad3 100644 (file)
@@ -135,6 +135,7 @@ struct config {
        int processed_main_config;
        int delay_watch_checks;
        int delay_wait_checks;
+       int uxsock_timeout;
        unsigned int version[3];
 
        char * dev;
index 720d074..2c10c22 100644 (file)
@@ -714,7 +714,7 @@ int check_daemon(void)
 
        if (send_packet(fd, "show daemon", 12) != 0)
                goto out;
-       if (recv_packet(fd, &reply, &len, DEFAULT_UXSOCK_TIMEOUT) != 0)
+       if (recv_packet(fd, &reply, &len, conf->uxsock_timeout) != 0)
                goto out;
 
        if (strstr(reply, "shutdown"))
index 35a1cf2..5c2da43 100644 (file)
@@ -1034,6 +1034,26 @@ declare_hw_snprint(delay_wait_checks, print_delay_checks)
 declare_mp_handler(delay_wait_checks, set_delay_checks)
 declare_mp_snprint(delay_wait_checks, print_delay_checks)
 
+static int
+def_uxsock_timeout_handler(vector strvec)
+{
+       unsigned int uxsock_timeout;
+       char *buff;
+
+       buff = set_value(strvec);
+       if (!buff)
+               return 1;
+
+       if (sscanf(buff, "%u", &uxsock_timeout) == 1 &&
+           uxsock_timeout > DEFAULT_UXSOCK_TIMEOUT)
+               conf->uxsock_timeout = uxsock_timeout;
+       else
+               conf->uxsock_timeout = DEFAULT_UXSOCK_TIMEOUT;
+
+       free(buff);
+       return 0;
+}
+
 /*
  * blacklist block handlers
  */
@@ -1114,6 +1134,15 @@ declare_ble_handler(elist_wwid)
 declare_ble_handler(blist_property)
 declare_ble_handler(elist_property)
 
+static int
+snprint_def_uxsock_timeout(char * buff, int len, void * data)
+{
+       if (conf->uxsock_timeout == DEFAULT_UXSOCK_TIMEOUT)
+               return 0;
+
+       return snprintf(buff, len, "%u", conf->uxsock_timeout);
+}
+
 static int
 snprint_ble_simple (char * buff, int len, void * data)
 {
@@ -1335,6 +1364,7 @@ init_keywords(void)
        install_keyword("delay_watch_checks", &def_delay_watch_checks_handler, &snprint_def_delay_watch_checks);
        install_keyword("delay_wait_checks", &def_delay_wait_checks_handler, &snprint_def_delay_wait_checks);
        install_keyword("find_multipaths", &def_find_multipaths_handler, &snprint_def_find_multipaths);
+       install_keyword("uxsock_timeout", &def_uxsock_timeout_handler, &snprint_def_uxsock_timeout);
        __deprecated install_keyword("default_selector", &def_selector_handler, NULL);
        __deprecated install_keyword("default_path_grouping_policy", &def_pgpolicy_handler, NULL);
        __deprecated install_keyword("default_uid_attribute", &def_uid_attribute_handler, NULL);
index d60dc2e..7e17f62 100644 (file)
@@ -480,6 +480,15 @@ used until it has passed
 .I delay_wait_checks
 checks. Default is
 .I no
+.TP
+.B uxsock_timeout
+CLI receive timeout in milliseconds. For larger systems CLI commands
+might timeout before the multipathd lock is released and the CLI command
+can be processed. This will result in errors like
+'timeout receiving packet' to be returned from CLI commands.
+In these cases it is recommended to increase the CLI timeout to avoid
+those issues. The default is
+.I 1000
 .
 .SH "blacklist section"
 The
index 9db2e55..e197d59 100644 (file)
@@ -2023,7 +2023,9 @@ main (int argc, char *argv[])
                        logsink = -1;
                        break;
                case 'k':
-                       uxclnt(optarg, DEFAULT_UXSOCK_TIMEOUT);
+                       if (load_config(DEFAULT_CONFIGFILE, udev_new()))
+                               exit(1);
+                       uxclnt(optarg, conf->uxsock_timeout);
                        exit(0);
                case 'B':
                        conf->bindings_read_only = 1;
@@ -2037,6 +2039,8 @@ main (int argc, char *argv[])
                char * s = cmd;
                char * c = s;
 
+               if (load_config(DEFAULT_CONFIGFILE, udev_new()))
+                       exit(1);
                while (optind < argc) {
                        if (strchr(argv[optind], ' '))
                                c += snprintf(c, s + CMDSIZE - c, "\"%s\" ", argv[optind]);
@@ -2045,7 +2049,7 @@ main (int argc, char *argv[])
                        optind++;
                }
                c += snprintf(c, s + CMDSIZE - c, "\n");
-               uxclnt(s, DEFAULT_UXSOCK_TIMEOUT);
+               uxclnt(s, conf->uxsock_timeout);
                exit(0);
        }