carp.c revision 1.1.20.2 1 1.1 liamjfoy /* $NetBSD: carp.c,v 1.1.20.2 2008/09/28 11:17:11 mjf Exp $ */
2 1.1 liamjfoy
3 1.1 liamjfoy /*
4 1.1 liamjfoy * Copyright (c) 2002 Michael Shalayeff. All rights reserved.
5 1.1 liamjfoy * Copyright (c) 2003 Ryan McBride. All rights reserved.
6 1.1 liamjfoy *
7 1.1 liamjfoy * Redistribution and use in source and binary forms, with or without
8 1.1 liamjfoy * modification, are permitted provided that the following conditions
9 1.1 liamjfoy * are met:
10 1.1 liamjfoy * 1. Redistributions of source code must retain the above copyright
11 1.1 liamjfoy * notice, this list of conditions and the following disclaimer.
12 1.1 liamjfoy * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 liamjfoy * notice, this list of conditions and the following disclaimer in the
14 1.1 liamjfoy * documentation and/or other materials provided with the distribution.
15 1.1 liamjfoy *
16 1.1 liamjfoy * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
17 1.1 liamjfoy * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
18 1.1 liamjfoy * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
19 1.1 liamjfoy * IN NO EVENT SHALL THE AUTHOR OR HIS RELATIVES BE LIABLE FOR ANY DIRECT,
20 1.1 liamjfoy * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
21 1.1 liamjfoy * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
22 1.1 liamjfoy * SERVICES; LOSS OF MIND, USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23 1.1 liamjfoy * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
24 1.1 liamjfoy * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
25 1.1 liamjfoy * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
26 1.1 liamjfoy * THE POSSIBILITY OF SUCH DAMAGE.
27 1.1 liamjfoy */
28 1.1 liamjfoy
29 1.1.20.2 mjf #include <sys/cdefs.h>
30 1.1.20.2 mjf #ifndef lint
31 1.1.20.2 mjf __RCSID("$NetBSD: carp.c,v 1.1.20.2 2008/09/28 11:17:11 mjf Exp $");
32 1.1.20.2 mjf #endif /* not lint */
33 1.1.20.2 mjf
34 1.1 liamjfoy #include <sys/param.h>
35 1.1 liamjfoy #include <sys/ioctl.h>
36 1.1 liamjfoy #include <sys/socket.h>
37 1.1 liamjfoy #include <sys/sockio.h>
38 1.1 liamjfoy
39 1.1 liamjfoy #include <net/if.h>
40 1.1 liamjfoy #include <netinet/ip_carp.h>
41 1.1 liamjfoy #include <net/route.h>
42 1.1 liamjfoy
43 1.1 liamjfoy #include <stdio.h>
44 1.1 liamjfoy #include <string.h>
45 1.1 liamjfoy #include <stdlib.h>
46 1.1 liamjfoy #include <unistd.h>
47 1.1 liamjfoy #include <err.h>
48 1.1 liamjfoy #include <errno.h>
49 1.1.20.1 mjf #include <util.h>
50 1.1 liamjfoy
51 1.1.20.1 mjf #include "env.h"
52 1.1.20.1 mjf #include "parse.h"
53 1.1 liamjfoy #include "extern.h"
54 1.1.20.2 mjf
55 1.1.20.2 mjf static status_func_t status;
56 1.1.20.2 mjf static usage_func_t usage;
57 1.1.20.2 mjf static cmdloop_branch_t branch;
58 1.1.20.2 mjf
59 1.1.20.2 mjf static void carp_constructor(void) __attribute__((constructor));
60 1.1.20.2 mjf static void carp_status(prop_dictionary_t, prop_dictionary_t);
61 1.1.20.2 mjf static int setcarp_advbase(prop_dictionary_t, prop_dictionary_t);
62 1.1.20.2 mjf static int setcarp_advskew(prop_dictionary_t, prop_dictionary_t);
63 1.1.20.2 mjf static int setcarp_passwd(prop_dictionary_t, prop_dictionary_t);
64 1.1.20.2 mjf static int setcarp_vhid(prop_dictionary_t, prop_dictionary_t);
65 1.1.20.2 mjf static int setcarp_state(prop_dictionary_t, prop_dictionary_t);
66 1.1.20.2 mjf static int setcarpdev(prop_dictionary_t, prop_dictionary_t);
67 1.1 liamjfoy
68 1.1 liamjfoy static const char *carp_states[] = { CARP_STATES };
69 1.1 liamjfoy
70 1.1.20.1 mjf struct kwinst carpstatekw[] = {
71 1.1.20.1 mjf {.k_word = "INIT", .k_nextparser = &command_root.pb_parser}
72 1.1.20.1 mjf , {.k_word = "BACKUP", .k_nextparser = &command_root.pb_parser}
73 1.1.20.1 mjf , {.k_word = "MASTER", .k_nextparser = &command_root.pb_parser}
74 1.1.20.1 mjf };
75 1.1.20.1 mjf
76 1.1.20.1 mjf struct pinteger parse_advbase = PINTEGER_INITIALIZER1(&parse_advbase, "advbase",
77 1.1.20.1 mjf 0, 255, 10, setcarp_advbase, "advbase", &command_root.pb_parser);
78 1.1.20.1 mjf
79 1.1.20.1 mjf struct pinteger parse_advskew = PINTEGER_INITIALIZER1(&parse_advskew, "advskew",
80 1.1.20.1 mjf 0, 254, 10, setcarp_advskew, "advskew", &command_root.pb_parser);
81 1.1.20.1 mjf
82 1.1.20.1 mjf struct piface carpdev = PIFACE_INITIALIZER(&carpdev, "carpdev", setcarpdev,
83 1.1.20.1 mjf "carpdev", &command_root.pb_parser);
84 1.1.20.1 mjf
85 1.1.20.2 mjf struct pkw carpstate = PKW_INITIALIZER(&carpstate, "carp state", setcarp_state,
86 1.1.20.1 mjf "carp_state", carpstatekw, __arraycount(carpstatekw),
87 1.1.20.1 mjf &command_root.pb_parser);
88 1.1.20.1 mjf
89 1.1.20.1 mjf struct pstr pass = PSTR_INITIALIZER(&pass, "pass", setcarp_passwd,
90 1.1.20.1 mjf "pass", &command_root.pb_parser);
91 1.1.20.1 mjf
92 1.1.20.1 mjf struct pinteger parse_vhid = PINTEGER_INITIALIZER1(&vhid, "vhid",
93 1.1.20.1 mjf 0, 255, 10, setcarp_vhid, "vhid", &command_root.pb_parser);
94 1.1.20.1 mjf
95 1.1.20.1 mjf static const struct kwinst carpkw[] = {
96 1.1.20.1 mjf {.k_word = "advbase", .k_nextparser = &parse_advbase.pi_parser}
97 1.1.20.1 mjf , {.k_word = "advskew", .k_nextparser = &parse_advskew.pi_parser}
98 1.1.20.1 mjf , {.k_word = "carpdev", .k_nextparser = &carpdev.pif_parser}
99 1.1.20.1 mjf , {.k_word = "-carpdev", .k_key = "carpdev", .k_type = KW_T_STR,
100 1.1.20.1 mjf .k_str = "", .k_exec = setcarpdev,
101 1.1.20.1 mjf .k_nextparser = &command_root.pb_parser}
102 1.1.20.1 mjf , {.k_word = "pass", .k_nextparser = &pass.ps_parser}
103 1.1.20.1 mjf , {.k_word = "state", .k_nextparser = &carpstate.pk_parser}
104 1.1.20.1 mjf , {.k_word = "vhid", .k_nextparser = &parse_vhid.pi_parser}
105 1.1.20.1 mjf };
106 1.1.20.1 mjf
107 1.1.20.1 mjf struct pkw carp = PKW_INITIALIZER(&carp, "CARP", NULL, NULL,
108 1.1.20.1 mjf carpkw, __arraycount(carpkw), NULL);
109 1.1.20.1 mjf
110 1.1.20.2 mjf static void
111 1.1.20.2 mjf carp_set(prop_dictionary_t env, struct carpreq *carpr)
112 1.1.20.2 mjf {
113 1.1.20.2 mjf if (indirect_ioctl(env, SIOCSVH, carpr) == -1)
114 1.1.20.2 mjf err(EXIT_FAILURE, "SIOCSVH");
115 1.1.20.2 mjf }
116 1.1.20.2 mjf
117 1.1.20.2 mjf static int
118 1.1.20.2 mjf carp_get1(prop_dictionary_t env, struct carpreq *carpr)
119 1.1.20.2 mjf {
120 1.1.20.2 mjf memset(carpr, 0, sizeof(*carpr));
121 1.1.20.2 mjf
122 1.1.20.2 mjf return indirect_ioctl(env, SIOCGVH, carpr);
123 1.1.20.2 mjf }
124 1.1.20.2 mjf
125 1.1.20.2 mjf static void
126 1.1.20.2 mjf carp_get(prop_dictionary_t env, struct carpreq *carpr)
127 1.1.20.2 mjf {
128 1.1.20.2 mjf if (carp_get1(env, carpr) == -1)
129 1.1.20.2 mjf err(EXIT_FAILURE, "SIOCGVH");
130 1.1.20.2 mjf }
131 1.1.20.1 mjf
132 1.1.20.2 mjf static void
133 1.1.20.1 mjf carp_status(prop_dictionary_t env, prop_dictionary_t oenv)
134 1.1 liamjfoy {
135 1.1 liamjfoy const char *state;
136 1.1 liamjfoy struct carpreq carpr;
137 1.1 liamjfoy
138 1.1.20.2 mjf if (carp_get1(env, &carpr) == -1)
139 1.1 liamjfoy return;
140 1.1 liamjfoy
141 1.1.20.1 mjf if (carpr.carpr_vhid <= 0)
142 1.1.20.1 mjf return;
143 1.1.20.1 mjf if (carpr.carpr_state > CARP_MAXSTATE)
144 1.1.20.1 mjf state = "<UNKNOWN>";
145 1.1.20.1 mjf else
146 1.1.20.1 mjf state = carp_states[carpr.carpr_state];
147 1.1.20.1 mjf
148 1.1.20.1 mjf printf("\tcarp: %s carpdev %s vhid %d advbase %d advskew %d\n",
149 1.1.20.1 mjf state, carpr.carpr_carpdev[0] != '\0' ?
150 1.1.20.1 mjf carpr.carpr_carpdev : "none", carpr.carpr_vhid,
151 1.1.20.1 mjf carpr.carpr_advbase, carpr.carpr_advskew);
152 1.1 liamjfoy }
153 1.1 liamjfoy
154 1.1.20.1 mjf int
155 1.1.20.2 mjf setcarp_passwd(prop_dictionary_t env, prop_dictionary_t oenv)
156 1.1 liamjfoy {
157 1.1 liamjfoy struct carpreq carpr;
158 1.1.20.1 mjf prop_data_t data;
159 1.1.20.1 mjf
160 1.1.20.1 mjf data = (prop_data_t)prop_dictionary_get(env, "pass");
161 1.1.20.1 mjf if (data == NULL) {
162 1.1.20.1 mjf errno = ENOENT;
163 1.1.20.1 mjf return -1;
164 1.1.20.1 mjf }
165 1.1 liamjfoy
166 1.1.20.2 mjf carp_get(env, &carpr);
167 1.1 liamjfoy
168 1.1.20.1 mjf memset(carpr.carpr_key, 0, sizeof(carpr.carpr_key));
169 1.1 liamjfoy /* XXX Should hash the password into the key here, perhaps? */
170 1.1.20.1 mjf strlcpy((char *)carpr.carpr_key, prop_data_data_nocopy(data),
171 1.1.20.1 mjf MIN(CARP_KEY_LEN, prop_data_size(data)));
172 1.1 liamjfoy
173 1.1.20.2 mjf carp_set(env, &carpr);
174 1.1.20.1 mjf return 0;
175 1.1 liamjfoy }
176 1.1 liamjfoy
177 1.1.20.1 mjf int
178 1.1.20.2 mjf setcarp_vhid(prop_dictionary_t env, prop_dictionary_t oenv)
179 1.1 liamjfoy {
180 1.1 liamjfoy struct carpreq carpr;
181 1.1.20.1 mjf int64_t vhid;
182 1.1 liamjfoy
183 1.1.20.1 mjf if (!prop_dictionary_get_int64(env, "vhid", &vhid)) {
184 1.1.20.1 mjf errno = ENOENT;
185 1.1.20.1 mjf return -1;
186 1.1.20.1 mjf }
187 1.1 liamjfoy
188 1.1.20.2 mjf carp_get(env, &carpr);
189 1.1 liamjfoy
190 1.1 liamjfoy carpr.carpr_vhid = vhid;
191 1.1 liamjfoy
192 1.1.20.2 mjf carp_set(env, &carpr);
193 1.1.20.1 mjf return 0;
194 1.1 liamjfoy }
195 1.1 liamjfoy
196 1.1.20.1 mjf int
197 1.1.20.2 mjf setcarp_advskew(prop_dictionary_t env, prop_dictionary_t oenv)
198 1.1 liamjfoy {
199 1.1 liamjfoy struct carpreq carpr;
200 1.1.20.1 mjf int64_t advskew;
201 1.1 liamjfoy
202 1.1.20.1 mjf if (!prop_dictionary_get_int64(env, "advskew", &advskew)) {
203 1.1.20.1 mjf errno = ENOENT;
204 1.1.20.1 mjf return -1;
205 1.1.20.1 mjf }
206 1.1 liamjfoy
207 1.1.20.2 mjf carp_get(env, &carpr);
208 1.1 liamjfoy
209 1.1 liamjfoy carpr.carpr_advskew = advskew;
210 1.1 liamjfoy
211 1.1.20.2 mjf carp_set(env, &carpr);
212 1.1.20.1 mjf return 0;
213 1.1 liamjfoy }
214 1.1 liamjfoy
215 1.1 liamjfoy /* ARGSUSED */
216 1.1.20.1 mjf int
217 1.1.20.2 mjf setcarp_advbase(prop_dictionary_t env, prop_dictionary_t oenv)
218 1.1 liamjfoy {
219 1.1 liamjfoy struct carpreq carpr;
220 1.1.20.1 mjf int64_t advbase;
221 1.1 liamjfoy
222 1.1.20.1 mjf if (!prop_dictionary_get_int64(env, "advbase", &advbase)) {
223 1.1.20.1 mjf errno = ENOENT;
224 1.1.20.1 mjf return -1;
225 1.1.20.1 mjf }
226 1.1 liamjfoy
227 1.1.20.2 mjf carp_get(env, &carpr);
228 1.1 liamjfoy
229 1.1 liamjfoy carpr.carpr_advbase = advbase;
230 1.1 liamjfoy
231 1.1.20.2 mjf carp_set(env, &carpr);
232 1.1.20.1 mjf return 0;
233 1.1 liamjfoy }
234 1.1 liamjfoy
235 1.1 liamjfoy /* ARGSUSED */
236 1.1.20.2 mjf static int
237 1.1.20.2 mjf setcarp_state(prop_dictionary_t env, prop_dictionary_t oenv)
238 1.1 liamjfoy {
239 1.1 liamjfoy struct carpreq carpr;
240 1.1.20.1 mjf int64_t carp_state;
241 1.1 liamjfoy
242 1.1.20.1 mjf if (!prop_dictionary_get_int64(env, "carp_state", &carp_state)) {
243 1.1.20.1 mjf errno = ENOENT;
244 1.1.20.1 mjf return -1;
245 1.1 liamjfoy }
246 1.1 liamjfoy
247 1.1.20.2 mjf carp_get(env, &carpr);
248 1.1 liamjfoy
249 1.1.20.1 mjf carpr.carpr_state = carp_state;
250 1.1 liamjfoy
251 1.1.20.2 mjf carp_set(env, &carpr);
252 1.1.20.1 mjf return 0;
253 1.1 liamjfoy }
254 1.1 liamjfoy
255 1.1.20.1 mjf /* ARGSUSED */
256 1.1.20.1 mjf int
257 1.1.20.2 mjf setcarpdev(prop_dictionary_t env, prop_dictionary_t oenv)
258 1.1 liamjfoy {
259 1.1 liamjfoy struct carpreq carpr;
260 1.1.20.1 mjf prop_data_t data;
261 1.1.20.1 mjf
262 1.1.20.1 mjf data = (prop_data_t)prop_dictionary_get(env, "carpdev");
263 1.1.20.1 mjf if (data == NULL) {
264 1.1.20.1 mjf errno = ENOENT;
265 1.1.20.1 mjf return -1;
266 1.1.20.1 mjf }
267 1.1 liamjfoy
268 1.1.20.2 mjf carp_get(env, &carpr);
269 1.1 liamjfoy
270 1.1.20.1 mjf strlcpy(carpr.carpr_carpdev, prop_data_data_nocopy(data),
271 1.1.20.1 mjf MIN(sizeof(carpr.carpr_carpdev), prop_data_size(data)));
272 1.1 liamjfoy
273 1.1.20.2 mjf carp_set(env, &carpr);
274 1.1.20.1 mjf return 0;
275 1.1 liamjfoy }
276 1.1.20.2 mjf
277 1.1.20.2 mjf static void
278 1.1.20.2 mjf carp_usage(prop_dictionary_t env)
279 1.1.20.2 mjf {
280 1.1.20.2 mjf fprintf(stderr,
281 1.1.20.2 mjf "\t[ advbase n ] [ advskew n ] [ carpdev iface ] "
282 1.1.20.2 mjf "[ pass passphrase ] [ state state ] [ vhid n ]\n");
283 1.1.20.2 mjf
284 1.1.20.2 mjf }
285 1.1.20.2 mjf
286 1.1.20.2 mjf static void
287 1.1.20.2 mjf carp_constructor(void)
288 1.1.20.2 mjf {
289 1.1.20.2 mjf cmdloop_branch_init(&branch, &carp.pk_parser);
290 1.1.20.2 mjf register_cmdloop_branch(&branch);
291 1.1.20.2 mjf status_func_init(&status, carp_status);
292 1.1.20.2 mjf usage_func_init(&usage, carp_usage);
293 1.1.20.2 mjf register_status(&status);
294 1.1.20.2 mjf register_usage(&usage);
295 1.1.20.2 mjf }
296