libmultipath/checkers.c

   1 #include <stdio.h>
   2 #include <string.h>
   3 #include <stddef.h>
   4 #include <dlfcn.h>
   5
   6 #include "debug.h"
   7 #include "checkers.h"
   8 #include "vector.h"
   9 #include "config.h"
  10
  11 static LIST_HEAD(checkers);
  12
  13 int init_checkers (void)
  14 {
  15         INIT_LIST_HEAD(&checkers);
  16         if (!add_checker(DEFAULT_CHECKER))
  17                 return 1;
  18         return 0;
  19 }
  20
  21 struct checker * alloc_checker (void)
  22 {
  23         return zalloc(sizeof(struct checker));
  24 }
  25
  26 void free_checker (struct checker * c)
  27 {
  28         free(c);
  29 }
  30
  31 void cleanup_checkers (void)
  32 {
  33         struct checker * checker_loop;
  34         struct checker * checker_temp;
  35
  36         list_for_each_entry_safe(checker_loop, checker_temp, &checkers, node) {
  37                 list_del(&checker_loop->node);
  38                 free(checker_loop);
  39         }
  40 }
  41
  42 struct checker * checker_lookup (char * name)
  43 {
  44         struct checker * c;
  45
  46         list_for_each_entry(c, &checkers, node) {
  47                 if (!strncmp(name, c->name, CHECKER_NAME_LEN))
  48                         return c;
  49         }
  50         return add_checker(name);
  51 }
  52
  53 struct checker * add_checker (char * name)
  54 {
  55         char libname[LIB_CHECKER_NAMELEN];
  56         void * handle;
  57         struct checker * c;
  58         char *errstr;
  59
  60         c = alloc_checker();
  61         if (!c)
  62                 return NULL;
  63         snprintf(libname, LIB_CHECKER_NAMELEN, "%s/libcheck%s.so",
  64                  conf->multipath_dir, name);
  65         condlog(3, "loading %s checker", libname);
  66         handle = dlopen(libname, RTLD_NOW);
  67         errstr = dlerror();
  68         if (errstr != NULL)
  69         condlog(0, "A dynamic linking error occurred: (%s)", errstr);
  70         if (!handle)
  71                 goto out;
  72
  73         c->check = (int (*)(struct checker *)) dlsym(handle, "libcheck_check");
  74         errstr = dlerror();
  75         if (errstr != NULL)
  76         condlog(0, "A dynamic linking error occurred: (%s)", errstr);
  77         if (!c->check)
  78                 goto out;
  79
  80         c->init = (int (*)(struct checker *)) dlsym(handle, "libcheck_init");
  81         errstr = dlerror();
  82         if (errstr != NULL)
  83         condlog(0, "A dynamic linking error occurred: (%s)", errstr);
  84         if (!c->init)
  85                 goto out;
  86
  87         c->free = (void (*)(struct checker *)) dlsym(handle, "libcheck_free");
  88         errstr = dlerror();
  89         if (errstr != NULL)
  90         condlog(0, "A dynamic linking error occurred: (%s)", errstr);
  91         if (!c->free)
  92                 goto out;
  93
  94         snprintf(c->name, CHECKER_NAME_LEN, "%s", name);
  95         c->fd = 0;
  96         c->sync = 1;
  97         list_add(&c->node, &checkers);
  98         return c;
  99 out:
 100         free_checker(c);
 101         return NULL;
 102 }
 103
 104 void checker_set_fd (struct checker * c, int fd)
 105 {
 106         c->fd = fd;
 107 }
 108
 109 void checker_set_sync (struct checker * c)
 110 {
 111         c->sync = 1;
 112 }
 113
 114 void checker_set_async (struct checker * c)
 115 {
 116         c->sync = 0;
 117 }
 118
 119 void checker_enable (struct checker * c)
 120 {
 121         c->disable = 0;
 122 }
 123
 124 void checker_disable (struct checker * c)
 125 {
 126         c->disable = 1;
 127 }
 128
 129 int checker_init (struct checker * c, void ** mpctxt_addr)
 130 {
 131         c->mpcontext = mpctxt_addr;
 132         return c->init(c);
 133 }
 134
 135 void checker_put (struct checker * c)
 136 {
 137         if (c->free)
 138                 c->free(c);
 139         memset(c, 0x0, sizeof(struct checker));
 140 }
 141
 142 int checker_check (struct checker * c)
 143 {
 144         int r;
 145
 146         if (c->disable)
 147                 return PATH_UNCHECKED;
 148         if (c->fd <= 0) {
 149                 MSG(c, "no usable fd");
 150                 return PATH_WILD;
 151         }
 152         r = c->check(c);
 153
 154         return r;
 155 }
 156
 157 int checker_selected (struct checker * c)
 158 {
 159         return (c->check) ? 1 : 0;
 160 }
 161
 162 char * checker_name (struct checker * c)
 163 {
 164         return c->name;
 165 }
 166
 167 char * checker_message (struct checker * c)
 168 {
 169         return c->message;
 170 }
 171
 172 void checker_get (struct checker * dst, char * name)
 173 {
 174         struct checker * src = checker_lookup(name);
 175
 176         if (!src) {
 177                 dst->check = NULL;
 178                 return;
 179         }
 180         dst->fd = src->fd;
 181         dst->sync = src->sync;
 182         strncpy(dst->name, src->name, CHECKER_NAME_LEN);
 183         strncpy(dst->message, src->message, CHECKER_MSG_LEN);
 184         dst->check = src->check;
 185         dst->init = src->init;
 186         dst->free = src->free;
 187 }