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