ip_carp.c revision 1.22 1 1.22 matt /* $NetBSD: ip_carp.c,v 1.22 2007/12/21 02:07:55 matt Exp $ */
2 1.1 liamjfoy /* $OpenBSD: ip_carp.c,v 1.113 2005/11/04 08:11:54 mcbride Exp $ */
3 1.1 liamjfoy
4 1.1 liamjfoy /*
5 1.1 liamjfoy * Copyright (c) 2002 Michael Shalayeff. All rights reserved.
6 1.1 liamjfoy * Copyright (c) 2003 Ryan McBride. All rights reserved.
7 1.1 liamjfoy *
8 1.1 liamjfoy * Redistribution and use in source and binary forms, with or without
9 1.1 liamjfoy * modification, are permitted provided that the following conditions
10 1.1 liamjfoy * are met:
11 1.1 liamjfoy * 1. Redistributions of source code must retain the above copyright
12 1.1 liamjfoy * notice, this list of conditions and the following disclaimer.
13 1.1 liamjfoy * 2. Redistributions in binary form must reproduce the above copyright
14 1.1 liamjfoy * notice, this list of conditions and the following disclaimer in the
15 1.1 liamjfoy * documentation and/or other materials provided with the distribution.
16 1.1 liamjfoy *
17 1.1 liamjfoy * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18 1.1 liamjfoy * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19 1.1 liamjfoy * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20 1.1 liamjfoy * IN NO EVENT SHALL THE AUTHOR OR HIS RELATIVES BE LIABLE FOR ANY DIRECT,
21 1.1 liamjfoy * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
22 1.1 liamjfoy * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
23 1.1 liamjfoy * SERVICES; LOSS OF MIND, USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
24 1.1 liamjfoy * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
25 1.1 liamjfoy * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
26 1.1 liamjfoy * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
27 1.1 liamjfoy * THE POSSIBILITY OF SUCH DAMAGE.
28 1.1 liamjfoy */
29 1.1 liamjfoy
30 1.20 lukem #include <sys/cdefs.h>
31 1.22 matt __KERNEL_RCSID(0, "$NetBSD: ip_carp.c,v 1.22 2007/12/21 02:07:55 matt Exp $");
32 1.20 lukem
33 1.1 liamjfoy /*
34 1.1 liamjfoy * TODO:
35 1.1 liamjfoy * - iface reconfigure
36 1.1 liamjfoy * - support for hardware checksum calculations;
37 1.1 liamjfoy *
38 1.1 liamjfoy */
39 1.1 liamjfoy
40 1.1 liamjfoy #include <sys/param.h>
41 1.1 liamjfoy #include <sys/proc.h>
42 1.1 liamjfoy #include <sys/mbuf.h>
43 1.1 liamjfoy #include <sys/socket.h>
44 1.1 liamjfoy #include <sys/socketvar.h>
45 1.1 liamjfoy #include <sys/callout.h>
46 1.1 liamjfoy #include <sys/ioctl.h>
47 1.1 liamjfoy #include <sys/errno.h>
48 1.1 liamjfoy #include <sys/device.h>
49 1.1 liamjfoy #include <sys/time.h>
50 1.1 liamjfoy #include <sys/kernel.h>
51 1.1 liamjfoy #include <sys/kauth.h>
52 1.1 liamjfoy #include <sys/sysctl.h>
53 1.1 liamjfoy #include <sys/ucred.h>
54 1.1 liamjfoy #include <sys/syslog.h>
55 1.1 liamjfoy #include <sys/acct.h>
56 1.1 liamjfoy
57 1.18 ad #include <sys/cpu.h>
58 1.1 liamjfoy
59 1.1 liamjfoy #include <net/if.h>
60 1.1 liamjfoy #include <net/pfil.h>
61 1.1 liamjfoy #include <net/if_types.h>
62 1.1 liamjfoy #include <net/if_ether.h>
63 1.1 liamjfoy #include <net/route.h>
64 1.1 liamjfoy #include <net/netisr.h>
65 1.1 liamjfoy #include <netinet/if_inarp.h>
66 1.1 liamjfoy
67 1.1 liamjfoy #include <machine/stdarg.h>
68 1.1 liamjfoy
69 1.1 liamjfoy #if NFDDI > 0
70 1.1 liamjfoy #include <net/if_fddi.h>
71 1.1 liamjfoy #endif
72 1.1 liamjfoy #if NTOKEN > 0
73 1.1 liamjfoy #include <net/if_token.h>
74 1.1 liamjfoy #endif
75 1.1 liamjfoy
76 1.1 liamjfoy #ifdef INET
77 1.1 liamjfoy #include <netinet/in.h>
78 1.1 liamjfoy #include <netinet/in_systm.h>
79 1.1 liamjfoy #include <netinet/in_var.h>
80 1.1 liamjfoy #include <netinet/ip.h>
81 1.1 liamjfoy #include <netinet/ip_var.h>
82 1.1 liamjfoy
83 1.1 liamjfoy #include <net/if_dl.h>
84 1.1 liamjfoy #endif
85 1.1 liamjfoy
86 1.1 liamjfoy #ifdef INET6
87 1.1 liamjfoy #include <netinet/icmp6.h>
88 1.1 liamjfoy #include <netinet/ip6.h>
89 1.1 liamjfoy #include <netinet6/ip6_var.h>
90 1.1 liamjfoy #include <netinet6/nd6.h>
91 1.1 liamjfoy #endif
92 1.1 liamjfoy
93 1.1 liamjfoy #include "bpfilter.h"
94 1.1 liamjfoy #if NBPFILTER > 0
95 1.1 liamjfoy #include <net/bpf.h>
96 1.1 liamjfoy #endif
97 1.1 liamjfoy
98 1.1 liamjfoy #include <sys/sha1.h>
99 1.1 liamjfoy
100 1.1 liamjfoy #include <netinet/ip_carp.h>
101 1.1 liamjfoy
102 1.1 liamjfoy struct carp_mc_entry {
103 1.1 liamjfoy LIST_ENTRY(carp_mc_entry) mc_entries;
104 1.1 liamjfoy union {
105 1.1 liamjfoy struct ether_multi *mcu_enm;
106 1.1 liamjfoy } mc_u;
107 1.1 liamjfoy struct sockaddr_storage mc_addr;
108 1.1 liamjfoy };
109 1.1 liamjfoy #define mc_enm mc_u.mcu_enm
110 1.1 liamjfoy
111 1.1 liamjfoy struct carp_softc {
112 1.1 liamjfoy struct ethercom sc_ac;
113 1.1 liamjfoy #define sc_if sc_ac.ec_if
114 1.1 liamjfoy #define sc_carpdev sc_ac.ec_if.if_carpdev
115 1.1 liamjfoy int ah_cookie;
116 1.1 liamjfoy int lh_cookie;
117 1.1 liamjfoy struct ip_moptions sc_imo;
118 1.1 liamjfoy #ifdef INET6
119 1.1 liamjfoy struct ip6_moptions sc_im6o;
120 1.1 liamjfoy #endif /* INET6 */
121 1.1 liamjfoy TAILQ_ENTRY(carp_softc) sc_list;
122 1.1 liamjfoy
123 1.1 liamjfoy enum { INIT = 0, BACKUP, MASTER } sc_state;
124 1.1 liamjfoy
125 1.1 liamjfoy int sc_suppress;
126 1.1 liamjfoy int sc_bow_out;
127 1.1 liamjfoy
128 1.1 liamjfoy int sc_sendad_errors;
129 1.1 liamjfoy #define CARP_SENDAD_MAX_ERRORS 3
130 1.1 liamjfoy int sc_sendad_success;
131 1.1 liamjfoy #define CARP_SENDAD_MIN_SUCCESS 3
132 1.1 liamjfoy
133 1.1 liamjfoy int sc_vhid;
134 1.1 liamjfoy int sc_advskew;
135 1.1 liamjfoy int sc_naddrs;
136 1.1 liamjfoy int sc_naddrs6;
137 1.1 liamjfoy int sc_advbase; /* seconds */
138 1.1 liamjfoy int sc_init_counter;
139 1.1 liamjfoy u_int64_t sc_counter;
140 1.1 liamjfoy
141 1.1 liamjfoy /* authentication */
142 1.1 liamjfoy #define CARP_HMAC_PAD 64
143 1.1 liamjfoy unsigned char sc_key[CARP_KEY_LEN];
144 1.1 liamjfoy unsigned char sc_pad[CARP_HMAC_PAD];
145 1.1 liamjfoy SHA1_CTX sc_sha1;
146 1.1 liamjfoy u_int32_t sc_hashkey[2];
147 1.1 liamjfoy
148 1.1 liamjfoy struct callout sc_ad_tmo; /* advertisement timeout */
149 1.1 liamjfoy struct callout sc_md_tmo; /* master down timeout */
150 1.1 liamjfoy struct callout sc_md6_tmo; /* master down timeout */
151 1.1 liamjfoy
152 1.1 liamjfoy LIST_HEAD(__carp_mchead, carp_mc_entry) carp_mc_listhead;
153 1.1 liamjfoy };
154 1.1 liamjfoy
155 1.1 liamjfoy int carp_suppress_preempt = 0;
156 1.1 liamjfoy int carp_opts[CARPCTL_MAXID] = { 0, 1, 0, 0, 0 }; /* XXX for now */
157 1.1 liamjfoy struct carpstats carpstats;
158 1.1 liamjfoy
159 1.1 liamjfoy struct carp_if {
160 1.1 liamjfoy TAILQ_HEAD(, carp_softc) vhif_vrs;
161 1.1 liamjfoy int vhif_nvrs;
162 1.1 liamjfoy
163 1.1 liamjfoy struct ifnet *vhif_ifp;
164 1.1 liamjfoy };
165 1.1 liamjfoy
166 1.1 liamjfoy #define CARP_LOG(sc, s) \
167 1.1 liamjfoy if (carp_opts[CARPCTL_LOG]) { \
168 1.1 liamjfoy if (sc) \
169 1.1 liamjfoy log(LOG_INFO, "%s: ", \
170 1.1 liamjfoy (sc)->sc_if.if_xname); \
171 1.1 liamjfoy else \
172 1.1 liamjfoy log(LOG_INFO, "carp: "); \
173 1.1 liamjfoy addlog s; \
174 1.1 liamjfoy addlog("\n"); \
175 1.1 liamjfoy }
176 1.1 liamjfoy
177 1.1 liamjfoy void carp_hmac_prepare(struct carp_softc *);
178 1.1 liamjfoy void carp_hmac_generate(struct carp_softc *, u_int32_t *,
179 1.1 liamjfoy unsigned char *);
180 1.1 liamjfoy int carp_hmac_verify(struct carp_softc *, u_int32_t *,
181 1.1 liamjfoy unsigned char *);
182 1.1 liamjfoy void carp_setroute(struct carp_softc *, int);
183 1.1 liamjfoy void carp_proto_input_c(struct mbuf *, struct carp_header *, sa_family_t);
184 1.1 liamjfoy void carpattach(int);
185 1.1 liamjfoy void carpdetach(struct carp_softc *);
186 1.1 liamjfoy int carp_prepare_ad(struct mbuf *, struct carp_softc *,
187 1.1 liamjfoy struct carp_header *);
188 1.1 liamjfoy void carp_send_ad_all(void);
189 1.1 liamjfoy void carp_send_ad(void *);
190 1.1 liamjfoy void carp_send_arp(struct carp_softc *);
191 1.1 liamjfoy void carp_master_down(void *);
192 1.12 christos int carp_ioctl(struct ifnet *, u_long, void *);
193 1.1 liamjfoy void carp_start(struct ifnet *);
194 1.1 liamjfoy void carp_setrun(struct carp_softc *, sa_family_t);
195 1.1 liamjfoy void carp_set_state(struct carp_softc *, int);
196 1.1 liamjfoy int carp_addrcount(struct carp_if *, struct in_ifaddr *, int);
197 1.1 liamjfoy enum { CARP_COUNT_MASTER, CARP_COUNT_RUNNING };
198 1.1 liamjfoy
199 1.1 liamjfoy void carp_multicast_cleanup(struct carp_softc *);
200 1.1 liamjfoy int carp_set_ifp(struct carp_softc *, struct ifnet *);
201 1.1 liamjfoy void carp_set_enaddr(struct carp_softc *);
202 1.1 liamjfoy void carp_addr_updated(void *);
203 1.1 liamjfoy u_int32_t carp_hash(struct carp_softc *, u_char *);
204 1.1 liamjfoy int carp_set_addr(struct carp_softc *, struct sockaddr_in *);
205 1.1 liamjfoy int carp_join_multicast(struct carp_softc *);
206 1.1 liamjfoy #ifdef INET6
207 1.1 liamjfoy void carp_send_na(struct carp_softc *);
208 1.1 liamjfoy int carp_set_addr6(struct carp_softc *, struct sockaddr_in6 *);
209 1.1 liamjfoy int carp_join_multicast6(struct carp_softc *);
210 1.1 liamjfoy #endif
211 1.1 liamjfoy int carp_clone_create(struct if_clone *, int);
212 1.1 liamjfoy int carp_clone_destroy(struct ifnet *);
213 1.1 liamjfoy int carp_ether_addmulti(struct carp_softc *, struct ifreq *);
214 1.1 liamjfoy int carp_ether_delmulti(struct carp_softc *, struct ifreq *);
215 1.1 liamjfoy void carp_ether_purgemulti(struct carp_softc *);
216 1.1 liamjfoy
217 1.1 liamjfoy struct if_clone carp_cloner =
218 1.1 liamjfoy IF_CLONE_INITIALIZER("carp", carp_clone_create, carp_clone_destroy);
219 1.1 liamjfoy
220 1.1 liamjfoy static __inline u_int16_t
221 1.1 liamjfoy carp_cksum(struct mbuf *m, int len)
222 1.1 liamjfoy {
223 1.1 liamjfoy return (in_cksum(m, len));
224 1.1 liamjfoy }
225 1.1 liamjfoy
226 1.1 liamjfoy void
227 1.1 liamjfoy carp_hmac_prepare(struct carp_softc *sc)
228 1.1 liamjfoy {
229 1.1 liamjfoy u_int8_t carp_version = CARP_VERSION, type = CARP_ADVERTISEMENT;
230 1.1 liamjfoy u_int8_t vhid = sc->sc_vhid & 0xff;
231 1.1 liamjfoy SHA1_CTX sha1ctx;
232 1.1 liamjfoy u_int32_t kmd[5];
233 1.1 liamjfoy struct ifaddr *ifa;
234 1.1 liamjfoy int i, found;
235 1.1 liamjfoy struct in_addr last, cur, in;
236 1.1 liamjfoy #ifdef INET6
237 1.1 liamjfoy struct in6_addr last6, cur6, in6;
238 1.1 liamjfoy #endif /* INET6 */
239 1.1 liamjfoy
240 1.1 liamjfoy /* compute ipad from key */
241 1.1 liamjfoy bzero(sc->sc_pad, sizeof(sc->sc_pad));
242 1.1 liamjfoy bcopy(sc->sc_key, sc->sc_pad, sizeof(sc->sc_key));
243 1.1 liamjfoy for (i = 0; i < sizeof(sc->sc_pad); i++)
244 1.1 liamjfoy sc->sc_pad[i] ^= 0x36;
245 1.1 liamjfoy
246 1.1 liamjfoy /* precompute first part of inner hash */
247 1.1 liamjfoy SHA1Init(&sc->sc_sha1);
248 1.1 liamjfoy SHA1Update(&sc->sc_sha1, sc->sc_pad, sizeof(sc->sc_pad));
249 1.1 liamjfoy SHA1Update(&sc->sc_sha1, (void *)&carp_version, sizeof(carp_version));
250 1.1 liamjfoy SHA1Update(&sc->sc_sha1, (void *)&type, sizeof(type));
251 1.1 liamjfoy
252 1.1 liamjfoy /* generate a key for the arpbalance hash, before the vhid is hashed */
253 1.1 liamjfoy bcopy(&sc->sc_sha1, &sha1ctx, sizeof(sha1ctx));
254 1.1 liamjfoy SHA1Final((unsigned char *)kmd, &sha1ctx);
255 1.1 liamjfoy sc->sc_hashkey[0] = kmd[0] ^ kmd[1];
256 1.1 liamjfoy sc->sc_hashkey[1] = kmd[2] ^ kmd[3];
257 1.1 liamjfoy
258 1.1 liamjfoy /* the rest of the precomputation */
259 1.1 liamjfoy SHA1Update(&sc->sc_sha1, (void *)&vhid, sizeof(vhid));
260 1.1 liamjfoy
261 1.1 liamjfoy /* Hash the addresses from smallest to largest, not interface order */
262 1.1 liamjfoy #ifdef INET
263 1.1 liamjfoy cur.s_addr = 0;
264 1.1 liamjfoy do {
265 1.1 liamjfoy found = 0;
266 1.1 liamjfoy last = cur;
267 1.1 liamjfoy cur.s_addr = 0xffffffff;
268 1.19 dyoung IFADDR_FOREACH(ifa, &sc->sc_if) {
269 1.1 liamjfoy in.s_addr = ifatoia(ifa)->ia_addr.sin_addr.s_addr;
270 1.1 liamjfoy if (ifa->ifa_addr->sa_family == AF_INET &&
271 1.1 liamjfoy ntohl(in.s_addr) > ntohl(last.s_addr) &&
272 1.1 liamjfoy ntohl(in.s_addr) < ntohl(cur.s_addr)) {
273 1.1 liamjfoy cur.s_addr = in.s_addr;
274 1.1 liamjfoy found++;
275 1.1 liamjfoy }
276 1.1 liamjfoy }
277 1.1 liamjfoy if (found)
278 1.1 liamjfoy SHA1Update(&sc->sc_sha1, (void *)&cur, sizeof(cur));
279 1.1 liamjfoy } while (found);
280 1.1 liamjfoy #endif /* INET */
281 1.1 liamjfoy
282 1.1 liamjfoy #ifdef INET6
283 1.1 liamjfoy memset(&cur6, 0x00, sizeof(cur6));
284 1.1 liamjfoy do {
285 1.1 liamjfoy found = 0;
286 1.1 liamjfoy last6 = cur6;
287 1.1 liamjfoy memset(&cur6, 0xff, sizeof(cur6));
288 1.19 dyoung IFADDR_FOREACH(ifa, &sc->sc_if) {
289 1.1 liamjfoy in6 = ifatoia6(ifa)->ia_addr.sin6_addr;
290 1.1 liamjfoy if (IN6_IS_ADDR_LINKLOCAL(&in6))
291 1.1 liamjfoy in6.s6_addr16[1] = 0;
292 1.1 liamjfoy if (ifa->ifa_addr->sa_family == AF_INET6 &&
293 1.1 liamjfoy memcmp(&in6, &last6, sizeof(in6)) > 0 &&
294 1.1 liamjfoy memcmp(&in6, &cur6, sizeof(in6)) < 0) {
295 1.1 liamjfoy cur6 = in6;
296 1.1 liamjfoy found++;
297 1.1 liamjfoy }
298 1.1 liamjfoy }
299 1.1 liamjfoy if (found)
300 1.1 liamjfoy SHA1Update(&sc->sc_sha1, (void *)&cur6, sizeof(cur6));
301 1.1 liamjfoy } while (found);
302 1.1 liamjfoy #endif /* INET6 */
303 1.1 liamjfoy
304 1.1 liamjfoy /* convert ipad to opad */
305 1.1 liamjfoy for (i = 0; i < sizeof(sc->sc_pad); i++)
306 1.1 liamjfoy sc->sc_pad[i] ^= 0x36 ^ 0x5c;
307 1.1 liamjfoy }
308 1.1 liamjfoy
309 1.1 liamjfoy void
310 1.1 liamjfoy carp_hmac_generate(struct carp_softc *sc, u_int32_t counter[2],
311 1.1 liamjfoy unsigned char md[20])
312 1.1 liamjfoy {
313 1.1 liamjfoy SHA1_CTX sha1ctx;
314 1.1 liamjfoy
315 1.1 liamjfoy /* fetch first half of inner hash */
316 1.1 liamjfoy bcopy(&sc->sc_sha1, &sha1ctx, sizeof(sha1ctx));
317 1.1 liamjfoy
318 1.1 liamjfoy SHA1Update(&sha1ctx, (void *)counter, sizeof(sc->sc_counter));
319 1.1 liamjfoy SHA1Final(md, &sha1ctx);
320 1.1 liamjfoy
321 1.1 liamjfoy /* outer hash */
322 1.1 liamjfoy SHA1Init(&sha1ctx);
323 1.1 liamjfoy SHA1Update(&sha1ctx, sc->sc_pad, sizeof(sc->sc_pad));
324 1.1 liamjfoy SHA1Update(&sha1ctx, md, 20);
325 1.1 liamjfoy SHA1Final(md, &sha1ctx);
326 1.1 liamjfoy }
327 1.1 liamjfoy
328 1.1 liamjfoy int
329 1.1 liamjfoy carp_hmac_verify(struct carp_softc *sc, u_int32_t counter[2],
330 1.1 liamjfoy unsigned char md[20])
331 1.1 liamjfoy {
332 1.1 liamjfoy unsigned char md2[20];
333 1.1 liamjfoy
334 1.1 liamjfoy carp_hmac_generate(sc, counter, md2);
335 1.1 liamjfoy
336 1.1 liamjfoy return (bcmp(md, md2, sizeof(md2)));
337 1.1 liamjfoy }
338 1.1 liamjfoy
339 1.1 liamjfoy void
340 1.1 liamjfoy carp_setroute(struct carp_softc *sc, int cmd)
341 1.1 liamjfoy {
342 1.1 liamjfoy struct ifaddr *ifa;
343 1.1 liamjfoy int s;
344 1.1 liamjfoy
345 1.1 liamjfoy s = splsoftnet();
346 1.19 dyoung IFADDR_FOREACH(ifa, &sc->sc_if) {
347 1.1 liamjfoy switch (ifa->ifa_addr->sa_family) {
348 1.1 liamjfoy case AF_INET: {
349 1.1 liamjfoy int count = 0;
350 1.1 liamjfoy struct rtentry *rt;
351 1.1 liamjfoy int hr_otherif, nr_ourif;
352 1.1 liamjfoy
353 1.1 liamjfoy /*
354 1.1 liamjfoy * Avoid screwing with the routes if there are other
355 1.1 liamjfoy * carp interfaces which are master and have the same
356 1.1 liamjfoy * address.
357 1.1 liamjfoy */
358 1.1 liamjfoy if (sc->sc_carpdev != NULL &&
359 1.1 liamjfoy sc->sc_carpdev->if_carp != NULL) {
360 1.1 liamjfoy count = carp_addrcount(
361 1.1 liamjfoy (struct carp_if *)sc->sc_carpdev->if_carp,
362 1.1 liamjfoy ifatoia(ifa), CARP_COUNT_MASTER);
363 1.1 liamjfoy if ((cmd == RTM_ADD && count != 1) ||
364 1.1 liamjfoy (cmd == RTM_DELETE && count != 0))
365 1.1 liamjfoy continue;
366 1.1 liamjfoy }
367 1.1 liamjfoy
368 1.1 liamjfoy /* Remove the existing host route, if any */
369 1.1 liamjfoy rtrequest(RTM_DELETE, ifa->ifa_addr,
370 1.1 liamjfoy ifa->ifa_addr, ifa->ifa_netmask,
371 1.1 liamjfoy RTF_HOST, NULL);
372 1.1 liamjfoy
373 1.14 dyoung rt = NULL;
374 1.14 dyoung (void)rtrequest(RTM_GET, ifa->ifa_addr, ifa->ifa_addr,
375 1.14 dyoung ifa->ifa_netmask, RTF_HOST, &rt);
376 1.1 liamjfoy hr_otherif = (rt && rt->rt_ifp != &sc->sc_if &&
377 1.1 liamjfoy rt->rt_flags & (RTF_CLONING|RTF_CLONED));
378 1.14 dyoung if (rt != NULL) {
379 1.14 dyoung RTFREE(rt);
380 1.14 dyoung rt = NULL;
381 1.14 dyoung }
382 1.1 liamjfoy
383 1.1 liamjfoy /* Check for a network route on our interface */
384 1.14 dyoung
385 1.14 dyoung rt = NULL;
386 1.14 dyoung (void)rtrequest(RTM_GET, ifa->ifa_addr, ifa->ifa_addr,
387 1.14 dyoung ifa->ifa_netmask, 0, &rt);
388 1.1 liamjfoy nr_ourif = (rt && rt->rt_ifp == &sc->sc_if);
389 1.1 liamjfoy
390 1.1 liamjfoy switch (cmd) {
391 1.1 liamjfoy case RTM_ADD:
392 1.1 liamjfoy if (hr_otherif) {
393 1.1 liamjfoy ifa->ifa_rtrequest = NULL;
394 1.1 liamjfoy ifa->ifa_flags &= ~RTF_CLONING;
395 1.1 liamjfoy
396 1.1 liamjfoy rtrequest(RTM_ADD, ifa->ifa_addr,
397 1.1 liamjfoy ifa->ifa_addr, ifa->ifa_netmask,
398 1.1 liamjfoy RTF_UP | RTF_HOST, NULL);
399 1.1 liamjfoy }
400 1.1 liamjfoy if (!hr_otherif || nr_ourif || !rt) {
401 1.1 liamjfoy if (nr_ourif && !(rt->rt_flags &
402 1.1 liamjfoy RTF_CLONING))
403 1.14 dyoung rtrequest(RTM_DELETE,
404 1.14 dyoung ifa->ifa_addr,
405 1.1 liamjfoy ifa->ifa_addr,
406 1.1 liamjfoy ifa->ifa_netmask, 0, NULL);
407 1.1 liamjfoy
408 1.1 liamjfoy ifa->ifa_rtrequest = arp_rtrequest;
409 1.1 liamjfoy ifa->ifa_flags |= RTF_CLONING;
410 1.1 liamjfoy
411 1.1 liamjfoy if (rtrequest(RTM_ADD, ifa->ifa_addr,
412 1.1 liamjfoy ifa->ifa_addr, ifa->ifa_netmask, 0,
413 1.1 liamjfoy NULL) == 0)
414 1.1 liamjfoy ifa->ifa_flags |= IFA_ROUTE;
415 1.1 liamjfoy }
416 1.1 liamjfoy break;
417 1.1 liamjfoy case RTM_DELETE:
418 1.1 liamjfoy break;
419 1.1 liamjfoy default:
420 1.1 liamjfoy break;
421 1.1 liamjfoy }
422 1.14 dyoung if (rt != NULL) {
423 1.14 dyoung RTFREE(rt);
424 1.14 dyoung rt = NULL;
425 1.14 dyoung }
426 1.1 liamjfoy break;
427 1.1 liamjfoy }
428 1.1 liamjfoy
429 1.1 liamjfoy #ifdef INET6
430 1.1 liamjfoy case AF_INET6:
431 1.1 liamjfoy if (cmd == RTM_ADD)
432 1.1 liamjfoy in6_ifaddloop(ifa);
433 1.1 liamjfoy else
434 1.1 liamjfoy in6_ifremloop(ifa);
435 1.1 liamjfoy break;
436 1.1 liamjfoy #endif /* INET6 */
437 1.1 liamjfoy default:
438 1.1 liamjfoy break;
439 1.1 liamjfoy }
440 1.1 liamjfoy }
441 1.1 liamjfoy splx(s);
442 1.1 liamjfoy }
443 1.1 liamjfoy
444 1.1 liamjfoy /*
445 1.1 liamjfoy * process input packet.
446 1.1 liamjfoy * we have rearranged checks order compared to the rfc,
447 1.1 liamjfoy * but it seems more efficient this way or not possible otherwise.
448 1.1 liamjfoy */
449 1.1 liamjfoy void
450 1.1 liamjfoy carp_proto_input(struct mbuf *m, ...)
451 1.1 liamjfoy {
452 1.1 liamjfoy struct ip *ip = mtod(m, struct ip *);
453 1.1 liamjfoy struct carp_softc *sc = NULL;
454 1.1 liamjfoy struct carp_header *ch;
455 1.1 liamjfoy int iplen, len, hlen;
456 1.1 liamjfoy va_list ap;
457 1.1 liamjfoy
458 1.1 liamjfoy va_start(ap, m);
459 1.1 liamjfoy hlen = va_arg(ap, int);
460 1.1 liamjfoy va_end(ap);
461 1.1 liamjfoy
462 1.1 liamjfoy carpstats.carps_ipackets++;
463 1.1 liamjfoy
464 1.1 liamjfoy if (!carp_opts[CARPCTL_ALLOW]) {
465 1.1 liamjfoy m_freem(m);
466 1.1 liamjfoy return;
467 1.1 liamjfoy }
468 1.1 liamjfoy
469 1.1 liamjfoy /* check if received on a valid carp interface */
470 1.1 liamjfoy if (m->m_pkthdr.rcvif->if_type != IFT_CARP) {
471 1.1 liamjfoy carpstats.carps_badif++;
472 1.1 liamjfoy CARP_LOG(sc, ("packet received on non-carp interface: %s",
473 1.1 liamjfoy m->m_pkthdr.rcvif->if_xname));
474 1.1 liamjfoy m_freem(m);
475 1.1 liamjfoy return;
476 1.1 liamjfoy }
477 1.1 liamjfoy
478 1.1 liamjfoy /* verify that the IP TTL is 255. */
479 1.1 liamjfoy if (ip->ip_ttl != CARP_DFLTTL) {
480 1.1 liamjfoy carpstats.carps_badttl++;
481 1.1 liamjfoy CARP_LOG(sc, ("received ttl %d != %d on %s", ip->ip_ttl,
482 1.1 liamjfoy CARP_DFLTTL, m->m_pkthdr.rcvif->if_xname));
483 1.1 liamjfoy m_freem(m);
484 1.1 liamjfoy return;
485 1.1 liamjfoy }
486 1.1 liamjfoy
487 1.1 liamjfoy /*
488 1.1 liamjfoy * verify that the received packet length is
489 1.1 liamjfoy * equal to the CARP header
490 1.1 liamjfoy */
491 1.1 liamjfoy iplen = ip->ip_hl << 2;
492 1.1 liamjfoy len = iplen + sizeof(*ch);
493 1.1 liamjfoy if (len > m->m_pkthdr.len) {
494 1.1 liamjfoy carpstats.carps_badlen++;
495 1.1 liamjfoy CARP_LOG(sc, ("packet too short %d on %s", m->m_pkthdr.len,
496 1.1 liamjfoy m->m_pkthdr.rcvif->if_xname));
497 1.1 liamjfoy m_freem(m);
498 1.1 liamjfoy return;
499 1.1 liamjfoy }
500 1.1 liamjfoy
501 1.1 liamjfoy if ((m = m_pullup(m, len)) == NULL) {
502 1.1 liamjfoy carpstats.carps_hdrops++;
503 1.1 liamjfoy return;
504 1.1 liamjfoy }
505 1.1 liamjfoy ip = mtod(m, struct ip *);
506 1.1 liamjfoy ch = (struct carp_header *)((char *)ip + iplen);
507 1.1 liamjfoy /* verify the CARP checksum */
508 1.1 liamjfoy m->m_data += iplen;
509 1.1 liamjfoy if (carp_cksum(m, len - iplen)) {
510 1.1 liamjfoy carpstats.carps_badsum++;
511 1.1 liamjfoy CARP_LOG(sc, ("checksum failed on %s",
512 1.1 liamjfoy m->m_pkthdr.rcvif->if_xname));
513 1.1 liamjfoy m_freem(m);
514 1.1 liamjfoy return;
515 1.1 liamjfoy }
516 1.1 liamjfoy m->m_data -= iplen;
517 1.1 liamjfoy
518 1.1 liamjfoy carp_proto_input_c(m, ch, AF_INET);
519 1.1 liamjfoy }
520 1.1 liamjfoy
521 1.1 liamjfoy #ifdef INET6
522 1.1 liamjfoy int
523 1.10 christos carp6_proto_input(struct mbuf **mp, int *offp, int proto)
524 1.1 liamjfoy {
525 1.1 liamjfoy struct mbuf *m = *mp;
526 1.1 liamjfoy struct carp_softc *sc = NULL;
527 1.1 liamjfoy struct ip6_hdr *ip6 = mtod(m, struct ip6_hdr *);
528 1.1 liamjfoy struct carp_header *ch;
529 1.1 liamjfoy u_int len;
530 1.1 liamjfoy
531 1.1 liamjfoy carpstats.carps_ipackets6++;
532 1.1 liamjfoy
533 1.1 liamjfoy if (!carp_opts[CARPCTL_ALLOW]) {
534 1.1 liamjfoy m_freem(m);
535 1.1 liamjfoy return (IPPROTO_DONE);
536 1.1 liamjfoy }
537 1.1 liamjfoy
538 1.1 liamjfoy /* check if received on a valid carp interface */
539 1.1 liamjfoy if (m->m_pkthdr.rcvif->if_type != IFT_CARP) {
540 1.1 liamjfoy carpstats.carps_badif++;
541 1.1 liamjfoy CARP_LOG(sc, ("packet received on non-carp interface: %s",
542 1.1 liamjfoy m->m_pkthdr.rcvif->if_xname));
543 1.1 liamjfoy m_freem(m);
544 1.1 liamjfoy return (IPPROTO_DONE);
545 1.1 liamjfoy }
546 1.1 liamjfoy
547 1.1 liamjfoy /* verify that the IP TTL is 255 */
548 1.1 liamjfoy if (ip6->ip6_hlim != CARP_DFLTTL) {
549 1.1 liamjfoy carpstats.carps_badttl++;
550 1.1 liamjfoy CARP_LOG(sc, ("received ttl %d != %d on %s", ip6->ip6_hlim,
551 1.1 liamjfoy CARP_DFLTTL, m->m_pkthdr.rcvif->if_xname));
552 1.1 liamjfoy m_freem(m);
553 1.1 liamjfoy return (IPPROTO_DONE);
554 1.1 liamjfoy }
555 1.1 liamjfoy
556 1.1 liamjfoy /* verify that we have a complete carp packet */
557 1.1 liamjfoy len = m->m_len;
558 1.1 liamjfoy IP6_EXTHDR_GET(ch, struct carp_header *, m, *offp, sizeof(*ch));
559 1.1 liamjfoy if (ch == NULL) {
560 1.1 liamjfoy carpstats.carps_badlen++;
561 1.1 liamjfoy CARP_LOG(sc, ("packet size %u too small", len));
562 1.1 liamjfoy return (IPPROTO_DONE);
563 1.1 liamjfoy }
564 1.1 liamjfoy
565 1.1 liamjfoy
566 1.1 liamjfoy /* verify the CARP checksum */
567 1.1 liamjfoy m->m_data += *offp;
568 1.1 liamjfoy if (carp_cksum(m, sizeof(*ch))) {
569 1.1 liamjfoy carpstats.carps_badsum++;
570 1.1 liamjfoy CARP_LOG(sc, ("checksum failed, on %s",
571 1.1 liamjfoy m->m_pkthdr.rcvif->if_xname));
572 1.1 liamjfoy m_freem(m);
573 1.1 liamjfoy return (IPPROTO_DONE);
574 1.1 liamjfoy }
575 1.1 liamjfoy m->m_data -= *offp;
576 1.1 liamjfoy
577 1.1 liamjfoy carp_proto_input_c(m, ch, AF_INET6);
578 1.1 liamjfoy return (IPPROTO_DONE);
579 1.1 liamjfoy }
580 1.1 liamjfoy #endif /* INET6 */
581 1.1 liamjfoy
582 1.1 liamjfoy void
583 1.1 liamjfoy carp_proto_input_c(struct mbuf *m, struct carp_header *ch, sa_family_t af)
584 1.1 liamjfoy {
585 1.1 liamjfoy struct carp_softc *sc;
586 1.1 liamjfoy u_int64_t tmp_counter;
587 1.1 liamjfoy struct timeval sc_tv, ch_tv;
588 1.1 liamjfoy
589 1.1 liamjfoy TAILQ_FOREACH(sc, &((struct carp_if *)
590 1.1 liamjfoy m->m_pkthdr.rcvif->if_carpdev->if_carp)->vhif_vrs, sc_list)
591 1.1 liamjfoy if (sc->sc_vhid == ch->carp_vhid)
592 1.1 liamjfoy break;
593 1.1 liamjfoy
594 1.1 liamjfoy if (!sc || (sc->sc_if.if_flags & (IFF_UP|IFF_RUNNING)) !=
595 1.1 liamjfoy (IFF_UP|IFF_RUNNING)) {
596 1.1 liamjfoy carpstats.carps_badvhid++;
597 1.1 liamjfoy m_freem(m);
598 1.1 liamjfoy return;
599 1.1 liamjfoy }
600 1.1 liamjfoy
601 1.2 liamjfoy /*
602 1.2 liamjfoy * Check if our own advertisement was duplicated
603 1.2 liamjfoy * from a non simplex interface.
604 1.2 liamjfoy * XXX If there is no address on our physical interface
605 1.2 liamjfoy * there is no way to distinguish our ads from the ones
606 1.2 liamjfoy * another carp host might have sent us.
607 1.2 liamjfoy */
608 1.2 liamjfoy if ((sc->sc_carpdev->if_flags & IFF_SIMPLEX) == 0) {
609 1.2 liamjfoy struct sockaddr sa;
610 1.2 liamjfoy struct ifaddr *ifa;
611 1.2 liamjfoy
612 1.2 liamjfoy bzero(&sa, sizeof(sa));
613 1.2 liamjfoy sa.sa_family = af;
614 1.2 liamjfoy ifa = ifaof_ifpforaddr(&sa, sc->sc_carpdev);
615 1.2 liamjfoy
616 1.2 liamjfoy if (ifa && af == AF_INET) {
617 1.2 liamjfoy struct ip *ip = mtod(m, struct ip *);
618 1.2 liamjfoy if (ip->ip_src.s_addr ==
619 1.2 liamjfoy ifatoia(ifa)->ia_addr.sin_addr.s_addr) {
620 1.2 liamjfoy m_freem(m);
621 1.2 liamjfoy return;
622 1.2 liamjfoy }
623 1.2 liamjfoy }
624 1.2 liamjfoy #ifdef INET6
625 1.2 liamjfoy if (ifa && af == AF_INET6) {
626 1.2 liamjfoy struct ip6_hdr *ip6 = mtod(m, struct ip6_hdr *);
627 1.2 liamjfoy struct in6_addr in6_src, in6_found;
628 1.2 liamjfoy
629 1.2 liamjfoy in6_src = ip6->ip6_src;
630 1.2 liamjfoy in6_found = ifatoia6(ifa)->ia_addr.sin6_addr;
631 1.2 liamjfoy if (IN6_IS_ADDR_LINKLOCAL(&in6_src))
632 1.2 liamjfoy in6_src.s6_addr16[1] = 0;
633 1.2 liamjfoy if (IN6_IS_ADDR_LINKLOCAL(&in6_found))
634 1.2 liamjfoy in6_found.s6_addr16[1] = 0;
635 1.2 liamjfoy if (IN6_ARE_ADDR_EQUAL(&in6_src, &in6_found)) {
636 1.2 liamjfoy m_freem(m);
637 1.2 liamjfoy return;
638 1.2 liamjfoy }
639 1.2 liamjfoy }
640 1.2 liamjfoy #endif /* INET6 */
641 1.2 liamjfoy }
642 1.2 liamjfoy
643 1.1 liamjfoy microtime(&sc->sc_if.if_lastchange);
644 1.1 liamjfoy sc->sc_if.if_ipackets++;
645 1.1 liamjfoy sc->sc_if.if_ibytes += m->m_pkthdr.len;
646 1.1 liamjfoy
647 1.1 liamjfoy /* verify the CARP version. */
648 1.1 liamjfoy if (ch->carp_version != CARP_VERSION) {
649 1.1 liamjfoy carpstats.carps_badver++;
650 1.1 liamjfoy sc->sc_if.if_ierrors++;
651 1.1 liamjfoy CARP_LOG(sc, ("invalid version %d != %d",
652 1.1 liamjfoy ch->carp_version, CARP_VERSION));
653 1.1 liamjfoy m_freem(m);
654 1.1 liamjfoy return;
655 1.1 liamjfoy }
656 1.1 liamjfoy
657 1.1 liamjfoy /* verify the hash */
658 1.1 liamjfoy if (carp_hmac_verify(sc, ch->carp_counter, ch->carp_md)) {
659 1.1 liamjfoy carpstats.carps_badauth++;
660 1.1 liamjfoy sc->sc_if.if_ierrors++;
661 1.1 liamjfoy CARP_LOG(sc, ("incorrect hash"));
662 1.1 liamjfoy m_freem(m);
663 1.1 liamjfoy return;
664 1.1 liamjfoy }
665 1.1 liamjfoy
666 1.1 liamjfoy tmp_counter = ntohl(ch->carp_counter[0]);
667 1.1 liamjfoy tmp_counter = tmp_counter<<32;
668 1.1 liamjfoy tmp_counter += ntohl(ch->carp_counter[1]);
669 1.1 liamjfoy
670 1.1 liamjfoy /* XXX Replay protection goes here */
671 1.1 liamjfoy
672 1.1 liamjfoy sc->sc_init_counter = 0;
673 1.1 liamjfoy sc->sc_counter = tmp_counter;
674 1.1 liamjfoy
675 1.1 liamjfoy
676 1.1 liamjfoy sc_tv.tv_sec = sc->sc_advbase;
677 1.1 liamjfoy if (carp_suppress_preempt && sc->sc_advskew < 240)
678 1.1 liamjfoy sc_tv.tv_usec = 240 * 1000000 / 256;
679 1.1 liamjfoy else
680 1.1 liamjfoy sc_tv.tv_usec = sc->sc_advskew * 1000000 / 256;
681 1.1 liamjfoy ch_tv.tv_sec = ch->carp_advbase;
682 1.1 liamjfoy ch_tv.tv_usec = ch->carp_advskew * 1000000 / 256;
683 1.1 liamjfoy
684 1.1 liamjfoy switch (sc->sc_state) {
685 1.1 liamjfoy case INIT:
686 1.1 liamjfoy break;
687 1.1 liamjfoy case MASTER:
688 1.1 liamjfoy /*
689 1.1 liamjfoy * If we receive an advertisement from a backup who's going to
690 1.1 liamjfoy * be more frequent than us, go into BACKUP state.
691 1.1 liamjfoy */
692 1.1 liamjfoy if (timercmp(&sc_tv, &ch_tv, >) ||
693 1.1 liamjfoy timercmp(&sc_tv, &ch_tv, ==)) {
694 1.1 liamjfoy callout_stop(&sc->sc_ad_tmo);
695 1.1 liamjfoy carp_set_state(sc, BACKUP);
696 1.1 liamjfoy carp_setrun(sc, 0);
697 1.1 liamjfoy carp_setroute(sc, RTM_DELETE);
698 1.1 liamjfoy }
699 1.1 liamjfoy break;
700 1.1 liamjfoy case BACKUP:
701 1.1 liamjfoy /*
702 1.1 liamjfoy * If we're pre-empting masters who advertise slower than us,
703 1.1 liamjfoy * and this one claims to be slower, treat him as down.
704 1.1 liamjfoy */
705 1.1 liamjfoy if (carp_opts[CARPCTL_PREEMPT] && timercmp(&sc_tv, &ch_tv, <)) {
706 1.1 liamjfoy carp_master_down(sc);
707 1.1 liamjfoy break;
708 1.1 liamjfoy }
709 1.1 liamjfoy
710 1.1 liamjfoy /*
711 1.1 liamjfoy * If the master is going to advertise at such a low frequency
712 1.1 liamjfoy * that he's guaranteed to time out, we'd might as well just
713 1.1 liamjfoy * treat him as timed out now.
714 1.1 liamjfoy */
715 1.1 liamjfoy sc_tv.tv_sec = sc->sc_advbase * 3;
716 1.1 liamjfoy if (timercmp(&sc_tv, &ch_tv, <)) {
717 1.1 liamjfoy carp_master_down(sc);
718 1.1 liamjfoy break;
719 1.1 liamjfoy }
720 1.1 liamjfoy
721 1.1 liamjfoy /*
722 1.1 liamjfoy * Otherwise, we reset the counter and wait for the next
723 1.1 liamjfoy * advertisement.
724 1.1 liamjfoy */
725 1.1 liamjfoy carp_setrun(sc, af);
726 1.1 liamjfoy break;
727 1.1 liamjfoy }
728 1.1 liamjfoy
729 1.1 liamjfoy m_freem(m);
730 1.1 liamjfoy return;
731 1.1 liamjfoy }
732 1.1 liamjfoy
733 1.1 liamjfoy /*
734 1.1 liamjfoy * Interface side of the CARP implementation.
735 1.1 liamjfoy */
736 1.1 liamjfoy
737 1.1 liamjfoy /* ARGSUSED */
738 1.1 liamjfoy void
739 1.10 christos carpattach(int n)
740 1.1 liamjfoy {
741 1.1 liamjfoy if_clone_attach(&carp_cloner);
742 1.1 liamjfoy }
743 1.1 liamjfoy
744 1.1 liamjfoy int
745 1.1 liamjfoy carp_clone_create(struct if_clone *ifc, int unit)
746 1.1 liamjfoy {
747 1.1 liamjfoy extern int ifqmaxlen;
748 1.1 liamjfoy struct carp_softc *sc;
749 1.1 liamjfoy struct ifnet *ifp;
750 1.1 liamjfoy
751 1.1 liamjfoy sc = malloc(sizeof(*sc), M_DEVBUF, M_NOWAIT);
752 1.1 liamjfoy if (!sc)
753 1.1 liamjfoy return (ENOMEM);
754 1.1 liamjfoy bzero(sc, sizeof(*sc));
755 1.1 liamjfoy
756 1.1 liamjfoy sc->sc_suppress = 0;
757 1.1 liamjfoy sc->sc_advbase = CARP_DFLTINTV;
758 1.1 liamjfoy sc->sc_vhid = -1; /* required setting */
759 1.1 liamjfoy sc->sc_advskew = 0;
760 1.1 liamjfoy sc->sc_init_counter = 1;
761 1.1 liamjfoy sc->sc_naddrs = sc->sc_naddrs6 = 0;
762 1.1 liamjfoy #ifdef INET6
763 1.1 liamjfoy sc->sc_im6o.im6o_multicast_hlim = CARP_DFLTTL;
764 1.1 liamjfoy #endif /* INET6 */
765 1.1 liamjfoy
766 1.13 ad callout_init(&sc->sc_ad_tmo, 0);
767 1.13 ad callout_init(&sc->sc_md_tmo, 0);
768 1.13 ad callout_init(&sc->sc_md6_tmo, 0);
769 1.1 liamjfoy
770 1.1 liamjfoy callout_setfunc(&sc->sc_ad_tmo, carp_send_ad, sc);
771 1.1 liamjfoy callout_setfunc(&sc->sc_md_tmo, carp_master_down, sc);
772 1.1 liamjfoy callout_setfunc(&sc->sc_md6_tmo, carp_master_down, sc);
773 1.1 liamjfoy
774 1.1 liamjfoy LIST_INIT(&sc->carp_mc_listhead);
775 1.1 liamjfoy ifp = &sc->sc_if;
776 1.1 liamjfoy ifp->if_softc = sc;
777 1.1 liamjfoy snprintf(ifp->if_xname, sizeof ifp->if_xname, "%s%d", ifc->ifc_name,
778 1.1 liamjfoy unit);
779 1.1 liamjfoy ifp->if_flags = IFF_BROADCAST | IFF_SIMPLEX | IFF_MULTICAST;
780 1.1 liamjfoy ifp->if_ioctl = carp_ioctl;
781 1.1 liamjfoy ifp->if_start = carp_start;
782 1.1 liamjfoy ifp->if_output = carp_output;
783 1.1 liamjfoy ifp->if_type = IFT_CARP;
784 1.1 liamjfoy ifp->if_addrlen = ETHER_ADDR_LEN;
785 1.1 liamjfoy ifp->if_hdrlen = ETHER_HDR_LEN;
786 1.1 liamjfoy ifp->if_mtu = ETHERMTU;
787 1.1 liamjfoy IFQ_SET_MAXLEN(&ifp->if_snd, ifqmaxlen);
788 1.1 liamjfoy IFQ_SET_READY(&ifp->if_snd);
789 1.1 liamjfoy if_attach(ifp);
790 1.1 liamjfoy
791 1.1 liamjfoy if_alloc_sadl(ifp);
792 1.1 liamjfoy ifp->if_broadcastaddr = etherbroadcastaddr;
793 1.1 liamjfoy carp_set_enaddr(sc);
794 1.1 liamjfoy LIST_INIT(&sc->sc_ac.ec_multiaddrs);
795 1.1 liamjfoy #if NBPFILTER > 0
796 1.1 liamjfoy bpfattach(ifp, DLT_EN10MB, ETHER_HDR_LEN);
797 1.1 liamjfoy #endif
798 1.1 liamjfoy return (0);
799 1.1 liamjfoy }
800 1.1 liamjfoy
801 1.1 liamjfoy int
802 1.1 liamjfoy carp_clone_destroy(struct ifnet *ifp)
803 1.1 liamjfoy {
804 1.13 ad struct carp_softc *sc = ifp->if_softc;
805 1.13 ad
806 1.1 liamjfoy carpdetach(ifp->if_softc);
807 1.1 liamjfoy ether_ifdetach(ifp);
808 1.1 liamjfoy if_detach(ifp);
809 1.13 ad callout_destroy(&sc->sc_ad_tmo);
810 1.13 ad callout_destroy(&sc->sc_md_tmo);
811 1.13 ad callout_destroy(&sc->sc_md6_tmo);
812 1.1 liamjfoy free(ifp->if_softc, M_DEVBUF);
813 1.1 liamjfoy
814 1.1 liamjfoy return (0);
815 1.1 liamjfoy }
816 1.1 liamjfoy
817 1.1 liamjfoy void
818 1.1 liamjfoy carpdetach(struct carp_softc *sc)
819 1.1 liamjfoy {
820 1.1 liamjfoy struct carp_if *cif;
821 1.1 liamjfoy int s;
822 1.1 liamjfoy
823 1.1 liamjfoy callout_stop(&sc->sc_ad_tmo);
824 1.1 liamjfoy callout_stop(&sc->sc_md_tmo);
825 1.1 liamjfoy callout_stop(&sc->sc_md6_tmo);
826 1.1 liamjfoy
827 1.1 liamjfoy if (sc->sc_suppress)
828 1.1 liamjfoy carp_suppress_preempt--;
829 1.1 liamjfoy sc->sc_suppress = 0;
830 1.1 liamjfoy
831 1.1 liamjfoy if (sc->sc_sendad_errors >= CARP_SENDAD_MAX_ERRORS)
832 1.1 liamjfoy carp_suppress_preempt--;
833 1.1 liamjfoy sc->sc_sendad_errors = 0;
834 1.1 liamjfoy
835 1.1 liamjfoy carp_set_state(sc, INIT);
836 1.1 liamjfoy sc->sc_if.if_flags &= ~IFF_UP;
837 1.1 liamjfoy carp_setrun(sc, 0);
838 1.1 liamjfoy carp_multicast_cleanup(sc);
839 1.1 liamjfoy
840 1.1 liamjfoy s = splnet();
841 1.1 liamjfoy if (sc->sc_carpdev != NULL) {
842 1.1 liamjfoy /* XXX linkstatehook removal */
843 1.1 liamjfoy cif = (struct carp_if *)sc->sc_carpdev->if_carp;
844 1.1 liamjfoy TAILQ_REMOVE(&cif->vhif_vrs, sc, sc_list);
845 1.1 liamjfoy if (!--cif->vhif_nvrs) {
846 1.1 liamjfoy ifpromisc(sc->sc_carpdev, 0);
847 1.1 liamjfoy sc->sc_carpdev->if_carp = NULL;
848 1.1 liamjfoy FREE(cif, M_IFADDR);
849 1.1 liamjfoy }
850 1.1 liamjfoy }
851 1.1 liamjfoy sc->sc_carpdev = NULL;
852 1.1 liamjfoy splx(s);
853 1.1 liamjfoy }
854 1.1 liamjfoy
855 1.1 liamjfoy /* Detach an interface from the carp. */
856 1.1 liamjfoy void
857 1.1 liamjfoy carp_ifdetach(struct ifnet *ifp)
858 1.1 liamjfoy {
859 1.1 liamjfoy struct carp_softc *sc, *nextsc;
860 1.1 liamjfoy struct carp_if *cif = (struct carp_if *)ifp->if_carp;
861 1.1 liamjfoy
862 1.1 liamjfoy for (sc = TAILQ_FIRST(&cif->vhif_vrs); sc; sc = nextsc) {
863 1.1 liamjfoy nextsc = TAILQ_NEXT(sc, sc_list);
864 1.1 liamjfoy carpdetach(sc);
865 1.1 liamjfoy }
866 1.1 liamjfoy }
867 1.1 liamjfoy
868 1.1 liamjfoy int
869 1.10 christos carp_prepare_ad(struct mbuf *m, struct carp_softc *sc,
870 1.6 christos struct carp_header *ch)
871 1.1 liamjfoy {
872 1.1 liamjfoy if (sc->sc_init_counter) {
873 1.1 liamjfoy /* this could also be seconds since unix epoch */
874 1.1 liamjfoy sc->sc_counter = arc4random();
875 1.1 liamjfoy sc->sc_counter = sc->sc_counter << 32;
876 1.1 liamjfoy sc->sc_counter += arc4random();
877 1.1 liamjfoy } else
878 1.1 liamjfoy sc->sc_counter++;
879 1.1 liamjfoy
880 1.1 liamjfoy ch->carp_counter[0] = htonl((sc->sc_counter>>32)&0xffffffff);
881 1.1 liamjfoy ch->carp_counter[1] = htonl(sc->sc_counter&0xffffffff);
882 1.1 liamjfoy
883 1.1 liamjfoy carp_hmac_generate(sc, ch->carp_counter, ch->carp_md);
884 1.1 liamjfoy
885 1.1 liamjfoy return (0);
886 1.1 liamjfoy }
887 1.1 liamjfoy
888 1.1 liamjfoy void
889 1.1 liamjfoy carp_send_ad_all(void)
890 1.1 liamjfoy {
891 1.1 liamjfoy struct ifnet *ifp;
892 1.1 liamjfoy struct carp_if *cif;
893 1.1 liamjfoy struct carp_softc *vh;
894 1.1 liamjfoy
895 1.1 liamjfoy TAILQ_FOREACH(ifp, &ifnet, if_list) {
896 1.1 liamjfoy if (ifp->if_carp == NULL || ifp->if_type == IFT_CARP)
897 1.1 liamjfoy continue;
898 1.1 liamjfoy
899 1.1 liamjfoy cif = (struct carp_if *)ifp->if_carp;
900 1.1 liamjfoy TAILQ_FOREACH(vh, &cif->vhif_vrs, sc_list) {
901 1.1 liamjfoy if ((vh->sc_if.if_flags & (IFF_UP|IFF_RUNNING)) ==
902 1.1 liamjfoy (IFF_UP|IFF_RUNNING) && vh->sc_state == MASTER)
903 1.1 liamjfoy carp_send_ad(vh);
904 1.1 liamjfoy }
905 1.1 liamjfoy }
906 1.1 liamjfoy }
907 1.1 liamjfoy
908 1.1 liamjfoy
909 1.1 liamjfoy void
910 1.1 liamjfoy carp_send_ad(void *v)
911 1.1 liamjfoy {
912 1.1 liamjfoy struct carp_header ch;
913 1.1 liamjfoy struct timeval tv;
914 1.1 liamjfoy struct carp_softc *sc = v;
915 1.1 liamjfoy struct carp_header *ch_ptr;
916 1.1 liamjfoy struct mbuf *m;
917 1.1 liamjfoy int error, len, advbase, advskew, s;
918 1.1 liamjfoy struct ifaddr *ifa;
919 1.1 liamjfoy struct sockaddr sa;
920 1.1 liamjfoy
921 1.1 liamjfoy s = splsoftnet();
922 1.1 liamjfoy
923 1.1 liamjfoy advbase = advskew = 0; /* Sssssh compiler */
924 1.1 liamjfoy if (sc->sc_carpdev == NULL) {
925 1.1 liamjfoy sc->sc_if.if_oerrors++;
926 1.1 liamjfoy goto retry_later;
927 1.1 liamjfoy }
928 1.1 liamjfoy
929 1.1 liamjfoy /* bow out if we've gone to backup (the carp interface is going down) */
930 1.1 liamjfoy if (sc->sc_bow_out) {
931 1.1 liamjfoy sc->sc_bow_out = 0;
932 1.1 liamjfoy advbase = 255;
933 1.1 liamjfoy advskew = 255;
934 1.1 liamjfoy } else {
935 1.1 liamjfoy advbase = sc->sc_advbase;
936 1.1 liamjfoy if (!carp_suppress_preempt || sc->sc_advskew > 240)
937 1.1 liamjfoy advskew = sc->sc_advskew;
938 1.1 liamjfoy else
939 1.1 liamjfoy advskew = 240;
940 1.1 liamjfoy tv.tv_sec = advbase;
941 1.1 liamjfoy tv.tv_usec = advskew * 1000000 / 256;
942 1.1 liamjfoy }
943 1.1 liamjfoy
944 1.1 liamjfoy ch.carp_version = CARP_VERSION;
945 1.1 liamjfoy ch.carp_type = CARP_ADVERTISEMENT;
946 1.1 liamjfoy ch.carp_vhid = sc->sc_vhid;
947 1.1 liamjfoy ch.carp_advbase = advbase;
948 1.1 liamjfoy ch.carp_advskew = advskew;
949 1.1 liamjfoy ch.carp_authlen = 7; /* XXX DEFINE */
950 1.1 liamjfoy ch.carp_pad1 = 0; /* must be zero */
951 1.1 liamjfoy ch.carp_cksum = 0;
952 1.1 liamjfoy
953 1.1 liamjfoy
954 1.1 liamjfoy #ifdef INET
955 1.1 liamjfoy if (sc->sc_naddrs) {
956 1.1 liamjfoy struct ip *ip;
957 1.1 liamjfoy
958 1.1 liamjfoy MGETHDR(m, M_DONTWAIT, MT_HEADER);
959 1.1 liamjfoy if (m == NULL) {
960 1.1 liamjfoy sc->sc_if.if_oerrors++;
961 1.1 liamjfoy carpstats.carps_onomem++;
962 1.1 liamjfoy /* XXX maybe less ? */
963 1.1 liamjfoy goto retry_later;
964 1.1 liamjfoy }
965 1.1 liamjfoy len = sizeof(*ip) + sizeof(ch);
966 1.1 liamjfoy m->m_pkthdr.len = len;
967 1.1 liamjfoy m->m_pkthdr.rcvif = NULL;
968 1.1 liamjfoy m->m_len = len;
969 1.1 liamjfoy MH_ALIGN(m, m->m_len);
970 1.1 liamjfoy m->m_flags |= M_MCAST;
971 1.1 liamjfoy ip = mtod(m, struct ip *);
972 1.1 liamjfoy ip->ip_v = IPVERSION;
973 1.1 liamjfoy ip->ip_hl = sizeof(*ip) >> 2;
974 1.1 liamjfoy ip->ip_tos = IPTOS_LOWDELAY;
975 1.1 liamjfoy ip->ip_len = htons(len);
976 1.22 matt ip->ip_id = 0; /* no need for id, we don't support fragments */
977 1.1 liamjfoy ip->ip_off = htons(IP_DF);
978 1.1 liamjfoy ip->ip_ttl = CARP_DFLTTL;
979 1.1 liamjfoy ip->ip_p = IPPROTO_CARP;
980 1.1 liamjfoy ip->ip_sum = 0;
981 1.1 liamjfoy
982 1.1 liamjfoy bzero(&sa, sizeof(sa));
983 1.1 liamjfoy sa.sa_family = AF_INET;
984 1.1 liamjfoy ifa = ifaof_ifpforaddr(&sa, sc->sc_carpdev);
985 1.1 liamjfoy if (ifa == NULL)
986 1.1 liamjfoy ip->ip_src.s_addr = 0;
987 1.1 liamjfoy else
988 1.1 liamjfoy ip->ip_src.s_addr =
989 1.1 liamjfoy ifatoia(ifa)->ia_addr.sin_addr.s_addr;
990 1.1 liamjfoy ip->ip_dst.s_addr = INADDR_CARP_GROUP;
991 1.1 liamjfoy
992 1.1 liamjfoy ch_ptr = (struct carp_header *)(&ip[1]);
993 1.1 liamjfoy bcopy(&ch, ch_ptr, sizeof(ch));
994 1.1 liamjfoy if (carp_prepare_ad(m, sc, ch_ptr))
995 1.1 liamjfoy goto retry_later;
996 1.1 liamjfoy
997 1.1 liamjfoy m->m_data += sizeof(*ip);
998 1.1 liamjfoy ch_ptr->carp_cksum = carp_cksum(m, len - sizeof(*ip));
999 1.1 liamjfoy m->m_data -= sizeof(*ip);
1000 1.1 liamjfoy
1001 1.1 liamjfoy microtime(&sc->sc_if.if_lastchange);
1002 1.1 liamjfoy sc->sc_if.if_opackets++;
1003 1.1 liamjfoy sc->sc_if.if_obytes += len;
1004 1.1 liamjfoy carpstats.carps_opackets++;
1005 1.1 liamjfoy
1006 1.1 liamjfoy error = ip_output(m, NULL, NULL, IP_RAWOUTPUT, &sc->sc_imo,
1007 1.1 liamjfoy NULL);
1008 1.1 liamjfoy if (error) {
1009 1.1 liamjfoy if (error == ENOBUFS)
1010 1.1 liamjfoy carpstats.carps_onomem++;
1011 1.1 liamjfoy else
1012 1.1 liamjfoy CARP_LOG(sc, ("ip_output failed: %d", error));
1013 1.1 liamjfoy sc->sc_if.if_oerrors++;
1014 1.1 liamjfoy if (sc->sc_sendad_errors < INT_MAX)
1015 1.1 liamjfoy sc->sc_sendad_errors++;
1016 1.1 liamjfoy if (sc->sc_sendad_errors == CARP_SENDAD_MAX_ERRORS) {
1017 1.1 liamjfoy carp_suppress_preempt++;
1018 1.1 liamjfoy if (carp_suppress_preempt == 1)
1019 1.1 liamjfoy carp_send_ad_all();
1020 1.1 liamjfoy }
1021 1.1 liamjfoy sc->sc_sendad_success = 0;
1022 1.1 liamjfoy } else {
1023 1.1 liamjfoy if (sc->sc_sendad_errors >= CARP_SENDAD_MAX_ERRORS) {
1024 1.1 liamjfoy if (++sc->sc_sendad_success >=
1025 1.1 liamjfoy CARP_SENDAD_MIN_SUCCESS) {
1026 1.1 liamjfoy carp_suppress_preempt--;
1027 1.1 liamjfoy sc->sc_sendad_errors = 0;
1028 1.1 liamjfoy }
1029 1.1 liamjfoy } else
1030 1.1 liamjfoy sc->sc_sendad_errors = 0;
1031 1.1 liamjfoy }
1032 1.1 liamjfoy }
1033 1.1 liamjfoy #endif /* INET */
1034 1.1 liamjfoy #ifdef INET6
1035 1.1 liamjfoy if (sc->sc_naddrs6) {
1036 1.1 liamjfoy struct ip6_hdr *ip6;
1037 1.1 liamjfoy
1038 1.1 liamjfoy MGETHDR(m, M_DONTWAIT, MT_HEADER);
1039 1.1 liamjfoy if (m == NULL) {
1040 1.1 liamjfoy sc->sc_if.if_oerrors++;
1041 1.1 liamjfoy carpstats.carps_onomem++;
1042 1.1 liamjfoy /* XXX maybe less ? */
1043 1.1 liamjfoy goto retry_later;
1044 1.1 liamjfoy }
1045 1.1 liamjfoy len = sizeof(*ip6) + sizeof(ch);
1046 1.1 liamjfoy m->m_pkthdr.len = len;
1047 1.1 liamjfoy m->m_pkthdr.rcvif = NULL;
1048 1.1 liamjfoy m->m_len = len;
1049 1.1 liamjfoy MH_ALIGN(m, m->m_len);
1050 1.1 liamjfoy m->m_flags |= M_MCAST;
1051 1.1 liamjfoy ip6 = mtod(m, struct ip6_hdr *);
1052 1.1 liamjfoy bzero(ip6, sizeof(*ip6));
1053 1.1 liamjfoy ip6->ip6_vfc |= IPV6_VERSION;
1054 1.1 liamjfoy ip6->ip6_hlim = CARP_DFLTTL;
1055 1.1 liamjfoy ip6->ip6_nxt = IPPROTO_CARP;
1056 1.1 liamjfoy
1057 1.1 liamjfoy /* set the source address */
1058 1.1 liamjfoy bzero(&sa, sizeof(sa));
1059 1.1 liamjfoy sa.sa_family = AF_INET6;
1060 1.1 liamjfoy ifa = ifaof_ifpforaddr(&sa, sc->sc_carpdev);
1061 1.1 liamjfoy if (ifa == NULL) /* This should never happen with IPv6 */
1062 1.1 liamjfoy bzero(&ip6->ip6_src, sizeof(struct in6_addr));
1063 1.1 liamjfoy else
1064 1.1 liamjfoy bcopy(ifatoia6(ifa)->ia_addr.sin6_addr.s6_addr,
1065 1.1 liamjfoy &ip6->ip6_src, sizeof(struct in6_addr));
1066 1.1 liamjfoy /* set the multicast destination */
1067 1.1 liamjfoy
1068 1.1 liamjfoy ip6->ip6_dst.s6_addr8[0] = 0xff;
1069 1.1 liamjfoy ip6->ip6_dst.s6_addr8[1] = 0x02;
1070 1.1 liamjfoy ip6->ip6_dst.s6_addr8[15] = 0x12;
1071 1.1 liamjfoy
1072 1.1 liamjfoy ch_ptr = (struct carp_header *)(&ip6[1]);
1073 1.1 liamjfoy bcopy(&ch, ch_ptr, sizeof(ch));
1074 1.1 liamjfoy if (carp_prepare_ad(m, sc, ch_ptr))
1075 1.1 liamjfoy goto retry_later;
1076 1.1 liamjfoy
1077 1.1 liamjfoy m->m_data += sizeof(*ip6);
1078 1.1 liamjfoy ch_ptr->carp_cksum = carp_cksum(m, len - sizeof(*ip6));
1079 1.1 liamjfoy m->m_data -= sizeof(*ip6);
1080 1.1 liamjfoy
1081 1.1 liamjfoy microtime(&sc->sc_if.if_lastchange);
1082 1.1 liamjfoy sc->sc_if.if_opackets++;
1083 1.1 liamjfoy sc->sc_if.if_obytes += len;
1084 1.1 liamjfoy carpstats.carps_opackets6++;
1085 1.1 liamjfoy
1086 1.1 liamjfoy error = ip6_output(m, NULL, NULL, 0, &sc->sc_im6o, NULL, NULL);
1087 1.1 liamjfoy if (error) {
1088 1.1 liamjfoy if (error == ENOBUFS)
1089 1.1 liamjfoy carpstats.carps_onomem++;
1090 1.1 liamjfoy else
1091 1.1 liamjfoy CARP_LOG(sc, ("ip6_output failed: %d", error));
1092 1.1 liamjfoy sc->sc_if.if_oerrors++;
1093 1.1 liamjfoy if (sc->sc_sendad_errors < INT_MAX)
1094 1.1 liamjfoy sc->sc_sendad_errors++;
1095 1.1 liamjfoy if (sc->sc_sendad_errors == CARP_SENDAD_MAX_ERRORS) {
1096 1.1 liamjfoy carp_suppress_preempt++;
1097 1.1 liamjfoy if (carp_suppress_preempt == 1)
1098 1.1 liamjfoy carp_send_ad_all();
1099 1.1 liamjfoy }
1100 1.1 liamjfoy sc->sc_sendad_success = 0;
1101 1.1 liamjfoy } else {
1102 1.1 liamjfoy if (sc->sc_sendad_errors >= CARP_SENDAD_MAX_ERRORS) {
1103 1.1 liamjfoy if (++sc->sc_sendad_success >=
1104 1.1 liamjfoy CARP_SENDAD_MIN_SUCCESS) {
1105 1.1 liamjfoy carp_suppress_preempt--;
1106 1.1 liamjfoy sc->sc_sendad_errors = 0;
1107 1.1 liamjfoy }
1108 1.1 liamjfoy } else
1109 1.1 liamjfoy sc->sc_sendad_errors = 0;
1110 1.1 liamjfoy }
1111 1.1 liamjfoy }
1112 1.1 liamjfoy #endif /* INET6 */
1113 1.1 liamjfoy
1114 1.1 liamjfoy retry_later:
1115 1.1 liamjfoy splx(s);
1116 1.1 liamjfoy if (advbase != 255 || advskew != 255)
1117 1.1 liamjfoy callout_schedule(&sc->sc_ad_tmo, tvtohz(&tv));
1118 1.1 liamjfoy }
1119 1.1 liamjfoy
1120 1.1 liamjfoy /*
1121 1.1 liamjfoy * Broadcast a gratuitous ARP request containing
1122 1.1 liamjfoy * the virtual router MAC address for each IP address
1123 1.1 liamjfoy * associated with the virtual router.
1124 1.1 liamjfoy */
1125 1.1 liamjfoy void
1126 1.1 liamjfoy carp_send_arp(struct carp_softc *sc)
1127 1.1 liamjfoy {
1128 1.1 liamjfoy struct ifaddr *ifa;
1129 1.1 liamjfoy struct in_addr *in;
1130 1.1 liamjfoy int s = splsoftnet();
1131 1.1 liamjfoy
1132 1.19 dyoung IFADDR_FOREACH(ifa, &sc->sc_if) {
1133 1.1 liamjfoy
1134 1.1 liamjfoy if (ifa->ifa_addr->sa_family != AF_INET)
1135 1.1 liamjfoy continue;
1136 1.1 liamjfoy
1137 1.1 liamjfoy in = &ifatoia(ifa)->ia_addr.sin_addr;
1138 1.16 dyoung arprequest(sc->sc_carpdev, in, in, CLLADDR(sc->sc_if.if_sadl));
1139 1.1 liamjfoy DELAY(1000); /* XXX */
1140 1.1 liamjfoy }
1141 1.1 liamjfoy splx(s);
1142 1.1 liamjfoy }
1143 1.1 liamjfoy
1144 1.1 liamjfoy #ifdef INET6
1145 1.1 liamjfoy void
1146 1.1 liamjfoy carp_send_na(struct carp_softc *sc)
1147 1.1 liamjfoy {
1148 1.1 liamjfoy struct ifaddr *ifa;
1149 1.1 liamjfoy struct in6_addr *in6;
1150 1.1 liamjfoy static struct in6_addr mcast = IN6ADDR_LINKLOCAL_ALLNODES_INIT;
1151 1.1 liamjfoy int s = splsoftnet();
1152 1.1 liamjfoy
1153 1.19 dyoung IFADDR_FOREACH(ifa, &sc->sc_if) {
1154 1.1 liamjfoy
1155 1.1 liamjfoy if (ifa->ifa_addr->sa_family != AF_INET6)
1156 1.1 liamjfoy continue;
1157 1.1 liamjfoy
1158 1.1 liamjfoy in6 = &ifatoia6(ifa)->ia_addr.sin6_addr;
1159 1.1 liamjfoy nd6_na_output(sc->sc_carpdev, &mcast, in6,
1160 1.1 liamjfoy ND_NA_FLAG_OVERRIDE, 1, NULL);
1161 1.1 liamjfoy DELAY(1000); /* XXX */
1162 1.1 liamjfoy }
1163 1.1 liamjfoy splx(s);
1164 1.1 liamjfoy }
1165 1.1 liamjfoy #endif /* INET6 */
1166 1.1 liamjfoy
1167 1.1 liamjfoy /*
1168 1.1 liamjfoy * Based on bridge_hash() in if_bridge.c
1169 1.1 liamjfoy */
1170 1.1 liamjfoy #define mix(a,b,c) \
1171 1.1 liamjfoy do { \
1172 1.1 liamjfoy a -= b; a -= c; a ^= (c >> 13); \
1173 1.1 liamjfoy b -= c; b -= a; b ^= (a << 8); \
1174 1.1 liamjfoy c -= a; c -= b; c ^= (b >> 13); \
1175 1.1 liamjfoy a -= b; a -= c; a ^= (c >> 12); \
1176 1.1 liamjfoy b -= c; b -= a; b ^= (a << 16); \
1177 1.1 liamjfoy c -= a; c -= b; c ^= (b >> 5); \
1178 1.1 liamjfoy a -= b; a -= c; a ^= (c >> 3); \
1179 1.1 liamjfoy b -= c; b -= a; b ^= (a << 10); \
1180 1.1 liamjfoy c -= a; c -= b; c ^= (b >> 15); \
1181 1.1 liamjfoy } while (0)
1182 1.1 liamjfoy
1183 1.1 liamjfoy u_int32_t
1184 1.1 liamjfoy carp_hash(struct carp_softc *sc, u_char *src)
1185 1.1 liamjfoy {
1186 1.1 liamjfoy u_int32_t a = 0x9e3779b9, b = sc->sc_hashkey[0], c = sc->sc_hashkey[1];
1187 1.1 liamjfoy
1188 1.1 liamjfoy c += sc->sc_key[3] << 24;
1189 1.1 liamjfoy c += sc->sc_key[2] << 16;
1190 1.1 liamjfoy c += sc->sc_key[1] << 8;
1191 1.1 liamjfoy c += sc->sc_key[0];
1192 1.1 liamjfoy b += src[5] << 8;
1193 1.1 liamjfoy b += src[4];
1194 1.1 liamjfoy a += src[3] << 24;
1195 1.1 liamjfoy a += src[2] << 16;
1196 1.1 liamjfoy a += src[1] << 8;
1197 1.1 liamjfoy a += src[0];
1198 1.1 liamjfoy
1199 1.1 liamjfoy mix(a, b, c);
1200 1.1 liamjfoy return (c);
1201 1.1 liamjfoy }
1202 1.1 liamjfoy
1203 1.1 liamjfoy int
1204 1.1 liamjfoy carp_addrcount(struct carp_if *cif, struct in_ifaddr *ia, int type)
1205 1.1 liamjfoy {
1206 1.1 liamjfoy struct carp_softc *vh;
1207 1.1 liamjfoy struct ifaddr *ifa;
1208 1.1 liamjfoy int count = 0;
1209 1.1 liamjfoy
1210 1.1 liamjfoy TAILQ_FOREACH(vh, &cif->vhif_vrs, sc_list) {
1211 1.1 liamjfoy if ((type == CARP_COUNT_RUNNING &&
1212 1.1 liamjfoy (vh->sc_if.if_flags & (IFF_UP|IFF_RUNNING)) ==
1213 1.1 liamjfoy (IFF_UP|IFF_RUNNING)) ||
1214 1.1 liamjfoy (type == CARP_COUNT_MASTER && vh->sc_state == MASTER)) {
1215 1.19 dyoung IFADDR_FOREACH(ifa, &vh->sc_if) {
1216 1.1 liamjfoy if (ifa->ifa_addr->sa_family == AF_INET &&
1217 1.1 liamjfoy ia->ia_addr.sin_addr.s_addr ==
1218 1.1 liamjfoy ifatoia(ifa)->ia_addr.sin_addr.s_addr)
1219 1.1 liamjfoy count++;
1220 1.1 liamjfoy }
1221 1.1 liamjfoy }
1222 1.1 liamjfoy }
1223 1.1 liamjfoy return (count);
1224 1.1 liamjfoy }
1225 1.1 liamjfoy
1226 1.1 liamjfoy int
1227 1.1 liamjfoy carp_iamatch(struct in_ifaddr *ia, u_char *src,
1228 1.1 liamjfoy u_int32_t *count, u_int32_t index)
1229 1.1 liamjfoy {
1230 1.1 liamjfoy struct carp_softc *sc = ia->ia_ifp->if_softc;
1231 1.1 liamjfoy
1232 1.1 liamjfoy if (carp_opts[CARPCTL_ARPBALANCE]) {
1233 1.1 liamjfoy /*
1234 1.1 liamjfoy * We use the source ip to decide which virtual host should
1235 1.1 liamjfoy * handle the request. If we're master of that virtual host,
1236 1.1 liamjfoy * then we respond, otherwise, just drop the arp packet on
1237 1.1 liamjfoy * the floor.
1238 1.1 liamjfoy */
1239 1.1 liamjfoy
1240 1.1 liamjfoy /* Count the elegible carp interfaces with this address */
1241 1.1 liamjfoy if (*count == 0)
1242 1.1 liamjfoy *count = carp_addrcount(
1243 1.1 liamjfoy (struct carp_if *)ia->ia_ifp->if_carpdev->if_carp,
1244 1.1 liamjfoy ia, CARP_COUNT_RUNNING);
1245 1.1 liamjfoy
1246 1.1 liamjfoy /* This should never happen, but... */
1247 1.1 liamjfoy if (*count == 0)
1248 1.1 liamjfoy return (0);
1249 1.1 liamjfoy
1250 1.1 liamjfoy if (carp_hash(sc, src) % *count == index - 1 &&
1251 1.1 liamjfoy sc->sc_state == MASTER) {
1252 1.1 liamjfoy return (1);
1253 1.1 liamjfoy }
1254 1.1 liamjfoy } else {
1255 1.1 liamjfoy if (sc->sc_state == MASTER)
1256 1.1 liamjfoy return (1);
1257 1.1 liamjfoy }
1258 1.1 liamjfoy
1259 1.1 liamjfoy return (0);
1260 1.1 liamjfoy }
1261 1.1 liamjfoy
1262 1.1 liamjfoy #ifdef INET6
1263 1.1 liamjfoy struct ifaddr *
1264 1.1 liamjfoy carp_iamatch6(void *v, struct in6_addr *taddr)
1265 1.1 liamjfoy {
1266 1.1 liamjfoy struct carp_if *cif = v;
1267 1.1 liamjfoy struct carp_softc *vh;
1268 1.1 liamjfoy struct ifaddr *ifa;
1269 1.1 liamjfoy
1270 1.1 liamjfoy TAILQ_FOREACH(vh, &cif->vhif_vrs, sc_list) {
1271 1.19 dyoung IFADDR_FOREACH(ifa, &vh->sc_if) {
1272 1.1 liamjfoy if (IN6_ARE_ADDR_EQUAL(taddr,
1273 1.1 liamjfoy &ifatoia6(ifa)->ia_addr.sin6_addr) &&
1274 1.1 liamjfoy ((vh->sc_if.if_flags & (IFF_UP|IFF_RUNNING)) ==
1275 1.1 liamjfoy (IFF_UP|IFF_RUNNING)) && vh->sc_state == MASTER)
1276 1.1 liamjfoy return (ifa);
1277 1.1 liamjfoy }
1278 1.1 liamjfoy }
1279 1.1 liamjfoy
1280 1.1 liamjfoy return (NULL);
1281 1.1 liamjfoy }
1282 1.1 liamjfoy #endif /* INET6 */
1283 1.1 liamjfoy
1284 1.1 liamjfoy struct ifnet *
1285 1.1 liamjfoy carp_ourether(void *v, struct ether_header *eh, u_char iftype, int src)
1286 1.1 liamjfoy {
1287 1.1 liamjfoy struct carp_if *cif = (struct carp_if *)v;
1288 1.1 liamjfoy struct carp_softc *vh;
1289 1.1 liamjfoy u_int8_t *ena;
1290 1.1 liamjfoy
1291 1.1 liamjfoy if (src)
1292 1.1 liamjfoy ena = (u_int8_t *)&eh->ether_shost;
1293 1.1 liamjfoy else
1294 1.1 liamjfoy ena = (u_int8_t *)&eh->ether_dhost;
1295 1.1 liamjfoy
1296 1.1 liamjfoy switch (iftype) {
1297 1.1 liamjfoy case IFT_ETHER:
1298 1.1 liamjfoy case IFT_FDDI:
1299 1.1 liamjfoy if (ena[0] || ena[1] || ena[2] != 0x5e || ena[3] || ena[4] != 1)
1300 1.1 liamjfoy return (NULL);
1301 1.1 liamjfoy break;
1302 1.1 liamjfoy case IFT_ISO88025:
1303 1.1 liamjfoy if (ena[0] != 3 || ena[1] || ena[4] || ena[5])
1304 1.1 liamjfoy return (NULL);
1305 1.1 liamjfoy break;
1306 1.1 liamjfoy default:
1307 1.1 liamjfoy return (NULL);
1308 1.1 liamjfoy break;
1309 1.1 liamjfoy }
1310 1.1 liamjfoy
1311 1.1 liamjfoy TAILQ_FOREACH(vh, &cif->vhif_vrs, sc_list)
1312 1.1 liamjfoy if ((vh->sc_if.if_flags & (IFF_UP|IFF_RUNNING)) ==
1313 1.1 liamjfoy (IFF_UP|IFF_RUNNING) && vh->sc_state == MASTER &&
1314 1.15 dyoung !bcmp(ena, CLLADDR(vh->sc_if.if_sadl),
1315 1.1 liamjfoy ETHER_ADDR_LEN)) {
1316 1.1 liamjfoy return (&vh->sc_if);
1317 1.1 liamjfoy }
1318 1.1 liamjfoy
1319 1.1 liamjfoy return (NULL);
1320 1.1 liamjfoy }
1321 1.1 liamjfoy
1322 1.1 liamjfoy int
1323 1.1 liamjfoy carp_input(struct mbuf *m, u_int8_t *shost, u_int8_t *dhost, u_int16_t etype)
1324 1.1 liamjfoy {
1325 1.1 liamjfoy struct ether_header eh;
1326 1.1 liamjfoy struct carp_if *cif = (struct carp_if *)m->m_pkthdr.rcvif->if_carp;
1327 1.1 liamjfoy struct ifnet *ifp;
1328 1.1 liamjfoy
1329 1.1 liamjfoy bcopy(shost, &eh.ether_shost, sizeof(eh.ether_shost));
1330 1.1 liamjfoy bcopy(dhost, &eh.ether_dhost, sizeof(eh.ether_dhost));
1331 1.1 liamjfoy eh.ether_type = etype;
1332 1.1 liamjfoy
1333 1.1 liamjfoy if (m->m_flags & (M_BCAST|M_MCAST)) {
1334 1.1 liamjfoy struct carp_softc *vh;
1335 1.1 liamjfoy struct mbuf *m0;
1336 1.1 liamjfoy
1337 1.1 liamjfoy /*
1338 1.1 liamjfoy * XXX Should really check the list of multicast addresses
1339 1.1 liamjfoy * for each CARP interface _before_ copying.
1340 1.1 liamjfoy */
1341 1.1 liamjfoy TAILQ_FOREACH(vh, &cif->vhif_vrs, sc_list) {
1342 1.1 liamjfoy m0 = m_copym(m, 0, M_COPYALL, M_DONTWAIT);
1343 1.1 liamjfoy if (m0 == NULL)
1344 1.1 liamjfoy continue;
1345 1.1 liamjfoy m0->m_pkthdr.rcvif = &vh->sc_if;
1346 1.1 liamjfoy ether_input(&vh->sc_if, m0);
1347 1.1 liamjfoy }
1348 1.1 liamjfoy return (1);
1349 1.1 liamjfoy }
1350 1.1 liamjfoy
1351 1.1 liamjfoy ifp = carp_ourether(cif, &eh, m->m_pkthdr.rcvif->if_type, 0);
1352 1.1 liamjfoy if (ifp == NULL) {
1353 1.1 liamjfoy return (1);
1354 1.1 liamjfoy }
1355 1.1 liamjfoy
1356 1.1 liamjfoy m->m_pkthdr.rcvif = ifp;
1357 1.1 liamjfoy
1358 1.1 liamjfoy #if NBPFILTER > 0
1359 1.1 liamjfoy if (ifp->if_bpf)
1360 1.1 liamjfoy bpf_mtap(ifp->if_bpf, m);
1361 1.1 liamjfoy #endif
1362 1.1 liamjfoy ifp->if_ipackets++;
1363 1.1 liamjfoy ether_input(ifp, m);
1364 1.1 liamjfoy return (0);
1365 1.1 liamjfoy }
1366 1.1 liamjfoy
1367 1.1 liamjfoy void
1368 1.1 liamjfoy carp_master_down(void *v)
1369 1.1 liamjfoy {
1370 1.1 liamjfoy struct carp_softc *sc = v;
1371 1.1 liamjfoy
1372 1.1 liamjfoy switch (sc->sc_state) {
1373 1.1 liamjfoy case INIT:
1374 1.1 liamjfoy printf("%s: master_down event in INIT state\n",
1375 1.1 liamjfoy sc->sc_if.if_xname);
1376 1.1 liamjfoy break;
1377 1.1 liamjfoy case MASTER:
1378 1.1 liamjfoy break;
1379 1.1 liamjfoy case BACKUP:
1380 1.1 liamjfoy carp_set_state(sc, MASTER);
1381 1.1 liamjfoy carp_send_ad(sc);
1382 1.1 liamjfoy carp_send_arp(sc);
1383 1.1 liamjfoy #ifdef INET6
1384 1.1 liamjfoy carp_send_na(sc);
1385 1.1 liamjfoy #endif /* INET6 */
1386 1.1 liamjfoy carp_setrun(sc, 0);
1387 1.1 liamjfoy carp_setroute(sc, RTM_ADD);
1388 1.1 liamjfoy break;
1389 1.1 liamjfoy }
1390 1.1 liamjfoy }
1391 1.1 liamjfoy
1392 1.1 liamjfoy /*
1393 1.1 liamjfoy * When in backup state, af indicates whether to reset the master down timer
1394 1.1 liamjfoy * for v4 or v6. If it's set to zero, reset the ones which are already pending.
1395 1.1 liamjfoy */
1396 1.1 liamjfoy void
1397 1.1 liamjfoy carp_setrun(struct carp_softc *sc, sa_family_t af)
1398 1.1 liamjfoy {
1399 1.1 liamjfoy struct timeval tv;
1400 1.1 liamjfoy
1401 1.1 liamjfoy if (sc->sc_carpdev == NULL) {
1402 1.1 liamjfoy sc->sc_if.if_flags &= ~IFF_RUNNING;
1403 1.1 liamjfoy carp_set_state(sc, INIT);
1404 1.1 liamjfoy return;
1405 1.1 liamjfoy }
1406 1.1 liamjfoy
1407 1.1 liamjfoy if (sc->sc_if.if_flags & IFF_UP && sc->sc_vhid > 0 &&
1408 1.1 liamjfoy (sc->sc_naddrs || sc->sc_naddrs6) && !sc->sc_suppress) {
1409 1.1 liamjfoy sc->sc_if.if_flags |= IFF_RUNNING;
1410 1.1 liamjfoy } else {
1411 1.1 liamjfoy sc->sc_if.if_flags &= ~IFF_RUNNING;
1412 1.1 liamjfoy carp_setroute(sc, RTM_DELETE);
1413 1.1 liamjfoy return;
1414 1.1 liamjfoy }
1415 1.1 liamjfoy
1416 1.1 liamjfoy switch (sc->sc_state) {
1417 1.1 liamjfoy case INIT:
1418 1.1 liamjfoy carp_set_state(sc, BACKUP);
1419 1.1 liamjfoy carp_setroute(sc, RTM_DELETE);
1420 1.1 liamjfoy carp_setrun(sc, 0);
1421 1.1 liamjfoy break;
1422 1.1 liamjfoy case BACKUP:
1423 1.1 liamjfoy callout_stop(&sc->sc_ad_tmo);
1424 1.1 liamjfoy tv.tv_sec = 3 * sc->sc_advbase;
1425 1.1 liamjfoy tv.tv_usec = sc->sc_advskew * 1000000 / 256;
1426 1.1 liamjfoy switch (af) {
1427 1.1 liamjfoy #ifdef INET
1428 1.1 liamjfoy case AF_INET:
1429 1.1 liamjfoy callout_schedule(&sc->sc_md_tmo, tvtohz(&tv));
1430 1.1 liamjfoy break;
1431 1.1 liamjfoy #endif /* INET */
1432 1.1 liamjfoy #ifdef INET6
1433 1.1 liamjfoy case AF_INET6:
1434 1.1 liamjfoy callout_schedule(&sc->sc_md6_tmo, tvtohz(&tv));
1435 1.1 liamjfoy break;
1436 1.1 liamjfoy #endif /* INET6 */
1437 1.1 liamjfoy default:
1438 1.1 liamjfoy if (sc->sc_naddrs)
1439 1.1 liamjfoy callout_schedule(&sc->sc_md_tmo, tvtohz(&tv));
1440 1.1 liamjfoy if (sc->sc_naddrs6)
1441 1.1 liamjfoy callout_schedule(&sc->sc_md6_tmo, tvtohz(&tv));
1442 1.1 liamjfoy break;
1443 1.1 liamjfoy }
1444 1.1 liamjfoy break;
1445 1.1 liamjfoy case MASTER:
1446 1.1 liamjfoy tv.tv_sec = sc->sc_advbase;
1447 1.1 liamjfoy tv.tv_usec = sc->sc_advskew * 1000000 / 256;
1448 1.1 liamjfoy callout_schedule(&sc->sc_ad_tmo, tvtohz(&tv));
1449 1.1 liamjfoy break;
1450 1.1 liamjfoy }
1451 1.1 liamjfoy }
1452 1.1 liamjfoy
1453 1.1 liamjfoy void
1454 1.1 liamjfoy carp_multicast_cleanup(struct carp_softc *sc)
1455 1.1 liamjfoy {
1456 1.1 liamjfoy struct ip_moptions *imo = &sc->sc_imo;
1457 1.1 liamjfoy #ifdef INET6
1458 1.1 liamjfoy struct ip6_moptions *im6o = &sc->sc_im6o;
1459 1.1 liamjfoy #endif
1460 1.1 liamjfoy u_int16_t n = imo->imo_num_memberships;
1461 1.1 liamjfoy
1462 1.1 liamjfoy /* Clean up our own multicast memberships */
1463 1.1 liamjfoy while (n-- > 0) {
1464 1.1 liamjfoy if (imo->imo_membership[n] != NULL) {
1465 1.1 liamjfoy in_delmulti(imo->imo_membership[n]);
1466 1.1 liamjfoy imo->imo_membership[n] = NULL;
1467 1.1 liamjfoy }
1468 1.1 liamjfoy }
1469 1.1 liamjfoy imo->imo_num_memberships = 0;
1470 1.1 liamjfoy imo->imo_multicast_ifp = NULL;
1471 1.1 liamjfoy
1472 1.1 liamjfoy #ifdef INET6
1473 1.1 liamjfoy while (!LIST_EMPTY(&im6o->im6o_memberships)) {
1474 1.1 liamjfoy struct in6_multi_mship *imm =
1475 1.1 liamjfoy LIST_FIRST(&im6o->im6o_memberships);
1476 1.1 liamjfoy
1477 1.1 liamjfoy LIST_REMOVE(imm, i6mm_chain);
1478 1.1 liamjfoy in6_leavegroup(imm);
1479 1.1 liamjfoy }
1480 1.1 liamjfoy im6o->im6o_multicast_ifp = NULL;
1481 1.1 liamjfoy #endif
1482 1.1 liamjfoy
1483 1.1 liamjfoy /* And any other multicast memberships */
1484 1.1 liamjfoy carp_ether_purgemulti(sc);
1485 1.1 liamjfoy }
1486 1.1 liamjfoy
1487 1.1 liamjfoy int
1488 1.1 liamjfoy carp_set_ifp(struct carp_softc *sc, struct ifnet *ifp)
1489 1.1 liamjfoy {
1490 1.1 liamjfoy struct carp_if *cif, *ncif = NULL;
1491 1.1 liamjfoy struct carp_softc *vr, *after = NULL;
1492 1.1 liamjfoy int myself = 0, error = 0;
1493 1.1 liamjfoy int s;
1494 1.1 liamjfoy
1495 1.1 liamjfoy if (ifp == sc->sc_carpdev)
1496 1.1 liamjfoy return (0);
1497 1.1 liamjfoy
1498 1.1 liamjfoy if (ifp != NULL) {
1499 1.1 liamjfoy if ((ifp->if_flags & IFF_MULTICAST) == 0)
1500 1.1 liamjfoy return (EADDRNOTAVAIL);
1501 1.1 liamjfoy
1502 1.1 liamjfoy if (ifp->if_type == IFT_CARP)
1503 1.1 liamjfoy return (EINVAL);
1504 1.1 liamjfoy
1505 1.1 liamjfoy if (ifp->if_carp == NULL) {
1506 1.1 liamjfoy MALLOC(ncif, struct carp_if *, sizeof(*cif),
1507 1.1 liamjfoy M_IFADDR, M_NOWAIT);
1508 1.1 liamjfoy if (ncif == NULL)
1509 1.1 liamjfoy return (ENOBUFS);
1510 1.1 liamjfoy if ((error = ifpromisc(ifp, 1))) {
1511 1.1 liamjfoy FREE(ncif, M_IFADDR);
1512 1.1 liamjfoy return (error);
1513 1.1 liamjfoy }
1514 1.1 liamjfoy
1515 1.1 liamjfoy ncif->vhif_ifp = ifp;
1516 1.1 liamjfoy TAILQ_INIT(&ncif->vhif_vrs);
1517 1.1 liamjfoy } else {
1518 1.1 liamjfoy cif = (struct carp_if *)ifp->if_carp;
1519 1.1 liamjfoy TAILQ_FOREACH(vr, &cif->vhif_vrs, sc_list)
1520 1.1 liamjfoy if (vr != sc && vr->sc_vhid == sc->sc_vhid)
1521 1.1 liamjfoy return (EINVAL);
1522 1.1 liamjfoy }
1523 1.1 liamjfoy
1524 1.1 liamjfoy /* detach from old interface */
1525 1.1 liamjfoy if (sc->sc_carpdev != NULL)
1526 1.1 liamjfoy carpdetach(sc);
1527 1.1 liamjfoy
1528 1.1 liamjfoy /* join multicast groups */
1529 1.1 liamjfoy if (sc->sc_naddrs < 0 &&
1530 1.1 liamjfoy (error = carp_join_multicast(sc)) != 0) {
1531 1.1 liamjfoy if (ncif != NULL)
1532 1.1 liamjfoy FREE(ncif, M_IFADDR);
1533 1.1 liamjfoy return (error);
1534 1.1 liamjfoy }
1535 1.1 liamjfoy
1536 1.1 liamjfoy #ifdef INET6
1537 1.1 liamjfoy if (sc->sc_naddrs6 < 0 &&
1538 1.1 liamjfoy (error = carp_join_multicast6(sc)) != 0) {
1539 1.1 liamjfoy if (ncif != NULL)
1540 1.1 liamjfoy FREE(ncif, M_IFADDR);
1541 1.1 liamjfoy carp_multicast_cleanup(sc);
1542 1.1 liamjfoy return (error);
1543 1.1 liamjfoy }
1544 1.1 liamjfoy #endif
1545 1.1 liamjfoy
1546 1.1 liamjfoy /* attach carp interface to physical interface */
1547 1.1 liamjfoy if (ncif != NULL)
1548 1.12 christos ifp->if_carp = (void *)ncif;
1549 1.1 liamjfoy sc->sc_carpdev = ifp;
1550 1.1 liamjfoy cif = (struct carp_if *)ifp->if_carp;
1551 1.1 liamjfoy TAILQ_FOREACH(vr, &cif->vhif_vrs, sc_list) {
1552 1.1 liamjfoy if (vr == sc)
1553 1.1 liamjfoy myself = 1;
1554 1.1 liamjfoy if (vr->sc_vhid < sc->sc_vhid)
1555 1.1 liamjfoy after = vr;
1556 1.1 liamjfoy }
1557 1.1 liamjfoy
1558 1.1 liamjfoy if (!myself) {
1559 1.1 liamjfoy /* We're trying to keep things in order */
1560 1.1 liamjfoy if (after == NULL) {
1561 1.1 liamjfoy TAILQ_INSERT_TAIL(&cif->vhif_vrs, sc, sc_list);
1562 1.1 liamjfoy } else {
1563 1.1 liamjfoy TAILQ_INSERT_AFTER(&cif->vhif_vrs, after,
1564 1.1 liamjfoy sc, sc_list);
1565 1.1 liamjfoy }
1566 1.1 liamjfoy cif->vhif_nvrs++;
1567 1.1 liamjfoy }
1568 1.1 liamjfoy if (sc->sc_naddrs || sc->sc_naddrs6)
1569 1.1 liamjfoy sc->sc_if.if_flags |= IFF_UP;
1570 1.1 liamjfoy carp_set_enaddr(sc);
1571 1.1 liamjfoy s = splnet();
1572 1.1 liamjfoy /* XXX linkstatehooks establish */
1573 1.1 liamjfoy carp_carpdev_state(ifp);
1574 1.1 liamjfoy splx(s);
1575 1.1 liamjfoy } else {
1576 1.1 liamjfoy carpdetach(sc);
1577 1.1 liamjfoy sc->sc_if.if_flags &= ~(IFF_UP|IFF_RUNNING);
1578 1.1 liamjfoy }
1579 1.1 liamjfoy return (0);
1580 1.1 liamjfoy }
1581 1.1 liamjfoy
1582 1.1 liamjfoy void
1583 1.1 liamjfoy carp_set_enaddr(struct carp_softc *sc)
1584 1.1 liamjfoy {
1585 1.16 dyoung uint8_t enaddr[ETHER_ADDR_LEN];
1586 1.1 liamjfoy if (sc->sc_carpdev && sc->sc_carpdev->if_type == IFT_ISO88025) {
1587 1.16 dyoung enaddr[0] = 3;
1588 1.16 dyoung enaddr[1] = 0;
1589 1.16 dyoung enaddr[2] = 0x40 >> (sc->sc_vhid - 1);
1590 1.16 dyoung enaddr[3] = 0x40000 >> (sc->sc_vhid - 1);
1591 1.16 dyoung enaddr[4] = 0;
1592 1.16 dyoung enaddr[5] = 0;
1593 1.1 liamjfoy } else {
1594 1.16 dyoung enaddr[0] = 0;
1595 1.16 dyoung enaddr[1] = 0;
1596 1.16 dyoung enaddr[2] = 0x5e;
1597 1.16 dyoung enaddr[3] = 0;
1598 1.16 dyoung enaddr[4] = 1;
1599 1.16 dyoung enaddr[5] = sc->sc_vhid;
1600 1.1 liamjfoy }
1601 1.21 dyoung if_set_sadl(&sc->sc_if, enaddr, sizeof(enaddr));
1602 1.1 liamjfoy }
1603 1.1 liamjfoy
1604 1.1 liamjfoy void
1605 1.1 liamjfoy carp_addr_updated(void *v)
1606 1.1 liamjfoy {
1607 1.1 liamjfoy struct carp_softc *sc = (struct carp_softc *) v;
1608 1.1 liamjfoy struct ifaddr *ifa;
1609 1.1 liamjfoy int new_naddrs = 0, new_naddrs6 = 0;
1610 1.1 liamjfoy
1611 1.19 dyoung IFADDR_FOREACH(ifa, &sc->sc_if) {
1612 1.1 liamjfoy if (ifa->ifa_addr->sa_family == AF_INET)
1613 1.1 liamjfoy new_naddrs++;
1614 1.1 liamjfoy else if (ifa->ifa_addr->sa_family == AF_INET6)
1615 1.1 liamjfoy new_naddrs6++;
1616 1.1 liamjfoy }
1617 1.1 liamjfoy
1618 1.1 liamjfoy /* Handle a callback after SIOCDIFADDR */
1619 1.1 liamjfoy if (new_naddrs < sc->sc_naddrs || new_naddrs6 < sc->sc_naddrs6) {
1620 1.1 liamjfoy struct in_addr mc_addr;
1621 1.1 liamjfoy struct in_multi *inm;
1622 1.1 liamjfoy
1623 1.1 liamjfoy sc->sc_naddrs = new_naddrs;
1624 1.1 liamjfoy sc->sc_naddrs6 = new_naddrs6;
1625 1.1 liamjfoy
1626 1.1 liamjfoy /* Re-establish multicast membership removed by in_control */
1627 1.1 liamjfoy mc_addr.s_addr = INADDR_CARP_GROUP;
1628 1.1 liamjfoy IN_LOOKUP_MULTI(mc_addr, &sc->sc_if, inm);
1629 1.1 liamjfoy if (inm == NULL) {
1630 1.1 liamjfoy bzero(&sc->sc_imo, sizeof(sc->sc_imo));
1631 1.1 liamjfoy
1632 1.1 liamjfoy if (sc->sc_carpdev != NULL && sc->sc_naddrs > 0)
1633 1.1 liamjfoy carp_join_multicast(sc);
1634 1.1 liamjfoy }
1635 1.1 liamjfoy
1636 1.1 liamjfoy if (sc->sc_naddrs == 0 && sc->sc_naddrs6 == 0) {
1637 1.1 liamjfoy sc->sc_if.if_flags &= ~IFF_UP;
1638 1.1 liamjfoy carp_set_state(sc, INIT);
1639 1.1 liamjfoy } else
1640 1.1 liamjfoy carp_hmac_prepare(sc);
1641 1.1 liamjfoy }
1642 1.1 liamjfoy
1643 1.1 liamjfoy carp_setrun(sc, 0);
1644 1.1 liamjfoy }
1645 1.1 liamjfoy
1646 1.1 liamjfoy int
1647 1.1 liamjfoy carp_set_addr(struct carp_softc *sc, struct sockaddr_in *sin)
1648 1.1 liamjfoy {
1649 1.1 liamjfoy struct ifnet *ifp = sc->sc_carpdev;
1650 1.1 liamjfoy struct in_ifaddr *ia, *ia_if;
1651 1.1 liamjfoy int error = 0;
1652 1.1 liamjfoy
1653 1.1 liamjfoy if (sin->sin_addr.s_addr == 0) {
1654 1.1 liamjfoy if (!(sc->sc_if.if_flags & IFF_UP))
1655 1.1 liamjfoy carp_set_state(sc, INIT);
1656 1.1 liamjfoy if (sc->sc_naddrs)
1657 1.1 liamjfoy sc->sc_if.if_flags |= IFF_UP;
1658 1.1 liamjfoy carp_setrun(sc, 0);
1659 1.1 liamjfoy return (0);
1660 1.1 liamjfoy }
1661 1.1 liamjfoy
1662 1.1 liamjfoy /* we have to do this by hand to ensure we don't match on ourselves */
1663 1.1 liamjfoy ia_if = NULL;
1664 1.1 liamjfoy for (ia = TAILQ_FIRST(&in_ifaddrhead); ia;
1665 1.1 liamjfoy ia = TAILQ_NEXT(ia, ia_list)) {
1666 1.1 liamjfoy
1667 1.1 liamjfoy /* and, yeah, we need a multicast-capable iface too */
1668 1.1 liamjfoy if (ia->ia_ifp != &sc->sc_if &&
1669 1.1 liamjfoy ia->ia_ifp->if_type != IFT_CARP &&
1670 1.1 liamjfoy (ia->ia_ifp->if_flags & IFF_MULTICAST) &&
1671 1.1 liamjfoy (sin->sin_addr.s_addr & ia->ia_subnetmask) ==
1672 1.1 liamjfoy ia->ia_subnet) {
1673 1.1 liamjfoy if (!ia_if)
1674 1.1 liamjfoy ia_if = ia;
1675 1.1 liamjfoy }
1676 1.1 liamjfoy }
1677 1.1 liamjfoy
1678 1.1 liamjfoy if (ia_if) {
1679 1.1 liamjfoy ia = ia_if;
1680 1.1 liamjfoy if (ifp) {
1681 1.1 liamjfoy if (ifp != ia->ia_ifp)
1682 1.1 liamjfoy return (EADDRNOTAVAIL);
1683 1.1 liamjfoy } else {
1684 1.1 liamjfoy ifp = ia->ia_ifp;
1685 1.1 liamjfoy }
1686 1.1 liamjfoy }
1687 1.1 liamjfoy
1688 1.1 liamjfoy if ((error = carp_set_ifp(sc, ifp)))
1689 1.1 liamjfoy return (error);
1690 1.1 liamjfoy
1691 1.1 liamjfoy if (sc->sc_carpdev == NULL)
1692 1.1 liamjfoy return (EADDRNOTAVAIL);
1693 1.1 liamjfoy
1694 1.1 liamjfoy if (sc->sc_naddrs == 0 && (error = carp_join_multicast(sc)) != 0)
1695 1.1 liamjfoy return (error);
1696 1.1 liamjfoy
1697 1.1 liamjfoy sc->sc_naddrs++;
1698 1.1 liamjfoy if (sc->sc_carpdev != NULL)
1699 1.1 liamjfoy sc->sc_if.if_flags |= IFF_UP;
1700 1.1 liamjfoy
1701 1.1 liamjfoy carp_set_state(sc, INIT);
1702 1.1 liamjfoy carp_setrun(sc, 0);
1703 1.1 liamjfoy
1704 1.1 liamjfoy /*
1705 1.1 liamjfoy * Hook if_addrhooks so that we get a callback after in_ifinit has run,
1706 1.1 liamjfoy * to correct any inappropriate routes that it inserted.
1707 1.1 liamjfoy */
1708 1.1 liamjfoy if (sc->ah_cookie == 0) {
1709 1.1 liamjfoy /* XXX link address hook */
1710 1.1 liamjfoy }
1711 1.1 liamjfoy
1712 1.1 liamjfoy return (0);
1713 1.1 liamjfoy }
1714 1.1 liamjfoy
1715 1.1 liamjfoy int
1716 1.1 liamjfoy carp_join_multicast(struct carp_softc *sc)
1717 1.1 liamjfoy {
1718 1.1 liamjfoy struct ip_moptions *imo = &sc->sc_imo, tmpimo;
1719 1.1 liamjfoy struct in_addr addr;
1720 1.1 liamjfoy
1721 1.1 liamjfoy bzero(&tmpimo, sizeof(tmpimo));
1722 1.1 liamjfoy addr.s_addr = INADDR_CARP_GROUP;
1723 1.1 liamjfoy if ((tmpimo.imo_membership[0] =
1724 1.1 liamjfoy in_addmulti(&addr, &sc->sc_if)) == NULL) {
1725 1.1 liamjfoy return (ENOBUFS);
1726 1.1 liamjfoy }
1727 1.1 liamjfoy
1728 1.1 liamjfoy imo->imo_membership[0] = tmpimo.imo_membership[0];
1729 1.1 liamjfoy imo->imo_num_memberships = 1;
1730 1.1 liamjfoy imo->imo_multicast_ifp = &sc->sc_if;
1731 1.1 liamjfoy imo->imo_multicast_ttl = CARP_DFLTTL;
1732 1.1 liamjfoy imo->imo_multicast_loop = 0;
1733 1.1 liamjfoy return (0);
1734 1.1 liamjfoy }
1735 1.1 liamjfoy
1736 1.1 liamjfoy
1737 1.1 liamjfoy #ifdef INET6
1738 1.1 liamjfoy int
1739 1.1 liamjfoy carp_set_addr6(struct carp_softc *sc, struct sockaddr_in6 *sin6)
1740 1.1 liamjfoy {
1741 1.1 liamjfoy struct ifnet *ifp = sc->sc_carpdev;
1742 1.1 liamjfoy struct in6_ifaddr *ia, *ia_if;
1743 1.1 liamjfoy int error = 0;
1744 1.1 liamjfoy
1745 1.1 liamjfoy if (IN6_IS_ADDR_UNSPECIFIED(&sin6->sin6_addr)) {
1746 1.1 liamjfoy if (!(sc->sc_if.if_flags & IFF_UP))
1747 1.1 liamjfoy carp_set_state(sc, INIT);
1748 1.1 liamjfoy if (sc->sc_naddrs6)
1749 1.1 liamjfoy sc->sc_if.if_flags |= IFF_UP;
1750 1.1 liamjfoy carp_setrun(sc, 0);
1751 1.1 liamjfoy return (0);
1752 1.1 liamjfoy }
1753 1.1 liamjfoy
1754 1.1 liamjfoy /* we have to do this by hand to ensure we don't match on ourselves */
1755 1.1 liamjfoy ia_if = NULL;
1756 1.1 liamjfoy for (ia = in6_ifaddr; ia; ia = ia->ia_next) {
1757 1.1 liamjfoy int i;
1758 1.1 liamjfoy
1759 1.1 liamjfoy for (i = 0; i < 4; i++) {
1760 1.1 liamjfoy if ((sin6->sin6_addr.s6_addr32[i] &
1761 1.1 liamjfoy ia->ia_prefixmask.sin6_addr.s6_addr32[i]) !=
1762 1.1 liamjfoy (ia->ia_addr.sin6_addr.s6_addr32[i] &
1763 1.1 liamjfoy ia->ia_prefixmask.sin6_addr.s6_addr32[i]))
1764 1.1 liamjfoy break;
1765 1.1 liamjfoy }
1766 1.1 liamjfoy /* and, yeah, we need a multicast-capable iface too */
1767 1.1 liamjfoy if (ia->ia_ifp != &sc->sc_if &&
1768 1.1 liamjfoy ia->ia_ifp->if_type != IFT_CARP &&
1769 1.1 liamjfoy (ia->ia_ifp->if_flags & IFF_MULTICAST) &&
1770 1.1 liamjfoy (i == 4)) {
1771 1.1 liamjfoy if (!ia_if)
1772 1.1 liamjfoy ia_if = ia;
1773 1.1 liamjfoy }
1774 1.1 liamjfoy }
1775 1.1 liamjfoy
1776 1.1 liamjfoy if (ia_if) {
1777 1.1 liamjfoy ia = ia_if;
1778 1.1 liamjfoy if (sc->sc_carpdev) {
1779 1.1 liamjfoy if (sc->sc_carpdev != ia->ia_ifp)
1780 1.1 liamjfoy return (EADDRNOTAVAIL);
1781 1.1 liamjfoy } else {
1782 1.1 liamjfoy ifp = ia->ia_ifp;
1783 1.1 liamjfoy }
1784 1.1 liamjfoy }
1785 1.1 liamjfoy
1786 1.1 liamjfoy if ((error = carp_set_ifp(sc, ifp)))
1787 1.1 liamjfoy return (error);
1788 1.1 liamjfoy
1789 1.1 liamjfoy if (sc->sc_carpdev == NULL)
1790 1.1 liamjfoy return (EADDRNOTAVAIL);
1791 1.1 liamjfoy
1792 1.1 liamjfoy if (sc->sc_naddrs6 == 0 && (error = carp_join_multicast6(sc)) != 0)
1793 1.1 liamjfoy return (error);
1794 1.1 liamjfoy
1795 1.1 liamjfoy sc->sc_naddrs6++;
1796 1.1 liamjfoy if (sc->sc_carpdev != NULL)
1797 1.1 liamjfoy sc->sc_if.if_flags |= IFF_UP;
1798 1.1 liamjfoy carp_set_state(sc, INIT);
1799 1.1 liamjfoy carp_setrun(sc, 0);
1800 1.1 liamjfoy
1801 1.1 liamjfoy return (0);
1802 1.1 liamjfoy }
1803 1.1 liamjfoy
1804 1.1 liamjfoy int
1805 1.1 liamjfoy carp_join_multicast6(struct carp_softc *sc)
1806 1.1 liamjfoy {
1807 1.1 liamjfoy struct in6_multi_mship *imm, *imm2;
1808 1.1 liamjfoy struct ip6_moptions *im6o = &sc->sc_im6o;
1809 1.1 liamjfoy struct sockaddr_in6 addr6;
1810 1.1 liamjfoy int error;
1811 1.1 liamjfoy
1812 1.1 liamjfoy /* Join IPv6 CARP multicast group */
1813 1.1 liamjfoy bzero(&addr6, sizeof(addr6));
1814 1.1 liamjfoy addr6.sin6_family = AF_INET6;
1815 1.1 liamjfoy addr6.sin6_len = sizeof(addr6);
1816 1.1 liamjfoy addr6.sin6_addr.s6_addr16[0] = htons(0xff02);
1817 1.1 liamjfoy addr6.sin6_addr.s6_addr16[1] = htons(sc->sc_if.if_index);
1818 1.1 liamjfoy addr6.sin6_addr.s6_addr8[15] = 0x12;
1819 1.1 liamjfoy if ((imm = in6_joingroup(&sc->sc_if,
1820 1.1 liamjfoy &addr6.sin6_addr, &error, 0)) == NULL) {
1821 1.1 liamjfoy return (error);
1822 1.1 liamjfoy }
1823 1.1 liamjfoy /* join solicited multicast address */
1824 1.1 liamjfoy bzero(&addr6.sin6_addr, sizeof(addr6.sin6_addr));
1825 1.1 liamjfoy addr6.sin6_addr.s6_addr16[0] = htons(0xff02);
1826 1.1 liamjfoy addr6.sin6_addr.s6_addr16[1] = htons(sc->sc_if.if_index);
1827 1.1 liamjfoy addr6.sin6_addr.s6_addr32[1] = 0;
1828 1.1 liamjfoy addr6.sin6_addr.s6_addr32[2] = htonl(1);
1829 1.1 liamjfoy addr6.sin6_addr.s6_addr32[3] = 0;
1830 1.1 liamjfoy addr6.sin6_addr.s6_addr8[12] = 0xff;
1831 1.1 liamjfoy if ((imm2 = in6_joingroup(&sc->sc_if,
1832 1.1 liamjfoy &addr6.sin6_addr, &error, 0)) == NULL) {
1833 1.1 liamjfoy in6_leavegroup(imm);
1834 1.1 liamjfoy return (error);
1835 1.1 liamjfoy }
1836 1.1 liamjfoy
1837 1.1 liamjfoy /* apply v6 multicast membership */
1838 1.1 liamjfoy im6o->im6o_multicast_ifp = &sc->sc_if;
1839 1.1 liamjfoy if (imm)
1840 1.1 liamjfoy LIST_INSERT_HEAD(&im6o->im6o_memberships, imm,
1841 1.1 liamjfoy i6mm_chain);
1842 1.1 liamjfoy if (imm2)
1843 1.1 liamjfoy LIST_INSERT_HEAD(&im6o->im6o_memberships, imm2,
1844 1.1 liamjfoy i6mm_chain);
1845 1.1 liamjfoy
1846 1.1 liamjfoy return (0);
1847 1.1 liamjfoy }
1848 1.1 liamjfoy
1849 1.1 liamjfoy #endif /* INET6 */
1850 1.1 liamjfoy
1851 1.1 liamjfoy int
1852 1.12 christos carp_ioctl(struct ifnet *ifp, u_long cmd, void *addr)
1853 1.1 liamjfoy {
1854 1.5 ad struct lwp *l = curlwp; /* XXX */
1855 1.1 liamjfoy struct carp_softc *sc = ifp->if_softc, *vr;
1856 1.1 liamjfoy struct carpreq carpr;
1857 1.1 liamjfoy struct ifaddr *ifa;
1858 1.1 liamjfoy struct ifreq *ifr;
1859 1.1 liamjfoy struct ifnet *cdev = NULL;
1860 1.1 liamjfoy int error = 0;
1861 1.1 liamjfoy
1862 1.1 liamjfoy ifa = (struct ifaddr *)addr;
1863 1.1 liamjfoy ifr = (struct ifreq *)addr;
1864 1.1 liamjfoy
1865 1.1 liamjfoy switch (cmd) {
1866 1.1 liamjfoy case SIOCSIFADDR:
1867 1.1 liamjfoy switch (ifa->ifa_addr->sa_family) {
1868 1.1 liamjfoy #ifdef INET
1869 1.1 liamjfoy case AF_INET:
1870 1.1 liamjfoy sc->sc_if.if_flags |= IFF_UP;
1871 1.1 liamjfoy bcopy(ifa->ifa_addr, ifa->ifa_dstaddr,
1872 1.1 liamjfoy sizeof(struct sockaddr));
1873 1.1 liamjfoy error = carp_set_addr(sc, satosin(ifa->ifa_addr));
1874 1.1 liamjfoy break;
1875 1.1 liamjfoy #endif /* INET */
1876 1.1 liamjfoy #ifdef INET6
1877 1.1 liamjfoy case AF_INET6:
1878 1.1 liamjfoy sc->sc_if.if_flags|= IFF_UP;
1879 1.1 liamjfoy error = carp_set_addr6(sc, satosin6(ifa->ifa_addr));
1880 1.1 liamjfoy break;
1881 1.1 liamjfoy #endif /* INET6 */
1882 1.1 liamjfoy default:
1883 1.1 liamjfoy error = EAFNOSUPPORT;
1884 1.1 liamjfoy break;
1885 1.1 liamjfoy }
1886 1.1 liamjfoy break;
1887 1.1 liamjfoy
1888 1.1 liamjfoy case SIOCSIFFLAGS:
1889 1.1 liamjfoy if (sc->sc_state != INIT && !(ifr->ifr_flags & IFF_UP)) {
1890 1.1 liamjfoy callout_stop(&sc->sc_ad_tmo);
1891 1.1 liamjfoy callout_stop(&sc->sc_md_tmo);
1892 1.1 liamjfoy callout_stop(&sc->sc_md6_tmo);
1893 1.1 liamjfoy if (sc->sc_state == MASTER) {
1894 1.1 liamjfoy /* we need the interface up to bow out */
1895 1.1 liamjfoy sc->sc_if.if_flags |= IFF_UP;
1896 1.1 liamjfoy sc->sc_bow_out = 1;
1897 1.1 liamjfoy carp_send_ad(sc);
1898 1.1 liamjfoy }
1899 1.1 liamjfoy sc->sc_if.if_flags &= ~IFF_UP;
1900 1.1 liamjfoy carp_set_state(sc, INIT);
1901 1.1 liamjfoy carp_setrun(sc, 0);
1902 1.1 liamjfoy } else if (sc->sc_state == INIT && (ifr->ifr_flags & IFF_UP)) {
1903 1.1 liamjfoy sc->sc_if.if_flags |= IFF_UP;
1904 1.1 liamjfoy carp_setrun(sc, 0);
1905 1.1 liamjfoy }
1906 1.1 liamjfoy break;
1907 1.1 liamjfoy
1908 1.1 liamjfoy case SIOCSVH:
1909 1.8 elad if (l == NULL)
1910 1.8 elad break;
1911 1.8 elad if ((error = kauth_authorize_network(l->l_cred,
1912 1.8 elad KAUTH_NETWORK_INTERFACE,
1913 1.9 christos KAUTH_REQ_NETWORK_INTERFACE_SETPRIV, ifp, (void *)cmd,
1914 1.8 elad NULL)) != 0)
1915 1.1 liamjfoy break;
1916 1.1 liamjfoy if ((error = copyin(ifr->ifr_data, &carpr, sizeof carpr)))
1917 1.1 liamjfoy break;
1918 1.1 liamjfoy error = 1;
1919 1.1 liamjfoy if (carpr.carpr_carpdev[0] != '\0' &&
1920 1.1 liamjfoy (cdev = ifunit(carpr.carpr_carpdev)) == NULL)
1921 1.1 liamjfoy return (EINVAL);
1922 1.1 liamjfoy if ((error = carp_set_ifp(sc, cdev)))
1923 1.1 liamjfoy return (error);
1924 1.1 liamjfoy if (sc->sc_state != INIT && carpr.carpr_state != sc->sc_state) {
1925 1.1 liamjfoy switch (carpr.carpr_state) {
1926 1.1 liamjfoy case BACKUP:
1927 1.1 liamjfoy callout_stop(&sc->sc_ad_tmo);
1928 1.1 liamjfoy carp_set_state(sc, BACKUP);
1929 1.1 liamjfoy carp_setrun(sc, 0);
1930 1.1 liamjfoy carp_setroute(sc, RTM_DELETE);
1931 1.1 liamjfoy break;
1932 1.1 liamjfoy case MASTER:
1933 1.1 liamjfoy carp_master_down(sc);
1934 1.1 liamjfoy break;
1935 1.1 liamjfoy default:
1936 1.1 liamjfoy break;
1937 1.1 liamjfoy }
1938 1.1 liamjfoy }
1939 1.1 liamjfoy if (carpr.carpr_vhid > 0) {
1940 1.1 liamjfoy if (carpr.carpr_vhid > 255) {
1941 1.1 liamjfoy error = EINVAL;
1942 1.1 liamjfoy break;
1943 1.1 liamjfoy }
1944 1.1 liamjfoy if (sc->sc_carpdev) {
1945 1.1 liamjfoy struct carp_if *cif;
1946 1.1 liamjfoy cif = (struct carp_if *)sc->sc_carpdev->if_carp;
1947 1.1 liamjfoy TAILQ_FOREACH(vr, &cif->vhif_vrs, sc_list)
1948 1.1 liamjfoy if (vr != sc &&
1949 1.1 liamjfoy vr->sc_vhid == carpr.carpr_vhid)
1950 1.1 liamjfoy return (EINVAL);
1951 1.1 liamjfoy }
1952 1.1 liamjfoy sc->sc_vhid = carpr.carpr_vhid;
1953 1.1 liamjfoy carp_set_enaddr(sc);
1954 1.1 liamjfoy carp_set_state(sc, INIT);
1955 1.1 liamjfoy error--;
1956 1.1 liamjfoy }
1957 1.1 liamjfoy if (carpr.carpr_advbase > 0 || carpr.carpr_advskew > 0) {
1958 1.1 liamjfoy if (carpr.carpr_advskew > 254) {
1959 1.1 liamjfoy error = EINVAL;
1960 1.1 liamjfoy break;
1961 1.1 liamjfoy }
1962 1.1 liamjfoy if (carpr.carpr_advbase > 255) {
1963 1.1 liamjfoy error = EINVAL;
1964 1.1 liamjfoy break;
1965 1.1 liamjfoy }
1966 1.1 liamjfoy sc->sc_advbase = carpr.carpr_advbase;
1967 1.1 liamjfoy sc->sc_advskew = carpr.carpr_advskew;
1968 1.1 liamjfoy error--;
1969 1.1 liamjfoy }
1970 1.1 liamjfoy bcopy(carpr.carpr_key, sc->sc_key, sizeof(sc->sc_key));
1971 1.1 liamjfoy if (error > 0)
1972 1.1 liamjfoy error = EINVAL;
1973 1.1 liamjfoy else {
1974 1.1 liamjfoy error = 0;
1975 1.1 liamjfoy carp_setrun(sc, 0);
1976 1.1 liamjfoy }
1977 1.1 liamjfoy break;
1978 1.1 liamjfoy
1979 1.1 liamjfoy case SIOCGVH:
1980 1.1 liamjfoy bzero(&carpr, sizeof(carpr));
1981 1.1 liamjfoy if (sc->sc_carpdev != NULL)
1982 1.1 liamjfoy strlcpy(carpr.carpr_carpdev, sc->sc_carpdev->if_xname,
1983 1.1 liamjfoy IFNAMSIZ);
1984 1.1 liamjfoy carpr.carpr_state = sc->sc_state;
1985 1.1 liamjfoy carpr.carpr_vhid = sc->sc_vhid;
1986 1.1 liamjfoy carpr.carpr_advbase = sc->sc_advbase;
1987 1.1 liamjfoy carpr.carpr_advskew = sc->sc_advskew;
1988 1.3 liamjfoy
1989 1.8 elad if ((l == NULL) || (error = kauth_authorize_network(l->l_cred,
1990 1.8 elad KAUTH_NETWORK_INTERFACE,
1991 1.9 christos KAUTH_REQ_NETWORK_INTERFACE_SETPRIV, ifp, (void *)cmd,
1992 1.8 elad NULL)) != 0)
1993 1.1 liamjfoy bcopy(sc->sc_key, carpr.carpr_key,
1994 1.1 liamjfoy sizeof(carpr.carpr_key));
1995 1.1 liamjfoy error = copyout(&carpr, ifr->ifr_data, sizeof(carpr));
1996 1.1 liamjfoy break;
1997 1.1 liamjfoy
1998 1.1 liamjfoy case SIOCADDMULTI:
1999 1.1 liamjfoy error = carp_ether_addmulti(sc, ifr);
2000 1.1 liamjfoy break;
2001 1.1 liamjfoy
2002 1.1 liamjfoy case SIOCDELMULTI:
2003 1.1 liamjfoy error = carp_ether_delmulti(sc, ifr);
2004 1.1 liamjfoy break;
2005 1.1 liamjfoy
2006 1.1 liamjfoy default:
2007 1.1 liamjfoy error = EINVAL;
2008 1.1 liamjfoy }
2009 1.1 liamjfoy
2010 1.1 liamjfoy carp_hmac_prepare(sc);
2011 1.1 liamjfoy return (error);
2012 1.1 liamjfoy }
2013 1.1 liamjfoy
2014 1.1 liamjfoy
2015 1.1 liamjfoy /*
2016 1.1 liamjfoy * Start output on carp interface. This function should never be called.
2017 1.1 liamjfoy */
2018 1.1 liamjfoy void
2019 1.1 liamjfoy carp_start(struct ifnet *ifp)
2020 1.1 liamjfoy {
2021 1.1 liamjfoy #ifdef DEBUG
2022 1.1 liamjfoy printf("%s: start called\n", ifp->if_xname);
2023 1.1 liamjfoy #endif
2024 1.1 liamjfoy }
2025 1.1 liamjfoy
2026 1.1 liamjfoy int
2027 1.11 dyoung carp_output(struct ifnet *ifp, struct mbuf *m, const struct sockaddr *sa,
2028 1.1 liamjfoy struct rtentry *rt)
2029 1.1 liamjfoy {
2030 1.1 liamjfoy struct carp_softc *sc = ((struct carp_softc *)ifp->if_softc);
2031 1.1 liamjfoy
2032 1.1 liamjfoy if (sc->sc_carpdev != NULL && sc->sc_state == MASTER) {
2033 1.1 liamjfoy return (sc->sc_carpdev->if_output(ifp, m, sa, rt));
2034 1.1 liamjfoy } else {
2035 1.1 liamjfoy m_freem(m);
2036 1.1 liamjfoy return (ENETUNREACH);
2037 1.1 liamjfoy }
2038 1.1 liamjfoy }
2039 1.1 liamjfoy
2040 1.1 liamjfoy void
2041 1.1 liamjfoy carp_set_state(struct carp_softc *sc, int state)
2042 1.1 liamjfoy {
2043 1.1 liamjfoy if (sc->sc_state == state)
2044 1.1 liamjfoy return;
2045 1.1 liamjfoy
2046 1.1 liamjfoy sc->sc_state = state;
2047 1.1 liamjfoy switch (state) {
2048 1.1 liamjfoy case BACKUP:
2049 1.1 liamjfoy sc->sc_if.if_link_state = LINK_STATE_DOWN;
2050 1.1 liamjfoy break;
2051 1.1 liamjfoy case MASTER:
2052 1.1 liamjfoy sc->sc_if.if_link_state = LINK_STATE_UP;
2053 1.1 liamjfoy break;
2054 1.1 liamjfoy default:
2055 1.1 liamjfoy sc->sc_if.if_link_state = LINK_STATE_UNKNOWN;
2056 1.1 liamjfoy break;
2057 1.1 liamjfoy }
2058 1.1 liamjfoy rt_ifmsg(&sc->sc_if);
2059 1.1 liamjfoy }
2060 1.1 liamjfoy
2061 1.1 liamjfoy void
2062 1.1 liamjfoy carp_carpdev_state(void *v)
2063 1.1 liamjfoy {
2064 1.1 liamjfoy struct carp_if *cif;
2065 1.1 liamjfoy struct carp_softc *sc;
2066 1.1 liamjfoy struct ifnet *ifp = v;
2067 1.1 liamjfoy
2068 1.1 liamjfoy if (ifp->if_type == IFT_CARP)
2069 1.1 liamjfoy return;
2070 1.1 liamjfoy
2071 1.1 liamjfoy cif = (struct carp_if *)ifp->if_carp;
2072 1.1 liamjfoy
2073 1.1 liamjfoy TAILQ_FOREACH(sc, &cif->vhif_vrs, sc_list) {
2074 1.1 liamjfoy int suppressed = sc->sc_suppress;
2075 1.1 liamjfoy
2076 1.1 liamjfoy if (sc->sc_carpdev->if_link_state == LINK_STATE_DOWN ||
2077 1.1 liamjfoy !(sc->sc_carpdev->if_flags & IFF_UP)) {
2078 1.1 liamjfoy sc->sc_if.if_flags &= ~IFF_RUNNING;
2079 1.1 liamjfoy callout_stop(&sc->sc_ad_tmo);
2080 1.1 liamjfoy callout_stop(&sc->sc_md_tmo);
2081 1.1 liamjfoy callout_stop(&sc->sc_md6_tmo);
2082 1.1 liamjfoy carp_set_state(sc, INIT);
2083 1.1 liamjfoy sc->sc_suppress = 1;
2084 1.1 liamjfoy carp_setrun(sc, 0);
2085 1.1 liamjfoy if (!suppressed) {
2086 1.1 liamjfoy carp_suppress_preempt++;
2087 1.1 liamjfoy if (carp_suppress_preempt == 1)
2088 1.1 liamjfoy carp_send_ad_all();
2089 1.1 liamjfoy }
2090 1.1 liamjfoy } else {
2091 1.1 liamjfoy carp_set_state(sc, INIT);
2092 1.1 liamjfoy sc->sc_suppress = 0;
2093 1.1 liamjfoy carp_setrun(sc, 0);
2094 1.1 liamjfoy if (suppressed)
2095 1.1 liamjfoy carp_suppress_preempt--;
2096 1.1 liamjfoy }
2097 1.1 liamjfoy }
2098 1.1 liamjfoy }
2099 1.1 liamjfoy
2100 1.1 liamjfoy int
2101 1.1 liamjfoy carp_ether_addmulti(struct carp_softc *sc, struct ifreq *ifr)
2102 1.1 liamjfoy {
2103 1.17 dyoung const struct sockaddr *sa = ifreq_getaddr(SIOCADDMULTI, ifr);
2104 1.1 liamjfoy struct ifnet *ifp;
2105 1.1 liamjfoy struct carp_mc_entry *mc;
2106 1.1 liamjfoy u_int8_t addrlo[ETHER_ADDR_LEN], addrhi[ETHER_ADDR_LEN];
2107 1.1 liamjfoy int error;
2108 1.1 liamjfoy
2109 1.1 liamjfoy ifp = sc->sc_carpdev;
2110 1.1 liamjfoy if (ifp == NULL)
2111 1.1 liamjfoy return (EINVAL);
2112 1.1 liamjfoy
2113 1.17 dyoung error = ether_addmulti(sa, &sc->sc_ac);
2114 1.1 liamjfoy if (error != ENETRESET)
2115 1.1 liamjfoy return (error);
2116 1.1 liamjfoy
2117 1.1 liamjfoy /*
2118 1.1 liamjfoy * This is new multicast address. We have to tell parent
2119 1.1 liamjfoy * about it. Also, remember this multicast address so that
2120 1.1 liamjfoy * we can delete them on unconfigure.
2121 1.1 liamjfoy */
2122 1.1 liamjfoy MALLOC(mc, struct carp_mc_entry *, sizeof(struct carp_mc_entry),
2123 1.1 liamjfoy M_DEVBUF, M_NOWAIT);
2124 1.1 liamjfoy if (mc == NULL) {
2125 1.1 liamjfoy error = ENOMEM;
2126 1.1 liamjfoy goto alloc_failed;
2127 1.1 liamjfoy }
2128 1.1 liamjfoy
2129 1.1 liamjfoy /*
2130 1.1 liamjfoy * As ether_addmulti() returns ENETRESET, following two
2131 1.1 liamjfoy * statement shouldn't fail.
2132 1.1 liamjfoy */
2133 1.17 dyoung (void)ether_multiaddr(sa, addrlo, addrhi);
2134 1.1 liamjfoy ETHER_LOOKUP_MULTI(addrlo, addrhi, &sc->sc_ac, mc->mc_enm);
2135 1.17 dyoung memcpy(&mc->mc_addr, sa, sa->sa_len);
2136 1.1 liamjfoy LIST_INSERT_HEAD(&sc->carp_mc_listhead, mc, mc_entries);
2137 1.1 liamjfoy
2138 1.12 christos error = (*ifp->if_ioctl)(ifp, SIOCADDMULTI, (void *)ifr);
2139 1.1 liamjfoy if (error != 0)
2140 1.1 liamjfoy goto ioctl_failed;
2141 1.1 liamjfoy
2142 1.1 liamjfoy return (error);
2143 1.1 liamjfoy
2144 1.1 liamjfoy ioctl_failed:
2145 1.1 liamjfoy LIST_REMOVE(mc, mc_entries);
2146 1.1 liamjfoy FREE(mc, M_DEVBUF);
2147 1.1 liamjfoy alloc_failed:
2148 1.17 dyoung (void)ether_delmulti(sa, &sc->sc_ac);
2149 1.1 liamjfoy
2150 1.1 liamjfoy return (error);
2151 1.1 liamjfoy }
2152 1.1 liamjfoy
2153 1.1 liamjfoy int
2154 1.1 liamjfoy carp_ether_delmulti(struct carp_softc *sc, struct ifreq *ifr)
2155 1.1 liamjfoy {
2156 1.17 dyoung const struct sockaddr *sa = ifreq_getaddr(SIOCDELMULTI, ifr);
2157 1.1 liamjfoy struct ifnet *ifp;
2158 1.1 liamjfoy struct ether_multi *enm;
2159 1.1 liamjfoy struct carp_mc_entry *mc;
2160 1.1 liamjfoy u_int8_t addrlo[ETHER_ADDR_LEN], addrhi[ETHER_ADDR_LEN];
2161 1.1 liamjfoy int error;
2162 1.1 liamjfoy
2163 1.1 liamjfoy ifp = sc->sc_carpdev;
2164 1.1 liamjfoy if (ifp == NULL)
2165 1.1 liamjfoy return (EINVAL);
2166 1.1 liamjfoy
2167 1.1 liamjfoy /*
2168 1.1 liamjfoy * Find a key to lookup carp_mc_entry. We have to do this
2169 1.1 liamjfoy * before calling ether_delmulti for obvious reason.
2170 1.1 liamjfoy */
2171 1.17 dyoung if ((error = ether_multiaddr(sa, addrlo, addrhi)) != 0)
2172 1.1 liamjfoy return (error);
2173 1.1 liamjfoy ETHER_LOOKUP_MULTI(addrlo, addrhi, &sc->sc_ac, enm);
2174 1.1 liamjfoy if (enm == NULL)
2175 1.1 liamjfoy return (EINVAL);
2176 1.1 liamjfoy
2177 1.1 liamjfoy LIST_FOREACH(mc, &sc->carp_mc_listhead, mc_entries)
2178 1.1 liamjfoy if (mc->mc_enm == enm)
2179 1.1 liamjfoy break;
2180 1.1 liamjfoy
2181 1.1 liamjfoy /* We won't delete entries we didn't add */
2182 1.1 liamjfoy if (mc == NULL)
2183 1.1 liamjfoy return (EINVAL);
2184 1.1 liamjfoy
2185 1.17 dyoung error = ether_delmulti(sa, &sc->sc_ac);
2186 1.1 liamjfoy if (error != ENETRESET)
2187 1.1 liamjfoy return (error);
2188 1.1 liamjfoy
2189 1.1 liamjfoy /* We no longer use this multicast address. Tell parent so. */
2190 1.12 christos error = (*ifp->if_ioctl)(ifp, SIOCDELMULTI, (void *)ifr);
2191 1.1 liamjfoy if (error == 0) {
2192 1.1 liamjfoy /* And forget about this address. */
2193 1.1 liamjfoy LIST_REMOVE(mc, mc_entries);
2194 1.1 liamjfoy FREE(mc, M_DEVBUF);
2195 1.1 liamjfoy } else
2196 1.17 dyoung (void)ether_addmulti(sa, &sc->sc_ac);
2197 1.1 liamjfoy return (error);
2198 1.1 liamjfoy }
2199 1.1 liamjfoy
2200 1.1 liamjfoy /*
2201 1.1 liamjfoy * Delete any multicast address we have asked to add from parent
2202 1.1 liamjfoy * interface. Called when the carp is being unconfigured.
2203 1.1 liamjfoy */
2204 1.1 liamjfoy void
2205 1.1 liamjfoy carp_ether_purgemulti(struct carp_softc *sc)
2206 1.1 liamjfoy {
2207 1.1 liamjfoy struct ifnet *ifp = sc->sc_carpdev; /* Parent. */
2208 1.1 liamjfoy struct carp_mc_entry *mc;
2209 1.1 liamjfoy union {
2210 1.1 liamjfoy struct ifreq ifreq;
2211 1.1 liamjfoy struct {
2212 1.1 liamjfoy char ifr_name[IFNAMSIZ];
2213 1.1 liamjfoy struct sockaddr_storage ifr_ss;
2214 1.1 liamjfoy } ifreq_storage;
2215 1.1 liamjfoy } u;
2216 1.1 liamjfoy struct ifreq *ifr = &u.ifreq;
2217 1.1 liamjfoy
2218 1.1 liamjfoy if (ifp == NULL)
2219 1.1 liamjfoy return;
2220 1.1 liamjfoy
2221 1.1 liamjfoy memcpy(ifr->ifr_name, ifp->if_xname, IFNAMSIZ);
2222 1.1 liamjfoy while ((mc = LIST_FIRST(&sc->carp_mc_listhead)) != NULL) {
2223 1.1 liamjfoy memcpy(&ifr->ifr_addr, &mc->mc_addr, mc->mc_addr.ss_len);
2224 1.12 christos (void)(*ifp->if_ioctl)(ifp, SIOCDELMULTI, (void *)ifr);
2225 1.1 liamjfoy LIST_REMOVE(mc, mc_entries);
2226 1.1 liamjfoy FREE(mc, M_DEVBUF);
2227 1.1 liamjfoy }
2228 1.1 liamjfoy }
2229 1.1 liamjfoy
2230 1.1 liamjfoy SYSCTL_SETUP(sysctl_net_inet_carp_setup, "sysctl net.inet.carp subtree setup")
2231 1.1 liamjfoy {
2232 1.1 liamjfoy
2233 1.1 liamjfoy sysctl_createv(clog, 0, NULL, NULL,
2234 1.1 liamjfoy CTLFLAG_PERMANENT,
2235 1.1 liamjfoy CTLTYPE_NODE, "net", NULL,
2236 1.1 liamjfoy NULL, 0, NULL, 0,
2237 1.1 liamjfoy CTL_NET, CTL_EOL);
2238 1.1 liamjfoy sysctl_createv(clog, 0, NULL, NULL,
2239 1.1 liamjfoy CTLFLAG_PERMANENT,
2240 1.1 liamjfoy CTLTYPE_NODE, "inet", NULL,
2241 1.1 liamjfoy NULL, 0, NULL, 0,
2242 1.1 liamjfoy CTL_NET, PF_INET, CTL_EOL);
2243 1.1 liamjfoy sysctl_createv(clog, 0, NULL, NULL,
2244 1.1 liamjfoy CTLFLAG_PERMANENT,
2245 1.1 liamjfoy CTLTYPE_NODE, "carp",
2246 1.1 liamjfoy SYSCTL_DESCR("CARP related settings"),
2247 1.1 liamjfoy NULL, 0, NULL, 0,
2248 1.1 liamjfoy CTL_NET, PF_INET, IPPROTO_CARP, CTL_EOL);
2249 1.1 liamjfoy
2250 1.1 liamjfoy sysctl_createv(clog, 0, NULL, NULL,
2251 1.1 liamjfoy CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2252 1.1 liamjfoy CTLTYPE_INT, "preempt",
2253 1.1 liamjfoy SYSCTL_DESCR("Enable CARP Preempt"),
2254 1.1 liamjfoy NULL, 0, &carp_opts[CARPCTL_PREEMPT], 0,
2255 1.1 liamjfoy CTL_NET, PF_INET, IPPROTO_CARP,
2256 1.1 liamjfoy CTL_CREATE, CTL_EOL);
2257 1.1 liamjfoy sysctl_createv(clog, 0, NULL, NULL,
2258 1.1 liamjfoy CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2259 1.1 liamjfoy CTLTYPE_INT, "arpbalance",
2260 1.1 liamjfoy SYSCTL_DESCR("Enable ARP balancing"),
2261 1.1 liamjfoy NULL, 0, &carp_opts[CARPCTL_ARPBALANCE], 0,
2262 1.1 liamjfoy CTL_NET, PF_INET, IPPROTO_CARP,
2263 1.1 liamjfoy CTL_CREATE, CTL_EOL);
2264 1.1 liamjfoy sysctl_createv(clog, 0, NULL, NULL,
2265 1.1 liamjfoy CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2266 1.1 liamjfoy CTLTYPE_INT, "allow",
2267 1.1 liamjfoy SYSCTL_DESCR("Enable CARP"),
2268 1.1 liamjfoy NULL, 0, &carp_opts[CARPCTL_ALLOW], 0,
2269 1.1 liamjfoy CTL_NET, PF_INET, IPPROTO_CARP,
2270 1.1 liamjfoy CTL_CREATE, CTL_EOL);
2271 1.1 liamjfoy sysctl_createv(clog, 0, NULL, NULL,
2272 1.1 liamjfoy CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
2273 1.1 liamjfoy CTLTYPE_INT, "log",
2274 1.1 liamjfoy SYSCTL_DESCR("CARP logging"),
2275 1.1 liamjfoy NULL, 0, &carp_opts[CARPCTL_LOG], 0,
2276 1.1 liamjfoy CTL_NET, PF_INET, IPPROTO_CARP,
2277 1.1 liamjfoy CTL_CREATE, CTL_EOL);
2278 1.1 liamjfoy sysctl_createv(clog, 0, NULL, NULL,
2279 1.1 liamjfoy CTLFLAG_PERMANENT,
2280 1.1 liamjfoy CTLTYPE_STRUCT, "stats",
2281 1.3 liamjfoy SYSCTL_DESCR("CARP statistics"),
2282 1.1 liamjfoy NULL, 0, &carpstats, sizeof(carpstats),
2283 1.1 liamjfoy CTL_NET, PF_INET, IPPROTO_CARP, CARPCTL_STATS,
2284 1.1 liamjfoy CTL_EOL);
2285 1.1 liamjfoy }
2286