if_arp.c revision 1.69 1 1.69 jhawk /* $NetBSD: if_arp.c,v 1.69 2000/05/20 03:08:42 jhawk Exp $ */
2 1.54 thorpej
3 1.54 thorpej /*-
4 1.54 thorpej * Copyright (c) 1998 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 * 3. All advertising materials mentioning features or use of this software
20 1.54 thorpej * must display the following acknowledgement:
21 1.54 thorpej * This product includes software developed by the NetBSD
22 1.54 thorpej * Foundation, Inc. and its contributors.
23 1.54 thorpej * 4. Neither the name of The NetBSD Foundation nor the names of its
24 1.54 thorpej * contributors may be used to endorse or promote products derived
25 1.54 thorpej * from this software without specific prior written permission.
26 1.54 thorpej *
27 1.54 thorpej * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
28 1.54 thorpej * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
29 1.54 thorpej * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
30 1.54 thorpej * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
31 1.54 thorpej * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
32 1.54 thorpej * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
33 1.54 thorpej * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
34 1.54 thorpej * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
35 1.54 thorpej * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
36 1.54 thorpej * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
37 1.54 thorpej * POSSIBILITY OF SUCH DAMAGE.
38 1.54 thorpej */
39 1.52 tls
40 1.52 tls /*
41 1.52 tls * Copyright (c) 1982, 1986, 1988, 1993
42 1.52 tls * The Regents of the University of California. All rights reserved.
43 1.52 tls *
44 1.52 tls * Redistribution and use in source and binary forms, with or without
45 1.52 tls * modification, are permitted provided that the following conditions
46 1.52 tls * are met:
47 1.52 tls * 1. Redistributions of source code must retain the above copyright
48 1.52 tls * notice, this list of conditions and the following disclaimer.
49 1.52 tls * 2. Redistributions in binary form must reproduce the above copyright
50 1.52 tls * notice, this list of conditions and the following disclaimer in the
51 1.52 tls * documentation and/or other materials provided with the distribution.
52 1.52 tls * 3. All advertising materials mentioning features or use of this software
53 1.52 tls * must display the following acknowledgement:
54 1.52 tls * This product includes software developed by the University of
55 1.52 tls * California, Berkeley and its contributors.
56 1.52 tls * 4. Neither the name of the University nor the names of its contributors
57 1.52 tls * may be used to endorse or promote products derived from this software
58 1.52 tls * without specific prior written permission.
59 1.52 tls *
60 1.52 tls * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
61 1.52 tls * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
62 1.52 tls * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
63 1.52 tls * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
64 1.52 tls * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
65 1.52 tls * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
66 1.52 tls * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
67 1.52 tls * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
68 1.52 tls * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
69 1.52 tls * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
70 1.52 tls * SUCH DAMAGE.
71 1.52 tls *
72 1.52 tls * @(#)if_ether.c 8.2 (Berkeley) 9/26/94
73 1.1 cgd */
74 1.1 cgd
75 1.1 cgd /*
76 1.1 cgd * Ethernet address resolution protocol.
77 1.1 cgd * TODO:
78 1.1 cgd * add "inuse/lock" bit (or ref. count) along with valid bit
79 1.1 cgd */
80 1.50 jonathan
81 1.50 jonathan #include "opt_ddb.h"
82 1.51 jonathan #include "opt_inet.h"
83 1.1 cgd
84 1.15 chopps #ifdef INET
85 1.15 chopps
86 1.5 mycroft #include <sys/param.h>
87 1.5 mycroft #include <sys/systm.h>
88 1.67 thorpej #include <sys/callout.h>
89 1.5 mycroft #include <sys/malloc.h>
90 1.5 mycroft #include <sys/mbuf.h>
91 1.5 mycroft #include <sys/socket.h>
92 1.5 mycroft #include <sys/time.h>
93 1.5 mycroft #include <sys/kernel.h>
94 1.5 mycroft #include <sys/errno.h>
95 1.5 mycroft #include <sys/ioctl.h>
96 1.5 mycroft #include <sys/syslog.h>
97 1.28 christos #include <sys/proc.h>
98 1.63 sommerfe #include <sys/protosw.h>
99 1.63 sommerfe #include <sys/domain.h>
100 1.1 cgd
101 1.35 is #include <net/ethertypes.h>
102 1.5 mycroft #include <net/if.h>
103 1.12 mycroft #include <net/if_dl.h>
104 1.56 bad #include <net/if_token.h>
105 1.56 bad #include <net/if_types.h>
106 1.12 mycroft #include <net/route.h>
107 1.5 mycroft
108 1.63 sommerfe
109 1.5 mycroft #include <netinet/in.h>
110 1.5 mycroft #include <netinet/in_systm.h>
111 1.5 mycroft #include <netinet/in_var.h>
112 1.5 mycroft #include <netinet/ip.h>
113 1.35 is #include <netinet/if_inarp.h>
114 1.1 cgd
115 1.39 lukem #include "loop.h"
116 1.66 is #include "arc.h"
117 1.66 is #if NARC > 0
118 1.66 is #include <net/if_arc.h>
119 1.66 is #endif
120 1.65 matt #include "fddi.h"
121 1.65 matt #if NFDDI > 0
122 1.65 matt #include <net/if_fddi.h>
123 1.65 matt #endif
124 1.56 bad #include "token.h"
125 1.66 is #include "token.h"
126 1.39 lukem
127 1.12 mycroft #define SIN(s) ((struct sockaddr_in *)s)
128 1.12 mycroft #define SDL(s) ((struct sockaddr_dl *)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.12 mycroft #define rt_expire rt_rmx.rmx_expire
142 1.12 mycroft
143 1.35 is static void arprequest __P((struct ifnet *,
144 1.35 is struct in_addr *, struct in_addr *, u_int8_t *));
145 1.12 mycroft static void arptfree __P((struct llinfo_arp *));
146 1.12 mycroft static void arptimer __P((void *));
147 1.35 is static struct llinfo_arp *arplookup __P((struct in_addr *, int, int));
148 1.12 mycroft static void in_arpinput __P((struct mbuf *));
149 1.12 mycroft
150 1.59 ad #if NLOOP > 0
151 1.39 lukem extern struct ifnet loif[NLOOP];
152 1.59 ad #endif
153 1.26 mycroft LIST_HEAD(, llinfo_arp) llinfo_arp;
154 1.12 mycroft struct ifqueue arpintrq = {0, 0, 0, 50};
155 1.12 mycroft int arp_inuse, arp_allocated, arp_intimer;
156 1.12 mycroft int arp_maxtries = 5;
157 1.12 mycroft int useloopback = 1; /* use loopback interface for local traffic */
158 1.12 mycroft int arpinit_done = 0;
159 1.9 glass
160 1.67 thorpej struct callout arptimer_ch;
161 1.67 thorpej
162 1.12 mycroft /* revarp state */
163 1.13 gwr static struct in_addr myip, srv_ip;
164 1.13 gwr static int myip_initialized = 0;
165 1.13 gwr static int revarp_in_progress = 0;
166 1.13 gwr static struct ifnet *myip_ifp = NULL;
167 1.1 cgd
168 1.28 christos #ifdef DDB
169 1.28 christos static void db_print_sa __P((struct sockaddr *));
170 1.28 christos static void db_print_ifa __P((struct ifaddr *));
171 1.28 christos static void db_print_llinfo __P((caddr_t));
172 1.28 christos static int db_show_radix_node __P((struct radix_node *, void *));
173 1.28 christos #endif
174 1.28 christos
175 1.1 cgd /*
176 1.35 is * this should be elsewhere.
177 1.35 is */
178 1.35 is
179 1.35 is static char *
180 1.35 is lla_snprintf __P((u_int8_t *, int));
181 1.35 is
182 1.35 is static char *
183 1.35 is lla_snprintf(adrp, len)
184 1.35 is u_int8_t *adrp;
185 1.35 is int len;
186 1.35 is {
187 1.35 is static char buf[16*3];
188 1.35 is static const char hexdigits[] = {
189 1.35 is '0','1','2','3','4','5','6','7',
190 1.35 is '8','9','a','b','c','d','e','f'
191 1.35 is };
192 1.35 is
193 1.35 is int i;
194 1.35 is char *p;
195 1.35 is
196 1.35 is p = buf;
197 1.35 is
198 1.35 is *p++ = hexdigits[(*adrp)>>4];
199 1.35 is *p++ = hexdigits[(*adrp++)&0xf];
200 1.35 is
201 1.35 is for (i=1; i<len && i<16; i++) {
202 1.35 is *p++ = ':';
203 1.35 is *p++ = hexdigits[(*adrp)>>4];
204 1.35 is *p++ = hexdigits[(*adrp++)&0xf];
205 1.35 is }
206 1.35 is
207 1.35 is *p = 0;
208 1.35 is return buf;
209 1.35 is }
210 1.35 is
211 1.63 sommerfe struct protosw arpsw[] = {
212 1.63 sommerfe { 0, 0, 0, 0,
213 1.63 sommerfe 0, 0, 0, 0,
214 1.63 sommerfe 0,
215 1.63 sommerfe 0, 0, 0, arp_drain,
216 1.63 sommerfe }
217 1.63 sommerfe };
218 1.63 sommerfe
219 1.63 sommerfe
220 1.63 sommerfe struct domain arpdomain =
221 1.63 sommerfe { PF_ARP, "arp", 0, 0, 0,
222 1.63 sommerfe arpsw, &arpsw[sizeof(arpsw)/sizeof(arpsw[0])]
223 1.63 sommerfe };
224 1.63 sommerfe
225 1.63 sommerfe /*
226 1.63 sommerfe * ARP table locking.
227 1.63 sommerfe *
228 1.63 sommerfe * to prevent lossage vs. the arp_drain routine (which may be called at
229 1.63 sommerfe * any time, including in a device driver context), we do two things:
230 1.63 sommerfe *
231 1.63 sommerfe * 1) manipulation of la->la_hold is done at splimp() (for all of
232 1.63 sommerfe * about two instructions).
233 1.63 sommerfe *
234 1.63 sommerfe * 2) manipulation of the arp table's linked list is done under the
235 1.63 sommerfe * protection of the ARP_LOCK; if arp_drain() or arptimer is called
236 1.63 sommerfe * while the arp table is locked, we punt and try again later.
237 1.63 sommerfe */
238 1.63 sommerfe
239 1.63 sommerfe int arp_locked;
240 1.63 sommerfe
241 1.63 sommerfe static __inline int arp_lock_try __P((int));
242 1.63 sommerfe static __inline void arp_unlock __P((void));
243 1.63 sommerfe
244 1.63 sommerfe static __inline int
245 1.63 sommerfe arp_lock_try(int recurse)
246 1.63 sommerfe {
247 1.63 sommerfe int s;
248 1.63 sommerfe
249 1.63 sommerfe s = splimp();
250 1.63 sommerfe if (!recurse && arp_locked) {
251 1.63 sommerfe splx(s);
252 1.63 sommerfe return (0);
253 1.63 sommerfe }
254 1.63 sommerfe arp_locked++;
255 1.63 sommerfe splx(s);
256 1.63 sommerfe return (1);
257 1.63 sommerfe }
258 1.63 sommerfe
259 1.63 sommerfe static __inline void
260 1.63 sommerfe arp_unlock()
261 1.63 sommerfe {
262 1.63 sommerfe int s;
263 1.63 sommerfe
264 1.63 sommerfe s = splimp();
265 1.63 sommerfe arp_locked--;
266 1.63 sommerfe splx(s);
267 1.63 sommerfe }
268 1.63 sommerfe
269 1.63 sommerfe #ifdef DIAGNOSTIC
270 1.63 sommerfe #define ARP_LOCK(recurse) \
271 1.63 sommerfe do { \
272 1.63 sommerfe if (arp_lock_try(recurse) == 0) { \
273 1.63 sommerfe printf("%s:%d: arp already locked\n", __FILE__, __LINE__); \
274 1.63 sommerfe panic("arp_lock"); \
275 1.63 sommerfe } \
276 1.63 sommerfe } while (0)
277 1.63 sommerfe #define ARP_LOCK_CHECK() \
278 1.63 sommerfe do { \
279 1.63 sommerfe if (arp_locked == 0) { \
280 1.63 sommerfe printf("%s:%d: arp lock not held\n", __FILE__, __LINE__); \
281 1.63 sommerfe panic("arp lock check"); \
282 1.63 sommerfe } \
283 1.63 sommerfe } while (0)
284 1.63 sommerfe #else
285 1.63 sommerfe #define ARP_LOCK(x) (void) arp_lock_try(x)
286 1.63 sommerfe #define ARP_LOCK_CHECK() /* nothing */
287 1.63 sommerfe #endif
288 1.63 sommerfe
289 1.63 sommerfe #define ARP_UNLOCK() arp_unlock()
290 1.63 sommerfe
291 1.63 sommerfe /*
292 1.63 sommerfe * ARP protocol drain routine. Called when memory is in short supply.
293 1.63 sommerfe * Called at splimp();
294 1.63 sommerfe */
295 1.63 sommerfe
296 1.63 sommerfe void
297 1.63 sommerfe arp_drain()
298 1.63 sommerfe {
299 1.68 augustss struct llinfo_arp *la, *nla;
300 1.63 sommerfe int count = 0;
301 1.63 sommerfe struct mbuf *mold;
302 1.63 sommerfe
303 1.63 sommerfe if (arp_lock_try(0) == 0) {
304 1.63 sommerfe printf("arp_drain: locked; punting\n");
305 1.63 sommerfe return;
306 1.63 sommerfe }
307 1.63 sommerfe
308 1.63 sommerfe for (la = llinfo_arp.lh_first; la != 0; la = nla) {
309 1.63 sommerfe nla = la->la_list.le_next;
310 1.63 sommerfe
311 1.63 sommerfe mold = la->la_hold;
312 1.63 sommerfe la->la_hold = 0;
313 1.63 sommerfe
314 1.63 sommerfe if (mold) {
315 1.63 sommerfe m_freem(mold);
316 1.63 sommerfe count++;
317 1.63 sommerfe }
318 1.63 sommerfe }
319 1.63 sommerfe ARP_UNLOCK();
320 1.63 sommerfe }
321 1.63 sommerfe
322 1.63 sommerfe
323 1.35 is /*
324 1.12 mycroft * Timeout routine. Age arp_tab entries periodically.
325 1.1 cgd */
326 1.3 andrew /* ARGSUSED */
327 1.12 mycroft static void
328 1.11 cgd arptimer(arg)
329 1.11 cgd void *arg;
330 1.1 cgd {
331 1.26 mycroft int s;
332 1.68 augustss struct llinfo_arp *la, *nla;
333 1.1 cgd
334 1.27 mycroft s = splsoftnet();
335 1.63 sommerfe
336 1.63 sommerfe if (arp_lock_try(0) == 0) {
337 1.63 sommerfe /* get it later.. */
338 1.63 sommerfe splx(s);
339 1.63 sommerfe return;
340 1.63 sommerfe }
341 1.63 sommerfe
342 1.67 thorpej callout_reset(&arptimer_ch, arpt_prune * hz, arptimer, NULL);
343 1.26 mycroft for (la = llinfo_arp.lh_first; la != 0; la = nla) {
344 1.68 augustss struct rtentry *rt = la->la_rt;
345 1.24 cgd
346 1.26 mycroft nla = la->la_list.le_next;
347 1.12 mycroft if (rt->rt_expire && rt->rt_expire <= time.tv_sec)
348 1.26 mycroft arptfree(la); /* timer has expired; clear */
349 1.12 mycroft }
350 1.63 sommerfe
351 1.63 sommerfe ARP_UNLOCK();
352 1.63 sommerfe
353 1.12 mycroft splx(s);
354 1.12 mycroft }
355 1.12 mycroft
356 1.12 mycroft /*
357 1.12 mycroft * Parallel to llc_rtrequest.
358 1.12 mycroft */
359 1.12 mycroft void
360 1.12 mycroft arp_rtrequest(req, rt, sa)
361 1.12 mycroft int req;
362 1.68 augustss struct rtentry *rt;
363 1.12 mycroft struct sockaddr *sa;
364 1.12 mycroft {
365 1.68 augustss struct sockaddr *gate = rt->rt_gateway;
366 1.68 augustss struct llinfo_arp *la = (struct llinfo_arp *)rt->rt_llinfo;
367 1.12 mycroft static struct sockaddr_dl null_sdl = {sizeof(null_sdl), AF_LINK};
368 1.56 bad size_t allocsize;
369 1.63 sommerfe struct mbuf *mold;
370 1.63 sommerfe int s;
371 1.12 mycroft
372 1.12 mycroft if (!arpinit_done) {
373 1.12 mycroft arpinit_done = 1;
374 1.13 gwr /*
375 1.13 gwr * We generate expiration times from time.tv_sec
376 1.13 gwr * so avoid accidently creating permanent routes.
377 1.13 gwr */
378 1.13 gwr if (time.tv_sec == 0) {
379 1.13 gwr time.tv_sec++;
380 1.13 gwr }
381 1.67 thorpej callout_init(&arptimer_ch);
382 1.67 thorpej callout_reset(&arptimer_ch, hz, arptimer, NULL);
383 1.12 mycroft }
384 1.12 mycroft if (rt->rt_flags & RTF_GATEWAY)
385 1.12 mycroft return;
386 1.63 sommerfe
387 1.63 sommerfe ARP_LOCK(1); /* we may already be locked here. */
388 1.63 sommerfe
389 1.12 mycroft switch (req) {
390 1.12 mycroft
391 1.12 mycroft case RTM_ADD:
392 1.12 mycroft /*
393 1.12 mycroft * XXX: If this is a manually added route to interface
394 1.12 mycroft * such as older version of routed or gated might provide,
395 1.12 mycroft * restore cloning bit.
396 1.12 mycroft */
397 1.12 mycroft if ((rt->rt_flags & RTF_HOST) == 0 &&
398 1.12 mycroft SIN(rt_mask(rt))->sin_addr.s_addr != 0xffffffff)
399 1.12 mycroft rt->rt_flags |= RTF_CLONING;
400 1.12 mycroft if (rt->rt_flags & RTF_CLONING) {
401 1.12 mycroft /*
402 1.12 mycroft * Case 1: This route should come from a route to iface.
403 1.12 mycroft */
404 1.12 mycroft rt_setgate(rt, rt_key(rt),
405 1.12 mycroft (struct sockaddr *)&null_sdl);
406 1.12 mycroft gate = rt->rt_gateway;
407 1.12 mycroft SDL(gate)->sdl_type = rt->rt_ifp->if_type;
408 1.12 mycroft SDL(gate)->sdl_index = rt->rt_ifp->if_index;
409 1.13 gwr /*
410 1.14 gwr * Give this route an expiration time, even though
411 1.14 gwr * it's a "permanent" route, so that routes cloned
412 1.14 gwr * from it do not need their expiration time set.
413 1.13 gwr */
414 1.14 gwr rt->rt_expire = time.tv_sec;
415 1.65 matt #if NFDDI > 0
416 1.65 matt if (rt->rt_ifp->if_type == IFT_FDDI
417 1.65 matt && (rt->rt_rmx.rmx_mtu > FDDIIPMTU
418 1.65 matt || (rt->rt_rmx.rmx_mtu == 0
419 1.65 matt && rt->rt_ifp->if_mtu > FDDIIPMTU))) {
420 1.65 matt rt->rt_rmx.rmx_mtu = FDDIIPMTU;
421 1.66 is }
422 1.66 is #endif
423 1.66 is #if NARC > 0
424 1.66 is if (rt->rt_ifp->if_type == IFT_ARCNET) {
425 1.66 is int arcipifmtu;
426 1.66 is
427 1.66 is if (rt->rt_ifp->if_flags & IFF_LINK0)
428 1.66 is arcipifmtu = arc_ipmtu;
429 1.66 is else
430 1.66 is arcipifmtu = ARCMTU;
431 1.66 is
432 1.66 is if (rt->rt_rmx.rmx_mtu > arcipifmtu ||
433 1.66 is (rt->rt_rmx.rmx_mtu == 0 &&
434 1.66 is rt->rt_ifp->if_mtu > arcipifmtu))
435 1.66 is
436 1.66 is rt->rt_rmx.rmx_mtu = arcipifmtu;
437 1.65 matt }
438 1.65 matt #endif
439 1.12 mycroft break;
440 1.12 mycroft }
441 1.12 mycroft /* Announce a new entry if requested. */
442 1.12 mycroft if (rt->rt_flags & RTF_ANNOUNCE)
443 1.35 is arprequest(rt->rt_ifp,
444 1.35 is &SIN(rt_key(rt))->sin_addr,
445 1.35 is &SIN(rt_key(rt))->sin_addr,
446 1.12 mycroft (u_char *)LLADDR(SDL(gate)));
447 1.12 mycroft /*FALLTHROUGH*/
448 1.12 mycroft case RTM_RESOLVE:
449 1.12 mycroft if (gate->sa_family != AF_LINK ||
450 1.12 mycroft gate->sa_len < sizeof(null_sdl)) {
451 1.37 jtk log(LOG_DEBUG, "arp_rtrequest: bad gateway value\n");
452 1.12 mycroft break;
453 1.12 mycroft }
454 1.12 mycroft SDL(gate)->sdl_type = rt->rt_ifp->if_type;
455 1.12 mycroft SDL(gate)->sdl_index = rt->rt_ifp->if_index;
456 1.12 mycroft if (la != 0)
457 1.12 mycroft break; /* This happens on a route change */
458 1.12 mycroft /*
459 1.12 mycroft * Case 2: This route may come from cloning, or a manual route
460 1.12 mycroft * add with a LL address.
461 1.12 mycroft */
462 1.56 bad switch (SDL(gate)->sdl_type) {
463 1.56 bad #if NTOKEN > 0
464 1.56 bad case IFT_ISO88025:
465 1.56 bad allocsize = sizeof(*la) + sizeof(struct token_rif);
466 1.56 bad break;
467 1.56 bad #endif /* NTOKEN > 0 */
468 1.56 bad default:
469 1.56 bad allocsize = sizeof(*la);
470 1.56 bad }
471 1.56 bad R_Malloc(la, struct llinfo_arp *, allocsize);
472 1.12 mycroft rt->rt_llinfo = (caddr_t)la;
473 1.12 mycroft if (la == 0) {
474 1.12 mycroft log(LOG_DEBUG, "arp_rtrequest: malloc failed\n");
475 1.12 mycroft break;
476 1.12 mycroft }
477 1.12 mycroft arp_inuse++, arp_allocated++;
478 1.56 bad Bzero(la, allocsize);
479 1.12 mycroft la->la_rt = rt;
480 1.12 mycroft rt->rt_flags |= RTF_LLINFO;
481 1.26 mycroft LIST_INSERT_HEAD(&llinfo_arp, la, la_list);
482 1.35 is if (in_hosteq(SIN(rt_key(rt))->sin_addr,
483 1.35 is (IA_SIN(rt->rt_ifa))->sin_addr)) {
484 1.24 cgd /*
485 1.24 cgd * This test used to be
486 1.24 cgd * if (loif.if_flags & IFF_UP)
487 1.24 cgd * It allowed local traffic to be forced through
488 1.24 cgd * the hardware by configuring the loopback down.
489 1.24 cgd * However, it causes problems during network
490 1.24 cgd * configuration for boards that can't receive
491 1.24 cgd * packets they send. It is now necessary to clear
492 1.24 cgd * "useloopback" and remove the route to force
493 1.24 cgd * traffic out to the hardware.
494 1.24 cgd */
495 1.12 mycroft rt->rt_expire = 0;
496 1.35 is Bcopy(LLADDR(rt->rt_ifp->if_sadl),
497 1.24 cgd LLADDR(SDL(gate)),
498 1.35 is SDL(gate)->sdl_alen =
499 1.35 is rt->rt_ifp->if_data.ifi_addrlen);
500 1.59 ad #if NLOOP > 0
501 1.12 mycroft if (useloopback)
502 1.39 lukem rt->rt_ifp = &loif[0];
503 1.59 ad #endif
504 1.12 mycroft }
505 1.12 mycroft break;
506 1.12 mycroft
507 1.12 mycroft case RTM_DELETE:
508 1.12 mycroft if (la == 0)
509 1.12 mycroft break;
510 1.12 mycroft arp_inuse--;
511 1.26 mycroft LIST_REMOVE(la, la_list);
512 1.12 mycroft rt->rt_llinfo = 0;
513 1.12 mycroft rt->rt_flags &= ~RTF_LLINFO;
514 1.63 sommerfe
515 1.63 sommerfe s = splimp();
516 1.63 sommerfe mold = la->la_hold;
517 1.63 sommerfe la->la_hold = 0;
518 1.63 sommerfe splx(s);
519 1.63 sommerfe
520 1.63 sommerfe if (mold)
521 1.63 sommerfe m_freem(mold);
522 1.63 sommerfe
523 1.12 mycroft Free((caddr_t)la);
524 1.1 cgd }
525 1.63 sommerfe ARP_UNLOCK();
526 1.1 cgd }
527 1.1 cgd
528 1.1 cgd /*
529 1.12 mycroft * Broadcast an ARP request. Caller specifies:
530 1.12 mycroft * - arp header source ip address
531 1.12 mycroft * - arp header target ip address
532 1.12 mycroft * - arp header source ethernet address
533 1.12 mycroft */
534 1.12 mycroft static void
535 1.35 is arprequest(ifp, sip, tip, enaddr)
536 1.68 augustss struct ifnet *ifp;
537 1.68 augustss struct in_addr *sip, *tip;
538 1.68 augustss u_int8_t *enaddr;
539 1.1 cgd {
540 1.68 augustss struct mbuf *m;
541 1.35 is struct arphdr *ah;
542 1.1 cgd struct sockaddr sa;
543 1.1 cgd
544 1.1 cgd if ((m = m_gethdr(M_DONTWAIT, MT_DATA)) == NULL)
545 1.1 cgd return;
546 1.35 is m->m_len = sizeof(*ah) + 2*sizeof(struct in_addr) +
547 1.35 is 2*ifp->if_data.ifi_addrlen;
548 1.35 is m->m_pkthdr.len = m->m_len;
549 1.35 is MH_ALIGN(m, m->m_len);
550 1.35 is ah = mtod(m, struct arphdr *);
551 1.35 is bzero((caddr_t)ah, m->m_len);
552 1.35 is ah->ar_pro = htons(ETHERTYPE_IP);
553 1.35 is ah->ar_hln = ifp->if_data.ifi_addrlen; /* hardware address length */
554 1.35 is ah->ar_pln = sizeof(struct in_addr); /* protocol address length */
555 1.35 is ah->ar_op = htons(ARPOP_REQUEST);
556 1.35 is bcopy((caddr_t)enaddr, (caddr_t)ar_sha(ah), ah->ar_hln);
557 1.35 is bcopy((caddr_t)sip, (caddr_t)ar_spa(ah), ah->ar_pln);
558 1.35 is bcopy((caddr_t)tip, (caddr_t)ar_tpa(ah), ah->ar_pln);
559 1.35 is sa.sa_family = AF_ARP;
560 1.35 is sa.sa_len = 2;
561 1.35 is m->m_flags |= M_BCAST;
562 1.35 is (*ifp->if_output)(ifp, m, &sa, (struct rtentry *)0);
563 1.1 cgd }
564 1.1 cgd
565 1.1 cgd /*
566 1.6 mycroft * Resolve an IP address into an ethernet address. If success,
567 1.1 cgd * desten is filled in. If there is no entry in arptab,
568 1.1 cgd * set one up and broadcast a request for the IP address.
569 1.1 cgd * Hold onto this mbuf and resend it once the address
570 1.1 cgd * is finally resolved. A return value of 1 indicates
571 1.1 cgd * that desten has been filled in and the packet should be sent
572 1.1 cgd * normally; a 0 return indicates that the packet has been
573 1.1 cgd * taken over here, either now or for later transmission.
574 1.1 cgd */
575 1.12 mycroft int
576 1.35 is arpresolve(ifp, rt, m, dst, desten)
577 1.68 augustss struct ifnet *ifp;
578 1.68 augustss struct rtentry *rt;
579 1.1 cgd struct mbuf *m;
580 1.68 augustss struct sockaddr *dst;
581 1.68 augustss u_char *desten;
582 1.1 cgd {
583 1.68 augustss struct llinfo_arp *la;
584 1.12 mycroft struct sockaddr_dl *sdl;
585 1.63 sommerfe struct mbuf *mold;
586 1.63 sommerfe int s;
587 1.63 sommerfe
588 1.12 mycroft if (rt)
589 1.12 mycroft la = (struct llinfo_arp *)rt->rt_llinfo;
590 1.12 mycroft else {
591 1.35 is if ((la = arplookup(&SIN(dst)->sin_addr, 1, 0)) != NULL)
592 1.12 mycroft rt = la->la_rt;
593 1.12 mycroft }
594 1.12 mycroft if (la == 0 || rt == 0) {
595 1.37 jtk log(LOG_DEBUG, "arpresolve: can't allocate llinfo\n");
596 1.12 mycroft m_freem(m);
597 1.12 mycroft return (0);
598 1.1 cgd }
599 1.12 mycroft sdl = SDL(rt->rt_gateway);
600 1.12 mycroft /*
601 1.12 mycroft * Check the address family and length is valid, the address
602 1.12 mycroft * is resolved; otherwise, try to resolve.
603 1.12 mycroft */
604 1.12 mycroft if ((rt->rt_expire == 0 || rt->rt_expire > time.tv_sec) &&
605 1.12 mycroft sdl->sdl_family == AF_LINK && sdl->sdl_alen != 0) {
606 1.35 is bcopy(LLADDR(sdl), desten,
607 1.35 is min(sdl->sdl_alen, ifp->if_data.ifi_addrlen));
608 1.12 mycroft return 1;
609 1.1 cgd }
610 1.1 cgd /*
611 1.1 cgd * There is an arptab entry, but no ethernet address
612 1.1 cgd * response yet. Replace the held mbuf with this
613 1.1 cgd * latest one.
614 1.1 cgd */
615 1.63 sommerfe
616 1.63 sommerfe s = splimp();
617 1.63 sommerfe mold = la->la_hold;
618 1.14 gwr la->la_hold = m;
619 1.63 sommerfe splx(s);
620 1.63 sommerfe
621 1.63 sommerfe if (mold)
622 1.63 sommerfe m_freem(mold);
623 1.63 sommerfe
624 1.63 sommerfe
625 1.13 gwr /*
626 1.13 gwr * Re-send the ARP request when appropriate.
627 1.13 gwr */
628 1.13 gwr #ifdef DIAGNOSTIC
629 1.13 gwr if (rt->rt_expire == 0) {
630 1.14 gwr /* This should never happen. (Should it? -gwr) */
631 1.34 christos printf("arpresolve: unresolved and rt_expire == 0\n");
632 1.13 gwr /* Set expiration time to now (expired). */
633 1.13 gwr rt->rt_expire = time.tv_sec;
634 1.13 gwr }
635 1.13 gwr #endif
636 1.14 gwr if (rt->rt_expire) {
637 1.14 gwr rt->rt_flags &= ~RTF_REJECT;
638 1.14 gwr if (la->la_asked == 0 || rt->rt_expire != time.tv_sec) {
639 1.14 gwr rt->rt_expire = time.tv_sec;
640 1.14 gwr if (la->la_asked++ < arp_maxtries)
641 1.35 is arprequest(ifp,
642 1.35 is &SIN(rt->rt_ifa->ifa_addr)->sin_addr,
643 1.35 is &SIN(dst)->sin_addr,
644 1.35 is LLADDR(ifp->if_sadl));
645 1.14 gwr else {
646 1.14 gwr rt->rt_flags |= RTF_REJECT;
647 1.14 gwr rt->rt_expire += arpt_down;
648 1.14 gwr la->la_asked = 0;
649 1.14 gwr }
650 1.14 gwr }
651 1.12 mycroft }
652 1.1 cgd return (0);
653 1.10 mycroft }
654 1.10 mycroft
655 1.1 cgd /*
656 1.12 mycroft * Common length and type checks are done here,
657 1.1 cgd * then the protocol-specific routine is called.
658 1.1 cgd */
659 1.12 mycroft void
660 1.12 mycroft arpintr()
661 1.1 cgd {
662 1.68 augustss struct mbuf *m;
663 1.68 augustss struct arphdr *ar;
664 1.12 mycroft int s;
665 1.1 cgd
666 1.12 mycroft while (arpintrq.ifq_head) {
667 1.12 mycroft s = splimp();
668 1.12 mycroft IF_DEQUEUE(&arpintrq, m);
669 1.12 mycroft splx(s);
670 1.12 mycroft if (m == 0 || (m->m_flags & M_PKTHDR) == 0)
671 1.12 mycroft panic("arpintr");
672 1.36 is
673 1.12 mycroft if (m->m_len >= sizeof(struct arphdr) &&
674 1.12 mycroft (ar = mtod(m, struct arphdr *)) &&
675 1.35 is /* XXX ntohs(ar->ar_hrd) == ARPHRD_ETHER && */
676 1.12 mycroft m->m_len >=
677 1.12 mycroft sizeof(struct arphdr) + 2 * (ar->ar_hln + ar->ar_pln))
678 1.12 mycroft switch (ntohs(ar->ar_pro)) {
679 1.12 mycroft
680 1.12 mycroft case ETHERTYPE_IP:
681 1.12 mycroft case ETHERTYPE_IPTRAILERS:
682 1.12 mycroft in_arpinput(m);
683 1.12 mycroft continue;
684 1.12 mycroft }
685 1.12 mycroft m_freem(m);
686 1.1 cgd }
687 1.1 cgd }
688 1.1 cgd
689 1.1 cgd /*
690 1.1 cgd * ARP for Internet protocols on 10 Mb/s Ethernet.
691 1.1 cgd * Algorithm is that given in RFC 826.
692 1.1 cgd * In addition, a sanity check is performed on the sender
693 1.1 cgd * protocol address, to catch impersonators.
694 1.12 mycroft * We no longer handle negotiations for use of trailer protocol:
695 1.12 mycroft * Formerly, ARP replied for protocol type ETHERTYPE_TRAIL sent
696 1.12 mycroft * along with IP replies if we wanted trailers sent to us,
697 1.12 mycroft * and also sent them in response to IP replies.
698 1.12 mycroft * This allowed either end to announce the desire to receive
699 1.1 cgd * trailer packets.
700 1.12 mycroft * We no longer reply to requests for ETHERTYPE_TRAIL protocol either,
701 1.12 mycroft * but formerly didn't normally send requests.
702 1.1 cgd */
703 1.12 mycroft static void
704 1.12 mycroft in_arpinput(m)
705 1.1 cgd struct mbuf *m;
706 1.1 cgd {
707 1.35 is struct arphdr *ah;
708 1.68 augustss struct ifnet *ifp = m->m_pkthdr.rcvif;
709 1.68 augustss struct llinfo_arp *la = 0;
710 1.68 augustss struct rtentry *rt;
711 1.44 tls struct in_ifaddr *ia;
712 1.12 mycroft struct sockaddr_dl *sdl;
713 1.1 cgd struct sockaddr sa;
714 1.1 cgd struct in_addr isaddr, itaddr, myaddr;
715 1.12 mycroft int op;
716 1.63 sommerfe struct mbuf *mold;
717 1.63 sommerfe int s;
718 1.63 sommerfe
719 1.1 cgd
720 1.35 is ah = mtod(m, struct arphdr *);
721 1.35 is op = ntohs(ah->ar_op);
722 1.35 is bcopy((caddr_t)ar_spa(ah), (caddr_t)&isaddr, sizeof (isaddr));
723 1.35 is bcopy((caddr_t)ar_tpa(ah), (caddr_t)&itaddr, sizeof (itaddr));
724 1.40 gwr
725 1.40 gwr /*
726 1.42 gwr * If the target IP address is zero, ignore the packet.
727 1.42 gwr * This prevents the code below from tring to answer
728 1.42 gwr * when we are using IP address zero (booting).
729 1.40 gwr */
730 1.42 gwr if (in_nullhost(itaddr))
731 1.42 gwr goto out;
732 1.42 gwr
733 1.42 gwr /*
734 1.42 gwr * If the source IP address is zero, this is most likely a
735 1.44 tls * confused host trying to use IP address zero. (Windoze?)
736 1.44 tls * XXX: Should we bother trying to reply to these?
737 1.42 gwr */
738 1.42 gwr if (in_nullhost(isaddr))
739 1.40 gwr goto out;
740 1.40 gwr
741 1.44 tls /*
742 1.44 tls * Search for a matching interface address
743 1.44 tls * or any address on the interface to use
744 1.44 tls * as a dummy address in the rest of this function
745 1.44 tls */
746 1.44 tls INADDR_TO_IA(itaddr, ia);
747 1.49 is while ((ia != NULL) && ia->ia_ifp != m->m_pkthdr.rcvif)
748 1.49 is NEXT_IA_WITH_SAME_ADDR(ia);
749 1.49 is
750 1.44 tls if (ia == NULL) {
751 1.44 tls INADDR_TO_IA(isaddr, ia);
752 1.49 is while ((ia != NULL) && ia->ia_ifp != m->m_pkthdr.rcvif)
753 1.49 is NEXT_IA_WITH_SAME_ADDR(ia);
754 1.49 is
755 1.49 is if (ia == NULL) {
756 1.48 is IFP_TO_IA(ifp, ia);
757 1.49 is if (ia == NULL)
758 1.49 is goto out;
759 1.49 is }
760 1.44 tls }
761 1.48 is
762 1.44 tls myaddr = ia->ia_addr.sin_addr;
763 1.36 is
764 1.35 is if (!bcmp((caddr_t)ar_sha(ah), LLADDR(ifp->if_sadl),
765 1.35 is ifp->if_data.ifi_addrlen))
766 1.1 cgd goto out; /* it's from me, ignore it. */
767 1.41 is
768 1.41 is if (!bcmp((caddr_t)ar_sha(ah), (caddr_t)ifp->if_broadcastaddr,
769 1.41 is ifp->if_data.ifi_addrlen)) {
770 1.41 is log(LOG_ERR,
771 1.46 matt "%s: arp: link address is broadcast for IP address %s!\n",
772 1.46 matt ifp->if_xname, in_fmtaddr(isaddr));
773 1.41 is goto out;
774 1.41 is }
775 1.41 is
776 1.35 is if (in_hosteq(isaddr, myaddr)) {
777 1.1 cgd log(LOG_ERR,
778 1.46 matt "duplicate IP address %s sent from link address %s\n",
779 1.46 matt in_fmtaddr(isaddr), lla_snprintf(ar_sha(ah), ah->ar_hln));
780 1.1 cgd itaddr = myaddr;
781 1.12 mycroft goto reply;
782 1.1 cgd }
783 1.35 is la = arplookup(&isaddr, in_hosteq(itaddr, myaddr), 0);
784 1.12 mycroft if (la && (rt = la->la_rt) && (sdl = SDL(rt->rt_gateway))) {
785 1.12 mycroft if (sdl->sdl_alen &&
786 1.57 is bcmp((caddr_t)ar_sha(ah), LLADDR(sdl), sdl->sdl_alen)) {
787 1.58 is if (rt->rt_flags & RTF_STATIC) {
788 1.58 is log(LOG_INFO,
789 1.58 is "%s tried to overwrite permanent arp info"
790 1.58 is " for %s\n",
791 1.58 is lla_snprintf(ar_sha(ah), ah->ar_hln),
792 1.58 is in_fmtaddr(isaddr));
793 1.58 is goto out;
794 1.58 is } else if (rt->rt_ifp != ifp) {
795 1.57 is log(LOG_INFO,
796 1.57 is "%s on %s tried to overwrite "
797 1.57 is "arp info for %s on %s\n",
798 1.57 is lla_snprintf(ar_sha(ah), ah->ar_hln),
799 1.57 is ifp->if_xname, in_fmtaddr(isaddr),
800 1.57 is rt->rt_ifp->if_xname);
801 1.57 is goto out;
802 1.57 is } else {
803 1.57 is log(LOG_INFO,
804 1.57 is "arp info overwritten for %s by %s\n",
805 1.57 is in_fmtaddr(isaddr),
806 1.57 is lla_snprintf(ar_sha(ah), ah->ar_hln));
807 1.57 is }
808 1.57 is }
809 1.35 is /*
810 1.35 is * sanity check for the address length.
811 1.35 is * XXX this does not work for protocols with variable address
812 1.35 is * length. -is
813 1.35 is */
814 1.35 is if (sdl->sdl_alen &&
815 1.35 is sdl->sdl_alen != ah->ar_hln) {
816 1.35 is log(LOG_WARNING,
817 1.46 matt "arp from %s: new addr len %d, was %d",
818 1.46 matt in_fmtaddr(isaddr), ah->ar_hln, sdl->sdl_alen);
819 1.35 is }
820 1.35 is if (ifp->if_data.ifi_addrlen != ah->ar_hln) {
821 1.35 is log(LOG_WARNING,
822 1.46 matt "arp from %s: addr len: new %d, i/f %d (ignored)",
823 1.46 matt in_fmtaddr(isaddr), ah->ar_hln,
824 1.35 is ifp->if_data.ifi_addrlen);
825 1.35 is goto reply;
826 1.35 is }
827 1.56 bad #if NTOKEN > 0
828 1.56 bad /*
829 1.60 bad * XXX uses m_data and assumes the complete answer including
830 1.56 bad * XXX token-ring headers is in the same buf
831 1.56 bad */
832 1.61 bad if (ifp->if_type == IFT_ISO88025) {
833 1.61 bad struct token_header *trh;
834 1.61 bad
835 1.61 bad trh = (struct token_header *)M_TRHSTART(m);
836 1.61 bad if (trh->token_shost[0] & TOKEN_RI_PRESENT) {
837 1.61 bad struct token_rif *rif;
838 1.61 bad size_t riflen;
839 1.61 bad
840 1.61 bad rif = TOKEN_RIF(trh);
841 1.61 bad riflen = (ntohs(rif->tr_rcf) &
842 1.61 bad TOKEN_RCF_LEN_MASK) >> 8;
843 1.61 bad
844 1.61 bad if (riflen > 2 &&
845 1.61 bad riflen < sizeof(struct token_rif) &&
846 1.61 bad (riflen & 1) == 0) {
847 1.61 bad rif->tr_rcf ^= htons(TOKEN_RCF_DIRECTION);
848 1.61 bad rif->tr_rcf &= htons(~TOKEN_RCF_BROADCAST_MASK);
849 1.61 bad bcopy(rif, TOKEN_RIF(la), riflen);
850 1.61 bad }
851 1.56 bad }
852 1.56 bad }
853 1.56 bad #endif /* NTOKEN > 0 */
854 1.35 is bcopy((caddr_t)ar_sha(ah), LLADDR(sdl),
855 1.35 is sdl->sdl_alen = ah->ar_hln);
856 1.12 mycroft if (rt->rt_expire)
857 1.12 mycroft rt->rt_expire = time.tv_sec + arpt_keep;
858 1.12 mycroft rt->rt_flags &= ~RTF_REJECT;
859 1.12 mycroft la->la_asked = 0;
860 1.63 sommerfe
861 1.63 sommerfe s = splimp();
862 1.63 sommerfe mold = la->la_hold;
863 1.63 sommerfe la->la_hold = 0;
864 1.63 sommerfe splx(s);
865 1.63 sommerfe
866 1.63 sommerfe if (mold)
867 1.63 sommerfe (*ifp->if_output)(ifp, mold, rt_key(rt), rt);
868 1.1 cgd }
869 1.1 cgd reply:
870 1.12 mycroft if (op != ARPOP_REQUEST) {
871 1.12 mycroft out:
872 1.12 mycroft m_freem(m);
873 1.12 mycroft return;
874 1.1 cgd }
875 1.35 is if (in_hosteq(itaddr, myaddr)) {
876 1.1 cgd /* I am the target */
877 1.35 is bcopy((caddr_t)ar_sha(ah), (caddr_t)ar_tha(ah), ah->ar_hln);
878 1.35 is bcopy(LLADDR(ifp->if_sadl), (caddr_t)ar_sha(ah), ah->ar_hln);
879 1.1 cgd } else {
880 1.35 is la = arplookup(&itaddr, 0, SIN_PROXY);
881 1.12 mycroft if (la == 0)
882 1.1 cgd goto out;
883 1.12 mycroft rt = la->la_rt;
884 1.35 is bcopy((caddr_t)ar_sha(ah), (caddr_t)ar_tha(ah), ah->ar_hln);
885 1.12 mycroft sdl = SDL(rt->rt_gateway);
886 1.35 is bcopy(LLADDR(sdl), (caddr_t)ar_sha(ah), ah->ar_hln);
887 1.1 cgd }
888 1.1 cgd
889 1.35 is bcopy((caddr_t)ar_spa(ah), (caddr_t)ar_tpa(ah), ah->ar_pln);
890 1.35 is bcopy((caddr_t)&itaddr, (caddr_t)ar_spa(ah), ah->ar_pln);
891 1.35 is ah->ar_op = htons(ARPOP_REPLY);
892 1.35 is ah->ar_pro = htons(ETHERTYPE_IP); /* let's be sure! */
893 1.36 is m->m_flags &= ~(M_BCAST|M_MCAST); /* never reply by broadcast */
894 1.62 thorpej m->m_len = sizeof(*ah) + (2 * ah->ar_pln) + (2 * ah->ar_hln);
895 1.62 thorpej m->m_pkthdr.len = m->m_len;
896 1.35 is sa.sa_family = AF_ARP;
897 1.35 is sa.sa_len = 2;
898 1.35 is (*ifp->if_output)(ifp, m, &sa, (struct rtentry *)0);
899 1.1 cgd return;
900 1.1 cgd }
901 1.1 cgd
902 1.1 cgd /*
903 1.12 mycroft * Free an arp entry.
904 1.1 cgd */
905 1.12 mycroft static void
906 1.12 mycroft arptfree(la)
907 1.68 augustss struct llinfo_arp *la;
908 1.12 mycroft {
909 1.68 augustss struct rtentry *rt = la->la_rt;
910 1.68 augustss struct sockaddr_dl *sdl;
911 1.12 mycroft
912 1.63 sommerfe ARP_LOCK_CHECK();
913 1.63 sommerfe
914 1.12 mycroft if (rt == 0)
915 1.12 mycroft panic("arptfree");
916 1.12 mycroft if (rt->rt_refcnt > 0 && (sdl = SDL(rt->rt_gateway)) &&
917 1.12 mycroft sdl->sdl_family == AF_LINK) {
918 1.12 mycroft sdl->sdl_alen = 0;
919 1.12 mycroft la->la_asked = 0;
920 1.12 mycroft rt->rt_flags &= ~RTF_REJECT;
921 1.12 mycroft return;
922 1.12 mycroft }
923 1.12 mycroft rtrequest(RTM_DELETE, rt_key(rt), (struct sockaddr *)0, rt_mask(rt),
924 1.12 mycroft 0, (struct rtentry **)0);
925 1.1 cgd }
926 1.1 cgd
927 1.1 cgd /*
928 1.12 mycroft * Lookup or enter a new address in arptab.
929 1.12 mycroft */
930 1.12 mycroft static struct llinfo_arp *
931 1.12 mycroft arplookup(addr, create, proxy)
932 1.35 is struct in_addr *addr;
933 1.12 mycroft int create, proxy;
934 1.12 mycroft {
935 1.68 augustss struct rtentry *rt;
936 1.12 mycroft static struct sockaddr_inarp sin;
937 1.53 drochner const char *why = 0;
938 1.1 cgd
939 1.12 mycroft sin.sin_len = sizeof(sin);
940 1.12 mycroft sin.sin_family = AF_INET;
941 1.35 is sin.sin_addr = *addr;
942 1.12 mycroft sin.sin_other = proxy ? SIN_PROXY : 0;
943 1.25 mycroft rt = rtalloc1(sintosa(&sin), create);
944 1.12 mycroft if (rt == 0)
945 1.12 mycroft return (0);
946 1.12 mycroft rt->rt_refcnt--;
947 1.53 drochner
948 1.53 drochner if (rt->rt_flags & RTF_GATEWAY)
949 1.53 drochner why = "host is not on local network";
950 1.53 drochner else if ((rt->rt_flags & RTF_LLINFO) == 0)
951 1.53 drochner why = "could not allocate llinfo";
952 1.53 drochner else if (rt->rt_gateway->sa_family != AF_LINK)
953 1.53 drochner why = "gateway route is not ours";
954 1.53 drochner else
955 1.53 drochner return ((struct llinfo_arp *)rt->rt_llinfo);
956 1.53 drochner
957 1.53 drochner if (create)
958 1.53 drochner log(LOG_DEBUG, "arplookup: unable to enter address"
959 1.53 drochner " for %s (%s)\n",
960 1.53 drochner in_fmtaddr(*addr), why);
961 1.53 drochner return (0);
962 1.1 cgd }
963 1.1 cgd
964 1.12 mycroft int
965 1.1 cgd arpioctl(cmd, data)
966 1.20 mycroft u_long cmd;
967 1.1 cgd caddr_t data;
968 1.1 cgd {
969 1.20 mycroft
970 1.12 mycroft return (EOPNOTSUPP);
971 1.20 mycroft }
972 1.20 mycroft
973 1.20 mycroft void
974 1.35 is arp_ifinit(ifp, ifa)
975 1.35 is struct ifnet *ifp;
976 1.20 mycroft struct ifaddr *ifa;
977 1.20 mycroft {
978 1.40 gwr struct in_addr *ip;
979 1.40 gwr
980 1.40 gwr /*
981 1.40 gwr * Warn the user if another station has this IP address,
982 1.40 gwr * but only if the interface IP address is not zero.
983 1.40 gwr */
984 1.40 gwr ip = &IA_SIN(ifa)->sin_addr;
985 1.40 gwr if (!in_nullhost(*ip))
986 1.40 gwr arprequest(ifp, ip, ip, LLADDR(ifp->if_sadl));
987 1.20 mycroft
988 1.20 mycroft ifa->ifa_rtrequest = arp_rtrequest;
989 1.20 mycroft ifa->ifa_flags |= RTF_CLONING;
990 1.9 glass }
991 1.9 glass
992 1.9 glass /*
993 1.9 glass * Called from 10 Mb/s Ethernet interrupt handlers
994 1.9 glass * when ether packet type ETHERTYPE_REVARP
995 1.9 glass * is received. Common length and type checks are done here,
996 1.9 glass * then the protocol-specific routine is called.
997 1.9 glass */
998 1.12 mycroft void
999 1.12 mycroft revarpinput(m)
1000 1.9 glass struct mbuf *m;
1001 1.9 glass {
1002 1.9 glass struct arphdr *ar;
1003 1.9 glass
1004 1.9 glass if (m->m_len < sizeof(struct arphdr))
1005 1.9 glass goto out;
1006 1.9 glass ar = mtod(m, struct arphdr *);
1007 1.35 is #if 0 /* XXX I don't think we need this... and it will prevent other LL */
1008 1.9 glass if (ntohs(ar->ar_hrd) != ARPHRD_ETHER)
1009 1.9 glass goto out;
1010 1.35 is #endif
1011 1.12 mycroft if (m->m_len < sizeof(struct arphdr) + 2 * (ar->ar_hln + ar->ar_pln))
1012 1.9 glass goto out;
1013 1.9 glass switch (ntohs(ar->ar_pro)) {
1014 1.9 glass
1015 1.9 glass case ETHERTYPE_IP:
1016 1.9 glass case ETHERTYPE_IPTRAILERS:
1017 1.12 mycroft in_revarpinput(m);
1018 1.9 glass return;
1019 1.9 glass
1020 1.9 glass default:
1021 1.9 glass break;
1022 1.9 glass }
1023 1.9 glass out:
1024 1.9 glass m_freem(m);
1025 1.9 glass }
1026 1.9 glass
1027 1.9 glass /*
1028 1.9 glass * RARP for Internet protocols on 10 Mb/s Ethernet.
1029 1.9 glass * Algorithm is that given in RFC 903.
1030 1.9 glass * We are only using for bootstrap purposes to get an ip address for one of
1031 1.9 glass * our interfaces. Thus we support no user-interface.
1032 1.9 glass *
1033 1.9 glass * Since the contents of the RARP reply are specific to the interface that
1034 1.9 glass * sent the request, this code must ensure that they are properly associated.
1035 1.9 glass *
1036 1.9 glass * Note: also supports ARP via RARP packets, per the RFC.
1037 1.9 glass */
1038 1.28 christos void
1039 1.12 mycroft in_revarpinput(m)
1040 1.9 glass struct mbuf *m;
1041 1.9 glass {
1042 1.12 mycroft struct ifnet *ifp;
1043 1.35 is struct arphdr *ah;
1044 1.28 christos int op;
1045 1.9 glass
1046 1.35 is ah = mtod(m, struct arphdr *);
1047 1.35 is op = ntohs(ah->ar_op);
1048 1.9 glass switch (op) {
1049 1.9 glass case ARPOP_REQUEST:
1050 1.9 glass case ARPOP_REPLY: /* per RFC */
1051 1.12 mycroft in_arpinput(m);
1052 1.9 glass return;
1053 1.12 mycroft case ARPOP_REVREPLY:
1054 1.9 glass break;
1055 1.12 mycroft case ARPOP_REVREQUEST: /* handled by rarpd(8) */
1056 1.9 glass default:
1057 1.9 glass goto out;
1058 1.9 glass }
1059 1.9 glass if (!revarp_in_progress)
1060 1.9 glass goto out;
1061 1.12 mycroft ifp = m->m_pkthdr.rcvif;
1062 1.12 mycroft if (ifp != myip_ifp) /* !same interface */
1063 1.9 glass goto out;
1064 1.13 gwr if (myip_initialized)
1065 1.13 gwr goto wake;
1066 1.35 is if (bcmp(ar_tha(ah), LLADDR(ifp->if_sadl), ifp->if_sadl->sdl_alen))
1067 1.9 glass goto out;
1068 1.35 is bcopy((caddr_t)ar_spa(ah), (caddr_t)&srv_ip, sizeof(srv_ip));
1069 1.35 is bcopy((caddr_t)ar_tpa(ah), (caddr_t)&myip, sizeof(myip));
1070 1.9 glass myip_initialized = 1;
1071 1.13 gwr wake: /* Do wakeup every time in case it was missed. */
1072 1.12 mycroft wakeup((caddr_t)&myip);
1073 1.12 mycroft
1074 1.12 mycroft out:
1075 1.9 glass m_freem(m);
1076 1.9 glass }
1077 1.9 glass
1078 1.9 glass /*
1079 1.9 glass * Send a RARP request for the ip address of the specified interface.
1080 1.9 glass * The request should be RFC 903-compliant.
1081 1.9 glass */
1082 1.12 mycroft void
1083 1.12 mycroft revarprequest(ifp)
1084 1.9 glass struct ifnet *ifp;
1085 1.9 glass {
1086 1.9 glass struct sockaddr sa;
1087 1.9 glass struct mbuf *m;
1088 1.35 is struct arphdr *ah;
1089 1.9 glass
1090 1.9 glass if ((m = m_gethdr(M_DONTWAIT, MT_DATA)) == NULL)
1091 1.9 glass return;
1092 1.35 is m->m_len = sizeof(*ah) + 2*sizeof(struct in_addr) +
1093 1.35 is 2*ifp->if_data.ifi_addrlen;
1094 1.35 is m->m_pkthdr.len = m->m_len;
1095 1.35 is MH_ALIGN(m, m->m_len);
1096 1.35 is ah = mtod(m, struct arphdr *);
1097 1.35 is bzero((caddr_t)ah, m->m_len);
1098 1.35 is ah->ar_pro = htons(ETHERTYPE_IP);
1099 1.35 is ah->ar_hln = ifp->if_data.ifi_addrlen; /* hardware address length */
1100 1.35 is ah->ar_pln = sizeof(struct in_addr); /* protocol address length */
1101 1.35 is ah->ar_op = htons(ARPOP_REVREQUEST);
1102 1.35 is
1103 1.35 is bcopy(LLADDR(ifp->if_sadl), (caddr_t)ar_sha(ah), ah->ar_hln);
1104 1.35 is bcopy(LLADDR(ifp->if_sadl), (caddr_t)ar_tha(ah), ah->ar_hln);
1105 1.35 is
1106 1.35 is sa.sa_family = AF_ARP;
1107 1.35 is sa.sa_len = 2;
1108 1.35 is m->m_flags |= M_BCAST;
1109 1.35 is (*ifp->if_output)(ifp, m, &sa, (struct rtentry *)0);
1110 1.35 is
1111 1.9 glass }
1112 1.9 glass
1113 1.9 glass /*
1114 1.13 gwr * RARP for the ip address of the specified interface, but also
1115 1.13 gwr * save the ip address of the server that sent the answer.
1116 1.13 gwr * Timeout if no response is received.
1117 1.9 glass */
1118 1.12 mycroft int
1119 1.13 gwr revarpwhoarewe(ifp, serv_in, clnt_in)
1120 1.9 glass struct ifnet *ifp;
1121 1.13 gwr struct in_addr *serv_in;
1122 1.13 gwr struct in_addr *clnt_in;
1123 1.9 glass {
1124 1.9 glass int result, count = 20;
1125 1.9 glass
1126 1.55 drochner myip_initialized = 0;
1127 1.55 drochner myip_ifp = ifp;
1128 1.55 drochner
1129 1.55 drochner revarp_in_progress = 1;
1130 1.55 drochner while (count--) {
1131 1.55 drochner revarprequest(ifp);
1132 1.55 drochner result = tsleep((caddr_t)&myip, PSOCK, "revarp", hz/2);
1133 1.55 drochner if (result != EWOULDBLOCK)
1134 1.55 drochner break;
1135 1.9 glass }
1136 1.55 drochner revarp_in_progress = 0;
1137 1.55 drochner
1138 1.9 glass if (!myip_initialized)
1139 1.9 glass return ENETUNREACH;
1140 1.9 glass
1141 1.13 gwr bcopy((caddr_t)&srv_ip, serv_in, sizeof(*serv_in));
1142 1.13 gwr bcopy((caddr_t)&myip, clnt_in, sizeof(*clnt_in));
1143 1.9 glass return 0;
1144 1.1 cgd }
1145 1.13 gwr
1146 1.13 gwr
1147 1.13 gwr
1149 1.28 christos #ifdef DDB
1150 1.28 christos
1151 1.28 christos #include <machine/db_machdep.h>
1152 1.28 christos #include <ddb/db_interface.h>
1153 1.13 gwr #include <ddb/db_output.h>
1154 1.13 gwr static void
1155 1.13 gwr db_print_sa(sa)
1156 1.13 gwr struct sockaddr *sa;
1157 1.13 gwr {
1158 1.13 gwr int len;
1159 1.13 gwr u_char *p;
1160 1.13 gwr
1161 1.13 gwr if (sa == 0) {
1162 1.13 gwr db_printf("[NULL]");
1163 1.13 gwr return;
1164 1.13 gwr }
1165 1.13 gwr
1166 1.13 gwr p = (u_char*)sa;
1167 1.13 gwr len = sa->sa_len;
1168 1.13 gwr db_printf("[");
1169 1.13 gwr while (len > 0) {
1170 1.13 gwr db_printf("%d", *p);
1171 1.13 gwr p++; len--;
1172 1.13 gwr if (len) db_printf(",");
1173 1.13 gwr }
1174 1.13 gwr db_printf("]\n");
1175 1.13 gwr }
1176 1.13 gwr static void
1177 1.13 gwr db_print_ifa(ifa)
1178 1.13 gwr struct ifaddr *ifa;
1179 1.13 gwr {
1180 1.13 gwr if (ifa == 0)
1181 1.13 gwr return;
1182 1.13 gwr db_printf(" ifa_addr=");
1183 1.13 gwr db_print_sa(ifa->ifa_addr);
1184 1.13 gwr db_printf(" ifa_dsta=");
1185 1.13 gwr db_print_sa(ifa->ifa_dstaddr);
1186 1.13 gwr db_printf(" ifa_mask=");
1187 1.13 gwr db_print_sa(ifa->ifa_netmask);
1188 1.13 gwr db_printf(" flags=0x%x,refcnt=%d,metric=%d\n",
1189 1.13 gwr ifa->ifa_flags,
1190 1.13 gwr ifa->ifa_refcnt,
1191 1.13 gwr ifa->ifa_metric);
1192 1.13 gwr }
1193 1.13 gwr static void
1194 1.13 gwr db_print_llinfo(li)
1195 1.13 gwr caddr_t li;
1196 1.13 gwr {
1197 1.13 gwr struct llinfo_arp *la;
1198 1.13 gwr
1199 1.13 gwr if (li == 0)
1200 1.13 gwr return;
1201 1.29 christos la = (struct llinfo_arp *)li;
1202 1.13 gwr db_printf(" la_rt=%p la_hold=%p, la_asked=0x%lx\n",
1203 1.13 gwr la->la_rt, la->la_hold, la->la_asked);
1204 1.13 gwr }
1205 1.13 gwr /*
1206 1.13 gwr * Function to pass to rn_walktree().
1207 1.13 gwr * Return non-zero error to abort walk.
1208 1.13 gwr */
1209 1.13 gwr static int
1210 1.13 gwr db_show_radix_node(rn, w)
1211 1.13 gwr struct radix_node *rn;
1212 1.13 gwr void *w;
1213 1.13 gwr {
1214 1.13 gwr struct rtentry *rt = (struct rtentry *)rn;
1215 1.29 christos
1216 1.13 gwr db_printf("rtentry=%p", rt);
1217 1.29 christos
1218 1.13 gwr db_printf(" flags=0x%x refcnt=%d use=%ld expire=%ld\n",
1219 1.13 gwr rt->rt_flags, rt->rt_refcnt,
1220 1.13 gwr rt->rt_use, rt->rt_expire);
1221 1.13 gwr
1222 1.13 gwr db_printf(" key="); db_print_sa(rt_key(rt));
1223 1.13 gwr db_printf(" mask="); db_print_sa(rt_mask(rt));
1224 1.13 gwr db_printf(" gw="); db_print_sa(rt->rt_gateway);
1225 1.29 christos
1226 1.13 gwr db_printf(" ifp=%p ", rt->rt_ifp);
1227 1.30 thorpej if (rt->rt_ifp)
1228 1.13 gwr db_printf("(%s)", rt->rt_ifp->if_xname);
1229 1.13 gwr else
1230 1.13 gwr db_printf("(NULL)");
1231 1.29 christos
1232 1.13 gwr db_printf(" ifa=%p\n", rt->rt_ifa);
1233 1.13 gwr db_print_ifa(rt->rt_ifa);
1234 1.13 gwr
1235 1.13 gwr db_printf(" genmask="); db_print_sa(rt->rt_genmask);
1236 1.29 christos
1237 1.13 gwr db_printf(" gwroute=%p llinfo=%p\n",
1238 1.13 gwr rt->rt_gwroute, rt->rt_llinfo);
1239 1.13 gwr db_print_llinfo(rt->rt_llinfo);
1240 1.13 gwr
1241 1.13 gwr return (0);
1242 1.13 gwr }
1243 1.13 gwr /*
1244 1.69 jhawk * Function to print all the route trees.
1245 1.13 gwr * Use this from ddb: "show arptab"
1246 1.69 jhawk */
1247 1.69 jhawk void
1248 1.69 jhawk db_show_arptab(addr, have_addr, count, modif)
1249 1.69 jhawk db_expr_t addr;
1250 1.69 jhawk int have_addr;
1251 1.69 jhawk db_expr_t count;
1252 1.13 gwr char * modif;
1253 1.13 gwr {
1254 1.13 gwr struct radix_node_head *rnh;
1255 1.13 gwr rnh = rt_tables[AF_INET];
1256 1.13 gwr db_printf("Route tree for AF_INET\n");
1257 1.13 gwr if (rnh == NULL) {
1258 1.69 jhawk db_printf(" (not initialized)\n");
1259 1.13 gwr return;
1260 1.13 gwr }
1261 1.69 jhawk rn_walktree(rnh, db_show_radix_node, NULL);
1262 1.13 gwr return;
1263 1.13 gwr }
1264 1.15 chopps #endif
1265 1.63 sommerfe #endif /* INET */
1266
1267