Home | History | Annotate | Line # | Download | only in netinet
if_arp.c revision 1.180
      1  1.180     ozaki /*	$NetBSD: if_arp.c,v 1.180 2015/09/09 01:24:01 ozaki-r Exp $	*/
      2   1.54   thorpej 
      3   1.54   thorpej /*-
      4  1.134        ad  * Copyright (c) 1998, 2000, 2008 The NetBSD Foundation, Inc.
      5   1.54   thorpej  * All rights reserved.
      6   1.54   thorpej  *
      7   1.54   thorpej  * This code is derived from software contributed to The NetBSD Foundation
      8   1.54   thorpej  * by Public Access Networks Corporation ("Panix").  It was developed under
      9   1.54   thorpej  * contract to Panix by Eric Haszlakiewicz and Thor Lancelot Simon.
     10   1.54   thorpej  *
     11   1.54   thorpej  * Redistribution and use in source and binary forms, with or without
     12   1.54   thorpej  * modification, are permitted provided that the following conditions
     13   1.54   thorpej  * are met:
     14   1.54   thorpej  * 1. Redistributions of source code must retain the above copyright
     15   1.54   thorpej  *    notice, this list of conditions and the following disclaimer.
     16   1.54   thorpej  * 2. Redistributions in binary form must reproduce the above copyright
     17   1.54   thorpej  *    notice, this list of conditions and the following disclaimer in the
     18   1.54   thorpej  *    documentation and/or other materials provided with the distribution.
     19   1.54   thorpej  *
     20   1.54   thorpej  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     21   1.54   thorpej  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     22   1.54   thorpej  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     23   1.54   thorpej  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     24   1.54   thorpej  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     25   1.54   thorpej  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     26   1.54   thorpej  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     27   1.54   thorpej  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     28   1.54   thorpej  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     29   1.54   thorpej  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     30   1.54   thorpej  * POSSIBILITY OF SUCH DAMAGE.
     31   1.54   thorpej  */
     32   1.52       tls 
     33   1.52       tls /*
     34   1.52       tls  * Copyright (c) 1982, 1986, 1988, 1993
     35   1.52       tls  *	The Regents of the University of California.  All rights reserved.
     36   1.52       tls  *
     37   1.52       tls  * Redistribution and use in source and binary forms, with or without
     38   1.52       tls  * modification, are permitted provided that the following conditions
     39   1.52       tls  * are met:
     40   1.52       tls  * 1. Redistributions of source code must retain the above copyright
     41   1.52       tls  *    notice, this list of conditions and the following disclaimer.
     42   1.52       tls  * 2. Redistributions in binary form must reproduce the above copyright
     43   1.52       tls  *    notice, this list of conditions and the following disclaimer in the
     44   1.52       tls  *    documentation and/or other materials provided with the distribution.
     45   1.93       agc  * 3. Neither the name of the University nor the names of its contributors
     46   1.52       tls  *    may be used to endorse or promote products derived from this software
     47   1.52       tls  *    without specific prior written permission.
     48   1.52       tls  *
     49   1.52       tls  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     50   1.52       tls  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     51   1.52       tls  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     52   1.52       tls  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     53   1.52       tls  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     54   1.52       tls  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     55   1.52       tls  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     56   1.52       tls  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     57   1.52       tls  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     58   1.52       tls  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     59   1.52       tls  * SUCH DAMAGE.
     60   1.52       tls  *
     61   1.52       tls  *	@(#)if_ether.c	8.2 (Berkeley) 9/26/94
     62    1.1       cgd  */
     63    1.1       cgd 
     64    1.1       cgd /*
     65    1.1       cgd  * Ethernet address resolution protocol.
     66    1.1       cgd  * TODO:
     67    1.1       cgd  *	add "inuse/lock" bit (or ref. count) along with valid bit
     68    1.1       cgd  */
     69   1.79     lukem 
     70   1.79     lukem #include <sys/cdefs.h>
     71  1.180     ozaki __KERNEL_RCSID(0, "$NetBSD: if_arp.c,v 1.180 2015/09/09 01:24:01 ozaki-r Exp $");
     72   1.50  jonathan 
     73  1.173     pooka #ifdef _KERNEL_OPT
     74   1.50  jonathan #include "opt_ddb.h"
     75   1.51  jonathan #include "opt_inet.h"
     76  1.173     pooka #endif
     77    1.1       cgd 
     78   1.15    chopps #ifdef INET
     79   1.15    chopps 
     80   1.77   thorpej #include "bridge.h"
     81   1.77   thorpej 
     82    1.5   mycroft #include <sys/param.h>
     83    1.5   mycroft #include <sys/systm.h>
     84   1.67   thorpej #include <sys/callout.h>
     85    1.5   mycroft #include <sys/malloc.h>
     86    1.5   mycroft #include <sys/mbuf.h>
     87    1.5   mycroft #include <sys/socket.h>
     88    1.5   mycroft #include <sys/time.h>
     89  1.112    kardel #include <sys/timetc.h>
     90    1.5   mycroft #include <sys/kernel.h>
     91    1.5   mycroft #include <sys/errno.h>
     92    1.5   mycroft #include <sys/ioctl.h>
     93    1.5   mycroft #include <sys/syslog.h>
     94   1.28  christos #include <sys/proc.h>
     95   1.63  sommerfe #include <sys/protosw.h>
     96   1.63  sommerfe #include <sys/domain.h>
     97   1.97     ragge #include <sys/sysctl.h>
     98  1.134        ad #include <sys/socketvar.h>
     99  1.134        ad #include <sys/percpu.h>
    100  1.163       roy #include <sys/cprng.h>
    101  1.174     ozaki #include <sys/kmem.h>
    102    1.1       cgd 
    103   1.35        is #include <net/ethertypes.h>
    104    1.5   mycroft #include <net/if.h>
    105   1.12   mycroft #include <net/if_dl.h>
    106   1.56       bad #include <net/if_token.h>
    107   1.56       bad #include <net/if_types.h>
    108  1.110  liamjfoy #include <net/if_ether.h>
    109  1.174     ozaki #include <net/if_llatbl.h>
    110  1.163       roy #include <net/net_osdep.h>
    111   1.12   mycroft #include <net/route.h>
    112  1.133   thorpej #include <net/net_stats.h>
    113    1.5   mycroft 
    114    1.5   mycroft #include <netinet/in.h>
    115    1.5   mycroft #include <netinet/in_systm.h>
    116    1.5   mycroft #include <netinet/in_var.h>
    117    1.5   mycroft #include <netinet/ip.h>
    118   1.35        is #include <netinet/if_inarp.h>
    119    1.1       cgd 
    120  1.129      cube #include "arcnet.h"
    121  1.129      cube #if NARCNET > 0
    122   1.66        is #include <net/if_arc.h>
    123   1.66        is #endif
    124   1.65      matt #include "fddi.h"
    125   1.65      matt #if NFDDI > 0
    126   1.65      matt #include <net/if_fddi.h>
    127   1.65      matt #endif
    128   1.66        is #include "token.h"
    129  1.110  liamjfoy #include "carp.h"
    130  1.110  liamjfoy #if NCARP > 0
    131  1.110  liamjfoy #include <netinet/ip_carp.h>
    132  1.110  liamjfoy #endif
    133   1.39     lukem 
    134   1.12   mycroft #define SIN(s) ((struct sockaddr_in *)s)
    135   1.12   mycroft #define SRP(s) ((struct sockaddr_inarp *)s)
    136    1.1       cgd 
    137    1.1       cgd /*
    138    1.1       cgd  * ARP trailer negotiation.  Trailer protocol is not IP specific,
    139    1.1       cgd  * but ARP request/response use IP addresses.
    140    1.1       cgd  */
    141   1.12   mycroft #define ETHERTYPE_IPTRAILERS ETHERTYPE_TRAIL
    142    1.1       cgd 
    143    1.1       cgd /* timer values */
    144  1.170     ozaki static int	arpt_keep = (20*60);	/* once resolved, good for 20 more minutes */
    145  1.170     ozaki static int	arpt_down = 20;		/* once declared down, don't send for 20 secs */
    146  1.174     ozaki static int	arp_maxhold = 1;	/* number of packets to hold per ARP entry */
    147   1.12   mycroft #define	rt_expire rt_rmx.rmx_expire
    148   1.97     ragge #define	rt_pksent rt_rmx.rmx_pksent
    149   1.12   mycroft 
    150  1.163       roy int		ip_dad_count = PROBE_NUM;
    151  1.163       roy #ifdef ARP_DEBUG
    152  1.163       roy static int	arp_debug = 1;
    153  1.163       roy #else
    154  1.163       roy static int	arp_debug = 0;
    155  1.163       roy #endif
    156  1.163       roy #define arplog(x)	do { if (arp_debug) log x; } while (/*CONSTCOND*/ 0)
    157  1.163       roy 
    158  1.166     ozaki static	void arp_init(void);
    159  1.166     ozaki 
    160  1.126    dyoung static	struct sockaddr *arp_setgate(struct rtentry *, struct sockaddr *,
    161  1.126    dyoung 	    const struct sockaddr *);
    162  1.180     ozaki static	void arptfree(struct rtentry *);
    163  1.102     perry static	void arptimer(void *);
    164  1.174     ozaki static	struct llentry *arplookup(struct ifnet *, struct mbuf *,
    165  1.174     ozaki 	    const struct in_addr *, int, int, int, struct rtentry *);
    166  1.102     perry static	void in_arpinput(struct mbuf *);
    167  1.166     ozaki static	void in_revarpinput(struct mbuf *);
    168  1.166     ozaki static	void revarprequest(struct ifnet *);
    169  1.166     ozaki 
    170  1.151    dyoung static	void arp_drainstub(void);
    171   1.12   mycroft 
    172  1.163       roy static void arp_dad_timer(struct ifaddr *);
    173  1.165       roy static void arp_dad_start(struct ifaddr *);
    174  1.165       roy static void arp_dad_stop(struct ifaddr *);
    175  1.163       roy static void arp_dad_duplicated(struct ifaddr *);
    176  1.163       roy 
    177  1.113  christos struct	ifqueue arpintrq = {
    178  1.113  christos 	.ifq_head = NULL,
    179  1.113  christos 	.ifq_tail = NULL,
    180  1.113  christos 	.ifq_len = 0,
    181  1.113  christos 	.ifq_maxlen = 50,
    182  1.113  christos 	.ifq_drops = 0,
    183  1.113  christos };
    184  1.170     ozaki static int	arp_inuse, arp_allocated;
    185  1.170     ozaki static int	arp_maxtries = 5;
    186  1.170     ozaki static int	useloopback = 1;	/* use loopback interface for local traffic */
    187    1.9     glass 
    188  1.132   thorpej static percpu_t *arpstat_percpu;
    189  1.132   thorpej 
    190  1.133   thorpej #define	ARP_STAT_GETREF()	_NET_STAT_GETREF(arpstat_percpu)
    191  1.133   thorpej #define	ARP_STAT_PUTREF()	_NET_STAT_PUTREF(arpstat_percpu)
    192  1.132   thorpej 
    193  1.133   thorpej #define	ARP_STATINC(x)		_NET_STATINC(arpstat_percpu, x)
    194  1.133   thorpej #define	ARP_STATADD(x, v)	_NET_STATADD(arpstat_percpu, x, v)
    195  1.132   thorpej 
    196   1.12   mycroft /* revarp state */
    197  1.170     ozaki static struct	in_addr myip, srv_ip;
    198  1.170     ozaki static int	myip_initialized = 0;
    199  1.170     ozaki static int	revarp_in_progress = 0;
    200  1.170     ozaki static struct	ifnet *myip_ifp = NULL;
    201    1.1       cgd 
    202   1.28  christos #ifdef DDB
    203  1.102     perry static void db_print_sa(const struct sockaddr *);
    204  1.102     perry static void db_print_ifa(struct ifaddr *);
    205  1.121  christos static void db_print_llinfo(void *);
    206  1.123    dyoung static int db_show_rtentry(struct rtentry *, void *);
    207   1.28  christos #endif
    208   1.28  christos 
    209  1.151    dyoung static int arp_drainwanted;
    210  1.151    dyoung 
    211  1.152  christos static int log_movements = 1;
    212  1.152  christos static int log_permanent_modify = 1;
    213  1.152  christos static int log_wrong_iface = 1;
    214  1.160  christos static int log_unknown_network = 1;
    215  1.152  christos 
    216    1.1       cgd /*
    217   1.35        is  * this should be elsewhere.
    218   1.35        is  */
    219   1.35        is 
    220   1.35        is static char *
    221  1.102     perry lla_snprintf(u_int8_t *, int);
    222   1.35        is 
    223   1.35        is static char *
    224  1.102     perry lla_snprintf(u_int8_t *adrp, int len)
    225   1.35        is {
    226   1.75      tron #define NUMBUFS 3
    227   1.75      tron 	static char buf[NUMBUFS][16*3];
    228   1.75      tron 	static int bnum = 0;
    229   1.81    itojun 
    230   1.35        is 	int i;
    231   1.35        is 	char *p;
    232   1.35        is 
    233   1.75      tron 	p = buf[bnum];
    234   1.35        is 
    235   1.35        is 	*p++ = hexdigits[(*adrp)>>4];
    236   1.35        is 	*p++ = hexdigits[(*adrp++)&0xf];
    237   1.35        is 
    238   1.35        is 	for (i=1; i<len && i<16; i++) {
    239   1.35        is 		*p++ = ':';
    240   1.35        is 		*p++ = hexdigits[(*adrp)>>4];
    241   1.35        is 		*p++ = hexdigits[(*adrp++)&0xf];
    242   1.35        is 	}
    243   1.35        is 
    244   1.35        is 	*p = 0;
    245   1.75      tron 	p = buf[bnum];
    246   1.75      tron 	bnum = (bnum + 1) % NUMBUFS;
    247   1.75      tron 	return p;
    248   1.35        is }
    249   1.35        is 
    250  1.101      matt DOMAIN_DEFINE(arpdomain);	/* forward declare and add to link set */
    251  1.101      matt 
    252  1.151    dyoung static void
    253  1.151    dyoung arp_fasttimo(void)
    254  1.151    dyoung {
    255  1.151    dyoung 	if (arp_drainwanted) {
    256  1.151    dyoung 		arp_drain();
    257  1.151    dyoung 		arp_drainwanted = 0;
    258  1.151    dyoung 	}
    259  1.151    dyoung }
    260  1.151    dyoung 
    261   1.96      matt const struct protosw arpsw[] = {
    262  1.130      elad 	{ .pr_type = 0,
    263  1.130      elad 	  .pr_domain = &arpdomain,
    264  1.130      elad 	  .pr_protocol = 0,
    265  1.130      elad 	  .pr_flags = 0,
    266  1.130      elad 	  .pr_input = 0,
    267  1.130      elad 	  .pr_output = 0,
    268  1.130      elad 	  .pr_ctlinput = 0,
    269  1.130      elad 	  .pr_ctloutput = 0,
    270  1.157     rmind 	  .pr_usrreqs = 0,
    271  1.132   thorpej 	  .pr_init = arp_init,
    272  1.151    dyoung 	  .pr_fasttimo = arp_fasttimo,
    273  1.130      elad 	  .pr_slowtimo = 0,
    274  1.151    dyoung 	  .pr_drain = arp_drainstub,
    275   1.63  sommerfe 	}
    276   1.63  sommerfe };
    277   1.63  sommerfe 
    278  1.113  christos struct domain arpdomain = {
    279  1.113  christos 	.dom_family = PF_ARP,
    280  1.113  christos 	.dom_name = "arp",
    281  1.113  christos 	.dom_protosw = arpsw,
    282  1.139    dyoung 	.dom_protoswNPROTOSW = &arpsw[__arraycount(arpsw)],
    283   1.63  sommerfe };
    284   1.63  sommerfe 
    285  1.147     pooka static void sysctl_net_inet_arp_setup(struct sysctllog **);
    286  1.147     pooka 
    287  1.132   thorpej void
    288  1.132   thorpej arp_init(void)
    289  1.132   thorpej {
    290  1.132   thorpej 
    291  1.147     pooka 	sysctl_net_inet_arp_setup(NULL);
    292  1.132   thorpej 	arpstat_percpu = percpu_alloc(sizeof(uint64_t) * ARP_NSTATS);
    293  1.132   thorpej }
    294  1.132   thorpej 
    295  1.151    dyoung static void
    296  1.151    dyoung arp_drainstub(void)
    297  1.151    dyoung {
    298  1.151    dyoung 	arp_drainwanted = 1;
    299  1.151    dyoung }
    300  1.151    dyoung 
    301   1.63  sommerfe /*
    302   1.63  sommerfe  * ARP protocol drain routine.  Called when memory is in short supply.
    303  1.136        ad  * Called at splvm();  don't acquire softnet_lock as can be called from
    304  1.136        ad  * hardware interrupt handlers.
    305   1.63  sommerfe  */
    306   1.63  sommerfe void
    307  1.102     perry arp_drain(void)
    308   1.63  sommerfe {
    309   1.63  sommerfe 
    310  1.174     ozaki 	lltable_drain(AF_INET);
    311   1.63  sommerfe }
    312   1.63  sommerfe 
    313   1.12   mycroft static void
    314  1.116  christos arptimer(void *arg)
    315    1.1       cgd {
    316  1.174     ozaki 	struct llentry *lle = arg;
    317  1.174     ozaki 	struct ifnet *ifp;
    318    1.1       cgd 
    319  1.134        ad 	mutex_enter(softnet_lock);
    320   1.63  sommerfe 
    321  1.174     ozaki 	if (lle == NULL)
    322  1.174     ozaki 		goto out;
    323  1.174     ozaki 
    324  1.174     ozaki 	if (lle->la_flags & LLE_STATIC)
    325  1.174     ozaki 		goto out;
    326  1.174     ozaki 
    327  1.174     ozaki 	LLE_WLOCK(lle);
    328  1.174     ozaki 	if (callout_pending(&lle->la_timer)) {
    329  1.174     ozaki 		/*
    330  1.174     ozaki 		 * Here we are a bit odd here in the treatment of
    331  1.174     ozaki 		 * active/pending. If the pending bit is set, it got
    332  1.174     ozaki 		 * rescheduled before I ran. The active
    333  1.174     ozaki 		 * bit we ignore, since if it was stopped
    334  1.174     ozaki 		 * in ll_tablefree() and was currently running
    335  1.174     ozaki 		 * it would have return 0 so the code would
    336  1.174     ozaki 		 * not have deleted it since the callout could
    337  1.174     ozaki 		 * not be stopped so we want to go through
    338  1.174     ozaki 		 * with the delete here now. If the callout
    339  1.174     ozaki 		 * was restarted, the pending bit will be back on and
    340  1.174     ozaki 		 * we just want to bail since the callout_reset would
    341  1.174     ozaki 		 * return 1 and our reference would have been removed
    342  1.174     ozaki 		 * by arpresolve() below.
    343  1.174     ozaki 		 */
    344  1.174     ozaki 		LLE_WUNLOCK(lle);
    345  1.174     ozaki 		goto out;
    346   1.63  sommerfe 	}
    347  1.174     ozaki 	ifp = lle->lle_tbl->llt_ifp;
    348  1.174     ozaki 
    349  1.174     ozaki 	callout_stop(&lle->la_timer);
    350  1.174     ozaki 
    351  1.174     ozaki 	/* XXX: LOR avoidance. We still have ref on lle. */
    352  1.174     ozaki 	LLE_WUNLOCK(lle);
    353  1.174     ozaki 
    354  1.180     ozaki 	if (lle->la_rt != NULL) {
    355  1.180     ozaki 		/* We have to call arptfree w/o IF_AFDATA_LOCK */
    356  1.180     ozaki 		arptfree(lle->la_rt);
    357  1.180     ozaki 		lle->la_rt = NULL;
    358  1.180     ozaki 	}
    359  1.174     ozaki 
    360  1.174     ozaki 	IF_AFDATA_LOCK(ifp);
    361  1.174     ozaki 	LLE_WLOCK(lle);
    362   1.63  sommerfe 
    363  1.174     ozaki 	/* Guard against race with other llentry_free(). */
    364  1.174     ozaki 	if (lle->la_flags & LLE_LINKED) {
    365  1.174     ozaki 		size_t pkts_dropped;
    366  1.174     ozaki 
    367  1.174     ozaki 		LLE_REMREF(lle);
    368  1.174     ozaki 		pkts_dropped = llentry_free(lle);
    369  1.174     ozaki 		ARP_STATADD(ARP_STAT_DFRDROPPED, pkts_dropped);
    370  1.174     ozaki 	} else {
    371  1.174     ozaki 		LLE_FREE_LOCKED(lle);
    372   1.12   mycroft 	}
    373   1.63  sommerfe 
    374  1.174     ozaki 	IF_AFDATA_UNLOCK(ifp);
    375   1.81    itojun 
    376  1.174     ozaki out:
    377  1.134        ad 	mutex_exit(softnet_lock);
    378   1.12   mycroft }
    379   1.12   mycroft 
    380   1.12   mycroft /*
    381  1.126    dyoung  * We set the gateway for RTF_CLONING routes to a "prototype"
    382  1.126    dyoung  * link-layer sockaddr whose interface type (if_type) and interface
    383  1.126    dyoung  * index (if_index) fields are prepared.
    384  1.126    dyoung  */
    385  1.126    dyoung static struct sockaddr *
    386  1.126    dyoung arp_setgate(struct rtentry *rt, struct sockaddr *gate,
    387  1.126    dyoung     const struct sockaddr *netmask)
    388  1.126    dyoung {
    389  1.127    dyoung 	const struct ifnet *ifp = rt->rt_ifp;
    390  1.127    dyoung 	uint8_t namelen = strlen(ifp->if_xname);
    391  1.127    dyoung 	uint8_t addrlen = ifp->if_addrlen;
    392  1.127    dyoung 
    393  1.126    dyoung 	/*
    394  1.126    dyoung 	 * XXX: If this is a manually added route to interface
    395  1.126    dyoung 	 * such as older version of routed or gated might provide,
    396  1.126    dyoung 	 * restore cloning bit.
    397  1.126    dyoung 	 */
    398  1.126    dyoung 	if ((rt->rt_flags & RTF_HOST) == 0 && netmask != NULL &&
    399  1.126    dyoung 	    satocsin(netmask)->sin_addr.s_addr != 0xffffffff)
    400  1.126    dyoung 		rt->rt_flags |= RTF_CLONING;
    401  1.161       roy 	if (rt->rt_flags & RTF_CLONING ||
    402  1.161       roy 	    ((rt->rt_flags & (RTF_LLINFO | RTF_LOCAL)) && !rt->rt_llinfo))
    403  1.161       roy 	{
    404  1.128    dyoung 		union {
    405  1.128    dyoung 			struct sockaddr sa;
    406  1.128    dyoung 			struct sockaddr_storage ss;
    407  1.128    dyoung 			struct sockaddr_dl sdl;
    408  1.128    dyoung 		} u;
    409  1.126    dyoung 		/*
    410  1.126    dyoung 		 * Case 1: This route should come from a route to iface.
    411  1.126    dyoung 		 */
    412  1.128    dyoung 		sockaddr_dl_init(&u.sdl, sizeof(u.ss),
    413  1.128    dyoung 		    ifp->if_index, ifp->if_type, NULL, namelen, NULL, addrlen);
    414  1.128    dyoung 		rt_setgate(rt, &u.sa);
    415  1.126    dyoung 		gate = rt->rt_gateway;
    416  1.126    dyoung 	}
    417  1.126    dyoung 	return gate;
    418  1.126    dyoung }
    419  1.126    dyoung 
    420  1.126    dyoung /*
    421   1.12   mycroft  * Parallel to llc_rtrequest.
    422   1.12   mycroft  */
    423   1.12   mycroft void
    424  1.143    dyoung arp_rtrequest(int req, struct rtentry *rt, const struct rt_addrinfo *info)
    425   1.12   mycroft {
    426   1.68  augustss 	struct sockaddr *gate = rt->rt_gateway;
    427  1.174     ozaki 	struct llentry *la = NULL;
    428   1.76    itojun 	struct in_ifaddr *ia;
    429   1.76    itojun 	struct ifaddr *ifa;
    430  1.127    dyoung 	struct ifnet *ifp = rt->rt_ifp;
    431  1.174     ozaki 	int flags = 0;
    432   1.80    itojun 
    433  1.144    dyoung 	if (req == RTM_LLINFO_UPD) {
    434  1.144    dyoung 		struct in_addr *in;
    435  1.144    dyoung 
    436  1.144    dyoung 		if ((ifa = info->rti_ifa) == NULL)
    437  1.144    dyoung 			return;
    438  1.144    dyoung 
    439  1.144    dyoung 		in = &ifatoia(ifa)->ia_addr.sin_addr;
    440  1.144    dyoung 
    441  1.163       roy 		if (ifatoia(ifa)->ia4_flags &
    442  1.163       roy 		    (IN_IFF_NOTREADY | IN_IFF_DETACHED))
    443  1.163       roy 		{
    444  1.163       roy 			arplog((LOG_DEBUG, "arp_request: %s not ready\n",
    445  1.163       roy 			   in_fmtaddr(*in)));
    446  1.163       roy 			return;
    447  1.163       roy 		}
    448  1.163       roy 
    449  1.144    dyoung 		arprequest(ifa->ifa_ifp, in, in,
    450  1.144    dyoung 		    CLLADDR(ifa->ifa_ifp->if_sadl));
    451  1.144    dyoung 		return;
    452  1.144    dyoung 	}
    453  1.144    dyoung 
    454   1.80    itojun 	if ((rt->rt_flags & RTF_GATEWAY) != 0) {
    455   1.80    itojun 		if (req != RTM_ADD)
    456   1.80    itojun 			return;
    457   1.80    itojun 
    458   1.80    itojun 		/*
    459   1.80    itojun 		 * linklayers with particular link MTU limitation.
    460   1.80    itojun 		 */
    461  1.127    dyoung 		switch(ifp->if_type) {
    462   1.80    itojun #if NFDDI > 0
    463   1.80    itojun 		case IFT_FDDI:
    464  1.127    dyoung 			if (ifp->if_mtu > FDDIIPMTU)
    465   1.80    itojun 				rt->rt_rmx.rmx_mtu = FDDIIPMTU;
    466   1.80    itojun 			break;
    467   1.80    itojun #endif
    468  1.169     ozaki #if NARCNET > 0
    469   1.80    itojun 		case IFT_ARCNET:
    470   1.80    itojun 		    {
    471   1.80    itojun 			int arcipifmtu;
    472   1.80    itojun 
    473  1.127    dyoung 			if (ifp->if_flags & IFF_LINK0)
    474   1.80    itojun 				arcipifmtu = arc_ipmtu;
    475   1.80    itojun 			else
    476   1.80    itojun 				arcipifmtu = ARCMTU;
    477  1.127    dyoung 			if (ifp->if_mtu > arcipifmtu)
    478   1.80    itojun 				rt->rt_rmx.rmx_mtu = arcipifmtu;
    479   1.80    itojun 			break;
    480   1.80    itojun 		    }
    481   1.80    itojun #endif
    482   1.80    itojun 		}
    483   1.12   mycroft 		return;
    484   1.80    itojun 	}
    485   1.63  sommerfe 
    486  1.174     ozaki 	IF_AFDATA_RLOCK(ifp);
    487  1.174     ozaki 	la = lla_lookup(LLTABLE(ifp), flags, rt_getkey(rt));
    488  1.174     ozaki 	IF_AFDATA_RUNLOCK(ifp);
    489   1.63  sommerfe 
    490   1.12   mycroft 	switch (req) {
    491  1.126    dyoung 	case RTM_SETGATE:
    492  1.126    dyoung 		gate = arp_setgate(rt, gate, info->rti_info[RTAX_NETMASK]);
    493  1.126    dyoung 		break;
    494   1.12   mycroft 	case RTM_ADD:
    495  1.126    dyoung 		gate = arp_setgate(rt, gate, info->rti_info[RTAX_NETMASK]);
    496  1.161       roy 		if (rt->rt_flags & RTF_CLONING ||
    497  1.161       roy 		    ((rt->rt_flags & (RTF_LLINFO | RTF_LOCAL)) && !la))
    498  1.161       roy 		{
    499   1.12   mycroft 			/*
    500   1.14       gwr 			 * Give this route an expiration time, even though
    501   1.14       gwr 			 * it's a "permanent" route, so that routes cloned
    502   1.14       gwr 			 * from it do not need their expiration time set.
    503   1.13       gwr 			 */
    504  1.171     ozaki 			KASSERT(time_uptime != 0);
    505  1.171     ozaki 			rt->rt_expire = time_uptime;
    506   1.80    itojun 			/*
    507   1.80    itojun 			 * linklayers with particular link MTU limitation.
    508   1.80    itojun 			 */
    509  1.127    dyoung 			switch (ifp->if_type) {
    510   1.65      matt #if NFDDI > 0
    511   1.80    itojun 			case IFT_FDDI:
    512   1.80    itojun 				if ((rt->rt_rmx.rmx_locks & RTV_MTU) == 0 &&
    513   1.80    itojun 				    (rt->rt_rmx.rmx_mtu > FDDIIPMTU ||
    514   1.80    itojun 				     (rt->rt_rmx.rmx_mtu == 0 &&
    515  1.127    dyoung 				      ifp->if_mtu > FDDIIPMTU)))
    516   1.80    itojun 					rt->rt_rmx.rmx_mtu = FDDIIPMTU;
    517   1.80    itojun 				break;
    518   1.66        is #endif
    519  1.169     ozaki #if NARCNET > 0
    520   1.80    itojun 			case IFT_ARCNET:
    521   1.80    itojun 			    {
    522   1.66        is 				int arcipifmtu;
    523  1.127    dyoung 				if (ifp->if_flags & IFF_LINK0)
    524   1.66        is 					arcipifmtu = arc_ipmtu;
    525   1.66        is 				else
    526   1.66        is 					arcipifmtu = ARCMTU;
    527   1.66        is 
    528   1.80    itojun 				if ((rt->rt_rmx.rmx_locks & RTV_MTU) == 0 &&
    529   1.80    itojun 				    (rt->rt_rmx.rmx_mtu > arcipifmtu ||
    530   1.80    itojun 				     (rt->rt_rmx.rmx_mtu == 0 &&
    531  1.127    dyoung 				      ifp->if_mtu > arcipifmtu)))
    532   1.66        is 					rt->rt_rmx.rmx_mtu = arcipifmtu;
    533   1.80    itojun 				break;
    534   1.80    itojun 			    }
    535   1.80    itojun #endif
    536   1.65      matt 			}
    537  1.161       roy 			if (rt->rt_flags & RTF_CLONING)
    538  1.161       roy 				break;
    539   1.12   mycroft 		}
    540   1.12   mycroft 		/* Announce a new entry if requested. */
    541  1.145  christos 		if (rt->rt_flags & RTF_ANNOUNCE) {
    542  1.163       roy 			INADDR_TO_IA(satocsin(rt_getkey(rt))->sin_addr, ia);
    543  1.163       roy 			while (ia && ia->ia_ifp != ifp)
    544  1.163       roy 				NEXT_IA_WITH_SAME_ADDR(ia);
    545  1.163       roy 			if (ia == NULL ||
    546  1.163       roy 			    ia->ia4_flags & (IN_IFF_NOTREADY | IN_IFF_DETACHED))
    547  1.163       roy 				;
    548  1.163       roy 			else
    549  1.163       roy 				arprequest(ifp,
    550  1.163       roy 				    &satocsin(rt_getkey(rt))->sin_addr,
    551  1.163       roy 				    &satocsin(rt_getkey(rt))->sin_addr,
    552  1.163       roy 				    CLLADDR(satocsdl(gate)));
    553  1.145  christos 		}
    554   1.12   mycroft 		/*FALLTHROUGH*/
    555   1.12   mycroft 	case RTM_RESOLVE:
    556   1.12   mycroft 		if (gate->sa_family != AF_LINK ||
    557  1.146    dyoung 		    gate->sa_len < sockaddr_dl_measure(0, ifp->if_addrlen)) {
    558   1.37       jtk 			log(LOG_DEBUG, "arp_rtrequest: bad gateway value\n");
    559   1.12   mycroft 			break;
    560   1.12   mycroft 		}
    561  1.162       roy 
    562  1.127    dyoung 		satosdl(gate)->sdl_type = ifp->if_type;
    563  1.127    dyoung 		satosdl(gate)->sdl_index = ifp->if_index;
    564  1.139    dyoung 		if (la != NULL)
    565   1.12   mycroft 			break; /* This happens on a route change */
    566  1.162       roy 
    567  1.162       roy 		/* If the route is for a broadcast address mark it as such.
    568  1.162       roy 		 * This way we can avoid an expensive call to in_broadcast()
    569  1.162       roy 		 * in ip_output() most of the time (because the route passed
    570  1.162       roy 		 * to ip_output() is almost always a host route). */
    571  1.162       roy 		if (rt->rt_flags & RTF_HOST &&
    572  1.162       roy 		    !(rt->rt_flags & RTF_BROADCAST) &&
    573  1.162       roy 		    in_broadcast(satocsin(rt_getkey(rt))->sin_addr, rt->rt_ifp))
    574  1.162       roy 			rt->rt_flags |= RTF_BROADCAST;
    575  1.162       roy 		/* There is little point in resolving the broadcast address */
    576  1.162       roy 		if (rt->rt_flags & RTF_BROADCAST)
    577  1.162       roy 			break;
    578  1.162       roy 
    579   1.12   mycroft 		/*
    580   1.12   mycroft 		 * Case 2:  This route may come from cloning, or a manual route
    581   1.12   mycroft 		 * add with a LL address.
    582   1.12   mycroft 		 */
    583  1.174     ozaki 		flags = LLE_EXCLUSIVE;
    584  1.174     ozaki 		if ((rt->rt_flags & RTF_CLONED) == 0)
    585  1.174     ozaki 			flags |= LLE_IFADDR;
    586  1.174     ozaki 
    587  1.174     ozaki 		IF_AFDATA_WLOCK(ifp);
    588  1.174     ozaki 		la = lla_create(LLTABLE(ifp), flags, rt_getkey(rt));
    589  1.174     ozaki 		IF_AFDATA_WUNLOCK(ifp);
    590  1.174     ozaki 
    591  1.174     ozaki 		if (la == NULL) {
    592  1.174     ozaki 			log(LOG_DEBUG, "%s: lla_create failed\n",
    593  1.174     ozaki 			    __func__);
    594  1.174     ozaki 			rt->rt_llinfo = NULL;
    595  1.174     ozaki 			break;
    596  1.174     ozaki 		}
    597  1.174     ozaki 		rt->rt_llinfo = la;
    598  1.146    dyoung 		switch (ifp->if_type) {
    599   1.56       bad #if NTOKEN > 0
    600   1.56       bad 		case IFT_ISO88025:
    601  1.174     ozaki 			la->la_opaque = kmem_alloc(sizeof(struct token_rif),
    602  1.174     ozaki 			    KM_SLEEP);
    603   1.56       bad 			break;
    604   1.56       bad #endif /* NTOKEN > 0 */
    605   1.56       bad 		default:
    606   1.12   mycroft 			break;
    607   1.12   mycroft 		}
    608   1.12   mycroft 		la->la_rt = rt;
    609  1.174     ozaki 		rt->rt_refcnt++;
    610   1.12   mycroft 		rt->rt_flags |= RTF_LLINFO;
    611  1.174     ozaki 		arp_inuse++, arp_allocated++;
    612  1.174     ozaki 
    613  1.174     ozaki 		LLE_WUNLOCK(la);
    614  1.174     ozaki 		la = NULL;
    615   1.76    itojun 
    616  1.125    dyoung 		INADDR_TO_IA(satocsin(rt_getkey(rt))->sin_addr, ia);
    617  1.127    dyoung 		while (ia && ia->ia_ifp != ifp)
    618   1.76    itojun 			NEXT_IA_WITH_SAME_ADDR(ia);
    619   1.76    itojun 		if (ia) {
    620   1.24       cgd 			/*
    621   1.24       cgd 			 * This test used to be
    622  1.100     peter 			 *	if (lo0ifp->if_flags & IFF_UP)
    623   1.24       cgd 			 * It allowed local traffic to be forced through
    624   1.24       cgd 			 * the hardware by configuring the loopback down.
    625   1.24       cgd 			 * However, it causes problems during network
    626   1.24       cgd 			 * configuration for boards that can't receive
    627   1.24       cgd 			 * packets they send.  It is now necessary to clear
    628   1.24       cgd 			 * "useloopback" and remove the route to force
    629   1.24       cgd 			 * traffic out to the hardware.
    630   1.76    itojun 			 *
    631   1.76    itojun 			 * In 4.4BSD, the above "if" statement checked
    632  1.125    dyoung 			 * rt->rt_ifa against rt_getkey(rt).  It was changed
    633   1.81    itojun 			 * to the current form so that we can provide a
    634   1.76    itojun 			 * better support for multiple IPv4 addresses on a
    635   1.76    itojun 			 * interface.
    636   1.24       cgd 			 */
    637   1.12   mycroft 			rt->rt_expire = 0;
    638  1.146    dyoung 			if (sockaddr_dl_init(satosdl(gate), gate->sa_len,
    639  1.146    dyoung 			    ifp->if_index, ifp->if_type, NULL, 0,
    640  1.146    dyoung 			    CLLADDR(ifp->if_sadl), ifp->if_addrlen) == NULL) {
    641  1.146    dyoung 				panic("%s(%s): sockaddr_dl_init cannot fail",
    642  1.146    dyoung 				    __func__, ifp->if_xname);
    643  1.146    dyoung 			}
    644   1.12   mycroft 			if (useloopback)
    645  1.127    dyoung 				ifp = rt->rt_ifp = lo0ifp;
    646   1.76    itojun 			/*
    647   1.76    itojun 			 * make sure to set rt->rt_ifa to the interface
    648   1.76    itojun 			 * address we are using, otherwise we will have trouble
    649   1.76    itojun 			 * with source address selection.
    650   1.76    itojun 			 */
    651   1.76    itojun 			ifa = &ia->ia_ifa;
    652  1.115    dyoung 			if (ifa != rt->rt_ifa)
    653  1.115    dyoung 				rt_replace_ifa(rt, ifa);
    654   1.12   mycroft 		}
    655   1.12   mycroft 		break;
    656   1.12   mycroft 
    657   1.12   mycroft 	case RTM_DELETE:
    658  1.139    dyoung 		if (la == NULL)
    659   1.12   mycroft 			break;
    660   1.12   mycroft 		arp_inuse--;
    661  1.139    dyoung 		rt->rt_llinfo = NULL;
    662   1.12   mycroft 		rt->rt_flags &= ~RTF_LLINFO;
    663   1.63  sommerfe 
    664  1.174     ozaki 		LLE_RUNLOCK(la);
    665  1.174     ozaki 
    666  1.174     ozaki 		flags |= LLE_EXCLUSIVE;
    667  1.174     ozaki 		IF_AFDATA_WLOCK(ifp);
    668  1.174     ozaki 
    669  1.174     ozaki 		la = lla_lookup(LLTABLE(ifp), flags, rt_getkey(rt));
    670  1.174     ozaki 		/* This shouldn't happen */
    671  1.174     ozaki 		if (la == NULL) {
    672  1.174     ozaki 			IF_AFDATA_WUNLOCK(ifp);
    673  1.174     ozaki 			break;
    674  1.174     ozaki 		}
    675  1.174     ozaki 
    676  1.174     ozaki 		if (la->la_opaque != NULL) {
    677  1.174     ozaki 			switch (ifp->if_type) {
    678  1.174     ozaki #if NTOKEN > 0
    679  1.174     ozaki 			case IFT_ISO88025:
    680  1.174     ozaki 				kmem_free(la->la_opaque,
    681  1.174     ozaki 				    sizeof(struct token_rif));
    682  1.174     ozaki 				break;
    683  1.174     ozaki #endif /* NTOKEN > 0 */
    684  1.174     ozaki 			default:
    685  1.174     ozaki 				break;
    686  1.174     ozaki 			}
    687  1.174     ozaki 		}
    688  1.174     ozaki 
    689  1.174     ozaki 		if (la->la_rt != NULL) {
    690  1.174     ozaki 			/*
    691  1.174     ozaki 			 * Don't rtfree (may actually free objects) here.
    692  1.174     ozaki 			 * Leave it to rtrequest1.
    693  1.174     ozaki 			 */
    694  1.174     ozaki 			la->la_rt->rt_refcnt--;
    695  1.174     ozaki 			la->la_rt = NULL;
    696  1.174     ozaki 		}
    697  1.174     ozaki 		llentry_free(la);
    698   1.81    itojun 
    699  1.174     ozaki 		IF_AFDATA_WUNLOCK(ifp);
    700  1.174     ozaki 		la = NULL;
    701  1.174     ozaki 	}
    702   1.63  sommerfe 
    703  1.174     ozaki 	if (la != NULL) {
    704  1.174     ozaki 		if (flags & LLE_EXCLUSIVE)
    705  1.174     ozaki 			LLE_WUNLOCK(la);
    706  1.174     ozaki 		else
    707  1.174     ozaki 			LLE_RUNLOCK(la);
    708    1.1       cgd 	}
    709    1.1       cgd }
    710    1.1       cgd 
    711    1.1       cgd /*
    712   1.12   mycroft  * Broadcast an ARP request. Caller specifies:
    713   1.12   mycroft  *	- arp header source ip address
    714   1.12   mycroft  *	- arp header target ip address
    715   1.12   mycroft  *	- arp header source ethernet address
    716   1.12   mycroft  */
    717  1.110  liamjfoy void
    718  1.102     perry arprequest(struct ifnet *ifp,
    719  1.119    dyoung     const struct in_addr *sip, const struct in_addr *tip,
    720  1.119    dyoung     const u_int8_t *enaddr)
    721    1.1       cgd {
    722   1.68  augustss 	struct mbuf *m;
    723   1.35        is 	struct arphdr *ah;
    724    1.1       cgd 	struct sockaddr sa;
    725  1.132   thorpej 	uint64_t *arps;
    726    1.1       cgd 
    727  1.174     ozaki 	KASSERT(sip != NULL);
    728  1.174     ozaki 	KASSERT(tip != NULL);
    729  1.174     ozaki 	KASSERT(enaddr != NULL);
    730  1.174     ozaki 
    731    1.1       cgd 	if ((m = m_gethdr(M_DONTWAIT, MT_DATA)) == NULL)
    732    1.1       cgd 		return;
    733   1.92      matt 	MCLAIM(m, &arpdomain.dom_mowner);
    734   1.82    itojun 	switch (ifp->if_type) {
    735   1.82    itojun 	case IFT_IEEE1394:
    736   1.82    itojun 		m->m_len = sizeof(*ah) + 2 * sizeof(struct in_addr) +
    737   1.86     enami 		    ifp->if_addrlen;
    738   1.82    itojun 		break;
    739   1.82    itojun 	default:
    740   1.82    itojun 		m->m_len = sizeof(*ah) + 2 * sizeof(struct in_addr) +
    741   1.86     enami 		    2 * ifp->if_addrlen;
    742   1.82    itojun 		break;
    743   1.82    itojun 	}
    744   1.35        is 	m->m_pkthdr.len = m->m_len;
    745   1.35        is 	MH_ALIGN(m, m->m_len);
    746   1.35        is 	ah = mtod(m, struct arphdr *);
    747  1.140    dyoung 	memset(ah, 0, m->m_len);
    748   1.82    itojun 	switch (ifp->if_type) {
    749   1.83    itojun 	case IFT_IEEE1394:	/* RFC2734 */
    750   1.88    itojun 		/* fill it now for ar_tpa computation */
    751   1.82    itojun 		ah->ar_hrd = htons(ARPHRD_IEEE1394);
    752   1.82    itojun 		break;
    753   1.82    itojun 	default:
    754   1.88    itojun 		/* ifp->if_output will fill ar_hrd */
    755   1.82    itojun 		break;
    756   1.82    itojun 	}
    757   1.35        is 	ah->ar_pro = htons(ETHERTYPE_IP);
    758   1.86     enami 	ah->ar_hln = ifp->if_addrlen;		/* hardware address length */
    759   1.35        is 	ah->ar_pln = sizeof(struct in_addr);	/* protocol address length */
    760   1.35        is 	ah->ar_op = htons(ARPOP_REQUEST);
    761  1.118    dyoung 	memcpy(ar_sha(ah), enaddr, ah->ar_hln);
    762  1.118    dyoung 	memcpy(ar_spa(ah), sip, ah->ar_pln);
    763  1.118    dyoung 	memcpy(ar_tpa(ah), tip, ah->ar_pln);
    764   1.35        is 	sa.sa_family = AF_ARP;
    765   1.35        is 	sa.sa_len = 2;
    766   1.35        is 	m->m_flags |= M_BCAST;
    767  1.132   thorpej 	arps = ARP_STAT_GETREF();
    768  1.132   thorpej 	arps[ARP_STAT_SNDTOTAL]++;
    769  1.132   thorpej 	arps[ARP_STAT_SENDREQUEST]++;
    770  1.132   thorpej 	ARP_STAT_PUTREF();
    771  1.118    dyoung 	(*ifp->if_output)(ifp, m, &sa, NULL);
    772    1.1       cgd }
    773    1.1       cgd 
    774    1.1       cgd /*
    775    1.6   mycroft  * Resolve an IP address into an ethernet address.  If success,
    776    1.1       cgd  * desten is filled in.  If there is no entry in arptab,
    777    1.1       cgd  * set one up and broadcast a request for the IP address.
    778    1.1       cgd  * Hold onto this mbuf and resend it once the address
    779    1.1       cgd  * is finally resolved.  A return value of 1 indicates
    780    1.1       cgd  * that desten has been filled in and the packet should be sent
    781    1.1       cgd  * normally; a 0 return indicates that the packet has been
    782    1.1       cgd  * taken over here, either now or for later transmission.
    783    1.1       cgd  */
    784   1.12   mycroft int
    785  1.102     perry arpresolve(struct ifnet *ifp, struct rtentry *rt, struct mbuf *m,
    786  1.119    dyoung     const struct sockaddr *dst, u_char *desten)
    787    1.1       cgd {
    788  1.174     ozaki 	struct llentry *la;
    789  1.126    dyoung 	const struct sockaddr_dl *sdl;
    790  1.174     ozaki 	int renew;
    791  1.174     ozaki 	int flags = 0;
    792  1.174     ozaki 	int error;
    793   1.81    itojun 
    794  1.178     ozaki 	KASSERT(m != NULL);
    795  1.178     ozaki 
    796  1.174     ozaki 	la = arplookup(ifp, m, &satocsin(dst)->sin_addr, 1, 0, 0, rt);
    797  1.174     ozaki 	if (la != NULL)
    798  1.126    dyoung 		rt = la->la_rt;
    799  1.126    dyoung 
    800  1.139    dyoung 	if (la == NULL || rt == NULL) {
    801  1.132   thorpej 		ARP_STATINC(ARP_STAT_ALLOCFAIL);
    802   1.72        is 		log(LOG_DEBUG,
    803   1.72        is 		    "arpresolve: can't allocate llinfo on %s for %s\n",
    804  1.119    dyoung 		    ifp->if_xname, in_fmtaddr(satocsin(dst)->sin_addr));
    805   1.12   mycroft 		m_freem(m);
    806  1.174     ozaki 		if (la != NULL)
    807  1.174     ozaki 			LLE_RUNLOCK(la);
    808  1.139    dyoung 		return 0;
    809    1.1       cgd 	}
    810  1.126    dyoung 	sdl = satocsdl(rt->rt_gateway);
    811   1.12   mycroft 	/*
    812   1.12   mycroft 	 * Check the address family and length is valid, the address
    813   1.12   mycroft 	 * is resolved; otherwise, try to resolve.
    814   1.12   mycroft 	 */
    815  1.171     ozaki 	if ((rt->rt_expire == 0 || rt->rt_expire > time_uptime) &&
    816   1.12   mycroft 	    sdl->sdl_family == AF_LINK && sdl->sdl_alen != 0) {
    817  1.140    dyoung 		memcpy(desten, CLLADDR(sdl),
    818   1.86     enami 		    min(sdl->sdl_alen, ifp->if_addrlen));
    819  1.171     ozaki 		rt->rt_pksent = time_uptime; /* Time for last pkt sent */
    820  1.174     ozaki 		LLE_RUNLOCK(la);
    821   1.12   mycroft 		return 1;
    822    1.1       cgd 	}
    823   1.81    itojun 
    824   1.13       gwr 	/*
    825   1.13       gwr 	 * Re-send the ARP request when appropriate.
    826   1.13       gwr 	 */
    827   1.13       gwr #ifdef	DIAGNOSTIC
    828   1.13       gwr 	if (rt->rt_expire == 0) {
    829   1.14       gwr 		/* This should never happen. (Should it? -gwr) */
    830   1.34  christos 		printf("arpresolve: unresolved and rt_expire == 0\n");
    831   1.13       gwr 		/* Set expiration time to now (expired). */
    832  1.171     ozaki 		rt->rt_expire = time_uptime;
    833   1.13       gwr 	}
    834   1.13       gwr #endif
    835  1.174     ozaki 
    836  1.174     ozaki retry:
    837  1.174     ozaki 	if (la == NULL) {
    838  1.174     ozaki 		IF_AFDATA_RLOCK(ifp);
    839  1.174     ozaki 		la = lla_lookup(LLTABLE(ifp), flags, dst);
    840  1.174     ozaki 		IF_AFDATA_RUNLOCK(ifp);
    841  1.174     ozaki 	}
    842  1.174     ozaki 
    843  1.174     ozaki 	if ((la == NULL) && ((flags & LLE_EXCLUSIVE) == 0)
    844  1.174     ozaki #ifdef __FreeBSD__
    845  1.174     ozaki 	    && ((ifp->if_flags & (IFF_NOARP | IFF_STATICARP)) == 0)) {
    846  1.174     ozaki #else
    847  1.174     ozaki 	    && ((ifp->if_flags & IFF_NOARP) == 0)) {
    848  1.174     ozaki #endif
    849  1.174     ozaki 		flags |= LLE_EXCLUSIVE;
    850  1.174     ozaki 		IF_AFDATA_WLOCK(ifp);
    851  1.174     ozaki 		la = lla_create(LLTABLE(ifp), flags, dst);
    852  1.174     ozaki 		IF_AFDATA_WUNLOCK(ifp);
    853  1.174     ozaki 
    854  1.177     ozaki 		if (la == NULL) {
    855  1.174     ozaki 			log(LOG_DEBUG,
    856  1.174     ozaki 			    "%s: failed to create llentry for %s on %s\n",
    857  1.174     ozaki 			    __func__, inet_ntoa(satocsin(dst)->sin_addr),
    858  1.174     ozaki 			    ifp->if_xname);
    859  1.174     ozaki 		}
    860  1.177     ozaki 	}
    861  1.177     ozaki 
    862  1.177     ozaki 	if (la == NULL) {
    863  1.174     ozaki 		m_freem(m);
    864  1.174     ozaki 		return 0;
    865  1.174     ozaki 	}
    866  1.174     ozaki 
    867  1.174     ozaki 	if ((la->la_flags & LLE_VALID) &&
    868  1.174     ozaki 	    ((la->la_flags & LLE_STATIC) || la->la_expire > time_uptime)) {
    869  1.174     ozaki 		memcpy(desten, CLLADDR(sdl),
    870  1.174     ozaki 		    min(sdl->sdl_alen, ifp->if_addrlen));
    871  1.174     ozaki 		renew = 0;
    872  1.174     ozaki 		/*
    873  1.174     ozaki 		 * If entry has an expiry time and it is approaching,
    874  1.174     ozaki 		 * see if we need to send an ARP request within this
    875  1.174     ozaki 		 * arpt_down interval.
    876  1.174     ozaki 		 */
    877  1.174     ozaki 		if (!(la->la_flags & LLE_STATIC) &&
    878  1.174     ozaki 		    time_uptime + la->la_preempt > la->la_expire) {
    879  1.174     ozaki 			renew = 1;
    880  1.174     ozaki 			la->la_preempt--;
    881  1.174     ozaki 		}
    882  1.174     ozaki 
    883  1.174     ozaki 		if (flags & LLE_EXCLUSIVE)
    884  1.174     ozaki 			LLE_WUNLOCK(la);
    885  1.174     ozaki 		else
    886  1.174     ozaki 			LLE_RUNLOCK(la);
    887  1.174     ozaki 
    888  1.174     ozaki 		if (renew == 1) {
    889  1.174     ozaki 			const u_int8_t *enaddr =
    890  1.110  liamjfoy #if NCARP > 0
    891  1.174     ozaki 			    (rt->rt_ifp->if_type == IFT_CARP) ?
    892  1.174     ozaki 			    CLLADDR(rt->rt_ifp->if_sadl):
    893  1.110  liamjfoy #endif
    894  1.174     ozaki 			    CLLADDR(ifp->if_sadl);
    895  1.174     ozaki 			arprequest(ifp, &satocsin(rt->rt_ifa->ifa_addr)->sin_addr,
    896  1.174     ozaki 			    &satocsin(dst)->sin_addr, enaddr);
    897  1.174     ozaki 		}
    898  1.174     ozaki 
    899  1.174     ozaki 		return 1;
    900  1.174     ozaki 	}
    901  1.174     ozaki 
    902  1.174     ozaki 	if (la->la_flags & LLE_STATIC) {   /* should not happen! */
    903  1.174     ozaki 		log(LOG_DEBUG, "arpresolve: ouch, empty static llinfo for %s\n",
    904  1.174     ozaki 		    inet_ntoa(satocsin(dst)->sin_addr));
    905  1.174     ozaki 		m_freem(m);
    906  1.174     ozaki 		error = EINVAL;
    907  1.174     ozaki 		goto done;
    908  1.174     ozaki 	}
    909  1.174     ozaki 
    910  1.174     ozaki 	renew = (la->la_asked == 0 || la->la_expire != time_uptime);
    911  1.178     ozaki 	if (renew && (flags & LLE_EXCLUSIVE) == 0) {
    912  1.174     ozaki 		flags |= LLE_EXCLUSIVE;
    913  1.174     ozaki 		LLE_RUNLOCK(la);
    914  1.174     ozaki 		la = NULL;
    915  1.174     ozaki 		goto retry;
    916  1.174     ozaki 	}
    917  1.178     ozaki 
    918  1.174     ozaki 	/*
    919  1.174     ozaki 	 * There is an arptab entry, but no ethernet address
    920  1.174     ozaki 	 * response yet.  Add the mbuf to the list, dropping
    921  1.174     ozaki 	 * the oldest packet if we have exceeded the system
    922  1.174     ozaki 	 * setting.
    923  1.174     ozaki 	 */
    924  1.178     ozaki 	LLE_WLOCK_ASSERT(la);
    925  1.178     ozaki 	if (la->la_numheld >= arp_maxhold) {
    926  1.174     ozaki 		if (la->la_hold != NULL) {
    927  1.178     ozaki 			struct mbuf *next = la->la_hold->m_nextpkt;
    928  1.178     ozaki 			m_freem(la->la_hold);
    929  1.178     ozaki 			la->la_hold = next;
    930  1.178     ozaki 			la->la_numheld--;
    931  1.178     ozaki 			ARP_STATINC(ARP_STAT_DFRDROPPED);
    932  1.174     ozaki 		}
    933  1.178     ozaki 	}
    934  1.178     ozaki 	if (la->la_hold != NULL) {
    935  1.178     ozaki 		struct mbuf *curr = la->la_hold;
    936  1.178     ozaki 		while (curr->m_nextpkt != NULL)
    937  1.178     ozaki 			curr = curr->m_nextpkt;
    938  1.178     ozaki 		curr->m_nextpkt = m;
    939  1.178     ozaki 	} else
    940  1.178     ozaki 		la->la_hold = m;
    941  1.178     ozaki 	la->la_numheld++;
    942  1.178     ozaki 	if (renew == 0 && (flags & LLE_EXCLUSIVE)) {
    943  1.178     ozaki 		flags &= ~LLE_EXCLUSIVE;
    944  1.178     ozaki 		LLE_DOWNGRADE(la);
    945  1.178     ozaki 	}
    946  1.174     ozaki 
    947  1.174     ozaki 	/*
    948  1.174     ozaki 	 * Return EWOULDBLOCK if we have tried less than arp_maxtries. It
    949  1.174     ozaki 	 * will be masked by ether_output(). Return EHOSTDOWN/EHOSTUNREACH
    950  1.174     ozaki 	 * if we have already sent arp_maxtries ARP requests. Retransmit the
    951  1.174     ozaki 	 * ARP request, but not faster than one request per second.
    952  1.174     ozaki 	 */
    953  1.174     ozaki 	if (la->la_asked < arp_maxtries)
    954  1.174     ozaki 		error = EWOULDBLOCK;	/* First request. */
    955  1.174     ozaki 	else
    956  1.174     ozaki 		error = (rt->rt_flags & RTF_GATEWAY) ?
    957  1.174     ozaki 		    EHOSTUNREACH : EHOSTDOWN;
    958  1.174     ozaki 
    959  1.174     ozaki 	if (renew) {
    960  1.174     ozaki 		const u_int8_t *enaddr =
    961  1.174     ozaki #if NCARP > 0
    962  1.174     ozaki 		    (rt->rt_ifp->if_type == IFT_CARP) ?
    963  1.174     ozaki 		    CLLADDR(rt->rt_ifp->if_sadl):
    964  1.174     ozaki #endif
    965  1.174     ozaki 		    CLLADDR(ifp->if_sadl);
    966  1.174     ozaki 		LLE_ADDREF(la);
    967  1.174     ozaki 		la->la_expire = time_uptime;
    968  1.174     ozaki 		callout_reset(&la->la_timer, hz * arpt_down,
    969  1.174     ozaki 		    arptimer, la);
    970  1.174     ozaki 		la->la_asked++;
    971  1.174     ozaki 		if (flags & LLE_EXCLUSIVE)
    972  1.174     ozaki 			LLE_WUNLOCK(la);
    973  1.174     ozaki 		else
    974  1.174     ozaki 			LLE_RUNLOCK(la);
    975  1.174     ozaki 		arprequest(ifp, &satocsin(rt->rt_ifa->ifa_addr)->sin_addr,
    976  1.174     ozaki 		    &satocsin(dst)->sin_addr, enaddr);
    977  1.174     ozaki 		return error == 0;
    978   1.12   mycroft 	}
    979  1.174     ozaki done:
    980  1.174     ozaki 	if (flags & LLE_EXCLUSIVE)
    981  1.174     ozaki 		LLE_WUNLOCK(la);
    982  1.174     ozaki 	else
    983  1.174     ozaki 		LLE_RUNLOCK(la);
    984  1.174     ozaki 	return error == 0;
    985   1.10   mycroft }
    986   1.10   mycroft 
    987    1.1       cgd /*
    988   1.12   mycroft  * Common length and type checks are done here,
    989    1.1       cgd  * then the protocol-specific routine is called.
    990    1.1       cgd  */
    991   1.12   mycroft void
    992  1.102     perry arpintr(void)
    993    1.1       cgd {
    994   1.68  augustss 	struct mbuf *m;
    995   1.68  augustss 	struct arphdr *ar;
    996   1.12   mycroft 	int s;
    997   1.82    itojun 	int arplen;
    998    1.1       cgd 
    999  1.134        ad 	mutex_enter(softnet_lock);
   1000  1.134        ad 	KERNEL_LOCK(1, NULL);
   1001   1.12   mycroft 	while (arpintrq.ifq_head) {
   1002   1.73   thorpej 		s = splnet();
   1003   1.12   mycroft 		IF_DEQUEUE(&arpintrq, m);
   1004   1.12   mycroft 		splx(s);
   1005  1.167     ozaki 		if (m == NULL || (m->m_flags & M_PKTHDR) == 0)
   1006   1.12   mycroft 			panic("arpintr");
   1007   1.36        is 
   1008   1.92      matt 		MCLAIM(m, &arpdomain.dom_mowner);
   1009  1.132   thorpej 		ARP_STATINC(ARP_STAT_RCVTOTAL);
   1010   1.70     jhawk 
   1011   1.84     enami 		/*
   1012   1.84     enami 		 * First, make sure we have at least struct arphdr.
   1013   1.84     enami 		 */
   1014   1.84     enami 		if (m->m_len < sizeof(struct arphdr) ||
   1015   1.84     enami 		    (ar = mtod(m, struct arphdr *)) == NULL)
   1016   1.84     enami 			goto badlen;
   1017   1.84     enami 
   1018   1.82    itojun 		switch (m->m_pkthdr.rcvif->if_type) {
   1019   1.82    itojun 		case IFT_IEEE1394:
   1020   1.82    itojun 			arplen = sizeof(struct arphdr) +
   1021   1.82    itojun 			    ar->ar_hln + 2 * ar->ar_pln;
   1022   1.82    itojun 			break;
   1023   1.82    itojun 		default:
   1024   1.82    itojun 			arplen = sizeof(struct arphdr) +
   1025   1.82    itojun 			    2 * ar->ar_hln + 2 * ar->ar_pln;
   1026   1.82    itojun 			break;
   1027   1.82    itojun 		}
   1028   1.82    itojun 
   1029   1.84     enami 		if (/* XXX ntohs(ar->ar_hrd) == ARPHRD_ETHER && */
   1030   1.82    itojun 		    m->m_len >= arplen)
   1031   1.12   mycroft 			switch (ntohs(ar->ar_pro)) {
   1032   1.12   mycroft 			case ETHERTYPE_IP:
   1033   1.12   mycroft 			case ETHERTYPE_IPTRAILERS:
   1034   1.12   mycroft 				in_arpinput(m);
   1035   1.12   mycroft 				continue;
   1036   1.70     jhawk 			default:
   1037  1.132   thorpej 				ARP_STATINC(ARP_STAT_RCVBADPROTO);
   1038   1.12   mycroft 			}
   1039   1.84     enami 		else {
   1040   1.84     enami badlen:
   1041  1.132   thorpej 			ARP_STATINC(ARP_STAT_RCVBADLEN);
   1042   1.84     enami 		}
   1043   1.12   mycroft 		m_freem(m);
   1044    1.1       cgd 	}
   1045  1.134        ad 	KERNEL_UNLOCK_ONE(NULL);
   1046  1.134        ad 	mutex_exit(softnet_lock);
   1047    1.1       cgd }
   1048    1.1       cgd 
   1049    1.1       cgd /*
   1050    1.1       cgd  * ARP for Internet protocols on 10 Mb/s Ethernet.
   1051    1.1       cgd  * Algorithm is that given in RFC 826.
   1052    1.1       cgd  * In addition, a sanity check is performed on the sender
   1053    1.1       cgd  * protocol address, to catch impersonators.
   1054   1.12   mycroft  * We no longer handle negotiations for use of trailer protocol:
   1055   1.12   mycroft  * Formerly, ARP replied for protocol type ETHERTYPE_TRAIL sent
   1056   1.12   mycroft  * along with IP replies if we wanted trailers sent to us,
   1057   1.12   mycroft  * and also sent them in response to IP replies.
   1058   1.12   mycroft  * This allowed either end to announce the desire to receive
   1059    1.1       cgd  * trailer packets.
   1060   1.12   mycroft  * We no longer reply to requests for ETHERTYPE_TRAIL protocol either,
   1061   1.12   mycroft  * but formerly didn't normally send requests.
   1062    1.1       cgd  */
   1063   1.12   mycroft static void
   1064  1.102     perry in_arpinput(struct mbuf *m)
   1065    1.1       cgd {
   1066   1.35        is 	struct arphdr *ah;
   1067   1.68  augustss 	struct ifnet *ifp = m->m_pkthdr.rcvif;
   1068  1.174     ozaki 	struct llentry *la = NULL;
   1069  1.174     ozaki 	struct rtentry  *rt = NULL;
   1070   1.44       tls 	struct in_ifaddr *ia;
   1071   1.77   thorpej #if NBRIDGE > 0
   1072   1.77   thorpej 	struct in_ifaddr *bridge_ia = NULL;
   1073   1.77   thorpej #endif
   1074  1.110  liamjfoy #if NCARP > 0
   1075  1.110  liamjfoy 	u_int32_t count = 0, index = 0;
   1076  1.110  liamjfoy #endif
   1077  1.174     ozaki 	struct sockaddr_dl *sdl = NULL;
   1078    1.1       cgd 	struct sockaddr sa;
   1079    1.1       cgd 	struct in_addr isaddr, itaddr, myaddr;
   1080   1.12   mycroft 	int op;
   1081  1.121  christos 	void *tha;
   1082  1.132   thorpej 	uint64_t *arps;
   1083   1.81    itojun 
   1084  1.111    bouyer 	if (__predict_false(m_makewritable(&m, 0, m->m_pkthdr.len, M_DONTWAIT)))
   1085  1.111    bouyer 		goto out;
   1086   1.35        is 	ah = mtod(m, struct arphdr *);
   1087   1.35        is 	op = ntohs(ah->ar_op);
   1088   1.40       gwr 
   1089   1.89     enami 	/*
   1090   1.89     enami 	 * Fix up ah->ar_hrd if necessary, before using ar_tha() or
   1091   1.89     enami 	 * ar_tpa().
   1092   1.89     enami 	 */
   1093   1.89     enami 	switch (ifp->if_type) {
   1094   1.82    itojun 	case IFT_IEEE1394:
   1095   1.82    itojun 		if (ntohs(ah->ar_hrd) == ARPHRD_IEEE1394)
   1096   1.82    itojun 			;
   1097   1.82    itojun 		else {
   1098   1.82    itojun 			/* XXX this is to make sure we compute ar_tha right */
   1099   1.82    itojun 			/* XXX check ar_hrd more strictly? */
   1100   1.82    itojun 			ah->ar_hrd = htons(ARPHRD_IEEE1394);
   1101   1.82    itojun 		}
   1102   1.82    itojun 		break;
   1103   1.82    itojun 	default:
   1104   1.82    itojun 		/* XXX check ar_hrd? */
   1105   1.82    itojun 		break;
   1106   1.82    itojun 	}
   1107   1.89     enami 
   1108  1.121  christos 	memcpy(&isaddr, ar_spa(ah), sizeof (isaddr));
   1109  1.121  christos 	memcpy(&itaddr, ar_tpa(ah), sizeof (itaddr));
   1110   1.82    itojun 
   1111   1.70     jhawk 	if (m->m_flags & (M_BCAST|M_MCAST))
   1112  1.132   thorpej 		ARP_STATINC(ARP_STAT_RCVMCAST);
   1113   1.70     jhawk 
   1114   1.40       gwr 
   1115   1.44       tls 	/*
   1116   1.44       tls 	 * Search for a matching interface address
   1117   1.44       tls 	 * or any address on the interface to use
   1118   1.44       tls 	 * as a dummy address in the rest of this function
   1119   1.44       tls 	 */
   1120  1.110  liamjfoy 
   1121   1.44       tls 	INADDR_TO_IA(itaddr, ia);
   1122   1.77   thorpej 	while (ia != NULL) {
   1123  1.110  liamjfoy #if NCARP > 0
   1124  1.110  liamjfoy 		if (ia->ia_ifp->if_type == IFT_CARP &&
   1125  1.110  liamjfoy 		    ((ia->ia_ifp->if_flags & (IFF_UP|IFF_RUNNING)) ==
   1126  1.110  liamjfoy 		    (IFF_UP|IFF_RUNNING))) {
   1127  1.110  liamjfoy 			index++;
   1128  1.110  liamjfoy 			if (ia->ia_ifp == m->m_pkthdr.rcvif &&
   1129  1.110  liamjfoy 			    carp_iamatch(ia, ar_sha(ah),
   1130  1.110  liamjfoy 			    &count, index)) {
   1131  1.110  liamjfoy 				break;
   1132  1.110  liamjfoy 				}
   1133  1.110  liamjfoy 		} else
   1134  1.110  liamjfoy #endif
   1135  1.110  liamjfoy 			    if (ia->ia_ifp == m->m_pkthdr.rcvif)
   1136  1.110  liamjfoy 				break;
   1137   1.77   thorpej #if NBRIDGE > 0
   1138   1.77   thorpej 		/*
   1139   1.77   thorpej 		 * If the interface we received the packet on
   1140   1.77   thorpej 		 * is part of a bridge, check to see if we need
   1141   1.77   thorpej 		 * to "bridge" the packet to ourselves at this
   1142   1.77   thorpej 		 * layer.  Note we still prefer a perfect match,
   1143   1.77   thorpej 		 * but allow this weaker match if necessary.
   1144   1.77   thorpej 		 */
   1145   1.77   thorpej 		if (m->m_pkthdr.rcvif->if_bridge != NULL &&
   1146   1.77   thorpej 		    m->m_pkthdr.rcvif->if_bridge == ia->ia_ifp->if_bridge)
   1147   1.77   thorpej 			bridge_ia = ia;
   1148   1.77   thorpej #endif /* NBRIDGE > 0 */
   1149   1.77   thorpej 
   1150   1.49        is 		NEXT_IA_WITH_SAME_ADDR(ia);
   1151   1.77   thorpej 	}
   1152   1.77   thorpej 
   1153   1.77   thorpej #if NBRIDGE > 0
   1154   1.78    itojun 	if (ia == NULL && bridge_ia != NULL) {
   1155   1.77   thorpej 		ia = bridge_ia;
   1156   1.78    itojun 		ifp = bridge_ia->ia_ifp;
   1157   1.78    itojun 	}
   1158   1.77   thorpej #endif
   1159   1.49        is 
   1160   1.44       tls 	if (ia == NULL) {
   1161   1.44       tls 		INADDR_TO_IA(isaddr, ia);
   1162   1.49        is 		while ((ia != NULL) && ia->ia_ifp != m->m_pkthdr.rcvif)
   1163   1.49        is 			NEXT_IA_WITH_SAME_ADDR(ia);
   1164   1.49        is 
   1165   1.49        is 		if (ia == NULL) {
   1166   1.48        is 			IFP_TO_IA(ifp, ia);
   1167   1.70     jhawk 			if (ia == NULL) {
   1168  1.132   thorpej 				ARP_STATINC(ARP_STAT_RCVNOINT);
   1169   1.49        is 				goto out;
   1170   1.70     jhawk 			}
   1171   1.49        is 		}
   1172   1.44       tls 	}
   1173   1.48        is 
   1174   1.44       tls 	myaddr = ia->ia_addr.sin_addr;
   1175   1.36        is 
   1176   1.78    itojun 	/* XXX checks for bridge case? */
   1177  1.126    dyoung 	if (!memcmp(ar_sha(ah), CLLADDR(ifp->if_sadl), ifp->if_addrlen)) {
   1178  1.132   thorpej 		ARP_STATINC(ARP_STAT_RCVLOCALSHA);
   1179    1.1       cgd 		goto out;	/* it's from me, ignore it. */
   1180   1.70     jhawk 	}
   1181   1.41        is 
   1182   1.78    itojun 	/* XXX checks for bridge case? */
   1183  1.104  christos 	if (!memcmp(ar_sha(ah), ifp->if_broadcastaddr, ifp->if_addrlen)) {
   1184  1.132   thorpej 		ARP_STATINC(ARP_STAT_RCVBCASTSHA);
   1185   1.41        is 		log(LOG_ERR,
   1186   1.46      matt 		    "%s: arp: link address is broadcast for IP address %s!\n",
   1187   1.46      matt 		    ifp->if_xname, in_fmtaddr(isaddr));
   1188   1.41        is 		goto out;
   1189   1.41        is 	}
   1190   1.41        is 
   1191  1.148  christos 	/*
   1192  1.148  christos 	 * If the source IP address is zero, this is an RFC 5227 ARP probe
   1193  1.148  christos 	 */
   1194  1.163       roy 	if (in_nullhost(isaddr))
   1195  1.148  christos 		ARP_STATINC(ARP_STAT_RCVZEROSPA);
   1196  1.163       roy 	else if (in_hosteq(isaddr, myaddr))
   1197  1.163       roy 		ARP_STATINC(ARP_STAT_RCVLOCALSPA);
   1198  1.163       roy 
   1199  1.163       roy 	if (in_nullhost(itaddr))
   1200  1.163       roy 		ARP_STATINC(ARP_STAT_RCVZEROTPA);
   1201  1.163       roy 
   1202  1.163       roy 	/* DAD check, RFC 5227 2.1.1, Probe Details */
   1203  1.163       roy 	if (in_hosteq(isaddr, myaddr) ||
   1204  1.163       roy 	    (in_nullhost(isaddr) && in_hosteq(itaddr, myaddr)))
   1205  1.163       roy 	{
   1206  1.163       roy 		/* If our address is tentative, mark it as duplicated */
   1207  1.163       roy 		if (ia->ia4_flags & IN_IFF_TENTATIVE)
   1208  1.163       roy 			arp_dad_duplicated((struct ifaddr *)ia);
   1209  1.163       roy 		/* If our address is unuseable, don't reply */
   1210  1.163       roy 		if (ia->ia4_flags & (IN_IFF_NOTREADY | IN_IFF_DETACHED))
   1211  1.163       roy 			goto out;
   1212  1.163       roy 	}
   1213  1.163       roy 
   1214  1.163       roy 	/*
   1215  1.163       roy 	 * If the target IP address is zero, ignore the packet.
   1216  1.163       roy 	 * This prevents the code below from tring to answer
   1217  1.163       roy 	 * when we are using IP address zero (booting).
   1218  1.163       roy 	 */
   1219  1.163       roy 	if (in_nullhost(itaddr))
   1220  1.163       roy 		goto out;
   1221  1.163       roy 
   1222  1.163       roy 	if (in_nullhost(isaddr))
   1223  1.148  christos 		goto reply;
   1224  1.148  christos 
   1225   1.35        is 	if (in_hosteq(isaddr, myaddr)) {
   1226    1.1       cgd 		log(LOG_ERR,
   1227   1.46      matt 		   "duplicate IP address %s sent from link address %s\n",
   1228   1.46      matt 		   in_fmtaddr(isaddr), lla_snprintf(ar_sha(ah), ah->ar_hln));
   1229    1.1       cgd 		itaddr = myaddr;
   1230   1.12   mycroft 		goto reply;
   1231    1.1       cgd 	}
   1232  1.174     ozaki 
   1233  1.174     ozaki 	la = arplookup(ifp, m, &isaddr, in_hosteq(itaddr, myaddr), 0, 1, NULL);
   1234  1.174     ozaki 	if (la != NULL) {
   1235  1.174     ozaki 		rt = la->la_rt;
   1236  1.174     ozaki 		if (rt != NULL)
   1237  1.174     ozaki 			sdl = satosdl(rt->rt_gateway);
   1238  1.174     ozaki 	}
   1239  1.174     ozaki 	if (sdl != NULL) {
   1240   1.12   mycroft 		if (sdl->sdl_alen &&
   1241  1.126    dyoung 		    memcmp(ar_sha(ah), CLLADDR(sdl), sdl->sdl_alen)) {
   1242   1.58        is 			if (rt->rt_flags & RTF_STATIC) {
   1243  1.132   thorpej 				ARP_STATINC(ARP_STAT_RCVOVERPERM);
   1244  1.152  christos 				if (!log_permanent_modify)
   1245  1.152  christos 					goto out;
   1246   1.58        is 				log(LOG_INFO,
   1247   1.58        is 				    "%s tried to overwrite permanent arp info"
   1248   1.58        is 				    " for %s\n",
   1249   1.58        is 				    lla_snprintf(ar_sha(ah), ah->ar_hln),
   1250   1.58        is 				    in_fmtaddr(isaddr));
   1251   1.58        is 				goto out;
   1252   1.58        is 			} else if (rt->rt_ifp != ifp) {
   1253  1.132   thorpej 				ARP_STATINC(ARP_STAT_RCVOVERINT);
   1254  1.152  christos 				if (!log_wrong_iface)
   1255  1.152  christos 					goto out;
   1256   1.57        is 				log(LOG_INFO,
   1257   1.57        is 				    "%s on %s tried to overwrite "
   1258   1.57        is 				    "arp info for %s on %s\n",
   1259   1.57        is 				    lla_snprintf(ar_sha(ah), ah->ar_hln),
   1260   1.57        is 				    ifp->if_xname, in_fmtaddr(isaddr),
   1261   1.57        is 				    rt->rt_ifp->if_xname);
   1262   1.57        is 				    goto out;
   1263   1.57        is 			} else {
   1264  1.132   thorpej 				ARP_STATINC(ARP_STAT_RCVOVER);
   1265  1.152  christos 				if (log_movements)
   1266  1.152  christos 					log(LOG_INFO, "arp info overwritten "
   1267  1.152  christos 					    "for %s by %s\n",
   1268  1.152  christos 					    in_fmtaddr(isaddr),
   1269  1.152  christos 					    lla_snprintf(ar_sha(ah),
   1270  1.152  christos 					    ah->ar_hln));
   1271   1.57        is 			}
   1272   1.57        is 		}
   1273   1.81    itojun 		/*
   1274   1.35        is 		 * sanity check for the address length.
   1275   1.35        is 		 * XXX this does not work for protocols with variable address
   1276   1.35        is 		 * length. -is
   1277   1.35        is 		 */
   1278   1.35        is 		if (sdl->sdl_alen &&
   1279   1.35        is 		    sdl->sdl_alen != ah->ar_hln) {
   1280  1.132   thorpej 			ARP_STATINC(ARP_STAT_RCVLENCHG);
   1281   1.81    itojun 			log(LOG_WARNING,
   1282  1.141  uebayasi 			    "arp from %s: new addr len %d, was %d\n",
   1283   1.46      matt 			    in_fmtaddr(isaddr), ah->ar_hln, sdl->sdl_alen);
   1284   1.35        is 		}
   1285   1.86     enami 		if (ifp->if_addrlen != ah->ar_hln) {
   1286  1.132   thorpej 			ARP_STATINC(ARP_STAT_RCVBADLEN);
   1287   1.81    itojun 			log(LOG_WARNING,
   1288  1.141  uebayasi 			    "arp from %s: addr len: new %d, i/f %d (ignored)\n",
   1289   1.46      matt 			    in_fmtaddr(isaddr), ah->ar_hln,
   1290   1.86     enami 			    ifp->if_addrlen);
   1291   1.35        is 			goto reply;
   1292   1.35        is 		}
   1293   1.56       bad #if NTOKEN > 0
   1294   1.56       bad 		/*
   1295   1.60       bad 		 * XXX uses m_data and assumes the complete answer including
   1296   1.56       bad 		 * XXX token-ring headers is in the same buf
   1297   1.56       bad 		 */
   1298   1.61       bad 		if (ifp->if_type == IFT_ISO88025) {
   1299   1.61       bad 			struct token_header *trh;
   1300   1.61       bad 
   1301   1.61       bad 			trh = (struct token_header *)M_TRHSTART(m);
   1302   1.61       bad 			if (trh->token_shost[0] & TOKEN_RI_PRESENT) {
   1303   1.61       bad 				struct token_rif	*rif;
   1304   1.61       bad 				size_t	riflen;
   1305   1.61       bad 
   1306   1.61       bad 				rif = TOKEN_RIF(trh);
   1307   1.61       bad 				riflen = (ntohs(rif->tr_rcf) &
   1308   1.61       bad 				    TOKEN_RCF_LEN_MASK) >> 8;
   1309   1.61       bad 
   1310   1.61       bad 				if (riflen > 2 &&
   1311   1.61       bad 				    riflen < sizeof(struct token_rif) &&
   1312   1.61       bad 				    (riflen & 1) == 0) {
   1313   1.61       bad 					rif->tr_rcf ^= htons(TOKEN_RCF_DIRECTION);
   1314   1.61       bad 					rif->tr_rcf &= htons(~TOKEN_RCF_BROADCAST_MASK);
   1315  1.140    dyoung 					memcpy(TOKEN_RIF(la), rif, riflen);
   1316   1.61       bad 				}
   1317   1.56       bad 			}
   1318   1.56       bad 		}
   1319   1.56       bad #endif /* NTOKEN > 0 */
   1320  1.127    dyoung 		(void)sockaddr_dl_setaddr(sdl, sdl->sdl_len, ar_sha(ah),
   1321  1.127    dyoung 		    ah->ar_hln);
   1322  1.174     ozaki 		if (rt->rt_expire) {
   1323  1.171     ozaki 			rt->rt_expire = time_uptime + arpt_keep;
   1324  1.174     ozaki 
   1325  1.174     ozaki 			KASSERT((la->la_flags & LLE_STATIC) == 0);
   1326  1.174     ozaki 			LLE_ADDREF(la);
   1327  1.174     ozaki 			callout_reset(&la->la_timer, hz * arpt_keep, arptimer, la);
   1328  1.174     ozaki 		}
   1329   1.12   mycroft 		rt->rt_flags &= ~RTF_REJECT;
   1330   1.12   mycroft 		la->la_asked = 0;
   1331   1.63  sommerfe 
   1332  1.174     ozaki 		if (la->la_hold != NULL) {
   1333  1.174     ozaki 			int n = la->la_numheld;
   1334  1.174     ozaki 			struct mbuf *m_hold, *m_hold_next;
   1335  1.174     ozaki 
   1336  1.174     ozaki 			m_hold = la->la_hold;
   1337  1.174     ozaki 			la->la_hold = NULL;
   1338  1.174     ozaki 			la->la_numheld = 0;
   1339  1.174     ozaki 			/*
   1340  1.174     ozaki 			 * We have to unlock here because if_output would call
   1341  1.174     ozaki 			 * arpresolve
   1342  1.174     ozaki 			 */
   1343  1.174     ozaki 			LLE_WUNLOCK(la);
   1344  1.174     ozaki 			ARP_STATADD(ARP_STAT_DFRSENT, n);
   1345  1.174     ozaki 			for (; m_hold != NULL; m_hold = m_hold_next) {
   1346  1.174     ozaki 				m_hold_next = m_hold->m_nextpkt;
   1347  1.174     ozaki 				m_hold->m_nextpkt = NULL;
   1348  1.174     ozaki 				(*ifp->if_output)(ifp, m_hold, rt_getkey(rt), rt);
   1349  1.174     ozaki 			}
   1350  1.174     ozaki 		} else
   1351  1.174     ozaki 			LLE_WUNLOCK(la);
   1352  1.174     ozaki 		la = NULL;
   1353    1.1       cgd 	}
   1354    1.1       cgd reply:
   1355  1.174     ozaki 	if (la != NULL) {
   1356  1.174     ozaki 		LLE_WUNLOCK(la);
   1357  1.174     ozaki 		la = NULL;
   1358  1.174     ozaki 	}
   1359   1.12   mycroft 	if (op != ARPOP_REQUEST) {
   1360   1.70     jhawk 		if (op == ARPOP_REPLY)
   1361  1.132   thorpej 			ARP_STATINC(ARP_STAT_RCVREPLY);
   1362  1.172     ozaki 		goto out;
   1363    1.1       cgd 	}
   1364  1.132   thorpej 	ARP_STATINC(ARP_STAT_RCVREQUEST);
   1365   1.35        is 	if (in_hosteq(itaddr, myaddr)) {
   1366  1.163       roy 		/* If our address is unuseable, don't reply */
   1367  1.163       roy 		if (ia->ia4_flags & (IN_IFF_NOTREADY | IN_IFF_DETACHED))
   1368  1.163       roy 			goto out;
   1369    1.1       cgd 		/* I am the target */
   1370  1.109       mrg 		tha = ar_tha(ah);
   1371  1.109       mrg 		if (tha)
   1372  1.121  christos 			memcpy(tha, ar_sha(ah), ah->ar_hln);
   1373  1.126    dyoung 		memcpy(ar_sha(ah), CLLADDR(ifp->if_sadl), ah->ar_hln);
   1374    1.1       cgd 	} else {
   1375  1.174     ozaki 		la = arplookup(ifp, m, &itaddr, 0, SIN_PROXY, 0, NULL);
   1376  1.139    dyoung 		if (la == NULL)
   1377    1.1       cgd 			goto out;
   1378   1.12   mycroft 		rt = la->la_rt;
   1379  1.174     ozaki 		LLE_RUNLOCK(la);
   1380  1.174     ozaki 		la = NULL;
   1381  1.110  liamjfoy 		if (rt->rt_ifp->if_type == IFT_CARP &&
   1382  1.110  liamjfoy 		    m->m_pkthdr.rcvif->if_type != IFT_CARP)
   1383  1.110  liamjfoy 			goto out;
   1384  1.109       mrg 		tha = ar_tha(ah);
   1385  1.109       mrg 		if (tha)
   1386  1.121  christos 			memcpy(tha, ar_sha(ah), ah->ar_hln);
   1387  1.126    dyoung 		sdl = satosdl(rt->rt_gateway);
   1388  1.126    dyoung 		memcpy(ar_sha(ah), CLLADDR(sdl), ah->ar_hln);
   1389    1.1       cgd 	}
   1390    1.1       cgd 
   1391  1.121  christos 	memcpy(ar_tpa(ah), ar_spa(ah), ah->ar_pln);
   1392  1.121  christos 	memcpy(ar_spa(ah), &itaddr, ah->ar_pln);
   1393   1.35        is 	ah->ar_op = htons(ARPOP_REPLY);
   1394   1.35        is 	ah->ar_pro = htons(ETHERTYPE_IP); /* let's be sure! */
   1395   1.85     enami 	switch (ifp->if_type) {
   1396   1.85     enami 	case IFT_IEEE1394:
   1397   1.85     enami 		/*
   1398   1.85     enami 		 * ieee1394 arp reply is broadcast
   1399   1.85     enami 		 */
   1400   1.85     enami 		m->m_flags &= ~M_MCAST;
   1401   1.85     enami 		m->m_flags |= M_BCAST;
   1402   1.85     enami 		m->m_len = sizeof(*ah) + (2 * ah->ar_pln) + ah->ar_hln;
   1403   1.85     enami 		break;
   1404   1.85     enami 
   1405   1.85     enami 	default:
   1406   1.85     enami 		m->m_flags &= ~(M_BCAST|M_MCAST); /* never reply by broadcast */
   1407   1.85     enami 		m->m_len = sizeof(*ah) + (2 * ah->ar_pln) + (2 * ah->ar_hln);
   1408   1.85     enami 		break;
   1409   1.85     enami 	}
   1410   1.62   thorpej 	m->m_pkthdr.len = m->m_len;
   1411   1.35        is 	sa.sa_family = AF_ARP;
   1412   1.35        is 	sa.sa_len = 2;
   1413  1.132   thorpej 	arps = ARP_STAT_GETREF();
   1414  1.132   thorpej 	arps[ARP_STAT_SNDTOTAL]++;
   1415  1.132   thorpej 	arps[ARP_STAT_SNDREPLY]++;
   1416  1.132   thorpej 	ARP_STAT_PUTREF();
   1417  1.153  christos 	(*ifp->if_output)(ifp, m, &sa, NULL);
   1418    1.1       cgd 	return;
   1419  1.174     ozaki 
   1420  1.172     ozaki out:
   1421  1.174     ozaki 	if (la != NULL)
   1422  1.174     ozaki 		LLE_WUNLOCK(la);
   1423  1.172     ozaki 	m_freem(m);
   1424    1.1       cgd }
   1425    1.1       cgd 
   1426    1.1       cgd /*
   1427   1.12   mycroft  * Free an arp entry.
   1428    1.1       cgd  */
   1429  1.180     ozaki static void arptfree(struct rtentry *rt)
   1430   1.12   mycroft {
   1431  1.174     ozaki 
   1432  1.125    dyoung 	rtrequest(RTM_DELETE, rt_getkey(rt), NULL, rt_mask(rt), 0, NULL);
   1433  1.180     ozaki 	rtfree(rt);
   1434    1.1       cgd }
   1435    1.1       cgd 
   1436    1.1       cgd /*
   1437   1.12   mycroft  * Lookup or enter a new address in arptab.
   1438   1.12   mycroft  */
   1439  1.174     ozaki static struct llentry *
   1440  1.174     ozaki arplookup(struct ifnet *ifp, struct mbuf *m, const struct in_addr *addr,
   1441  1.174     ozaki     int create, int proxy, int wlock, struct rtentry *rt0)
   1442   1.12   mycroft {
   1443   1.75      tron 	struct arphdr *ah;
   1444   1.68  augustss 	struct rtentry *rt;
   1445  1.138    dyoung 	struct sockaddr_inarp sin;
   1446  1.138    dyoung 	const char *why = NULL;
   1447    1.1       cgd 
   1448   1.75      tron 	ah = mtod(m, struct arphdr *);
   1449  1.126    dyoung 	if (rt0 == NULL) {
   1450  1.138    dyoung 		memset(&sin, 0, sizeof(sin));
   1451  1.126    dyoung 		sin.sin_len = sizeof(sin);
   1452  1.126    dyoung 		sin.sin_family = AF_INET;
   1453  1.126    dyoung 		sin.sin_addr = *addr;
   1454  1.126    dyoung 		sin.sin_other = proxy ? SIN_PROXY : 0;
   1455  1.126    dyoung 		rt = rtalloc1(sintosa(&sin), create);
   1456  1.126    dyoung 		if (rt == NULL)
   1457  1.139    dyoung 			return NULL;
   1458  1.126    dyoung 		rt->rt_refcnt--;
   1459  1.126    dyoung 	} else
   1460  1.126    dyoung 		rt = rt0;
   1461  1.126    dyoung 
   1462  1.126    dyoung #define	IS_LLINFO(__rt)							  \
   1463  1.126    dyoung 	(((__rt)->rt_flags & (RTF_GATEWAY | RTF_LLINFO)) == RTF_LLINFO && \
   1464  1.126    dyoung 	 (__rt)->rt_gateway->sa_family == AF_LINK)
   1465  1.126    dyoung 
   1466   1.53  drochner 
   1467  1.174     ozaki 	if (IS_LLINFO(rt)) {
   1468  1.174     ozaki 		struct llentry *la;
   1469  1.174     ozaki 		int flags = wlock ? LLE_EXCLUSIVE : 0;
   1470  1.174     ozaki 
   1471  1.174     ozaki 		if (create) {
   1472  1.174     ozaki 			IF_AFDATA_WLOCK(ifp);
   1473  1.174     ozaki 			la = lla_create(LLTABLE(ifp), flags, rt_getkey(rt));
   1474  1.174     ozaki 			IF_AFDATA_WUNLOCK(ifp);
   1475  1.174     ozaki 		} else {
   1476  1.174     ozaki 			IF_AFDATA_RLOCK(ifp);
   1477  1.174     ozaki 			la = lla_lookup(LLTABLE(ifp), flags, rt_getkey(rt));
   1478  1.174     ozaki 			IF_AFDATA_RUNLOCK(ifp);
   1479  1.174     ozaki 		}
   1480  1.174     ozaki 
   1481  1.174     ozaki 		return la;
   1482  1.174     ozaki 	}
   1483   1.53  drochner 
   1484   1.94    itojun 	if (create) {
   1485  1.160  christos 		if (rt->rt_flags & RTF_GATEWAY) {
   1486  1.160  christos 			if (log_unknown_network)
   1487  1.160  christos 				why = "host is not on local network";
   1488  1.160  christos 		} else if ((rt->rt_flags & RTF_LLINFO) == 0) {
   1489  1.132   thorpej 			ARP_STATINC(ARP_STAT_ALLOCFAIL);
   1490   1.99  christos 			why = "could not allocate llinfo";
   1491  1.103     perry 		} else
   1492   1.99  christos 			why = "gateway route is not ours";
   1493  1.160  christos 		if (why) {
   1494  1.160  christos 			log(LOG_DEBUG, "arplookup: unable to enter address"
   1495  1.160  christos 			    " for %s@%s on %s (%s)\n", in_fmtaddr(*addr),
   1496  1.160  christos 			    lla_snprintf(ar_sha(ah), ah->ar_hln),
   1497  1.160  christos 			    (ifp) ? ifp->if_xname : "null", why);
   1498  1.160  christos 		}
   1499  1.174     ozaki 		if ((rt->rt_flags & RTF_CLONED) != 0) {
   1500  1.125    dyoung 			rtrequest(RTM_DELETE, rt_getkey(rt),
   1501  1.139    dyoung 		    	    rt->rt_gateway, rt_mask(rt), rt->rt_flags, NULL);
   1502   1.94    itojun 		}
   1503   1.94    itojun 	}
   1504  1.139    dyoung 	return NULL;
   1505    1.1       cgd }
   1506    1.1       cgd 
   1507   1.12   mycroft int
   1508  1.121  christos arpioctl(u_long cmd, void *data)
   1509    1.1       cgd {
   1510   1.20   mycroft 
   1511  1.139    dyoung 	return EOPNOTSUPP;
   1512   1.20   mycroft }
   1513   1.20   mycroft 
   1514   1.20   mycroft void
   1515  1.102     perry arp_ifinit(struct ifnet *ifp, struct ifaddr *ifa)
   1516   1.20   mycroft {
   1517   1.40       gwr 	struct in_addr *ip;
   1518  1.163       roy 	struct in_ifaddr *ia = (struct in_ifaddr *)ifa;
   1519   1.40       gwr 
   1520   1.40       gwr 	/*
   1521   1.40       gwr 	 * Warn the user if another station has this IP address,
   1522   1.40       gwr 	 * but only if the interface IP address is not zero.
   1523   1.40       gwr 	 */
   1524   1.40       gwr 	ip = &IA_SIN(ifa)->sin_addr;
   1525  1.163       roy 	if (!in_nullhost(*ip) &&
   1526  1.163       roy 	    (ia->ia4_flags & (IN_IFF_NOTREADY | IN_IFF_DETACHED)) == 0)
   1527  1.127    dyoung 		arprequest(ifp, ip, ip, CLLADDR(ifp->if_sadl));
   1528   1.20   mycroft 
   1529   1.20   mycroft 	ifa->ifa_rtrequest = arp_rtrequest;
   1530   1.20   mycroft 	ifa->ifa_flags |= RTF_CLONING;
   1531  1.165       roy 
   1532  1.165       roy 	/* ARP will handle DAD for this address. */
   1533  1.165       roy 	if (ia->ia4_flags & IN_IFF_TRYTENTATIVE) {
   1534  1.165       roy 		ia->ia4_flags |= IN_IFF_TENTATIVE;
   1535  1.165       roy 		ia->ia_dad_start = arp_dad_start;
   1536  1.165       roy 		ia->ia_dad_stop = arp_dad_stop;
   1537  1.165       roy 	}
   1538    1.9     glass }
   1539    1.9     glass 
   1540  1.163       roy TAILQ_HEAD(dadq_head, dadq);
   1541  1.163       roy struct dadq {
   1542  1.163       roy 	TAILQ_ENTRY(dadq) dad_list;
   1543  1.163       roy 	struct ifaddr *dad_ifa;
   1544  1.163       roy 	int dad_count;		/* max ARP to send */
   1545  1.163       roy 	int dad_arp_tcount;	/* # of trials to send ARP */
   1546  1.163       roy 	int dad_arp_ocount;	/* ARP sent so far */
   1547  1.163       roy 	int dad_arp_announce;	/* max ARP announcements */
   1548  1.163       roy 	int dad_arp_acount;	/* # of announcements */
   1549  1.163       roy 	struct callout dad_timer_ch;
   1550  1.163       roy };
   1551  1.163       roy MALLOC_JUSTDEFINE(M_IPARP, "ARP DAD", "ARP DAD Structure");
   1552  1.163       roy 
   1553  1.163       roy static struct dadq_head dadq;
   1554  1.163       roy static int dad_init = 0;
   1555  1.163       roy static int dad_maxtry = 15;     /* max # of *tries* to transmit DAD packet */
   1556  1.163       roy 
   1557  1.163       roy static struct dadq *
   1558  1.163       roy arp_dad_find(struct ifaddr *ifa)
   1559  1.163       roy {
   1560  1.163       roy 	struct dadq *dp;
   1561  1.163       roy 
   1562  1.163       roy 	TAILQ_FOREACH(dp, &dadq, dad_list) {
   1563  1.163       roy 		if (dp->dad_ifa == ifa)
   1564  1.163       roy 			return dp;
   1565  1.163       roy 	}
   1566  1.163       roy 	return NULL;
   1567  1.163       roy }
   1568  1.163       roy 
   1569  1.163       roy static void
   1570  1.163       roy arp_dad_starttimer(struct dadq *dp, int ticks)
   1571  1.163       roy {
   1572  1.163       roy 
   1573  1.163       roy 	callout_reset(&dp->dad_timer_ch, ticks,
   1574  1.163       roy 	    (void (*)(void *))arp_dad_timer, (void *)dp->dad_ifa);
   1575  1.163       roy }
   1576  1.163       roy 
   1577  1.163       roy static void
   1578  1.163       roy arp_dad_stoptimer(struct dadq *dp)
   1579  1.163       roy {
   1580  1.163       roy 
   1581  1.163       roy 	callout_stop(&dp->dad_timer_ch);
   1582  1.163       roy }
   1583  1.163       roy 
   1584  1.163       roy static void
   1585  1.163       roy arp_dad_output(struct dadq *dp, struct ifaddr *ifa)
   1586  1.163       roy {
   1587  1.163       roy 	struct in_ifaddr *ia = (struct in_ifaddr *)ifa;
   1588  1.163       roy 	struct ifnet *ifp = ifa->ifa_ifp;
   1589  1.163       roy 	struct in_addr sip;
   1590  1.163       roy 
   1591  1.163       roy 	dp->dad_arp_tcount++;
   1592  1.163       roy 	if ((ifp->if_flags & IFF_UP) == 0)
   1593  1.163       roy 		return;
   1594  1.163       roy 	if ((ifp->if_flags & IFF_RUNNING) == 0)
   1595  1.163       roy 		return;
   1596  1.163       roy 
   1597  1.163       roy 	dp->dad_arp_tcount = 0;
   1598  1.163       roy 	dp->dad_arp_ocount++;
   1599  1.163       roy 
   1600  1.163       roy 	memset(&sip, 0, sizeof(sip));
   1601  1.163       roy 	arprequest(ifa->ifa_ifp, &sip, &ia->ia_addr.sin_addr,
   1602  1.163       roy 	    CLLADDR(ifa->ifa_ifp->if_sadl));
   1603  1.163       roy }
   1604  1.163       roy 
   1605  1.163       roy /*
   1606  1.163       roy  * Start Duplicate Address Detection (DAD) for specified interface address.
   1607  1.163       roy  */
   1608  1.165       roy static void
   1609  1.163       roy arp_dad_start(struct ifaddr *ifa)
   1610  1.163       roy {
   1611  1.163       roy 	struct in_ifaddr *ia = (struct in_ifaddr *)ifa;
   1612  1.163       roy 	struct dadq *dp;
   1613  1.163       roy 
   1614  1.163       roy 	if (!dad_init) {
   1615  1.163       roy 		TAILQ_INIT(&dadq);
   1616  1.163       roy 		dad_init++;
   1617  1.163       roy 	}
   1618  1.163       roy 
   1619  1.163       roy 	/*
   1620  1.163       roy 	 * If we don't need DAD, don't do it.
   1621  1.163       roy 	 * - DAD is disabled (ip_dad_count == 0)
   1622  1.163       roy 	 */
   1623  1.163       roy 	if (!(ia->ia4_flags & IN_IFF_TENTATIVE)) {
   1624  1.163       roy 		log(LOG_DEBUG,
   1625  1.163       roy 			"arp_dad_start: called with non-tentative address "
   1626  1.163       roy 			"%s(%s)\n",
   1627  1.163       roy 			in_fmtaddr(ia->ia_addr.sin_addr),
   1628  1.163       roy 			ifa->ifa_ifp ? if_name(ifa->ifa_ifp) : "???");
   1629  1.163       roy 		return;
   1630  1.163       roy 	}
   1631  1.163       roy 	if (!ip_dad_count) {
   1632  1.163       roy 		struct in_addr *ip = &IA_SIN(ifa)->sin_addr;
   1633  1.163       roy 
   1634  1.163       roy 		ia->ia4_flags &= ~IN_IFF_TENTATIVE;
   1635  1.163       roy 		rt_newaddrmsg(RTM_NEWADDR, ifa, 0, NULL);
   1636  1.163       roy 		arprequest(ifa->ifa_ifp, ip, ip,
   1637  1.163       roy 		    CLLADDR(ifa->ifa_ifp->if_sadl));
   1638  1.163       roy 		return;
   1639  1.163       roy 	}
   1640  1.163       roy 	if (ifa->ifa_ifp == NULL)
   1641  1.163       roy 		panic("arp_dad_start: ifa->ifa_ifp == NULL");
   1642  1.163       roy 	if (!(ifa->ifa_ifp->if_flags & IFF_UP))
   1643  1.163       roy 		return;
   1644  1.163       roy 	if (arp_dad_find(ifa) != NULL) {
   1645  1.163       roy 		/* DAD already in progress */
   1646  1.163       roy 		return;
   1647  1.163       roy 	}
   1648  1.163       roy 
   1649  1.163       roy 	dp = malloc(sizeof(*dp), M_IPARP, M_NOWAIT);
   1650  1.163       roy 	if (dp == NULL) {
   1651  1.163       roy 		log(LOG_ERR, "arp_dad_start: memory allocation failed for "
   1652  1.163       roy 			"%s(%s)\n",
   1653  1.163       roy 			in_fmtaddr(ia->ia_addr.sin_addr),
   1654  1.163       roy 			ifa->ifa_ifp ? if_name(ifa->ifa_ifp) : "???");
   1655  1.163       roy 		return;
   1656  1.163       roy 	}
   1657  1.163       roy 	memset(dp, 0, sizeof(*dp));
   1658  1.163       roy 	callout_init(&dp->dad_timer_ch, CALLOUT_MPSAFE);
   1659  1.163       roy 	TAILQ_INSERT_TAIL(&dadq, (struct dadq *)dp, dad_list);
   1660  1.163       roy 
   1661  1.163       roy 	arplog((LOG_DEBUG, "%s: starting DAD for %s\n", if_name(ifa->ifa_ifp),
   1662  1.163       roy 	    in_fmtaddr(ia->ia_addr.sin_addr)));
   1663  1.163       roy 
   1664  1.163       roy 	/*
   1665  1.163       roy 	 * Send ARP packet for DAD, ip_dad_count times.
   1666  1.163       roy 	 * Note that we must delay the first transmission.
   1667  1.163       roy 	 */
   1668  1.163       roy 	dp->dad_ifa = ifa;
   1669  1.163       roy 	ifaref(ifa);	/* just for safety */
   1670  1.163       roy 	dp->dad_count = ip_dad_count;
   1671  1.163       roy 	dp->dad_arp_announce = 0; /* Will be set when starting to announce */
   1672  1.163       roy 	dp->dad_arp_acount = dp->dad_arp_ocount = dp->dad_arp_tcount = 0;
   1673  1.163       roy 
   1674  1.163       roy 	arp_dad_starttimer(dp, cprng_fast32() % (PROBE_WAIT * hz));
   1675  1.163       roy }
   1676  1.163       roy 
   1677  1.163       roy /*
   1678  1.163       roy  * terminate DAD unconditionally.  used for address removals.
   1679  1.163       roy  */
   1680  1.165       roy static void
   1681  1.163       roy arp_dad_stop(struct ifaddr *ifa)
   1682  1.163       roy {
   1683  1.163       roy 	struct dadq *dp;
   1684  1.163       roy 
   1685  1.163       roy 	if (!dad_init)
   1686  1.163       roy 		return;
   1687  1.163       roy 	dp = arp_dad_find(ifa);
   1688  1.163       roy 	if (dp == NULL) {
   1689  1.163       roy 		/* DAD wasn't started yet */
   1690  1.163       roy 		return;
   1691  1.163       roy 	}
   1692  1.163       roy 
   1693  1.163       roy 	arp_dad_stoptimer(dp);
   1694  1.163       roy 
   1695  1.163       roy 	TAILQ_REMOVE(&dadq, dp, dad_list);
   1696  1.163       roy 	free(dp, M_IPARP);
   1697  1.163       roy 	dp = NULL;
   1698  1.163       roy 	ifafree(ifa);
   1699  1.163       roy }
   1700  1.163       roy 
   1701  1.163       roy static void
   1702  1.163       roy arp_dad_timer(struct ifaddr *ifa)
   1703  1.163       roy {
   1704  1.163       roy 	struct in_ifaddr *ia = (struct in_ifaddr *)ifa;
   1705  1.163       roy 	struct dadq *dp;
   1706  1.163       roy 	struct in_addr *ip;
   1707  1.163       roy 
   1708  1.163       roy 	mutex_enter(softnet_lock);
   1709  1.163       roy 	KERNEL_LOCK(1, NULL);
   1710  1.163       roy 
   1711  1.163       roy 	/* Sanity check */
   1712  1.163       roy 	if (ia == NULL) {
   1713  1.163       roy 		log(LOG_ERR, "arp_dad_timer: called with null parameter\n");
   1714  1.163       roy 		goto done;
   1715  1.163       roy 	}
   1716  1.163       roy 	dp = arp_dad_find(ifa);
   1717  1.163       roy 	if (dp == NULL) {
   1718  1.163       roy 		log(LOG_ERR, "arp_dad_timer: DAD structure not found\n");
   1719  1.163       roy 		goto done;
   1720  1.163       roy 	}
   1721  1.163       roy 	if (ia->ia4_flags & IN_IFF_DUPLICATED) {
   1722  1.163       roy 		log(LOG_ERR, "nd4_dad_timer: called with duplicate address "
   1723  1.163       roy 			"%s(%s)\n",
   1724  1.163       roy 			in_fmtaddr(ia->ia_addr.sin_addr),
   1725  1.163       roy 			ifa->ifa_ifp ? if_name(ifa->ifa_ifp) : "???");
   1726  1.163       roy 		goto done;
   1727  1.163       roy 	}
   1728  1.163       roy 	if ((ia->ia4_flags & IN_IFF_TENTATIVE) == 0 && dp->dad_arp_acount == 0){
   1729  1.163       roy 		log(LOG_ERR, "arp_dad_timer: called with non-tentative address "
   1730  1.163       roy 			"%s(%s)\n",
   1731  1.163       roy 			in_fmtaddr(ia->ia_addr.sin_addr),
   1732  1.163       roy 			ifa->ifa_ifp ? if_name(ifa->ifa_ifp) : "???");
   1733  1.163       roy 		goto done;
   1734  1.163       roy 	}
   1735  1.163       roy 
   1736  1.163       roy 	/* timeouted with IFF_{RUNNING,UP} check */
   1737  1.163       roy 	if (dp->dad_arp_tcount > dad_maxtry) {
   1738  1.163       roy 		arplog((LOG_INFO, "%s: could not run DAD, driver problem?\n",
   1739  1.163       roy 			if_name(ifa->ifa_ifp)));
   1740  1.163       roy 
   1741  1.163       roy 		TAILQ_REMOVE(&dadq, dp, dad_list);
   1742  1.163       roy 		free(dp, M_IPARP);
   1743  1.163       roy 		dp = NULL;
   1744  1.163       roy 		ifafree(ifa);
   1745  1.163       roy 		goto done;
   1746  1.163       roy 	}
   1747  1.163       roy 
   1748  1.163       roy 	/* Need more checks? */
   1749  1.163       roy 	if (dp->dad_arp_ocount < dp->dad_count) {
   1750  1.164    justin 		int adelay;
   1751  1.163       roy 
   1752  1.163       roy 		/*
   1753  1.163       roy 		 * We have more ARP to go.  Send ARP packet for DAD.
   1754  1.163       roy 		 */
   1755  1.163       roy 		arp_dad_output(dp, ifa);
   1756  1.163       roy 		if (dp->dad_arp_ocount < dp->dad_count)
   1757  1.164    justin 			adelay = (PROBE_MIN * hz) +
   1758  1.163       roy 			    (cprng_fast32() %
   1759  1.163       roy 			    ((PROBE_MAX * hz) - (PROBE_MIN * hz)));
   1760  1.163       roy 		else
   1761  1.164    justin 			adelay = ANNOUNCE_WAIT * hz;
   1762  1.164    justin 		arp_dad_starttimer(dp, adelay);
   1763  1.163       roy 		goto done;
   1764  1.163       roy 	} else if (dp->dad_arp_acount == 0) {
   1765  1.163       roy 		/*
   1766  1.163       roy 		 * We are done with DAD.
   1767  1.163       roy 		 * No duplicate address found.
   1768  1.163       roy 		 */
   1769  1.163       roy 		ia->ia4_flags &= ~IN_IFF_TENTATIVE;
   1770  1.163       roy 		rt_newaddrmsg(RTM_NEWADDR, ifa, 0, NULL);
   1771  1.163       roy 		arplog((LOG_DEBUG,
   1772  1.163       roy 		    "%s: DAD complete for %s - no duplicates found\n",
   1773  1.163       roy 		    if_name(ifa->ifa_ifp),
   1774  1.163       roy 		    in_fmtaddr(ia->ia_addr.sin_addr)));
   1775  1.163       roy 		dp->dad_arp_announce = ANNOUNCE_NUM;
   1776  1.163       roy 		goto announce;
   1777  1.163       roy 	} else if (dp->dad_arp_acount < dp->dad_arp_announce) {
   1778  1.163       roy announce:
   1779  1.163       roy 		/*
   1780  1.163       roy 		 * Announce the address.
   1781  1.163       roy 		 */
   1782  1.163       roy 		ip = &IA_SIN(ifa)->sin_addr;
   1783  1.163       roy 		arprequest(ifa->ifa_ifp, ip, ip,
   1784  1.163       roy 		    CLLADDR(ifa->ifa_ifp->if_sadl));
   1785  1.163       roy 		dp->dad_arp_acount++;
   1786  1.163       roy 		if (dp->dad_arp_acount < dp->dad_arp_announce) {
   1787  1.163       roy 			arp_dad_starttimer(dp, ANNOUNCE_INTERVAL * hz);
   1788  1.163       roy 			goto done;
   1789  1.163       roy 		}
   1790  1.163       roy 		arplog((LOG_DEBUG,
   1791  1.163       roy 		    "%s: ARP announcement complete for %s\n",
   1792  1.163       roy 		    if_name(ifa->ifa_ifp),
   1793  1.163       roy 		    in_fmtaddr(ia->ia_addr.sin_addr)));
   1794  1.163       roy 	}
   1795  1.163       roy 
   1796  1.163       roy 	TAILQ_REMOVE(&dadq, dp, dad_list);
   1797  1.163       roy 	free(dp, M_IPARP);
   1798  1.163       roy 	dp = NULL;
   1799  1.163       roy 	ifafree(ifa);
   1800  1.163       roy 
   1801  1.163       roy done:
   1802  1.163       roy 	KERNEL_UNLOCK_ONE(NULL);
   1803  1.163       roy 	mutex_exit(softnet_lock);
   1804  1.163       roy }
   1805  1.163       roy 
   1806  1.163       roy static void
   1807  1.163       roy arp_dad_duplicated(struct ifaddr *ifa)
   1808  1.163       roy {
   1809  1.163       roy 	struct in_ifaddr *ia = (struct in_ifaddr *)ifa;
   1810  1.163       roy 	struct ifnet *ifp;
   1811  1.163       roy 	struct dadq *dp;
   1812  1.163       roy 
   1813  1.163       roy 	dp = arp_dad_find(ifa);
   1814  1.163       roy 	if (dp == NULL) {
   1815  1.163       roy 		log(LOG_ERR, "arp_dad_duplicated: DAD structure not found\n");
   1816  1.163       roy 		return;
   1817  1.163       roy 	}
   1818  1.163       roy 
   1819  1.163       roy 	ifp = ifa->ifa_ifp;
   1820  1.163       roy 	log(LOG_ERR, "%s: DAD detected duplicate IPv4 address %s: "
   1821  1.163       roy 	    "ARP out=%d\n",
   1822  1.163       roy 	    if_name(ifp), in_fmtaddr(ia->ia_addr.sin_addr),
   1823  1.163       roy 	    dp->dad_arp_ocount);
   1824  1.163       roy 
   1825  1.163       roy 	ia->ia4_flags &= ~IN_IFF_TENTATIVE;
   1826  1.163       roy 	ia->ia4_flags |= IN_IFF_DUPLICATED;
   1827  1.163       roy 
   1828  1.163       roy 	/* We are done with DAD, with duplicated address found. (failure) */
   1829  1.163       roy 	arp_dad_stoptimer(dp);
   1830  1.163       roy 
   1831  1.163       roy 	/* Inform the routing socket that DAD has completed */
   1832  1.163       roy 	rt_newaddrmsg(RTM_NEWADDR, ifa, 0, NULL);
   1833  1.163       roy 
   1834  1.163       roy 	TAILQ_REMOVE(&dadq, dp, dad_list);
   1835  1.163       roy 	free(dp, M_IPARP);
   1836  1.163       roy 	dp = NULL;
   1837  1.163       roy 	ifafree(ifa);
   1838  1.163       roy }
   1839  1.163       roy 
   1840    1.9     glass /*
   1841    1.9     glass  * Called from 10 Mb/s Ethernet interrupt handlers
   1842    1.9     glass  * when ether packet type ETHERTYPE_REVARP
   1843    1.9     glass  * is received.  Common length and type checks are done here,
   1844    1.9     glass  * then the protocol-specific routine is called.
   1845    1.9     glass  */
   1846   1.12   mycroft void
   1847  1.102     perry revarpinput(struct mbuf *m)
   1848    1.9     glass {
   1849    1.9     glass 	struct arphdr *ar;
   1850    1.9     glass 
   1851    1.9     glass 	if (m->m_len < sizeof(struct arphdr))
   1852    1.9     glass 		goto out;
   1853    1.9     glass 	ar = mtod(m, struct arphdr *);
   1854   1.35        is #if 0 /* XXX I don't think we need this... and it will prevent other LL */
   1855    1.9     glass 	if (ntohs(ar->ar_hrd) != ARPHRD_ETHER)
   1856    1.9     glass 		goto out;
   1857   1.35        is #endif
   1858   1.12   mycroft 	if (m->m_len < sizeof(struct arphdr) + 2 * (ar->ar_hln + ar->ar_pln))
   1859    1.9     glass 		goto out;
   1860    1.9     glass 	switch (ntohs(ar->ar_pro)) {
   1861    1.9     glass 	case ETHERTYPE_IP:
   1862    1.9     glass 	case ETHERTYPE_IPTRAILERS:
   1863   1.12   mycroft 		in_revarpinput(m);
   1864    1.9     glass 		return;
   1865    1.9     glass 
   1866    1.9     glass 	default:
   1867    1.9     glass 		break;
   1868    1.9     glass 	}
   1869    1.9     glass out:
   1870    1.9     glass 	m_freem(m);
   1871    1.9     glass }
   1872    1.9     glass 
   1873    1.9     glass /*
   1874    1.9     glass  * RARP for Internet protocols on 10 Mb/s Ethernet.
   1875    1.9     glass  * Algorithm is that given in RFC 903.
   1876    1.9     glass  * We are only using for bootstrap purposes to get an ip address for one of
   1877    1.9     glass  * our interfaces.  Thus we support no user-interface.
   1878    1.9     glass  *
   1879    1.9     glass  * Since the contents of the RARP reply are specific to the interface that
   1880    1.9     glass  * sent the request, this code must ensure that they are properly associated.
   1881    1.9     glass  *
   1882    1.9     glass  * Note: also supports ARP via RARP packets, per the RFC.
   1883    1.9     glass  */
   1884   1.28  christos void
   1885  1.102     perry in_revarpinput(struct mbuf *m)
   1886    1.9     glass {
   1887   1.12   mycroft 	struct ifnet *ifp;
   1888   1.35        is 	struct arphdr *ah;
   1889  1.121  christos 	void *tha;
   1890   1.28  christos 	int op;
   1891    1.9     glass 
   1892   1.35        is 	ah = mtod(m, struct arphdr *);
   1893   1.35        is 	op = ntohs(ah->ar_op);
   1894   1.82    itojun 
   1895   1.82    itojun 	switch (m->m_pkthdr.rcvif->if_type) {
   1896   1.82    itojun 	case IFT_IEEE1394:
   1897   1.82    itojun 		/* ARP without target hardware address is not supported */
   1898   1.82    itojun 		goto out;
   1899   1.82    itojun 	default:
   1900   1.82    itojun 		break;
   1901   1.82    itojun 	}
   1902   1.82    itojun 
   1903    1.9     glass 	switch (op) {
   1904    1.9     glass 	case ARPOP_REQUEST:
   1905    1.9     glass 	case ARPOP_REPLY:	/* per RFC */
   1906   1.12   mycroft 		in_arpinput(m);
   1907    1.9     glass 		return;
   1908   1.12   mycroft 	case ARPOP_REVREPLY:
   1909    1.9     glass 		break;
   1910   1.12   mycroft 	case ARPOP_REVREQUEST:	/* handled by rarpd(8) */
   1911    1.9     glass 	default:
   1912    1.9     glass 		goto out;
   1913    1.9     glass 	}
   1914    1.9     glass 	if (!revarp_in_progress)
   1915    1.9     glass 		goto out;
   1916   1.12   mycroft 	ifp = m->m_pkthdr.rcvif;
   1917   1.12   mycroft 	if (ifp != myip_ifp) /* !same interface */
   1918    1.9     glass 		goto out;
   1919   1.13       gwr 	if (myip_initialized)
   1920   1.13       gwr 		goto wake;
   1921  1.109       mrg 	tha = ar_tha(ah);
   1922  1.149  christos 	if (tha == NULL)
   1923  1.149  christos 		goto out;
   1924  1.140    dyoung 	if (memcmp(tha, CLLADDR(ifp->if_sadl), ifp->if_sadl->sdl_alen))
   1925    1.9     glass 		goto out;
   1926  1.121  christos 	memcpy(&srv_ip, ar_spa(ah), sizeof(srv_ip));
   1927  1.121  christos 	memcpy(&myip, ar_tpa(ah), sizeof(myip));
   1928    1.9     glass 	myip_initialized = 1;
   1929   1.13       gwr wake:	/* Do wakeup every time in case it was missed. */
   1930  1.121  christos 	wakeup((void *)&myip);
   1931   1.12   mycroft 
   1932   1.12   mycroft out:
   1933    1.9     glass 	m_freem(m);
   1934    1.9     glass }
   1935    1.9     glass 
   1936    1.9     glass /*
   1937    1.9     glass  * Send a RARP request for the ip address of the specified interface.
   1938    1.9     glass  * The request should be RFC 903-compliant.
   1939    1.9     glass  */
   1940   1.12   mycroft void
   1941  1.102     perry revarprequest(struct ifnet *ifp)
   1942    1.9     glass {
   1943    1.9     glass 	struct sockaddr sa;
   1944    1.9     glass 	struct mbuf *m;
   1945   1.35        is 	struct arphdr *ah;
   1946  1.121  christos 	void *tha;
   1947    1.9     glass 
   1948    1.9     glass 	if ((m = m_gethdr(M_DONTWAIT, MT_DATA)) == NULL)
   1949    1.9     glass 		return;
   1950   1.92      matt 	MCLAIM(m, &arpdomain.dom_mowner);
   1951   1.35        is 	m->m_len = sizeof(*ah) + 2*sizeof(struct in_addr) +
   1952   1.86     enami 	    2*ifp->if_addrlen;
   1953   1.35        is 	m->m_pkthdr.len = m->m_len;
   1954   1.35        is 	MH_ALIGN(m, m->m_len);
   1955   1.35        is 	ah = mtod(m, struct arphdr *);
   1956  1.140    dyoung 	memset(ah, 0, m->m_len);
   1957   1.35        is 	ah->ar_pro = htons(ETHERTYPE_IP);
   1958   1.86     enami 	ah->ar_hln = ifp->if_addrlen;		/* hardware address length */
   1959   1.35        is 	ah->ar_pln = sizeof(struct in_addr);	/* protocol address length */
   1960   1.35        is 	ah->ar_op = htons(ARPOP_REVREQUEST);
   1961   1.35        is 
   1962  1.126    dyoung 	memcpy(ar_sha(ah), CLLADDR(ifp->if_sadl), ah->ar_hln);
   1963  1.109       mrg 	tha = ar_tha(ah);
   1964  1.156       gdt 	if (tha == NULL) {
   1965  1.156       gdt 		m_free(m);
   1966  1.149  christos 		return;
   1967  1.156       gdt 	}
   1968  1.140    dyoung 	memcpy(tha, CLLADDR(ifp->if_sadl), ah->ar_hln);
   1969   1.35        is 
   1970   1.35        is 	sa.sa_family = AF_ARP;
   1971   1.35        is 	sa.sa_len = 2;
   1972   1.35        is 	m->m_flags |= M_BCAST;
   1973  1.158     ozaki 
   1974  1.158     ozaki 	KERNEL_LOCK(1, NULL);
   1975  1.139    dyoung 	(*ifp->if_output)(ifp, m, &sa, NULL);
   1976  1.158     ozaki 	KERNEL_UNLOCK_ONE(NULL);
   1977    1.9     glass }
   1978    1.9     glass 
   1979    1.9     glass /*
   1980   1.13       gwr  * RARP for the ip address of the specified interface, but also
   1981   1.13       gwr  * save the ip address of the server that sent the answer.
   1982   1.13       gwr  * Timeout if no response is received.
   1983    1.9     glass  */
   1984   1.12   mycroft int
   1985  1.102     perry revarpwhoarewe(struct ifnet *ifp, struct in_addr *serv_in,
   1986  1.102     perry     struct in_addr *clnt_in)
   1987    1.9     glass {
   1988    1.9     glass 	int result, count = 20;
   1989   1.81    itojun 
   1990   1.55  drochner 	myip_initialized = 0;
   1991   1.55  drochner 	myip_ifp = ifp;
   1992   1.55  drochner 
   1993   1.55  drochner 	revarp_in_progress = 1;
   1994   1.55  drochner 	while (count--) {
   1995   1.55  drochner 		revarprequest(ifp);
   1996  1.121  christos 		result = tsleep((void *)&myip, PSOCK, "revarp", hz/2);
   1997   1.55  drochner 		if (result != EWOULDBLOCK)
   1998   1.55  drochner 			break;
   1999    1.9     glass 	}
   2000   1.55  drochner 	revarp_in_progress = 0;
   2001   1.55  drochner 
   2002    1.9     glass 	if (!myip_initialized)
   2003    1.9     glass 		return ENETUNREACH;
   2004   1.81    itojun 
   2005  1.140    dyoung 	memcpy(serv_in, &srv_ip, sizeof(*serv_in));
   2006  1.140    dyoung 	memcpy(clnt_in, &myip, sizeof(*clnt_in));
   2007    1.9     glass 	return 0;
   2008    1.1       cgd }
   2009   1.13       gwr 
   2010   1.13       gwr 
   2011   1.13       gwr 
   2013   1.28  christos #ifdef DDB
   2014   1.28  christos 
   2015   1.28  christos #include <machine/db_machdep.h>
   2016   1.28  christos #include <ddb/db_interface.h>
   2017  1.102     perry #include <ddb/db_output.h>
   2018   1.13       gwr 
   2019  1.102     perry static void
   2020   1.13       gwr db_print_sa(const struct sockaddr *sa)
   2021   1.13       gwr {
   2022  1.104  christos 	int len;
   2023   1.13       gwr 	const u_char *p;
   2024  1.139    dyoung 
   2025   1.13       gwr 	if (sa == NULL) {
   2026   1.13       gwr 		db_printf("[NULL]");
   2027   1.13       gwr 		return;
   2028   1.13       gwr 	}
   2029  1.104  christos 
   2030   1.13       gwr 	p = (const u_char *)sa;
   2031   1.13       gwr 	len = sa->sa_len;
   2032   1.13       gwr 	db_printf("[");
   2033   1.13       gwr 	while (len > 0) {
   2034   1.13       gwr 		db_printf("%d", *p);
   2035   1.13       gwr 		p++; len--;
   2036   1.13       gwr 		if (len) db_printf(",");
   2037   1.13       gwr 	}
   2038   1.13       gwr 	db_printf("]\n");
   2039  1.102     perry }
   2040   1.13       gwr 
   2041  1.102     perry static void
   2042   1.13       gwr db_print_ifa(struct ifaddr *ifa)
   2043  1.139    dyoung {
   2044   1.13       gwr 	if (ifa == NULL)
   2045   1.13       gwr 		return;
   2046   1.13       gwr 	db_printf("  ifa_addr=");
   2047   1.13       gwr 	db_print_sa(ifa->ifa_addr);
   2048   1.13       gwr 	db_printf("  ifa_dsta=");
   2049   1.13       gwr 	db_print_sa(ifa->ifa_dstaddr);
   2050   1.13       gwr 	db_printf("  ifa_mask=");
   2051   1.13       gwr 	db_print_sa(ifa->ifa_netmask);
   2052   1.13       gwr 	db_printf("  flags=0x%x,refcnt=%d,metric=%d\n",
   2053   1.13       gwr 			  ifa->ifa_flags,
   2054   1.13       gwr 			  ifa->ifa_refcnt,
   2055   1.13       gwr 			  ifa->ifa_metric);
   2056  1.102     perry }
   2057   1.13       gwr 
   2058  1.121  christos static void
   2059   1.13       gwr db_print_llinfo(void *li)
   2060   1.13       gwr {
   2061   1.13       gwr 	struct llinfo_arp *la;
   2062  1.139    dyoung 
   2063   1.13       gwr 	if (li == NULL)
   2064   1.13       gwr 		return;
   2065   1.29  christos 	la = (struct llinfo_arp *)li;
   2066   1.13       gwr 	db_printf("  la_rt=%p la_hold=%p, la_asked=0x%lx\n",
   2067   1.13       gwr 			  la->la_rt, la->la_hold, la->la_asked);
   2068  1.102     perry }
   2069   1.13       gwr 
   2070  1.122    dyoung /*
   2071   1.13       gwr  * Function to pass to rt_walktree().
   2072   1.13       gwr  * Return non-zero error to abort walk.
   2073   1.13       gwr  */
   2074  1.123    dyoung static int
   2075   1.13       gwr db_show_rtentry(struct rtentry *rt, void *w)
   2076   1.29  christos {
   2077   1.13       gwr 	db_printf("rtentry=%p", rt);
   2078  1.150      matt 
   2079   1.13       gwr 	db_printf(" flags=0x%x refcnt=%d use=%"PRId64" expire=%"PRId64"\n",
   2080  1.150      matt 			  rt->rt_flags, rt->rt_refcnt,
   2081   1.13       gwr 			  rt->rt_use, (uint64_t)rt->rt_expire);
   2082  1.125    dyoung 
   2083   1.13       gwr 	db_printf(" key="); db_print_sa(rt_getkey(rt));
   2084   1.13       gwr 	db_printf(" mask="); db_print_sa(rt_mask(rt));
   2085   1.13       gwr 	db_printf(" gw="); db_print_sa(rt->rt_gateway);
   2086   1.29  christos 
   2087   1.13       gwr 	db_printf(" ifp=%p ", rt->rt_ifp);
   2088   1.30   thorpej 	if (rt->rt_ifp)
   2089   1.13       gwr 		db_printf("(%s)", rt->rt_ifp->if_xname);
   2090   1.13       gwr 	else
   2091   1.13       gwr 		db_printf("(NULL)");
   2092   1.29  christos 
   2093   1.13       gwr 	db_printf(" ifa=%p\n", rt->rt_ifa);
   2094   1.13       gwr 	db_print_ifa(rt->rt_ifa);
   2095   1.29  christos 
   2096   1.13       gwr 	db_printf(" gwroute=%p llinfo=%p\n",
   2097   1.13       gwr 			  rt->rt_gwroute, rt->rt_llinfo);
   2098   1.13       gwr 	db_print_llinfo(rt->rt_llinfo);
   2099  1.139    dyoung 
   2100   1.13       gwr 	return 0;
   2101  1.102     perry }
   2102   1.13       gwr 
   2103   1.13       gwr /*
   2104   1.69     jhawk  * Function to print all the route trees.
   2105   1.13       gwr  * Use this from ddb:  "show arptab"
   2106   1.69     jhawk  */
   2107  1.120      matt void
   2108  1.116  christos db_show_arptab(db_expr_t addr, bool have_addr,
   2109   1.13       gwr     db_expr_t count, const char *modif)
   2110  1.123    dyoung {
   2111   1.13       gwr 	rt_walktree(AF_INET, db_show_rtentry, NULL);
   2112   1.13       gwr }
   2113   1.97     ragge #endif
   2114  1.174     ozaki 
   2115  1.174     ozaki void
   2116  1.174     ozaki arp_stat_add(int type, uint64_t count)
   2117  1.174     ozaki {
   2118  1.174     ozaki 	ARP_STATADD(type, count);
   2119  1.174     ozaki }
   2120  1.132   thorpej 
   2121  1.132   thorpej static int
   2122  1.132   thorpej sysctl_net_inet_arp_stats(SYSCTLFN_ARGS)
   2123  1.132   thorpej {
   2124  1.139    dyoung 
   2125  1.132   thorpej 	return NETSTAT_SYSCTL(arpstat_percpu, ARP_NSTATS);
   2126  1.132   thorpej }
   2127  1.147     pooka 
   2128  1.147     pooka static void
   2129   1.97     ragge sysctl_net_inet_arp_setup(struct sysctllog **clog)
   2130  1.106    atatat {
   2131   1.97     ragge 	const struct sysctlnode *node;
   2132   1.97     ragge 
   2133   1.97     ragge 	sysctl_createv(clog, 0, NULL, NULL,
   2134   1.97     ragge 			CTLFLAG_PERMANENT,
   2135   1.97     ragge 			CTLTYPE_NODE, "inet", NULL,
   2136   1.97     ragge 			NULL, 0, NULL, 0,
   2137   1.97     ragge 			CTL_NET, PF_INET, CTL_EOL);
   2138   1.97     ragge 	sysctl_createv(clog, 0, NULL, &node,
   2139   1.98    atatat 			CTLFLAG_PERMANENT,
   2140   1.98    atatat 			CTLTYPE_NODE, "arp",
   2141   1.97     ragge 			SYSCTL_DESCR("Address Resolution Protocol"),
   2142   1.97     ragge 			NULL, 0, NULL, 0,
   2143   1.97     ragge 			CTL_NET, PF_INET, CTL_CREATE, CTL_EOL);
   2144   1.97     ragge 
   2145   1.97     ragge 	sysctl_createv(clog, 0, NULL, NULL,
   2146   1.98    atatat 			CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2147  1.152  christos 			CTLTYPE_INT, "keep",
   2148   1.97     ragge 			SYSCTL_DESCR("Valid ARP entry lifetime in seconds"),
   2149   1.97     ragge 			NULL, 0, &arpt_keep, 0,
   2150   1.97     ragge 			CTL_NET,PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
   2151   1.97     ragge 
   2152   1.97     ragge 	sysctl_createv(clog, 0, NULL, NULL,
   2153   1.98    atatat 			CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2154  1.152  christos 			CTLTYPE_INT, "down",
   2155   1.97     ragge 			SYSCTL_DESCR("Failed ARP entry lifetime in seconds"),
   2156   1.97     ragge 			NULL, 0, &arpt_down, 0,
   2157   1.97     ragge 			CTL_NET,PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
   2158   1.97     ragge 
   2159  1.132   thorpej 	sysctl_createv(clog, 0, NULL, NULL,
   2160  1.132   thorpej 			CTLFLAG_PERMANENT,
   2161  1.132   thorpej 			CTLTYPE_STRUCT, "stats",
   2162  1.132   thorpej 			SYSCTL_DESCR("ARP statistics"),
   2163  1.132   thorpej 			sysctl_net_inet_arp_stats, 0, NULL, 0,
   2164  1.152  christos 			CTL_NET,PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
   2165  1.152  christos 
   2166  1.152  christos 	sysctl_createv(clog, 0, NULL, NULL,
   2167  1.152  christos 			CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2168  1.152  christos 			CTLTYPE_INT, "log_movements",
   2169  1.152  christos 			SYSCTL_DESCR("log ARP replies from MACs different than"
   2170  1.152  christos 			    " the one in the cache"),
   2171  1.152  christos 			NULL, 0, &log_movements, 0,
   2172  1.152  christos 			CTL_NET,PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
   2173  1.152  christos 
   2174  1.152  christos 	sysctl_createv(clog, 0, NULL, NULL,
   2175  1.152  christos 			CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2176  1.152  christos 			CTLTYPE_INT, "log_permanent_modify",
   2177  1.152  christos 			SYSCTL_DESCR("log ARP replies from MACs different than"
   2178  1.152  christos 			    " the one in the permanent arp entry"),
   2179  1.152  christos 			NULL, 0, &log_permanent_modify, 0,
   2180  1.152  christos 			CTL_NET,PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
   2181  1.152  christos 
   2182  1.152  christos 	sysctl_createv(clog, 0, NULL, NULL,
   2183  1.152  christos 			CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2184  1.152  christos 			CTLTYPE_INT, "log_wrong_iface",
   2185  1.152  christos 			SYSCTL_DESCR("log ARP packets arriving on the wrong"
   2186  1.152  christos 			    " interface"),
   2187  1.152  christos 			NULL, 0, &log_wrong_iface, 0,
   2188  1.160  christos 			CTL_NET,PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
   2189  1.160  christos 
   2190  1.160  christos 	sysctl_createv(clog, 0, NULL, NULL,
   2191  1.160  christos 			CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2192  1.160  christos 			CTLTYPE_INT, "log_unknown_network",
   2193  1.160  christos 			SYSCTL_DESCR("log ARP packets from non-local network"),
   2194  1.160  christos 			NULL, 0, &log_unknown_network, 0,
   2195  1.163       roy 			CTL_NET,PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
   2196  1.163       roy 
   2197  1.163       roy 	sysctl_createv(clog, 0, NULL, NULL,
   2198  1.163       roy 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2199  1.163       roy 		       CTLTYPE_INT, "debug",
   2200  1.163       roy 		       SYSCTL_DESCR("Enable ARP DAD debug output"),
   2201  1.163       roy 		       NULL, 0, &arp_debug, 0,
   2202   1.97     ragge 		       CTL_NET, PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
   2203   1.97     ragge }
   2204   1.15    chopps 
   2205                  #endif /* INET */
   2206