[checkers]
[multipath-tools/.git] / 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 }