multipath-tools: add checker callout to repair path
authorMike Christie <mchristi@redhat.com>
Mon, 8 Aug 2016 12:01:48 +0000 (07:01 -0500)
committerChristophe Varoqui <christophe.varoqui@opensvc.com>
Tue, 9 Aug 2016 15:18:17 +0000 (17:18 +0200)
This patch adds a callback which can be used to repair a path
if check() has determined it is in the PATH_DOWN state.

The next patch that adds rbd checker support which will use this to
handle the case where a rbd device is blacklisted.

Signed-off-by: Mike Christie <mchristi@redhat.com>
libmultipath/checkers.c
libmultipath/checkers.h
libmultipath/checkers/cciss_tur.c
libmultipath/checkers/directio.c
libmultipath/checkers/emc_clariion.c
libmultipath/checkers/hp_sw.c
libmultipath/checkers/rdac.c
libmultipath/checkers/readsector0.c
libmultipath/checkers/tur.c
multipathd/main.c

index 42baa86..8976c89 100644 (file)
@@ -138,6 +138,14 @@ struct checker * add_checker (char *multipath_dir, char * name)
        if (!c->free)
                goto out;
 
+       c->repair = (void (*)(struct checker *)) dlsym(c->handle,
+                                                      "libcheck_repair");
+       errstr = dlerror();
+       if (errstr != NULL)
+               condlog(0, "A dynamic linking error occurred: (%s)", errstr);
+       if (!c->repair)
+               goto out;
+
        c->fd = 0;
        c->sync = 1;
        list_add(&c->node, &checkers);
@@ -203,6 +211,20 @@ void checker_put (struct checker * dst)
        free_checker(src);
 }
 
+void checker_repair (struct checker * c)
+{
+       if (!c)
+               return;
+
+       c->message[0] = '\0';
+       if (c->disable) {
+               MSG(c, "checker disabled");
+               return;
+       }
+
+       c->repair(c);
+}
+
 int checker_check (struct checker * c)
 {
        int r;
@@ -272,6 +294,7 @@ void checker_get (char *multipath_dir, struct checker * dst, char * name)
        dst->sync = src->sync;
        strncpy(dst->name, src->name, CHECKER_NAME_LEN);
        strncpy(dst->message, src->message, CHECKER_MSG_LEN);
+       dst->repair = src->repair;
        dst->check = src->check;
        dst->init = src->init;
        dst->free = src->free;
index 8fc8616..502d2d9 100644 (file)
@@ -113,6 +113,9 @@ struct checker {
                                                multipath-wide. Use MALLOC if
                                                you want to stuff data in. */
        int (*check)(struct checker *);
+       void (*repair)(struct checker *);     /* called if check returns
+                                               PATH_DOWN to bring path into
+                                               usable state */
        int (*init)(struct checker *);       /* to allocate the context */
        void (*free)(struct checker *);      /* to free the context */
 };
@@ -132,6 +135,7 @@ void checker_set_async (struct checker *);
 void checker_set_fd (struct checker *, int);
 void checker_enable (struct checker *);
 void checker_disable (struct checker *);
+void checker_repair (struct checker *);
 int checker_check (struct checker *);
 int checker_selected (struct checker *);
 char * checker_name (struct checker *);
index 81500dc..a0ffffe 100644 (file)
@@ -59,6 +59,11 @@ void libcheck_free (struct checker * c)
        return;
 }
 
+void libcheck_repair (struct checker * c)
+{
+       return;
+}
+
 extern int
 libcheck_check (struct checker * c)
 {
index 94bf8f7..eec12d5 100644 (file)
@@ -118,6 +118,11 @@ void libcheck_free (struct checker * c)
        free(ct);
 }
 
+void libcheck_repair (struct checker * c)
+{
+       return;
+}
+
 static int
 check_state(int fd, struct directio_context *ct, int sync, int timeout_secs)
 {
index 5e416a0..a7b9f86 100644 (file)
@@ -91,6 +91,11 @@ void libcheck_free (struct checker * c)
        free(c->context);
 }
 
+void libcheck_repair (struct checker * c)
+{
+       return;
+}
+
 int libcheck_check (struct checker * c)
 {
        unsigned char sense_buffer[128] = { 0, };
index fe5e0f9..0cc1111 100644 (file)
@@ -44,6 +44,11 @@ void libcheck_free (struct checker * c)
        return;
 }
 
+void libcheck_repair (struct checker * c)
+{
+       return;
+}
+
 static int
 do_inq(int sg_fd, int cmddt, int evpd, unsigned int pg_op,
        void *resp, int mx_resp_len, int noisy, unsigned int timeout)
index 00e3c44..68682c8 100644 (file)
@@ -139,6 +139,11 @@ void libcheck_free (struct checker * c)
        return;
 }
 
+void libcheck_repair (struct checker * c)
+{
+       return;
+}
+
 static int
 do_inq(int sg_fd, unsigned int pg_op, void *resp, int mx_resp_len,
        unsigned int timeout)
index 1c2a868..8fccb46 100644 (file)
@@ -23,6 +23,11 @@ void libcheck_free (struct checker * c)
        return;
 }
 
+void libcheck_repair (struct checker * c)
+{
+       return;
+}
+
 int libcheck_check (struct checker * c)
 {
        unsigned char buf[4096];
index b53078f..c2ff5e9 100644 (file)
@@ -97,6 +97,11 @@ void libcheck_free (struct checker * c)
        return;
 }
 
+void libcheck_repair (struct checker * c)
+{
+       return;
+}
+
 #define TUR_MSG(msg, fmt, args...) snprintf(msg, CHECKER_MSG_LEN, fmt, ##args);
 
 int
index ec3b907..f5e9a01 100644 (file)
@@ -1725,6 +1725,14 @@ check_path (struct vectors * vecs, struct path * pp, int ticks)
        return 1;
 }
 
+void repair_path(struct vectors * vecs, struct path * pp)
+{
+       if (pp->state != PATH_DOWN)
+               return;
+
+       checker_repair(&pp->checker);
+}
+
 static void *
 checkerloop (void *ap)
 {
@@ -1796,6 +1804,7 @@ checkerloop (void *ap)
                                        i--;
                                } else
                                        num_paths += rc;
+                               repair_path(vecs, pp);
                        }
                        lock_cleanup_pop(vecs->lock);
                }