Home | History | Annotate | Line # | Download | only in netinet
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