if_arp.c revision 1.146 1 1.146 dyoung /* $NetBSD: if_arp.c,v 1.146 2009/08/12 22:16:15 dyoung 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.146 dyoung __KERNEL_RCSID(0, "$NetBSD: if_arp.c,v 1.146 2009/08/12 22:16:15 dyoung Exp $");
72 1.50 jonathan
73 1.50 jonathan #include "opt_ddb.h"
74 1.51 jonathan #include "opt_inet.h"
75 1.1 cgd
76 1.15 chopps #ifdef INET
77 1.15 chopps
78 1.77 thorpej #include "bridge.h"
79 1.77 thorpej
80 1.5 mycroft #include <sys/param.h>
81 1.5 mycroft #include <sys/systm.h>
82 1.67 thorpej #include <sys/callout.h>
83 1.5 mycroft #include <sys/malloc.h>
84 1.5 mycroft #include <sys/mbuf.h>
85 1.5 mycroft #include <sys/socket.h>
86 1.5 mycroft #include <sys/time.h>
87 1.112 kardel #include <sys/timetc.h>
88 1.5 mycroft #include <sys/kernel.h>
89 1.5 mycroft #include <sys/errno.h>
90 1.5 mycroft #include <sys/ioctl.h>
91 1.5 mycroft #include <sys/syslog.h>
92 1.28 christos #include <sys/proc.h>
93 1.63 sommerfe #include <sys/protosw.h>
94 1.63 sommerfe #include <sys/domain.h>
95 1.97 ragge #include <sys/sysctl.h>
96 1.134 ad #include <sys/socketvar.h>
97 1.134 ad #include <sys/percpu.h>
98 1.1 cgd
99 1.35 is #include <net/ethertypes.h>
100 1.5 mycroft #include <net/if.h>
101 1.12 mycroft #include <net/if_dl.h>
102 1.56 bad #include <net/if_token.h>
103 1.56 bad #include <net/if_types.h>
104 1.110 liamjfoy #include <net/if_ether.h>
105 1.12 mycroft #include <net/route.h>
106 1.133 thorpej #include <net/net_stats.h>
107 1.5 mycroft
108 1.5 mycroft #include <netinet/in.h>
109 1.5 mycroft #include <netinet/in_systm.h>
110 1.5 mycroft #include <netinet/in_var.h>
111 1.5 mycroft #include <netinet/ip.h>
112 1.35 is #include <netinet/if_inarp.h>
113 1.1 cgd
114 1.129 cube #include "arcnet.h"
115 1.129 cube #if NARCNET > 0
116 1.66 is #include <net/if_arc.h>
117 1.66 is #endif
118 1.65 matt #include "fddi.h"
119 1.65 matt #if NFDDI > 0
120 1.65 matt #include <net/if_fddi.h>
121 1.65 matt #endif
122 1.66 is #include "token.h"
123 1.110 liamjfoy #include "carp.h"
124 1.110 liamjfoy #if NCARP > 0
125 1.110 liamjfoy #include <netinet/ip_carp.h>
126 1.110 liamjfoy #endif
127 1.39 lukem
128 1.12 mycroft #define SIN(s) ((struct sockaddr_in *)s)
129 1.12 mycroft #define SRP(s) ((struct sockaddr_inarp *)s)
130 1.1 cgd
131 1.1 cgd /*
132 1.1 cgd * ARP trailer negotiation. Trailer protocol is not IP specific,
133 1.1 cgd * but ARP request/response use IP addresses.
134 1.1 cgd */
135 1.12 mycroft #define ETHERTYPE_IPTRAILERS ETHERTYPE_TRAIL
136 1.1 cgd
137 1.1 cgd /* timer values */
138 1.12 mycroft int arpt_prune = (5*60*1); /* walk list every 5 minutes */
139 1.12 mycroft int arpt_keep = (20*60); /* once resolved, good for 20 more minutes */
140 1.12 mycroft int arpt_down = 20; /* once declared down, don't send for 20 secs */
141 1.97 ragge int arpt_refresh = (5*60); /* time left before refreshing */
142 1.12 mycroft #define rt_expire rt_rmx.rmx_expire
143 1.97 ragge #define rt_pksent rt_rmx.rmx_pksent
144 1.12 mycroft
145 1.126 dyoung static struct sockaddr *arp_setgate(struct rtentry *, struct sockaddr *,
146 1.126 dyoung const struct sockaddr *);
147 1.102 perry static void arptfree(struct llinfo_arp *);
148 1.102 perry static void arptimer(void *);
149 1.126 dyoung static struct llinfo_arp *arplookup1(struct mbuf *, const struct in_addr *,
150 1.126 dyoung int, int, struct rtentry *);
151 1.119 dyoung static struct llinfo_arp *arplookup(struct mbuf *, const struct in_addr *,
152 1.102 perry int, int);
153 1.102 perry static void in_arpinput(struct mbuf *);
154 1.12 mycroft
155 1.26 mycroft LIST_HEAD(, llinfo_arp) llinfo_arp;
156 1.113 christos struct ifqueue arpintrq = {
157 1.113 christos .ifq_head = NULL,
158 1.113 christos .ifq_tail = NULL,
159 1.113 christos .ifq_len = 0,
160 1.113 christos .ifq_maxlen = 50,
161 1.113 christos .ifq_drops = 0,
162 1.113 christos };
163 1.12 mycroft int arp_inuse, arp_allocated, arp_intimer;
164 1.12 mycroft int arp_maxtries = 5;
165 1.12 mycroft int useloopback = 1; /* use loopback interface for local traffic */
166 1.12 mycroft int arpinit_done = 0;
167 1.9 glass
168 1.132 thorpej static percpu_t *arpstat_percpu;
169 1.132 thorpej
170 1.133 thorpej #define ARP_STAT_GETREF() _NET_STAT_GETREF(arpstat_percpu)
171 1.133 thorpej #define ARP_STAT_PUTREF() _NET_STAT_PUTREF(arpstat_percpu)
172 1.132 thorpej
173 1.133 thorpej #define ARP_STATINC(x) _NET_STATINC(arpstat_percpu, x)
174 1.133 thorpej #define ARP_STATADD(x, v) _NET_STATADD(arpstat_percpu, x, v)
175 1.132 thorpej
176 1.67 thorpej struct callout arptimer_ch;
177 1.67 thorpej
178 1.12 mycroft /* revarp state */
179 1.110 liamjfoy struct in_addr myip, srv_ip;
180 1.110 liamjfoy int myip_initialized = 0;
181 1.110 liamjfoy int revarp_in_progress = 0;
182 1.110 liamjfoy struct ifnet *myip_ifp = NULL;
183 1.1 cgd
184 1.28 christos #ifdef DDB
185 1.102 perry static void db_print_sa(const struct sockaddr *);
186 1.102 perry static void db_print_ifa(struct ifaddr *);
187 1.121 christos static void db_print_llinfo(void *);
188 1.123 dyoung static int db_show_rtentry(struct rtentry *, void *);
189 1.28 christos #endif
190 1.28 christos
191 1.1 cgd /*
192 1.35 is * this should be elsewhere.
193 1.35 is */
194 1.35 is
195 1.35 is static char *
196 1.102 perry lla_snprintf(u_int8_t *, int);
197 1.35 is
198 1.35 is static char *
199 1.102 perry lla_snprintf(u_int8_t *adrp, int len)
200 1.35 is {
201 1.75 tron #define NUMBUFS 3
202 1.75 tron static char buf[NUMBUFS][16*3];
203 1.75 tron static int bnum = 0;
204 1.81 itojun
205 1.35 is int i;
206 1.35 is char *p;
207 1.35 is
208 1.75 tron p = buf[bnum];
209 1.35 is
210 1.35 is *p++ = hexdigits[(*adrp)>>4];
211 1.35 is *p++ = hexdigits[(*adrp++)&0xf];
212 1.35 is
213 1.35 is for (i=1; i<len && i<16; i++) {
214 1.35 is *p++ = ':';
215 1.35 is *p++ = hexdigits[(*adrp)>>4];
216 1.35 is *p++ = hexdigits[(*adrp++)&0xf];
217 1.35 is }
218 1.35 is
219 1.35 is *p = 0;
220 1.75 tron p = buf[bnum];
221 1.75 tron bnum = (bnum + 1) % NUMBUFS;
222 1.75 tron return p;
223 1.35 is }
224 1.35 is
225 1.101 matt DOMAIN_DEFINE(arpdomain); /* forward declare and add to link set */
226 1.101 matt
227 1.96 matt const struct protosw arpsw[] = {
228 1.130 elad { .pr_type = 0,
229 1.130 elad .pr_domain = &arpdomain,
230 1.130 elad .pr_protocol = 0,
231 1.130 elad .pr_flags = 0,
232 1.130 elad .pr_input = 0,
233 1.130 elad .pr_output = 0,
234 1.130 elad .pr_ctlinput = 0,
235 1.130 elad .pr_ctloutput = 0,
236 1.130 elad .pr_usrreq = 0,
237 1.132 thorpej .pr_init = arp_init,
238 1.130 elad .pr_fasttimo = 0,
239 1.130 elad .pr_slowtimo = 0,
240 1.130 elad .pr_drain = arp_drain,
241 1.63 sommerfe }
242 1.63 sommerfe };
243 1.63 sommerfe
244 1.63 sommerfe
245 1.113 christos struct domain arpdomain = {
246 1.113 christos .dom_family = PF_ARP,
247 1.113 christos .dom_name = "arp",
248 1.113 christos .dom_protosw = arpsw,
249 1.139 dyoung .dom_protoswNPROTOSW = &arpsw[__arraycount(arpsw)],
250 1.63 sommerfe };
251 1.63 sommerfe
252 1.63 sommerfe /*
253 1.63 sommerfe * ARP table locking.
254 1.63 sommerfe *
255 1.63 sommerfe * to prevent lossage vs. the arp_drain routine (which may be called at
256 1.63 sommerfe * any time, including in a device driver context), we do two things:
257 1.63 sommerfe *
258 1.73 thorpej * 1) manipulation of la->la_hold is done at splnet() (for all of
259 1.63 sommerfe * about two instructions).
260 1.63 sommerfe *
261 1.63 sommerfe * 2) manipulation of the arp table's linked list is done under the
262 1.63 sommerfe * protection of the ARP_LOCK; if arp_drain() or arptimer is called
263 1.63 sommerfe * while the arp table is locked, we punt and try again later.
264 1.63 sommerfe */
265 1.63 sommerfe
266 1.82 itojun static int arp_locked;
267 1.108 perry static inline int arp_lock_try(int);
268 1.108 perry static inline void arp_unlock(void);
269 1.63 sommerfe
270 1.108 perry static inline int
271 1.63 sommerfe arp_lock_try(int recurse)
272 1.63 sommerfe {
273 1.63 sommerfe int s;
274 1.63 sommerfe
275 1.73 thorpej /*
276 1.73 thorpej * Use splvm() -- we're blocking things that would cause
277 1.73 thorpej * mbuf allocation.
278 1.73 thorpej */
279 1.73 thorpej s = splvm();
280 1.63 sommerfe if (!recurse && arp_locked) {
281 1.63 sommerfe splx(s);
282 1.139 dyoung return 0;
283 1.63 sommerfe }
284 1.63 sommerfe arp_locked++;
285 1.63 sommerfe splx(s);
286 1.139 dyoung return 1;
287 1.63 sommerfe }
288 1.63 sommerfe
289 1.108 perry static inline void
290 1.102 perry arp_unlock(void)
291 1.63 sommerfe {
292 1.63 sommerfe int s;
293 1.63 sommerfe
294 1.73 thorpej s = splvm();
295 1.63 sommerfe arp_locked--;
296 1.63 sommerfe splx(s);
297 1.63 sommerfe }
298 1.63 sommerfe
299 1.63 sommerfe #ifdef DIAGNOSTIC
300 1.63 sommerfe #define ARP_LOCK(recurse) \
301 1.63 sommerfe do { \
302 1.63 sommerfe if (arp_lock_try(recurse) == 0) { \
303 1.63 sommerfe printf("%s:%d: arp already locked\n", __FILE__, __LINE__); \
304 1.63 sommerfe panic("arp_lock"); \
305 1.63 sommerfe } \
306 1.90 perry } while (/*CONSTCOND*/ 0)
307 1.63 sommerfe #define ARP_LOCK_CHECK() \
308 1.63 sommerfe do { \
309 1.63 sommerfe if (arp_locked == 0) { \
310 1.63 sommerfe printf("%s:%d: arp lock not held\n", __FILE__, __LINE__); \
311 1.63 sommerfe panic("arp lock check"); \
312 1.63 sommerfe } \
313 1.90 perry } while (/*CONSTCOND*/ 0)
314 1.63 sommerfe #else
315 1.63 sommerfe #define ARP_LOCK(x) (void) arp_lock_try(x)
316 1.63 sommerfe #define ARP_LOCK_CHECK() /* nothing */
317 1.63 sommerfe #endif
318 1.63 sommerfe
319 1.63 sommerfe #define ARP_UNLOCK() arp_unlock()
320 1.63 sommerfe
321 1.132 thorpej void
322 1.132 thorpej arp_init(void)
323 1.132 thorpej {
324 1.132 thorpej
325 1.132 thorpej arpstat_percpu = percpu_alloc(sizeof(uint64_t) * ARP_NSTATS);
326 1.132 thorpej }
327 1.132 thorpej
328 1.63 sommerfe /*
329 1.63 sommerfe * ARP protocol drain routine. Called when memory is in short supply.
330 1.136 ad * Called at splvm(); don't acquire softnet_lock as can be called from
331 1.136 ad * hardware interrupt handlers.
332 1.63 sommerfe */
333 1.63 sommerfe void
334 1.102 perry arp_drain(void)
335 1.63 sommerfe {
336 1.68 augustss struct llinfo_arp *la, *nla;
337 1.63 sommerfe int count = 0;
338 1.63 sommerfe struct mbuf *mold;
339 1.81 itojun
340 1.134 ad KERNEL_LOCK(1, NULL);
341 1.134 ad
342 1.63 sommerfe if (arp_lock_try(0) == 0) {
343 1.134 ad KERNEL_UNLOCK_ONE(NULL);
344 1.63 sommerfe return;
345 1.63 sommerfe }
346 1.81 itojun
347 1.139 dyoung for (la = LIST_FIRST(&llinfo_arp); la != NULL; la = nla) {
348 1.74 matt nla = LIST_NEXT(la, la_list);
349 1.63 sommerfe
350 1.63 sommerfe mold = la->la_hold;
351 1.63 sommerfe la->la_hold = 0;
352 1.63 sommerfe
353 1.63 sommerfe if (mold) {
354 1.63 sommerfe m_freem(mold);
355 1.63 sommerfe count++;
356 1.63 sommerfe }
357 1.63 sommerfe }
358 1.63 sommerfe ARP_UNLOCK();
359 1.132 thorpej ARP_STATADD(ARP_STAT_DFRDROPPED, count);
360 1.134 ad KERNEL_UNLOCK_ONE(NULL);
361 1.63 sommerfe }
362 1.63 sommerfe
363 1.63 sommerfe
364 1.35 is /*
365 1.12 mycroft * Timeout routine. Age arp_tab entries periodically.
366 1.1 cgd */
367 1.3 andrew /* ARGSUSED */
368 1.12 mycroft static void
369 1.116 christos arptimer(void *arg)
370 1.1 cgd {
371 1.68 augustss struct llinfo_arp *la, *nla;
372 1.1 cgd
373 1.134 ad mutex_enter(softnet_lock);
374 1.134 ad KERNEL_LOCK(1, NULL);
375 1.63 sommerfe
376 1.63 sommerfe if (arp_lock_try(0) == 0) {
377 1.63 sommerfe /* get it later.. */
378 1.134 ad KERNEL_UNLOCK_ONE(NULL);
379 1.134 ad mutex_exit(softnet_lock);
380 1.63 sommerfe return;
381 1.63 sommerfe }
382 1.63 sommerfe
383 1.67 thorpej callout_reset(&arptimer_ch, arpt_prune * hz, arptimer, NULL);
384 1.139 dyoung for (la = LIST_FIRST(&llinfo_arp); la != NULL; la = nla) {
385 1.68 augustss struct rtentry *rt = la->la_rt;
386 1.24 cgd
387 1.74 matt nla = LIST_NEXT(la, la_list);
388 1.97 ragge if (rt->rt_expire == 0)
389 1.97 ragge continue;
390 1.112 kardel if ((rt->rt_expire - time_second) < arpt_refresh &&
391 1.112 kardel rt->rt_pksent > (time_second - arpt_keep)) {
392 1.97 ragge /*
393 1.97 ragge * If the entry has been used during since last
394 1.97 ragge * refresh, try to renew it before deleting.
395 1.97 ragge */
396 1.97 ragge arprequest(rt->rt_ifp,
397 1.119 dyoung &satocsin(rt->rt_ifa->ifa_addr)->sin_addr,
398 1.125 dyoung &satocsin(rt_getkey(rt))->sin_addr,
399 1.127 dyoung CLLADDR(rt->rt_ifp->if_sadl));
400 1.112 kardel } else if (rt->rt_expire <= time_second)
401 1.26 mycroft arptfree(la); /* timer has expired; clear */
402 1.12 mycroft }
403 1.63 sommerfe
404 1.63 sommerfe ARP_UNLOCK();
405 1.81 itojun
406 1.134 ad KERNEL_UNLOCK_ONE(NULL);
407 1.134 ad mutex_exit(softnet_lock);
408 1.12 mycroft }
409 1.12 mycroft
410 1.12 mycroft /*
411 1.126 dyoung * We set the gateway for RTF_CLONING routes to a "prototype"
412 1.126 dyoung * link-layer sockaddr whose interface type (if_type) and interface
413 1.126 dyoung * index (if_index) fields are prepared.
414 1.126 dyoung */
415 1.126 dyoung static struct sockaddr *
416 1.126 dyoung arp_setgate(struct rtentry *rt, struct sockaddr *gate,
417 1.126 dyoung const struct sockaddr *netmask)
418 1.126 dyoung {
419 1.127 dyoung const struct ifnet *ifp = rt->rt_ifp;
420 1.127 dyoung uint8_t namelen = strlen(ifp->if_xname);
421 1.127 dyoung uint8_t addrlen = ifp->if_addrlen;
422 1.127 dyoung
423 1.126 dyoung /*
424 1.126 dyoung * XXX: If this is a manually added route to interface
425 1.126 dyoung * such as older version of routed or gated might provide,
426 1.126 dyoung * restore cloning bit.
427 1.126 dyoung */
428 1.126 dyoung if ((rt->rt_flags & RTF_HOST) == 0 && netmask != NULL &&
429 1.126 dyoung satocsin(netmask)->sin_addr.s_addr != 0xffffffff)
430 1.126 dyoung rt->rt_flags |= RTF_CLONING;
431 1.126 dyoung if (rt->rt_flags & RTF_CLONING) {
432 1.128 dyoung union {
433 1.128 dyoung struct sockaddr sa;
434 1.128 dyoung struct sockaddr_storage ss;
435 1.128 dyoung struct sockaddr_dl sdl;
436 1.128 dyoung } u;
437 1.126 dyoung /*
438 1.126 dyoung * Case 1: This route should come from a route to iface.
439 1.126 dyoung */
440 1.128 dyoung sockaddr_dl_init(&u.sdl, sizeof(u.ss),
441 1.128 dyoung ifp->if_index, ifp->if_type, NULL, namelen, NULL, addrlen);
442 1.128 dyoung rt_setgate(rt, &u.sa);
443 1.126 dyoung gate = rt->rt_gateway;
444 1.126 dyoung }
445 1.126 dyoung return gate;
446 1.126 dyoung }
447 1.126 dyoung
448 1.126 dyoung /*
449 1.12 mycroft * Parallel to llc_rtrequest.
450 1.12 mycroft */
451 1.12 mycroft void
452 1.143 dyoung arp_rtrequest(int req, struct rtentry *rt, const struct rt_addrinfo *info)
453 1.12 mycroft {
454 1.68 augustss struct sockaddr *gate = rt->rt_gateway;
455 1.68 augustss struct llinfo_arp *la = (struct llinfo_arp *)rt->rt_llinfo;
456 1.56 bad size_t allocsize;
457 1.63 sommerfe struct mbuf *mold;
458 1.63 sommerfe int s;
459 1.76 itojun struct in_ifaddr *ia;
460 1.76 itojun struct ifaddr *ifa;
461 1.127 dyoung struct ifnet *ifp = rt->rt_ifp;
462 1.12 mycroft
463 1.12 mycroft if (!arpinit_done) {
464 1.12 mycroft arpinit_done = 1;
465 1.13 gwr /*
466 1.112 kardel * We generate expiration times from time_second
467 1.117 christos * so avoid accidentally creating permanent routes.
468 1.13 gwr */
469 1.112 kardel if (time_second == 0) {
470 1.112 kardel struct timespec ts;
471 1.112 kardel ts.tv_sec = 1;
472 1.112 kardel ts.tv_nsec = 0;
473 1.112 kardel tc_setclock(&ts);
474 1.13 gwr }
475 1.134 ad callout_init(&arptimer_ch, CALLOUT_MPSAFE);
476 1.67 thorpej callout_reset(&arptimer_ch, hz, arptimer, NULL);
477 1.12 mycroft }
478 1.80 itojun
479 1.144 dyoung if (req == RTM_LLINFO_UPD) {
480 1.144 dyoung struct in_addr *in;
481 1.144 dyoung
482 1.144 dyoung if ((ifa = info->rti_ifa) == NULL)
483 1.144 dyoung return;
484 1.144 dyoung
485 1.144 dyoung in = &ifatoia(ifa)->ia_addr.sin_addr;
486 1.144 dyoung
487 1.144 dyoung arprequest(ifa->ifa_ifp, in, in,
488 1.144 dyoung CLLADDR(ifa->ifa_ifp->if_sadl));
489 1.144 dyoung return;
490 1.144 dyoung }
491 1.144 dyoung
492 1.80 itojun if ((rt->rt_flags & RTF_GATEWAY) != 0) {
493 1.80 itojun if (req != RTM_ADD)
494 1.80 itojun return;
495 1.80 itojun
496 1.80 itojun /*
497 1.80 itojun * linklayers with particular link MTU limitation.
498 1.80 itojun */
499 1.127 dyoung switch(ifp->if_type) {
500 1.80 itojun #if NFDDI > 0
501 1.80 itojun case IFT_FDDI:
502 1.127 dyoung if (ifp->if_mtu > FDDIIPMTU)
503 1.80 itojun rt->rt_rmx.rmx_mtu = FDDIIPMTU;
504 1.80 itojun break;
505 1.80 itojun #endif
506 1.80 itojun #if NARC > 0
507 1.80 itojun case IFT_ARCNET:
508 1.80 itojun {
509 1.80 itojun int arcipifmtu;
510 1.80 itojun
511 1.127 dyoung if (ifp->if_flags & IFF_LINK0)
512 1.80 itojun arcipifmtu = arc_ipmtu;
513 1.80 itojun else
514 1.80 itojun arcipifmtu = ARCMTU;
515 1.127 dyoung if (ifp->if_mtu > arcipifmtu)
516 1.80 itojun rt->rt_rmx.rmx_mtu = arcipifmtu;
517 1.80 itojun break;
518 1.80 itojun }
519 1.80 itojun #endif
520 1.80 itojun }
521 1.12 mycroft return;
522 1.80 itojun }
523 1.63 sommerfe
524 1.63 sommerfe ARP_LOCK(1); /* we may already be locked here. */
525 1.63 sommerfe
526 1.12 mycroft switch (req) {
527 1.126 dyoung case RTM_SETGATE:
528 1.126 dyoung gate = arp_setgate(rt, gate, info->rti_info[RTAX_NETMASK]);
529 1.126 dyoung break;
530 1.12 mycroft case RTM_ADD:
531 1.126 dyoung gate = arp_setgate(rt, gate, info->rti_info[RTAX_NETMASK]);
532 1.12 mycroft if (rt->rt_flags & RTF_CLONING) {
533 1.12 mycroft /*
534 1.14 gwr * Give this route an expiration time, even though
535 1.14 gwr * it's a "permanent" route, so that routes cloned
536 1.14 gwr * from it do not need their expiration time set.
537 1.13 gwr */
538 1.112 kardel rt->rt_expire = time_second;
539 1.80 itojun /*
540 1.80 itojun * linklayers with particular link MTU limitation.
541 1.80 itojun */
542 1.127 dyoung switch (ifp->if_type) {
543 1.65 matt #if NFDDI > 0
544 1.80 itojun case IFT_FDDI:
545 1.80 itojun if ((rt->rt_rmx.rmx_locks & RTV_MTU) == 0 &&
546 1.80 itojun (rt->rt_rmx.rmx_mtu > FDDIIPMTU ||
547 1.80 itojun (rt->rt_rmx.rmx_mtu == 0 &&
548 1.127 dyoung ifp->if_mtu > FDDIIPMTU)))
549 1.80 itojun rt->rt_rmx.rmx_mtu = FDDIIPMTU;
550 1.80 itojun break;
551 1.66 is #endif
552 1.66 is #if NARC > 0
553 1.80 itojun case IFT_ARCNET:
554 1.80 itojun {
555 1.66 is int arcipifmtu;
556 1.127 dyoung if (ifp->if_flags & IFF_LINK0)
557 1.66 is arcipifmtu = arc_ipmtu;
558 1.66 is else
559 1.66 is arcipifmtu = ARCMTU;
560 1.66 is
561 1.80 itojun if ((rt->rt_rmx.rmx_locks & RTV_MTU) == 0 &&
562 1.80 itojun (rt->rt_rmx.rmx_mtu > arcipifmtu ||
563 1.80 itojun (rt->rt_rmx.rmx_mtu == 0 &&
564 1.127 dyoung ifp->if_mtu > arcipifmtu)))
565 1.66 is rt->rt_rmx.rmx_mtu = arcipifmtu;
566 1.80 itojun break;
567 1.80 itojun }
568 1.80 itojun #endif
569 1.65 matt }
570 1.12 mycroft break;
571 1.12 mycroft }
572 1.12 mycroft /* Announce a new entry if requested. */
573 1.145 christos if (rt->rt_flags & RTF_ANNOUNCE) {
574 1.127 dyoung arprequest(ifp,
575 1.125 dyoung &satocsin(rt_getkey(rt))->sin_addr,
576 1.125 dyoung &satocsin(rt_getkey(rt))->sin_addr,
577 1.126 dyoung CLLADDR(satocsdl(gate)));
578 1.145 christos }
579 1.12 mycroft /*FALLTHROUGH*/
580 1.12 mycroft case RTM_RESOLVE:
581 1.12 mycroft if (gate->sa_family != AF_LINK ||
582 1.146 dyoung gate->sa_len < sockaddr_dl_measure(0, ifp->if_addrlen)) {
583 1.37 jtk log(LOG_DEBUG, "arp_rtrequest: bad gateway value\n");
584 1.12 mycroft break;
585 1.12 mycroft }
586 1.127 dyoung satosdl(gate)->sdl_type = ifp->if_type;
587 1.127 dyoung satosdl(gate)->sdl_index = ifp->if_index;
588 1.139 dyoung if (la != NULL)
589 1.12 mycroft break; /* This happens on a route change */
590 1.12 mycroft /*
591 1.12 mycroft * Case 2: This route may come from cloning, or a manual route
592 1.12 mycroft * add with a LL address.
593 1.12 mycroft */
594 1.146 dyoung switch (ifp->if_type) {
595 1.56 bad #if NTOKEN > 0
596 1.56 bad case IFT_ISO88025:
597 1.56 bad allocsize = sizeof(*la) + sizeof(struct token_rif);
598 1.56 bad break;
599 1.56 bad #endif /* NTOKEN > 0 */
600 1.56 bad default:
601 1.56 bad allocsize = sizeof(*la);
602 1.56 bad }
603 1.56 bad R_Malloc(la, struct llinfo_arp *, allocsize);
604 1.121 christos rt->rt_llinfo = (void *)la;
605 1.139 dyoung if (la == NULL) {
606 1.12 mycroft log(LOG_DEBUG, "arp_rtrequest: malloc failed\n");
607 1.12 mycroft break;
608 1.12 mycroft }
609 1.12 mycroft arp_inuse++, arp_allocated++;
610 1.138 dyoung memset(la, 0, allocsize);
611 1.12 mycroft la->la_rt = rt;
612 1.12 mycroft rt->rt_flags |= RTF_LLINFO;
613 1.26 mycroft LIST_INSERT_HEAD(&llinfo_arp, la, la_list);
614 1.76 itojun
615 1.125 dyoung INADDR_TO_IA(satocsin(rt_getkey(rt))->sin_addr, ia);
616 1.127 dyoung while (ia && ia->ia_ifp != ifp)
617 1.76 itojun NEXT_IA_WITH_SAME_ADDR(ia);
618 1.76 itojun if (ia) {
619 1.24 cgd /*
620 1.24 cgd * This test used to be
621 1.100 peter * if (lo0ifp->if_flags & IFF_UP)
622 1.24 cgd * It allowed local traffic to be forced through
623 1.24 cgd * the hardware by configuring the loopback down.
624 1.24 cgd * However, it causes problems during network
625 1.24 cgd * configuration for boards that can't receive
626 1.24 cgd * packets they send. It is now necessary to clear
627 1.24 cgd * "useloopback" and remove the route to force
628 1.24 cgd * traffic out to the hardware.
629 1.76 itojun *
630 1.76 itojun * In 4.4BSD, the above "if" statement checked
631 1.125 dyoung * rt->rt_ifa against rt_getkey(rt). It was changed
632 1.81 itojun * to the current form so that we can provide a
633 1.76 itojun * better support for multiple IPv4 addresses on a
634 1.76 itojun * interface.
635 1.24 cgd */
636 1.12 mycroft rt->rt_expire = 0;
637 1.146 dyoung if (sockaddr_dl_init(satosdl(gate), gate->sa_len,
638 1.146 dyoung ifp->if_index, ifp->if_type, NULL, 0,
639 1.146 dyoung CLLADDR(ifp->if_sadl), ifp->if_addrlen) == NULL) {
640 1.146 dyoung panic("%s(%s): sockaddr_dl_init cannot fail",
641 1.146 dyoung __func__, ifp->if_xname);
642 1.146 dyoung }
643 1.12 mycroft if (useloopback)
644 1.127 dyoung ifp = rt->rt_ifp = lo0ifp;
645 1.76 itojun /*
646 1.76 itojun * make sure to set rt->rt_ifa to the interface
647 1.76 itojun * address we are using, otherwise we will have trouble
648 1.76 itojun * with source address selection.
649 1.76 itojun */
650 1.76 itojun ifa = &ia->ia_ifa;
651 1.115 dyoung if (ifa != rt->rt_ifa)
652 1.115 dyoung rt_replace_ifa(rt, ifa);
653 1.12 mycroft }
654 1.12 mycroft break;
655 1.12 mycroft
656 1.12 mycroft case RTM_DELETE:
657 1.139 dyoung if (la == NULL)
658 1.12 mycroft break;
659 1.12 mycroft arp_inuse--;
660 1.26 mycroft LIST_REMOVE(la, la_list);
661 1.139 dyoung rt->rt_llinfo = NULL;
662 1.12 mycroft rt->rt_flags &= ~RTF_LLINFO;
663 1.63 sommerfe
664 1.73 thorpej s = splnet();
665 1.63 sommerfe mold = la->la_hold;
666 1.63 sommerfe la->la_hold = 0;
667 1.63 sommerfe splx(s);
668 1.81 itojun
669 1.63 sommerfe if (mold)
670 1.63 sommerfe m_freem(mold);
671 1.63 sommerfe
672 1.121 christos Free((void *)la);
673 1.1 cgd }
674 1.63 sommerfe ARP_UNLOCK();
675 1.1 cgd }
676 1.1 cgd
677 1.1 cgd /*
678 1.12 mycroft * Broadcast an ARP request. Caller specifies:
679 1.12 mycroft * - arp header source ip address
680 1.12 mycroft * - arp header target ip address
681 1.12 mycroft * - arp header source ethernet address
682 1.12 mycroft */
683 1.110 liamjfoy void
684 1.102 perry arprequest(struct ifnet *ifp,
685 1.119 dyoung const struct in_addr *sip, const struct in_addr *tip,
686 1.119 dyoung const u_int8_t *enaddr)
687 1.1 cgd {
688 1.68 augustss struct mbuf *m;
689 1.35 is struct arphdr *ah;
690 1.1 cgd struct sockaddr sa;
691 1.132 thorpej uint64_t *arps;
692 1.1 cgd
693 1.1 cgd if ((m = m_gethdr(M_DONTWAIT, MT_DATA)) == NULL)
694 1.1 cgd return;
695 1.92 matt MCLAIM(m, &arpdomain.dom_mowner);
696 1.82 itojun switch (ifp->if_type) {
697 1.82 itojun case IFT_IEEE1394:
698 1.82 itojun m->m_len = sizeof(*ah) + 2 * sizeof(struct in_addr) +
699 1.86 enami ifp->if_addrlen;
700 1.82 itojun break;
701 1.82 itojun default:
702 1.82 itojun m->m_len = sizeof(*ah) + 2 * sizeof(struct in_addr) +
703 1.86 enami 2 * ifp->if_addrlen;
704 1.82 itojun break;
705 1.82 itojun }
706 1.35 is m->m_pkthdr.len = m->m_len;
707 1.35 is MH_ALIGN(m, m->m_len);
708 1.35 is ah = mtod(m, struct arphdr *);
709 1.140 dyoung memset(ah, 0, m->m_len);
710 1.82 itojun switch (ifp->if_type) {
711 1.83 itojun case IFT_IEEE1394: /* RFC2734 */
712 1.88 itojun /* fill it now for ar_tpa computation */
713 1.82 itojun ah->ar_hrd = htons(ARPHRD_IEEE1394);
714 1.82 itojun break;
715 1.82 itojun default:
716 1.88 itojun /* ifp->if_output will fill ar_hrd */
717 1.82 itojun break;
718 1.82 itojun }
719 1.35 is ah->ar_pro = htons(ETHERTYPE_IP);
720 1.86 enami ah->ar_hln = ifp->if_addrlen; /* hardware address length */
721 1.35 is ah->ar_pln = sizeof(struct in_addr); /* protocol address length */
722 1.35 is ah->ar_op = htons(ARPOP_REQUEST);
723 1.118 dyoung memcpy(ar_sha(ah), enaddr, ah->ar_hln);
724 1.118 dyoung memcpy(ar_spa(ah), sip, ah->ar_pln);
725 1.118 dyoung memcpy(ar_tpa(ah), tip, ah->ar_pln);
726 1.35 is sa.sa_family = AF_ARP;
727 1.35 is sa.sa_len = 2;
728 1.35 is m->m_flags |= M_BCAST;
729 1.132 thorpej arps = ARP_STAT_GETREF();
730 1.132 thorpej arps[ARP_STAT_SNDTOTAL]++;
731 1.132 thorpej arps[ARP_STAT_SENDREQUEST]++;
732 1.132 thorpej ARP_STAT_PUTREF();
733 1.118 dyoung (*ifp->if_output)(ifp, m, &sa, NULL);
734 1.1 cgd }
735 1.1 cgd
736 1.1 cgd /*
737 1.6 mycroft * Resolve an IP address into an ethernet address. If success,
738 1.1 cgd * desten is filled in. If there is no entry in arptab,
739 1.1 cgd * set one up and broadcast a request for the IP address.
740 1.1 cgd * Hold onto this mbuf and resend it once the address
741 1.1 cgd * is finally resolved. A return value of 1 indicates
742 1.1 cgd * that desten has been filled in and the packet should be sent
743 1.1 cgd * normally; a 0 return indicates that the packet has been
744 1.1 cgd * taken over here, either now or for later transmission.
745 1.1 cgd */
746 1.12 mycroft int
747 1.102 perry arpresolve(struct ifnet *ifp, struct rtentry *rt, struct mbuf *m,
748 1.119 dyoung const struct sockaddr *dst, u_char *desten)
749 1.1 cgd {
750 1.68 augustss struct llinfo_arp *la;
751 1.126 dyoung const struct sockaddr_dl *sdl;
752 1.63 sommerfe struct mbuf *mold;
753 1.63 sommerfe int s;
754 1.81 itojun
755 1.126 dyoung if ((la = arplookup1(m, &satocsin(dst)->sin_addr, 1, 0, rt)) != NULL)
756 1.126 dyoung rt = la->la_rt;
757 1.126 dyoung
758 1.139 dyoung if (la == NULL || rt == NULL) {
759 1.132 thorpej ARP_STATINC(ARP_STAT_ALLOCFAIL);
760 1.72 is log(LOG_DEBUG,
761 1.72 is "arpresolve: can't allocate llinfo on %s for %s\n",
762 1.119 dyoung ifp->if_xname, in_fmtaddr(satocsin(dst)->sin_addr));
763 1.12 mycroft m_freem(m);
764 1.139 dyoung return 0;
765 1.1 cgd }
766 1.126 dyoung sdl = satocsdl(rt->rt_gateway);
767 1.12 mycroft /*
768 1.12 mycroft * Check the address family and length is valid, the address
769 1.12 mycroft * is resolved; otherwise, try to resolve.
770 1.12 mycroft */
771 1.112 kardel if ((rt->rt_expire == 0 || rt->rt_expire > time_second) &&
772 1.12 mycroft sdl->sdl_family == AF_LINK && sdl->sdl_alen != 0) {
773 1.140 dyoung memcpy(desten, CLLADDR(sdl),
774 1.86 enami min(sdl->sdl_alen, ifp->if_addrlen));
775 1.112 kardel rt->rt_pksent = time_second; /* Time for last pkt sent */
776 1.12 mycroft return 1;
777 1.1 cgd }
778 1.1 cgd /*
779 1.1 cgd * There is an arptab entry, but no ethernet address
780 1.1 cgd * response yet. Replace the held mbuf with this
781 1.1 cgd * latest one.
782 1.1 cgd */
783 1.63 sommerfe
784 1.132 thorpej ARP_STATINC(ARP_STAT_DFRTOTAL);
785 1.73 thorpej s = splnet();
786 1.63 sommerfe mold = la->la_hold;
787 1.14 gwr la->la_hold = m;
788 1.63 sommerfe splx(s);
789 1.63 sommerfe
790 1.70 jhawk if (mold) {
791 1.132 thorpej ARP_STATINC(ARP_STAT_DFRDROPPED);
792 1.63 sommerfe m_freem(mold);
793 1.70 jhawk }
794 1.81 itojun
795 1.13 gwr /*
796 1.13 gwr * Re-send the ARP request when appropriate.
797 1.13 gwr */
798 1.13 gwr #ifdef DIAGNOSTIC
799 1.13 gwr if (rt->rt_expire == 0) {
800 1.14 gwr /* This should never happen. (Should it? -gwr) */
801 1.34 christos printf("arpresolve: unresolved and rt_expire == 0\n");
802 1.13 gwr /* Set expiration time to now (expired). */
803 1.112 kardel rt->rt_expire = time_second;
804 1.13 gwr }
805 1.13 gwr #endif
806 1.14 gwr if (rt->rt_expire) {
807 1.14 gwr rt->rt_flags &= ~RTF_REJECT;
808 1.112 kardel if (la->la_asked == 0 || rt->rt_expire != time_second) {
809 1.112 kardel rt->rt_expire = time_second;
810 1.145 christos if (la->la_asked++ < arp_maxtries) {
811 1.35 is arprequest(ifp,
812 1.119 dyoung &satocsin(rt->rt_ifa->ifa_addr)->sin_addr,
813 1.119 dyoung &satocsin(dst)->sin_addr,
814 1.110 liamjfoy #if NCARP > 0
815 1.110 liamjfoy (rt->rt_ifp->if_type == IFT_CARP) ?
816 1.127 dyoung CLLADDR(rt->rt_ifp->if_sadl):
817 1.110 liamjfoy #endif
818 1.127 dyoung CLLADDR(ifp->if_sadl));
819 1.145 christos } else {
820 1.14 gwr rt->rt_flags |= RTF_REJECT;
821 1.14 gwr rt->rt_expire += arpt_down;
822 1.14 gwr la->la_asked = 0;
823 1.14 gwr }
824 1.14 gwr }
825 1.12 mycroft }
826 1.139 dyoung return 0;
827 1.10 mycroft }
828 1.10 mycroft
829 1.1 cgd /*
830 1.12 mycroft * Common length and type checks are done here,
831 1.1 cgd * then the protocol-specific routine is called.
832 1.1 cgd */
833 1.12 mycroft void
834 1.102 perry arpintr(void)
835 1.1 cgd {
836 1.68 augustss struct mbuf *m;
837 1.68 augustss struct arphdr *ar;
838 1.12 mycroft int s;
839 1.82 itojun int arplen;
840 1.1 cgd
841 1.134 ad mutex_enter(softnet_lock);
842 1.134 ad KERNEL_LOCK(1, NULL);
843 1.12 mycroft while (arpintrq.ifq_head) {
844 1.73 thorpej s = splnet();
845 1.12 mycroft IF_DEQUEUE(&arpintrq, m);
846 1.12 mycroft splx(s);
847 1.12 mycroft if (m == 0 || (m->m_flags & M_PKTHDR) == 0)
848 1.12 mycroft panic("arpintr");
849 1.36 is
850 1.92 matt MCLAIM(m, &arpdomain.dom_mowner);
851 1.132 thorpej ARP_STATINC(ARP_STAT_RCVTOTAL);
852 1.70 jhawk
853 1.84 enami /*
854 1.84 enami * First, make sure we have at least struct arphdr.
855 1.84 enami */
856 1.84 enami if (m->m_len < sizeof(struct arphdr) ||
857 1.84 enami (ar = mtod(m, struct arphdr *)) == NULL)
858 1.84 enami goto badlen;
859 1.84 enami
860 1.82 itojun switch (m->m_pkthdr.rcvif->if_type) {
861 1.82 itojun case IFT_IEEE1394:
862 1.82 itojun arplen = sizeof(struct arphdr) +
863 1.82 itojun ar->ar_hln + 2 * ar->ar_pln;
864 1.82 itojun break;
865 1.82 itojun default:
866 1.82 itojun arplen = sizeof(struct arphdr) +
867 1.82 itojun 2 * ar->ar_hln + 2 * ar->ar_pln;
868 1.82 itojun break;
869 1.82 itojun }
870 1.82 itojun
871 1.84 enami if (/* XXX ntohs(ar->ar_hrd) == ARPHRD_ETHER && */
872 1.82 itojun m->m_len >= arplen)
873 1.12 mycroft switch (ntohs(ar->ar_pro)) {
874 1.12 mycroft case ETHERTYPE_IP:
875 1.12 mycroft case ETHERTYPE_IPTRAILERS:
876 1.12 mycroft in_arpinput(m);
877 1.12 mycroft continue;
878 1.70 jhawk default:
879 1.132 thorpej ARP_STATINC(ARP_STAT_RCVBADPROTO);
880 1.12 mycroft }
881 1.84 enami else {
882 1.84 enami badlen:
883 1.132 thorpej ARP_STATINC(ARP_STAT_RCVBADLEN);
884 1.84 enami }
885 1.12 mycroft m_freem(m);
886 1.1 cgd }
887 1.134 ad KERNEL_UNLOCK_ONE(NULL);
888 1.134 ad mutex_exit(softnet_lock);
889 1.1 cgd }
890 1.1 cgd
891 1.1 cgd /*
892 1.1 cgd * ARP for Internet protocols on 10 Mb/s Ethernet.
893 1.1 cgd * Algorithm is that given in RFC 826.
894 1.1 cgd * In addition, a sanity check is performed on the sender
895 1.1 cgd * protocol address, to catch impersonators.
896 1.12 mycroft * We no longer handle negotiations for use of trailer protocol:
897 1.12 mycroft * Formerly, ARP replied for protocol type ETHERTYPE_TRAIL sent
898 1.12 mycroft * along with IP replies if we wanted trailers sent to us,
899 1.12 mycroft * and also sent them in response to IP replies.
900 1.12 mycroft * This allowed either end to announce the desire to receive
901 1.1 cgd * trailer packets.
902 1.12 mycroft * We no longer reply to requests for ETHERTYPE_TRAIL protocol either,
903 1.12 mycroft * but formerly didn't normally send requests.
904 1.1 cgd */
905 1.12 mycroft static void
906 1.102 perry in_arpinput(struct mbuf *m)
907 1.1 cgd {
908 1.35 is struct arphdr *ah;
909 1.68 augustss struct ifnet *ifp = m->m_pkthdr.rcvif;
910 1.139 dyoung struct llinfo_arp *la = NULL;
911 1.68 augustss struct rtentry *rt;
912 1.44 tls struct in_ifaddr *ia;
913 1.77 thorpej #if NBRIDGE > 0
914 1.77 thorpej struct in_ifaddr *bridge_ia = NULL;
915 1.77 thorpej #endif
916 1.110 liamjfoy #if NCARP > 0
917 1.110 liamjfoy u_int32_t count = 0, index = 0;
918 1.110 liamjfoy #endif
919 1.12 mycroft struct sockaddr_dl *sdl;
920 1.1 cgd struct sockaddr sa;
921 1.1 cgd struct in_addr isaddr, itaddr, myaddr;
922 1.12 mycroft int op;
923 1.63 sommerfe struct mbuf *mold;
924 1.121 christos void *tha;
925 1.63 sommerfe int s;
926 1.132 thorpej uint64_t *arps;
927 1.81 itojun
928 1.111 bouyer if (__predict_false(m_makewritable(&m, 0, m->m_pkthdr.len, M_DONTWAIT)))
929 1.111 bouyer goto out;
930 1.35 is ah = mtod(m, struct arphdr *);
931 1.35 is op = ntohs(ah->ar_op);
932 1.40 gwr
933 1.89 enami /*
934 1.89 enami * Fix up ah->ar_hrd if necessary, before using ar_tha() or
935 1.89 enami * ar_tpa().
936 1.89 enami */
937 1.89 enami switch (ifp->if_type) {
938 1.82 itojun case IFT_IEEE1394:
939 1.82 itojun if (ntohs(ah->ar_hrd) == ARPHRD_IEEE1394)
940 1.82 itojun ;
941 1.82 itojun else {
942 1.82 itojun /* XXX this is to make sure we compute ar_tha right */
943 1.82 itojun /* XXX check ar_hrd more strictly? */
944 1.82 itojun ah->ar_hrd = htons(ARPHRD_IEEE1394);
945 1.82 itojun }
946 1.82 itojun break;
947 1.82 itojun default:
948 1.82 itojun /* XXX check ar_hrd? */
949 1.82 itojun break;
950 1.82 itojun }
951 1.89 enami
952 1.121 christos memcpy(&isaddr, ar_spa(ah), sizeof (isaddr));
953 1.121 christos memcpy(&itaddr, ar_tpa(ah), sizeof (itaddr));
954 1.82 itojun
955 1.70 jhawk if (m->m_flags & (M_BCAST|M_MCAST))
956 1.132 thorpej ARP_STATINC(ARP_STAT_RCVMCAST);
957 1.70 jhawk
958 1.40 gwr /*
959 1.42 gwr * If the target IP address is zero, ignore the packet.
960 1.42 gwr * This prevents the code below from tring to answer
961 1.42 gwr * when we are using IP address zero (booting).
962 1.40 gwr */
963 1.70 jhawk if (in_nullhost(itaddr)) {
964 1.132 thorpej ARP_STATINC(ARP_STAT_RCVZEROTPA);
965 1.42 gwr goto out;
966 1.70 jhawk }
967 1.42 gwr
968 1.42 gwr /*
969 1.42 gwr * If the source IP address is zero, this is most likely a
970 1.44 tls * confused host trying to use IP address zero. (Windoze?)
971 1.44 tls * XXX: Should we bother trying to reply to these?
972 1.42 gwr */
973 1.70 jhawk if (in_nullhost(isaddr)) {
974 1.132 thorpej ARP_STATINC(ARP_STAT_RCVZEROSPA);
975 1.40 gwr goto out;
976 1.70 jhawk }
977 1.40 gwr
978 1.44 tls /*
979 1.44 tls * Search for a matching interface address
980 1.44 tls * or any address on the interface to use
981 1.44 tls * as a dummy address in the rest of this function
982 1.44 tls */
983 1.110 liamjfoy
984 1.44 tls INADDR_TO_IA(itaddr, ia);
985 1.77 thorpej while (ia != NULL) {
986 1.110 liamjfoy #if NCARP > 0
987 1.110 liamjfoy if (ia->ia_ifp->if_type == IFT_CARP &&
988 1.110 liamjfoy ((ia->ia_ifp->if_flags & (IFF_UP|IFF_RUNNING)) ==
989 1.110 liamjfoy (IFF_UP|IFF_RUNNING))) {
990 1.110 liamjfoy index++;
991 1.110 liamjfoy if (ia->ia_ifp == m->m_pkthdr.rcvif &&
992 1.110 liamjfoy carp_iamatch(ia, ar_sha(ah),
993 1.110 liamjfoy &count, index)) {
994 1.110 liamjfoy break;
995 1.110 liamjfoy }
996 1.110 liamjfoy } else
997 1.110 liamjfoy #endif
998 1.110 liamjfoy if (ia->ia_ifp == m->m_pkthdr.rcvif)
999 1.110 liamjfoy break;
1000 1.77 thorpej #if NBRIDGE > 0
1001 1.77 thorpej /*
1002 1.77 thorpej * If the interface we received the packet on
1003 1.77 thorpej * is part of a bridge, check to see if we need
1004 1.77 thorpej * to "bridge" the packet to ourselves at this
1005 1.77 thorpej * layer. Note we still prefer a perfect match,
1006 1.77 thorpej * but allow this weaker match if necessary.
1007 1.77 thorpej */
1008 1.77 thorpej if (m->m_pkthdr.rcvif->if_bridge != NULL &&
1009 1.77 thorpej m->m_pkthdr.rcvif->if_bridge == ia->ia_ifp->if_bridge)
1010 1.77 thorpej bridge_ia = ia;
1011 1.77 thorpej #endif /* NBRIDGE > 0 */
1012 1.77 thorpej
1013 1.49 is NEXT_IA_WITH_SAME_ADDR(ia);
1014 1.77 thorpej }
1015 1.77 thorpej
1016 1.77 thorpej #if NBRIDGE > 0
1017 1.78 itojun if (ia == NULL && bridge_ia != NULL) {
1018 1.77 thorpej ia = bridge_ia;
1019 1.78 itojun ifp = bridge_ia->ia_ifp;
1020 1.78 itojun }
1021 1.77 thorpej #endif
1022 1.49 is
1023 1.44 tls if (ia == NULL) {
1024 1.44 tls INADDR_TO_IA(isaddr, ia);
1025 1.49 is while ((ia != NULL) && ia->ia_ifp != m->m_pkthdr.rcvif)
1026 1.49 is NEXT_IA_WITH_SAME_ADDR(ia);
1027 1.49 is
1028 1.49 is if (ia == NULL) {
1029 1.48 is IFP_TO_IA(ifp, ia);
1030 1.70 jhawk if (ia == NULL) {
1031 1.132 thorpej ARP_STATINC(ARP_STAT_RCVNOINT);
1032 1.49 is goto out;
1033 1.70 jhawk }
1034 1.49 is }
1035 1.44 tls }
1036 1.48 is
1037 1.44 tls myaddr = ia->ia_addr.sin_addr;
1038 1.36 is
1039 1.78 itojun /* XXX checks for bridge case? */
1040 1.126 dyoung if (!memcmp(ar_sha(ah), CLLADDR(ifp->if_sadl), ifp->if_addrlen)) {
1041 1.132 thorpej ARP_STATINC(ARP_STAT_RCVLOCALSHA);
1042 1.1 cgd goto out; /* it's from me, ignore it. */
1043 1.70 jhawk }
1044 1.41 is
1045 1.78 itojun /* XXX checks for bridge case? */
1046 1.104 christos if (!memcmp(ar_sha(ah), ifp->if_broadcastaddr, ifp->if_addrlen)) {
1047 1.132 thorpej ARP_STATINC(ARP_STAT_RCVBCASTSHA);
1048 1.41 is log(LOG_ERR,
1049 1.46 matt "%s: arp: link address is broadcast for IP address %s!\n",
1050 1.46 matt ifp->if_xname, in_fmtaddr(isaddr));
1051 1.41 is goto out;
1052 1.41 is }
1053 1.41 is
1054 1.35 is if (in_hosteq(isaddr, myaddr)) {
1055 1.132 thorpej ARP_STATINC(ARP_STAT_RCVLOCALSPA);
1056 1.1 cgd log(LOG_ERR,
1057 1.46 matt "duplicate IP address %s sent from link address %s\n",
1058 1.46 matt in_fmtaddr(isaddr), lla_snprintf(ar_sha(ah), ah->ar_hln));
1059 1.1 cgd itaddr = myaddr;
1060 1.12 mycroft goto reply;
1061 1.1 cgd }
1062 1.75 tron la = arplookup(m, &isaddr, in_hosteq(itaddr, myaddr), 0);
1063 1.139 dyoung if (la != NULL && (rt = la->la_rt) && (sdl = satosdl(rt->rt_gateway))) {
1064 1.12 mycroft if (sdl->sdl_alen &&
1065 1.126 dyoung memcmp(ar_sha(ah), CLLADDR(sdl), sdl->sdl_alen)) {
1066 1.58 is if (rt->rt_flags & RTF_STATIC) {
1067 1.132 thorpej ARP_STATINC(ARP_STAT_RCVOVERPERM);
1068 1.58 is log(LOG_INFO,
1069 1.58 is "%s tried to overwrite permanent arp info"
1070 1.58 is " for %s\n",
1071 1.58 is lla_snprintf(ar_sha(ah), ah->ar_hln),
1072 1.58 is in_fmtaddr(isaddr));
1073 1.58 is goto out;
1074 1.58 is } else if (rt->rt_ifp != ifp) {
1075 1.132 thorpej ARP_STATINC(ARP_STAT_RCVOVERINT);
1076 1.57 is log(LOG_INFO,
1077 1.57 is "%s on %s tried to overwrite "
1078 1.57 is "arp info for %s on %s\n",
1079 1.57 is lla_snprintf(ar_sha(ah), ah->ar_hln),
1080 1.57 is ifp->if_xname, in_fmtaddr(isaddr),
1081 1.57 is rt->rt_ifp->if_xname);
1082 1.57 is goto out;
1083 1.57 is } else {
1084 1.132 thorpej ARP_STATINC(ARP_STAT_RCVOVER);
1085 1.57 is log(LOG_INFO,
1086 1.57 is "arp info overwritten for %s by %s\n",
1087 1.57 is in_fmtaddr(isaddr),
1088 1.57 is lla_snprintf(ar_sha(ah), ah->ar_hln));
1089 1.57 is }
1090 1.57 is }
1091 1.81 itojun /*
1092 1.35 is * sanity check for the address length.
1093 1.35 is * XXX this does not work for protocols with variable address
1094 1.35 is * length. -is
1095 1.35 is */
1096 1.35 is if (sdl->sdl_alen &&
1097 1.35 is sdl->sdl_alen != ah->ar_hln) {
1098 1.132 thorpej ARP_STATINC(ARP_STAT_RCVLENCHG);
1099 1.81 itojun log(LOG_WARNING,
1100 1.141 uebayasi "arp from %s: new addr len %d, was %d\n",
1101 1.46 matt in_fmtaddr(isaddr), ah->ar_hln, sdl->sdl_alen);
1102 1.35 is }
1103 1.86 enami if (ifp->if_addrlen != ah->ar_hln) {
1104 1.132 thorpej ARP_STATINC(ARP_STAT_RCVBADLEN);
1105 1.81 itojun log(LOG_WARNING,
1106 1.141 uebayasi "arp from %s: addr len: new %d, i/f %d (ignored)\n",
1107 1.46 matt in_fmtaddr(isaddr), ah->ar_hln,
1108 1.86 enami ifp->if_addrlen);
1109 1.35 is goto reply;
1110 1.35 is }
1111 1.56 bad #if NTOKEN > 0
1112 1.56 bad /*
1113 1.60 bad * XXX uses m_data and assumes the complete answer including
1114 1.56 bad * XXX token-ring headers is in the same buf
1115 1.56 bad */
1116 1.61 bad if (ifp->if_type == IFT_ISO88025) {
1117 1.61 bad struct token_header *trh;
1118 1.61 bad
1119 1.61 bad trh = (struct token_header *)M_TRHSTART(m);
1120 1.61 bad if (trh->token_shost[0] & TOKEN_RI_PRESENT) {
1121 1.61 bad struct token_rif *rif;
1122 1.61 bad size_t riflen;
1123 1.61 bad
1124 1.61 bad rif = TOKEN_RIF(trh);
1125 1.61 bad riflen = (ntohs(rif->tr_rcf) &
1126 1.61 bad TOKEN_RCF_LEN_MASK) >> 8;
1127 1.61 bad
1128 1.61 bad if (riflen > 2 &&
1129 1.61 bad riflen < sizeof(struct token_rif) &&
1130 1.61 bad (riflen & 1) == 0) {
1131 1.61 bad rif->tr_rcf ^= htons(TOKEN_RCF_DIRECTION);
1132 1.61 bad rif->tr_rcf &= htons(~TOKEN_RCF_BROADCAST_MASK);
1133 1.140 dyoung memcpy(TOKEN_RIF(la), rif, riflen);
1134 1.61 bad }
1135 1.56 bad }
1136 1.56 bad }
1137 1.56 bad #endif /* NTOKEN > 0 */
1138 1.127 dyoung (void)sockaddr_dl_setaddr(sdl, sdl->sdl_len, ar_sha(ah),
1139 1.127 dyoung ah->ar_hln);
1140 1.12 mycroft if (rt->rt_expire)
1141 1.112 kardel rt->rt_expire = time_second + arpt_keep;
1142 1.12 mycroft rt->rt_flags &= ~RTF_REJECT;
1143 1.12 mycroft la->la_asked = 0;
1144 1.63 sommerfe
1145 1.73 thorpej s = splnet();
1146 1.63 sommerfe mold = la->la_hold;
1147 1.63 sommerfe la->la_hold = 0;
1148 1.63 sommerfe splx(s);
1149 1.63 sommerfe
1150 1.70 jhawk if (mold) {
1151 1.132 thorpej ARP_STATINC(ARP_STAT_DFRSENT);
1152 1.125 dyoung (*ifp->if_output)(ifp, mold, rt_getkey(rt), rt);
1153 1.70 jhawk }
1154 1.1 cgd }
1155 1.1 cgd reply:
1156 1.12 mycroft if (op != ARPOP_REQUEST) {
1157 1.70 jhawk if (op == ARPOP_REPLY)
1158 1.132 thorpej ARP_STATINC(ARP_STAT_RCVREPLY);
1159 1.12 mycroft out:
1160 1.12 mycroft m_freem(m);
1161 1.12 mycroft return;
1162 1.1 cgd }
1163 1.132 thorpej ARP_STATINC(ARP_STAT_RCVREQUEST);
1164 1.35 is if (in_hosteq(itaddr, myaddr)) {
1165 1.1 cgd /* I am the target */
1166 1.109 mrg tha = ar_tha(ah);
1167 1.109 mrg if (tha)
1168 1.121 christos memcpy(tha, ar_sha(ah), ah->ar_hln);
1169 1.126 dyoung memcpy(ar_sha(ah), CLLADDR(ifp->if_sadl), ah->ar_hln);
1170 1.1 cgd } else {
1171 1.75 tron la = arplookup(m, &itaddr, 0, SIN_PROXY);
1172 1.139 dyoung if (la == NULL)
1173 1.1 cgd goto out;
1174 1.12 mycroft rt = la->la_rt;
1175 1.110 liamjfoy if (rt->rt_ifp->if_type == IFT_CARP &&
1176 1.110 liamjfoy m->m_pkthdr.rcvif->if_type != IFT_CARP)
1177 1.110 liamjfoy goto out;
1178 1.109 mrg tha = ar_tha(ah);
1179 1.109 mrg if (tha)
1180 1.121 christos memcpy(tha, ar_sha(ah), ah->ar_hln);
1181 1.126 dyoung sdl = satosdl(rt->rt_gateway);
1182 1.126 dyoung memcpy(ar_sha(ah), CLLADDR(sdl), ah->ar_hln);
1183 1.1 cgd }
1184 1.1 cgd
1185 1.121 christos memcpy(ar_tpa(ah), ar_spa(ah), ah->ar_pln);
1186 1.121 christos memcpy(ar_spa(ah), &itaddr, ah->ar_pln);
1187 1.35 is ah->ar_op = htons(ARPOP_REPLY);
1188 1.35 is ah->ar_pro = htons(ETHERTYPE_IP); /* let's be sure! */
1189 1.85 enami switch (ifp->if_type) {
1190 1.85 enami case IFT_IEEE1394:
1191 1.85 enami /*
1192 1.85 enami * ieee1394 arp reply is broadcast
1193 1.85 enami */
1194 1.85 enami m->m_flags &= ~M_MCAST;
1195 1.85 enami m->m_flags |= M_BCAST;
1196 1.85 enami m->m_len = sizeof(*ah) + (2 * ah->ar_pln) + ah->ar_hln;
1197 1.85 enami break;
1198 1.85 enami
1199 1.85 enami default:
1200 1.85 enami m->m_flags &= ~(M_BCAST|M_MCAST); /* never reply by broadcast */
1201 1.85 enami m->m_len = sizeof(*ah) + (2 * ah->ar_pln) + (2 * ah->ar_hln);
1202 1.85 enami break;
1203 1.85 enami }
1204 1.62 thorpej m->m_pkthdr.len = m->m_len;
1205 1.35 is sa.sa_family = AF_ARP;
1206 1.35 is sa.sa_len = 2;
1207 1.132 thorpej arps = ARP_STAT_GETREF();
1208 1.132 thorpej arps[ARP_STAT_SNDTOTAL]++;
1209 1.132 thorpej arps[ARP_STAT_SNDREPLY]++;
1210 1.132 thorpej ARP_STAT_PUTREF();
1211 1.35 is (*ifp->if_output)(ifp, m, &sa, (struct rtentry *)0);
1212 1.1 cgd return;
1213 1.1 cgd }
1214 1.1 cgd
1215 1.1 cgd /*
1216 1.12 mycroft * Free an arp entry.
1217 1.1 cgd */
1218 1.102 perry static void arptfree(struct llinfo_arp *la)
1219 1.12 mycroft {
1220 1.68 augustss struct rtentry *rt = la->la_rt;
1221 1.68 augustss struct sockaddr_dl *sdl;
1222 1.12 mycroft
1223 1.63 sommerfe ARP_LOCK_CHECK();
1224 1.63 sommerfe
1225 1.139 dyoung if (rt == NULL)
1226 1.12 mycroft panic("arptfree");
1227 1.126 dyoung if (rt->rt_refcnt > 0 && (sdl = satosdl(rt->rt_gateway)) &&
1228 1.12 mycroft sdl->sdl_family == AF_LINK) {
1229 1.12 mycroft sdl->sdl_alen = 0;
1230 1.12 mycroft la->la_asked = 0;
1231 1.12 mycroft rt->rt_flags &= ~RTF_REJECT;
1232 1.12 mycroft return;
1233 1.12 mycroft }
1234 1.125 dyoung rtrequest(RTM_DELETE, rt_getkey(rt), NULL, rt_mask(rt), 0, NULL);
1235 1.1 cgd }
1236 1.1 cgd
1237 1.126 dyoung static struct llinfo_arp *
1238 1.126 dyoung arplookup(struct mbuf *m, const struct in_addr *addr, int create, int proxy)
1239 1.126 dyoung {
1240 1.126 dyoung return arplookup1(m, addr, create, proxy, NULL);
1241 1.126 dyoung }
1242 1.126 dyoung
1243 1.1 cgd /*
1244 1.12 mycroft * Lookup or enter a new address in arptab.
1245 1.12 mycroft */
1246 1.12 mycroft static struct llinfo_arp *
1247 1.126 dyoung arplookup1(struct mbuf *m, const struct in_addr *addr, int create, int proxy,
1248 1.126 dyoung struct rtentry *rt0)
1249 1.12 mycroft {
1250 1.75 tron struct arphdr *ah;
1251 1.75 tron struct ifnet *ifp = m->m_pkthdr.rcvif;
1252 1.68 augustss struct rtentry *rt;
1253 1.138 dyoung struct sockaddr_inarp sin;
1254 1.138 dyoung const char *why = NULL;
1255 1.1 cgd
1256 1.75 tron ah = mtod(m, struct arphdr *);
1257 1.126 dyoung if (rt0 == NULL) {
1258 1.138 dyoung memset(&sin, 0, sizeof(sin));
1259 1.126 dyoung sin.sin_len = sizeof(sin);
1260 1.126 dyoung sin.sin_family = AF_INET;
1261 1.126 dyoung sin.sin_addr = *addr;
1262 1.126 dyoung sin.sin_other = proxy ? SIN_PROXY : 0;
1263 1.126 dyoung rt = rtalloc1(sintosa(&sin), create);
1264 1.126 dyoung if (rt == NULL)
1265 1.139 dyoung return NULL;
1266 1.126 dyoung rt->rt_refcnt--;
1267 1.126 dyoung } else
1268 1.126 dyoung rt = rt0;
1269 1.126 dyoung
1270 1.126 dyoung #define IS_LLINFO(__rt) \
1271 1.126 dyoung (((__rt)->rt_flags & (RTF_GATEWAY | RTF_LLINFO)) == RTF_LLINFO && \
1272 1.126 dyoung (__rt)->rt_gateway->sa_family == AF_LINK)
1273 1.126 dyoung
1274 1.53 drochner
1275 1.126 dyoung if (IS_LLINFO(rt))
1276 1.139 dyoung return (struct llinfo_arp *)rt->rt_llinfo;
1277 1.53 drochner
1278 1.94 itojun if (create) {
1279 1.99 christos if (rt->rt_flags & RTF_GATEWAY)
1280 1.99 christos why = "host is not on local network";
1281 1.99 christos else if ((rt->rt_flags & RTF_LLINFO) == 0) {
1282 1.132 thorpej ARP_STATINC(ARP_STAT_ALLOCFAIL);
1283 1.99 christos why = "could not allocate llinfo";
1284 1.103 perry } else
1285 1.99 christos why = "gateway route is not ours";
1286 1.53 drochner log(LOG_DEBUG, "arplookup: unable to enter address"
1287 1.75 tron " for %s@%s on %s (%s)\n",
1288 1.75 tron in_fmtaddr(*addr), lla_snprintf(ar_sha(ah), ah->ar_hln),
1289 1.139 dyoung (ifp) ? ifp->if_xname : "null", why);
1290 1.94 itojun if (rt->rt_refcnt <= 0 && (rt->rt_flags & RTF_CLONED) != 0) {
1291 1.125 dyoung rtrequest(RTM_DELETE, rt_getkey(rt),
1292 1.139 dyoung rt->rt_gateway, rt_mask(rt), rt->rt_flags, NULL);
1293 1.94 itojun }
1294 1.94 itojun }
1295 1.139 dyoung return NULL;
1296 1.1 cgd }
1297 1.1 cgd
1298 1.12 mycroft int
1299 1.121 christos arpioctl(u_long cmd, void *data)
1300 1.1 cgd {
1301 1.20 mycroft
1302 1.139 dyoung return EOPNOTSUPP;
1303 1.20 mycroft }
1304 1.20 mycroft
1305 1.20 mycroft void
1306 1.102 perry arp_ifinit(struct ifnet *ifp, struct ifaddr *ifa)
1307 1.20 mycroft {
1308 1.40 gwr struct in_addr *ip;
1309 1.40 gwr
1310 1.40 gwr /*
1311 1.40 gwr * Warn the user if another station has this IP address,
1312 1.40 gwr * but only if the interface IP address is not zero.
1313 1.40 gwr */
1314 1.40 gwr ip = &IA_SIN(ifa)->sin_addr;
1315 1.40 gwr if (!in_nullhost(*ip))
1316 1.127 dyoung arprequest(ifp, ip, ip, CLLADDR(ifp->if_sadl));
1317 1.20 mycroft
1318 1.20 mycroft ifa->ifa_rtrequest = arp_rtrequest;
1319 1.20 mycroft ifa->ifa_flags |= RTF_CLONING;
1320 1.9 glass }
1321 1.9 glass
1322 1.9 glass /*
1323 1.9 glass * Called from 10 Mb/s Ethernet interrupt handlers
1324 1.9 glass * when ether packet type ETHERTYPE_REVARP
1325 1.9 glass * is received. Common length and type checks are done here,
1326 1.9 glass * then the protocol-specific routine is called.
1327 1.9 glass */
1328 1.12 mycroft void
1329 1.102 perry revarpinput(struct mbuf *m)
1330 1.9 glass {
1331 1.9 glass struct arphdr *ar;
1332 1.9 glass
1333 1.9 glass if (m->m_len < sizeof(struct arphdr))
1334 1.9 glass goto out;
1335 1.9 glass ar = mtod(m, struct arphdr *);
1336 1.35 is #if 0 /* XXX I don't think we need this... and it will prevent other LL */
1337 1.9 glass if (ntohs(ar->ar_hrd) != ARPHRD_ETHER)
1338 1.9 glass goto out;
1339 1.35 is #endif
1340 1.12 mycroft if (m->m_len < sizeof(struct arphdr) + 2 * (ar->ar_hln + ar->ar_pln))
1341 1.9 glass goto out;
1342 1.9 glass switch (ntohs(ar->ar_pro)) {
1343 1.9 glass case ETHERTYPE_IP:
1344 1.9 glass case ETHERTYPE_IPTRAILERS:
1345 1.12 mycroft in_revarpinput(m);
1346 1.9 glass return;
1347 1.9 glass
1348 1.9 glass default:
1349 1.9 glass break;
1350 1.9 glass }
1351 1.9 glass out:
1352 1.9 glass m_freem(m);
1353 1.9 glass }
1354 1.9 glass
1355 1.9 glass /*
1356 1.9 glass * RARP for Internet protocols on 10 Mb/s Ethernet.
1357 1.9 glass * Algorithm is that given in RFC 903.
1358 1.9 glass * We are only using for bootstrap purposes to get an ip address for one of
1359 1.9 glass * our interfaces. Thus we support no user-interface.
1360 1.9 glass *
1361 1.9 glass * Since the contents of the RARP reply are specific to the interface that
1362 1.9 glass * sent the request, this code must ensure that they are properly associated.
1363 1.9 glass *
1364 1.9 glass * Note: also supports ARP via RARP packets, per the RFC.
1365 1.9 glass */
1366 1.28 christos void
1367 1.102 perry in_revarpinput(struct mbuf *m)
1368 1.9 glass {
1369 1.12 mycroft struct ifnet *ifp;
1370 1.35 is struct arphdr *ah;
1371 1.121 christos void *tha;
1372 1.28 christos int op;
1373 1.9 glass
1374 1.35 is ah = mtod(m, struct arphdr *);
1375 1.35 is op = ntohs(ah->ar_op);
1376 1.82 itojun
1377 1.82 itojun switch (m->m_pkthdr.rcvif->if_type) {
1378 1.82 itojun case IFT_IEEE1394:
1379 1.82 itojun /* ARP without target hardware address is not supported */
1380 1.82 itojun goto out;
1381 1.82 itojun default:
1382 1.82 itojun break;
1383 1.82 itojun }
1384 1.82 itojun
1385 1.9 glass switch (op) {
1386 1.9 glass case ARPOP_REQUEST:
1387 1.9 glass case ARPOP_REPLY: /* per RFC */
1388 1.12 mycroft in_arpinput(m);
1389 1.9 glass return;
1390 1.12 mycroft case ARPOP_REVREPLY:
1391 1.9 glass break;
1392 1.12 mycroft case ARPOP_REVREQUEST: /* handled by rarpd(8) */
1393 1.9 glass default:
1394 1.9 glass goto out;
1395 1.9 glass }
1396 1.9 glass if (!revarp_in_progress)
1397 1.9 glass goto out;
1398 1.12 mycroft ifp = m->m_pkthdr.rcvif;
1399 1.12 mycroft if (ifp != myip_ifp) /* !same interface */
1400 1.9 glass goto out;
1401 1.13 gwr if (myip_initialized)
1402 1.13 gwr goto wake;
1403 1.109 mrg tha = ar_tha(ah);
1404 1.109 mrg KASSERT(tha);
1405 1.140 dyoung if (memcmp(tha, CLLADDR(ifp->if_sadl), ifp->if_sadl->sdl_alen))
1406 1.9 glass goto out;
1407 1.121 christos memcpy(&srv_ip, ar_spa(ah), sizeof(srv_ip));
1408 1.121 christos memcpy(&myip, ar_tpa(ah), sizeof(myip));
1409 1.9 glass myip_initialized = 1;
1410 1.13 gwr wake: /* Do wakeup every time in case it was missed. */
1411 1.121 christos wakeup((void *)&myip);
1412 1.12 mycroft
1413 1.12 mycroft out:
1414 1.9 glass m_freem(m);
1415 1.9 glass }
1416 1.9 glass
1417 1.9 glass /*
1418 1.9 glass * Send a RARP request for the ip address of the specified interface.
1419 1.9 glass * The request should be RFC 903-compliant.
1420 1.9 glass */
1421 1.12 mycroft void
1422 1.102 perry revarprequest(struct ifnet *ifp)
1423 1.9 glass {
1424 1.9 glass struct sockaddr sa;
1425 1.9 glass struct mbuf *m;
1426 1.35 is struct arphdr *ah;
1427 1.121 christos void *tha;
1428 1.9 glass
1429 1.9 glass if ((m = m_gethdr(M_DONTWAIT, MT_DATA)) == NULL)
1430 1.9 glass return;
1431 1.92 matt MCLAIM(m, &arpdomain.dom_mowner);
1432 1.35 is m->m_len = sizeof(*ah) + 2*sizeof(struct in_addr) +
1433 1.86 enami 2*ifp->if_addrlen;
1434 1.35 is m->m_pkthdr.len = m->m_len;
1435 1.35 is MH_ALIGN(m, m->m_len);
1436 1.35 is ah = mtod(m, struct arphdr *);
1437 1.140 dyoung memset(ah, 0, m->m_len);
1438 1.35 is ah->ar_pro = htons(ETHERTYPE_IP);
1439 1.86 enami ah->ar_hln = ifp->if_addrlen; /* hardware address length */
1440 1.35 is ah->ar_pln = sizeof(struct in_addr); /* protocol address length */
1441 1.35 is ah->ar_op = htons(ARPOP_REVREQUEST);
1442 1.35 is
1443 1.126 dyoung memcpy(ar_sha(ah), CLLADDR(ifp->if_sadl), ah->ar_hln);
1444 1.109 mrg tha = ar_tha(ah);
1445 1.109 mrg KASSERT(tha);
1446 1.140 dyoung memcpy(tha, CLLADDR(ifp->if_sadl), ah->ar_hln);
1447 1.35 is
1448 1.35 is sa.sa_family = AF_ARP;
1449 1.35 is sa.sa_len = 2;
1450 1.35 is m->m_flags |= M_BCAST;
1451 1.139 dyoung (*ifp->if_output)(ifp, m, &sa, NULL);
1452 1.35 is
1453 1.9 glass }
1454 1.9 glass
1455 1.9 glass /*
1456 1.13 gwr * RARP for the ip address of the specified interface, but also
1457 1.13 gwr * save the ip address of the server that sent the answer.
1458 1.13 gwr * Timeout if no response is received.
1459 1.9 glass */
1460 1.12 mycroft int
1461 1.102 perry revarpwhoarewe(struct ifnet *ifp, struct in_addr *serv_in,
1462 1.102 perry struct in_addr *clnt_in)
1463 1.9 glass {
1464 1.9 glass int result, count = 20;
1465 1.81 itojun
1466 1.55 drochner myip_initialized = 0;
1467 1.55 drochner myip_ifp = ifp;
1468 1.55 drochner
1469 1.55 drochner revarp_in_progress = 1;
1470 1.55 drochner while (count--) {
1471 1.55 drochner revarprequest(ifp);
1472 1.121 christos result = tsleep((void *)&myip, PSOCK, "revarp", hz/2);
1473 1.55 drochner if (result != EWOULDBLOCK)
1474 1.55 drochner break;
1475 1.9 glass }
1476 1.55 drochner revarp_in_progress = 0;
1477 1.55 drochner
1478 1.9 glass if (!myip_initialized)
1479 1.9 glass return ENETUNREACH;
1480 1.81 itojun
1481 1.140 dyoung memcpy(serv_in, &srv_ip, sizeof(*serv_in));
1482 1.140 dyoung memcpy(clnt_in, &myip, sizeof(*clnt_in));
1483 1.9 glass return 0;
1484 1.1 cgd }
1485 1.13 gwr
1486 1.13 gwr
1487 1.13 gwr
1489 1.28 christos #ifdef DDB
1490 1.28 christos
1491 1.28 christos #include <machine/db_machdep.h>
1492 1.28 christos #include <ddb/db_interface.h>
1493 1.102 perry #include <ddb/db_output.h>
1494 1.13 gwr
1495 1.102 perry static void
1496 1.13 gwr db_print_sa(const struct sockaddr *sa)
1497 1.13 gwr {
1498 1.104 christos int len;
1499 1.13 gwr const u_char *p;
1500 1.139 dyoung
1501 1.13 gwr if (sa == NULL) {
1502 1.13 gwr db_printf("[NULL]");
1503 1.13 gwr return;
1504 1.13 gwr }
1505 1.104 christos
1506 1.13 gwr p = (const u_char *)sa;
1507 1.13 gwr len = sa->sa_len;
1508 1.13 gwr db_printf("[");
1509 1.13 gwr while (len > 0) {
1510 1.13 gwr db_printf("%d", *p);
1511 1.13 gwr p++; len--;
1512 1.13 gwr if (len) db_printf(",");
1513 1.13 gwr }
1514 1.13 gwr db_printf("]\n");
1515 1.102 perry }
1516 1.13 gwr
1517 1.102 perry static void
1518 1.13 gwr db_print_ifa(struct ifaddr *ifa)
1519 1.139 dyoung {
1520 1.13 gwr if (ifa == NULL)
1521 1.13 gwr return;
1522 1.13 gwr db_printf(" ifa_addr=");
1523 1.13 gwr db_print_sa(ifa->ifa_addr);
1524 1.13 gwr db_printf(" ifa_dsta=");
1525 1.13 gwr db_print_sa(ifa->ifa_dstaddr);
1526 1.13 gwr db_printf(" ifa_mask=");
1527 1.13 gwr db_print_sa(ifa->ifa_netmask);
1528 1.13 gwr db_printf(" flags=0x%x,refcnt=%d,metric=%d\n",
1529 1.13 gwr ifa->ifa_flags,
1530 1.13 gwr ifa->ifa_refcnt,
1531 1.13 gwr ifa->ifa_metric);
1532 1.102 perry }
1533 1.13 gwr
1534 1.121 christos static void
1535 1.13 gwr db_print_llinfo(void *li)
1536 1.13 gwr {
1537 1.13 gwr struct llinfo_arp *la;
1538 1.139 dyoung
1539 1.13 gwr if (li == NULL)
1540 1.13 gwr return;
1541 1.29 christos la = (struct llinfo_arp *)li;
1542 1.13 gwr db_printf(" la_rt=%p la_hold=%p, la_asked=0x%lx\n",
1543 1.13 gwr la->la_rt, la->la_hold, la->la_asked);
1544 1.102 perry }
1545 1.13 gwr
1546 1.122 dyoung /*
1547 1.13 gwr * Function to pass to rt_walktree().
1548 1.13 gwr * Return non-zero error to abort walk.
1549 1.13 gwr */
1550 1.123 dyoung static int
1551 1.13 gwr db_show_rtentry(struct rtentry *rt, void *w)
1552 1.29 christos {
1553 1.13 gwr db_printf("rtentry=%p", rt);
1554 1.145 christos
1555 1.13 gwr db_printf(" flags=0x%x refcnt=%d use=%ld expire=%lld\n",
1556 1.145 christos rt->rt_flags, rt->rt_refcnt,
1557 1.13 gwr rt->rt_use, (long long)rt->rt_expire);
1558 1.125 dyoung
1559 1.13 gwr db_printf(" key="); db_print_sa(rt_getkey(rt));
1560 1.13 gwr db_printf(" mask="); db_print_sa(rt_mask(rt));
1561 1.13 gwr db_printf(" gw="); db_print_sa(rt->rt_gateway);
1562 1.29 christos
1563 1.13 gwr db_printf(" ifp=%p ", rt->rt_ifp);
1564 1.30 thorpej if (rt->rt_ifp)
1565 1.13 gwr db_printf("(%s)", rt->rt_ifp->if_xname);
1566 1.13 gwr else
1567 1.13 gwr db_printf("(NULL)");
1568 1.29 christos
1569 1.13 gwr db_printf(" ifa=%p\n", rt->rt_ifa);
1570 1.13 gwr db_print_ifa(rt->rt_ifa);
1571 1.29 christos
1572 1.13 gwr db_printf(" gwroute=%p llinfo=%p\n",
1573 1.13 gwr rt->rt_gwroute, rt->rt_llinfo);
1574 1.13 gwr db_print_llinfo(rt->rt_llinfo);
1575 1.139 dyoung
1576 1.13 gwr return 0;
1577 1.102 perry }
1578 1.13 gwr
1579 1.13 gwr /*
1580 1.69 jhawk * Function to print all the route trees.
1581 1.13 gwr * Use this from ddb: "show arptab"
1582 1.69 jhawk */
1583 1.120 matt void
1584 1.116 christos db_show_arptab(db_expr_t addr, bool have_addr,
1585 1.13 gwr db_expr_t count, const char *modif)
1586 1.123 dyoung {
1587 1.13 gwr rt_walktree(AF_INET, db_show_rtentry, NULL);
1588 1.13 gwr }
1589 1.97 ragge #endif
1590 1.132 thorpej
1591 1.132 thorpej static int
1592 1.132 thorpej sysctl_net_inet_arp_stats(SYSCTLFN_ARGS)
1593 1.132 thorpej {
1594 1.139 dyoung
1595 1.132 thorpej return NETSTAT_SYSCTL(arpstat_percpu, ARP_NSTATS);
1596 1.132 thorpej }
1597 1.97 ragge
1598 1.97 ragge SYSCTL_SETUP(sysctl_net_inet_arp_setup, "sysctl net.inet.arp subtree setup")
1599 1.106 atatat {
1600 1.97 ragge const struct sysctlnode *node;
1601 1.97 ragge
1602 1.97 ragge sysctl_createv(clog, 0, NULL, NULL,
1603 1.97 ragge CTLFLAG_PERMANENT,
1604 1.97 ragge CTLTYPE_NODE, "net", NULL,
1605 1.97 ragge NULL, 0, NULL, 0,
1606 1.97 ragge CTL_NET, CTL_EOL);
1607 1.97 ragge sysctl_createv(clog, 0, NULL, NULL,
1608 1.97 ragge CTLFLAG_PERMANENT,
1609 1.97 ragge CTLTYPE_NODE, "inet", NULL,
1610 1.97 ragge NULL, 0, NULL, 0,
1611 1.97 ragge CTL_NET, PF_INET, CTL_EOL);
1612 1.97 ragge sysctl_createv(clog, 0, NULL, &node,
1613 1.98 atatat CTLFLAG_PERMANENT,
1614 1.98 atatat CTLTYPE_NODE, "arp",
1615 1.97 ragge SYSCTL_DESCR("Address Resolution Protocol"),
1616 1.97 ragge NULL, 0, NULL, 0,
1617 1.97 ragge CTL_NET, PF_INET, CTL_CREATE, CTL_EOL);
1618 1.97 ragge
1619 1.97 ragge sysctl_createv(clog, 0, NULL, NULL,
1620 1.98 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1621 1.98 atatat CTLTYPE_INT, "prune",
1622 1.97 ragge SYSCTL_DESCR("ARP cache pruning interval"),
1623 1.97 ragge NULL, 0, &arpt_prune, 0,
1624 1.97 ragge CTL_NET,PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
1625 1.97 ragge
1626 1.97 ragge sysctl_createv(clog, 0, NULL, NULL,
1627 1.98 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1628 1.98 atatat CTLTYPE_INT, "keep",
1629 1.97 ragge SYSCTL_DESCR("Valid ARP entry lifetime"),
1630 1.97 ragge NULL, 0, &arpt_keep, 0,
1631 1.97 ragge CTL_NET,PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
1632 1.97 ragge
1633 1.97 ragge sysctl_createv(clog, 0, NULL, NULL,
1634 1.98 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1635 1.98 atatat CTLTYPE_INT, "down",
1636 1.97 ragge SYSCTL_DESCR("Failed ARP entry lifetime"),
1637 1.97 ragge NULL, 0, &arpt_down, 0,
1638 1.97 ragge CTL_NET,PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
1639 1.97 ragge
1640 1.97 ragge sysctl_createv(clog, 0, NULL, NULL,
1641 1.98 atatat CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
1642 1.98 atatat CTLTYPE_INT, "refresh",
1643 1.97 ragge SYSCTL_DESCR("ARP entry refresh interval"),
1644 1.97 ragge NULL, 0, &arpt_refresh, 0,
1645 1.132 thorpej CTL_NET,PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
1646 1.132 thorpej
1647 1.132 thorpej sysctl_createv(clog, 0, NULL, NULL,
1648 1.132 thorpej CTLFLAG_PERMANENT,
1649 1.132 thorpej CTLTYPE_STRUCT, "stats",
1650 1.132 thorpej SYSCTL_DESCR("ARP statistics"),
1651 1.132 thorpej sysctl_net_inet_arp_stats, 0, NULL, 0,
1652 1.97 ragge CTL_NET,PF_INET, node->sysctl_num, CTL_CREATE, CTL_EOL);
1653 1.97 ragge }
1654 1.15 chopps
1655 #endif /* INET */
1656