aarp.c revision 1.33 1 /* $NetBSD: aarp.c,v 1.33 2009/04/18 14:58:05 tsutsui Exp $ */
2
3 /*
4 * Copyright (c) 1990,1991 Regents of The University of Michigan.
5 * All Rights Reserved.
6 *
7 * Permission to use, copy, modify, and distribute this software and
8 * its documentation for any purpose and without fee is hereby granted,
9 * provided that the above copyright notice appears in all copies and
10 * that both that copyright notice and this permission notice appear
11 * in supporting documentation, and that the name of The University
12 * of Michigan not be used in advertising or publicity pertaining to
13 * distribution of the software without specific, written prior
14 * permission. This software is supplied as is without expressed or
15 * implied warranties of any kind.
16 *
17 * This product includes software developed by the University of
18 * California, Berkeley and its contributors.
19 *
20 * Research Systems Unix Group
21 * The University of Michigan
22 * c/o Wesley Craig
23 * 535 W. William Street
24 * Ann Arbor, Michigan
25 * +1-313-764-2278
26 * netatalk (at) umich.edu
27 */
28
29 #include <sys/cdefs.h>
30 __KERNEL_RCSID(0, "$NetBSD: aarp.c,v 1.33 2009/04/18 14:58:05 tsutsui Exp $");
31
32 #include "opt_mbuftrace.h"
33
34 #include <sys/param.h>
35 #include <sys/socket.h>
36 #include <sys/syslog.h>
37 #include <sys/systm.h>
38 #include <sys/callout.h>
39 #include <sys/proc.h>
40 #include <sys/mbuf.h>
41 #include <sys/time.h>
42 #include <sys/kernel.h>
43 #include <sys/socketvar.h>
44 #include <net/if.h>
45 #include <net/route.h>
46 #include <net/if_ether.h>
47 #include <net/if_dl.h>
48 #include <netinet/in.h>
49 #undef s_net
50
51 #include <netatalk/at.h>
52 #include <netatalk/at_var.h>
53 #include <netatalk/aarp.h>
54 #include <netatalk/ddp_var.h>
55 #include <netatalk/phase2.h>
56 #include <netatalk/at_extern.h>
57
58 static struct aarptab *aarptnew(const struct at_addr *);
59 static void aarptfree(struct aarptab *);
60 static void at_aarpinput(struct ifnet *, struct mbuf *);
61 static void aarptimer(void *);
62 static void aarpwhohas(struct ifnet *, const struct sockaddr_at *);
63
64 #define AARPTAB_BSIZ 9
65 #define AARPTAB_NB 19
66 #define AARPTAB_SIZE (AARPTAB_BSIZ * AARPTAB_NB)
67 struct aarptab aarptab[AARPTAB_SIZE];
68
69 #define AARPTAB_HASH(a) \
70 ((((a).s_net << 8 ) + (a).s_node ) % AARPTAB_NB )
71
72 #define AARPTAB_LOOK(aat,addr) { \
73 int n; \
74 aat = &aarptab[ AARPTAB_HASH(addr) * AARPTAB_BSIZ ]; \
75 for ( n = 0; n < AARPTAB_BSIZ; n++, aat++ ) \
76 if ( aat->aat_ataddr.s_net == (addr).s_net && \
77 aat->aat_ataddr.s_node == (addr).s_node ) \
78 break; \
79 if ( n >= AARPTAB_BSIZ ) \
80 aat = 0; \
81 }
82
83 #define AARPT_AGE (60 * 1)
84 #define AARPT_KILLC 20
85 #define AARPT_KILLI 3
86
87 const u_char atmulticastaddr[6] = {
88 0x09, 0x00, 0x07, 0xff, 0xff, 0xff
89 };
90
91 const u_char at_org_code[3] = {
92 0x08, 0x00, 0x07
93 };
94 const u_char aarp_org_code[3] = {
95 0x00, 0x00, 0x00
96 };
97
98 struct callout aarptimer_callout;
99 #ifdef MBUFTRACE
100 struct mowner aarp_mowner = MOWNER_INIT("atalk", "arp");
101 #endif
102
103 /*ARGSUSED*/
104 static void
105 aarptimer(void *ignored)
106 {
107 struct aarptab *aat;
108 int i, s;
109
110 mutex_enter(softnet_lock);
111 callout_reset(&aarptimer_callout, AARPT_AGE * hz, aarptimer, NULL);
112 aat = aarptab;
113 for (i = 0; i < AARPTAB_SIZE; i++, aat++) {
114 int killtime = (aat->aat_flags & ATF_COM) ? AARPT_KILLC :
115 AARPT_KILLI;
116 if (aat->aat_flags == 0 || (aat->aat_flags & ATF_PERM))
117 continue;
118 if (++aat->aat_timer < killtime)
119 continue;
120 s = splnet();
121 aarptfree(aat);
122 splx(s);
123 }
124 mutex_exit(softnet_lock);
125 }
126
127 /*
128 * search through the network addresses to find one that includes the given
129 * network.. remember to take netranges into consideration.
130 */
131 struct ifaddr *
132 at_ifawithnet(const struct sockaddr_at *sat, struct ifnet *ifp)
133 {
134 struct ifaddr *ifa;
135 struct sockaddr_at *sat2;
136 struct netrange *nr;
137
138 IFADDR_FOREACH(ifa, ifp) {
139 if (ifa->ifa_addr->sa_family != AF_APPLETALK)
140 continue;
141
142 sat2 = satosat(ifa->ifa_addr);
143 if (sat2->sat_addr.s_net == sat->sat_addr.s_net)
144 break;
145
146 nr = (struct netrange *) (sat2->sat_zero);
147 if ((nr->nr_phase == 2)
148 && (ntohs(nr->nr_firstnet) <= ntohs(sat->sat_addr.s_net))
149 && (ntohs(nr->nr_lastnet) >= ntohs(sat->sat_addr.s_net)))
150 break;
151 }
152 return ifa;
153 }
154
155 static void
156 aarpwhohas(struct ifnet *ifp, const struct sockaddr_at *sat)
157 {
158 struct mbuf *m;
159 struct ether_header *eh;
160 struct ether_aarp *ea;
161 struct at_ifaddr *aa;
162 struct llc *llc;
163 struct sockaddr sa;
164
165 if ((m = m_gethdr(M_DONTWAIT, MT_DATA)) == NULL)
166 return;
167
168 MCLAIM(m, &aarp_mowner);
169 m->m_len = sizeof(*ea);
170 m->m_pkthdr.len = sizeof(*ea);
171 MH_ALIGN(m, sizeof(*ea));
172
173 ea = mtod(m, struct ether_aarp *);
174 memset(ea, 0, sizeof(*ea));
175
176 ea->aarp_hrd = htons(AARPHRD_ETHER);
177 ea->aarp_pro = htons(ETHERTYPE_ATALK);
178 ea->aarp_hln = sizeof(ea->aarp_sha);
179 ea->aarp_pln = sizeof(ea->aarp_spu);
180 ea->aarp_op = htons(AARPOP_REQUEST);
181 memcpy(ea->aarp_sha, CLLADDR(ifp->if_sadl), sizeof(ea->aarp_sha));
182
183 /*
184 * We need to check whether the output ethernet type should
185 * be phase 1 or 2. We have the interface that we'll be sending
186 * the aarp out. We need to find an AppleTalk network on that
187 * interface with the same address as we're looking for. If the
188 * net is phase 2, generate an 802.2 and SNAP header.
189 */
190 if ((aa = (struct at_ifaddr *) at_ifawithnet(sat, ifp)) == NULL) {
191 m_freem(m);
192 return;
193 }
194 eh = (struct ether_header *) sa.sa_data;
195
196 if (aa->aa_flags & AFA_PHASE2) {
197 memcpy(eh->ether_dhost, atmulticastaddr,
198 sizeof(eh->ether_dhost));
199 eh->ether_type = 0; /* if_output will treat as 802 */
200 M_PREPEND(m, sizeof(struct llc), M_DONTWAIT);
201 if (!m)
202 return;
203
204 llc = mtod(m, struct llc *);
205 llc->llc_dsap = llc->llc_ssap = LLC_SNAP_LSAP;
206 llc->llc_control = LLC_UI;
207 memcpy(llc->llc_org_code, aarp_org_code, sizeof(aarp_org_code));
208 llc->llc_ether_type = htons(ETHERTYPE_AARP);
209
210 memcpy(ea->aarp_spnet, &AA_SAT(aa)->sat_addr.s_net,
211 sizeof(ea->aarp_spnet));
212 memcpy(ea->aarp_tpnet, &sat->sat_addr.s_net,
213 sizeof(ea->aarp_tpnet));
214 ea->aarp_spnode = AA_SAT(aa)->sat_addr.s_node;
215 ea->aarp_tpnode = sat->sat_addr.s_node;
216 } else {
217 memcpy(eh->ether_dhost, etherbroadcastaddr,
218 sizeof(eh->ether_dhost));
219 eh->ether_type = htons(ETHERTYPE_AARP);
220
221 ea->aarp_spa = AA_SAT(aa)->sat_addr.s_node;
222 ea->aarp_tpa = sat->sat_addr.s_node;
223 }
224
225 #ifdef NETATALKDEBUG
226 printf("aarp: sending request via %u.%u seaking %u.%u\n",
227 ntohs(AA_SAT(aa)->sat_addr.s_net), AA_SAT(aa)->sat_addr.s_node,
228 ntohs(sat->sat_addr.s_net), sat->sat_addr.s_node);
229 #endif /* NETATALKDEBUG */
230
231 sa.sa_len = sizeof(struct sockaddr);
232 sa.sa_family = AF_UNSPEC;
233 (*ifp->if_output) (ifp, m, &sa, NULL); /* XXX NULL should be routing */
234 /* information */
235 }
236
237 int
238 aarpresolve(struct ifnet *ifp, struct mbuf *m,
239 const struct sockaddr_at *destsat, u_char *desten)
240 {
241 struct at_ifaddr *aa;
242 struct aarptab *aat;
243 int s;
244
245 if (at_broadcast(destsat)) {
246 aa = (struct at_ifaddr *) at_ifawithnet(destsat, ifp);
247 if (aa == NULL) {
248 m_freem(m);
249 return (0);
250 }
251 if (aa->aa_flags & AFA_PHASE2)
252 memcpy(desten, atmulticastaddr,
253 sizeof(atmulticastaddr));
254 else
255 memcpy(desten, etherbroadcastaddr,
256 sizeof(etherbroadcastaddr));
257 return 1;
258 }
259 s = splnet();
260 AARPTAB_LOOK(aat, destsat->sat_addr);
261 if (aat == 0) { /* No entry */
262 aat = aarptnew(&destsat->sat_addr);
263 if (aat == 0)
264 panic("aarpresolve: no free entry");
265
266 aat->aat_hold = m;
267 aarpwhohas(ifp, destsat);
268 splx(s);
269 return 0;
270 }
271
272 /* found an entry */
273 aat->aat_timer = 0;
274 if (aat->aat_flags & ATF_COM) { /* entry is COMplete */
275 memcpy(desten, aat->aat_enaddr, sizeof(aat->aat_enaddr));
276 splx(s);
277 return 1;
278 }
279
280 /* entry has not completed */
281 if (aat->aat_hold)
282 m_freem(aat->aat_hold);
283 aat->aat_hold = m;
284 aarpwhohas(ifp, destsat);
285 splx(s);
286
287 return 0;
288 }
289
290 void
291 aarpinput(struct ifnet *ifp, struct mbuf *m)
292 {
293 struct arphdr *ar;
294
295 if (ifp->if_flags & IFF_NOARP)
296 goto out;
297
298 if (m->m_len < sizeof(struct arphdr))
299 goto out;
300
301 ar = mtod(m, struct arphdr *);
302 if (ntohs(ar->ar_hrd) != AARPHRD_ETHER)
303 goto out;
304
305 if (m->m_len < sizeof(struct arphdr) + 2 * ar->ar_hln + 2 * ar->ar_pln)
306 goto out;
307
308 switch (ntohs(ar->ar_pro)) {
309 case ETHERTYPE_ATALK:
310 at_aarpinput(ifp, m);
311 return;
312
313 default:
314 break;
315 }
316
317 out:
318 m_freem(m);
319 }
320
321 static void
322 at_aarpinput(struct ifnet *ifp, struct mbuf *m)
323 {
324 struct ether_aarp *ea;
325 struct at_ifaddr *aa;
326 struct ifaddr *ia;
327 struct aarptab *aat;
328 struct ether_header *eh;
329 struct llc *llc;
330 struct sockaddr_at sat;
331 struct sockaddr sa;
332 struct at_addr spa, tpa, ma;
333 int op;
334 u_int16_t net;
335
336 ea = mtod(m, struct ether_aarp *);
337
338 /* Check to see if from my hardware address */
339 if (!memcmp(ea->aarp_sha, CLLADDR(ifp->if_sadl), sizeof(ea->aarp_sha))) {
340 m_freem(m);
341 return;
342 }
343 op = ntohs(ea->aarp_op);
344 memcpy(&net, ea->aarp_tpnet, sizeof(net));
345
346 if (net != 0) { /* should be ATADDR_ANYNET? */
347 sat.sat_len = sizeof(struct sockaddr_at);
348 sat.sat_family = AF_APPLETALK;
349 sat.sat_addr.s_net = net;
350 aa = (struct at_ifaddr *) at_ifawithnet(&sat, ifp);
351 if (aa == NULL) {
352 m_freem(m);
353 return;
354 }
355 memcpy(&spa.s_net, ea->aarp_spnet, sizeof(spa.s_net));
356 memcpy(&tpa.s_net, ea->aarp_tpnet, sizeof(tpa.s_net));
357 } else {
358 /*
359 * Since we don't know the net, we just look for the first
360 * phase 1 address on the interface.
361 */
362 IFADDR_FOREACH(ia, ifp) {
363 aa = (struct at_ifaddr *)ia;
364 if (AA_SAT(aa)->sat_family == AF_APPLETALK &&
365 (aa->aa_flags & AFA_PHASE2) == 0)
366 break;
367 }
368 if (ia == NULL) {
369 m_freem(m);
370 return;
371 }
372 tpa.s_net = spa.s_net = AA_SAT(aa)->sat_addr.s_net;
373 }
374
375 spa.s_node = ea->aarp_spnode;
376 tpa.s_node = ea->aarp_tpnode;
377 ma.s_net = AA_SAT(aa)->sat_addr.s_net;
378 ma.s_node = AA_SAT(aa)->sat_addr.s_node;
379
380 /*
381 * This looks like it's from us.
382 */
383 if (spa.s_net == ma.s_net && spa.s_node == ma.s_node) {
384 if (aa->aa_flags & AFA_PROBING) {
385 /*
386 * We're probing, someone either responded to our
387 * probe, or probed for the same address we'd like
388 * to use. Change the address we're probing for.
389 */
390 callout_stop(&aa->aa_probe_ch);
391 wakeup(aa);
392 m_freem(m);
393 return;
394 } else if (op != AARPOP_PROBE) {
395 /*
396 * This is not a probe, and we're not probing.
397 * This means that someone's saying they have the same
398 * source address as the one we're using. Get upset...
399 */
400 log(LOG_ERR, "aarp: duplicate AT address!! %s\n",
401 ether_sprintf(ea->aarp_sha));
402 m_freem(m);
403 return;
404 }
405 }
406 AARPTAB_LOOK(aat, spa);
407 if (aat) {
408 if (op == AARPOP_PROBE) {
409 /*
410 * Someone's probing for spa, deallocate the one we've
411 * got, so that if the prober keeps the address, we'll
412 * be able to arp for him.
413 */
414 aarptfree(aat);
415 m_freem(m);
416 return;
417 }
418 memcpy(aat->aat_enaddr, ea->aarp_sha, sizeof(ea->aarp_sha));
419 aat->aat_flags |= ATF_COM;
420 if (aat->aat_hold) {
421 sat.sat_len = sizeof(struct sockaddr_at);
422 sat.sat_family = AF_APPLETALK;
423 sat.sat_addr = spa;
424 (*ifp->if_output)(ifp, aat->aat_hold,
425 (struct sockaddr *) & sat, NULL); /* XXX */
426 aat->aat_hold = 0;
427 }
428 }
429 if (aat == 0 && tpa.s_net == ma.s_net && tpa.s_node == ma.s_node
430 && op != AARPOP_PROBE) {
431 if ((aat = aarptnew(&spa)) != NULL) {
432 memcpy(aat->aat_enaddr, ea->aarp_sha,
433 sizeof(ea->aarp_sha));
434 aat->aat_flags |= ATF_COM;
435 }
436 }
437 /*
438 * Don't respond to responses, and never respond if we're
439 * still probing.
440 */
441 if (tpa.s_net != ma.s_net || tpa.s_node != ma.s_node ||
442 op == AARPOP_RESPONSE || (aa->aa_flags & AFA_PROBING)) {
443 m_freem(m);
444 return;
445 }
446 memcpy(ea->aarp_tha, ea->aarp_sha, sizeof(ea->aarp_sha));
447 memcpy(ea->aarp_sha, CLLADDR(ifp->if_sadl), sizeof(ea->aarp_sha));
448
449 /* XXX */
450 eh = (struct ether_header *) sa.sa_data;
451 memcpy(eh->ether_dhost, ea->aarp_tha, sizeof(eh->ether_dhost));
452
453 if (aa->aa_flags & AFA_PHASE2) {
454 M_PREPEND(m, sizeof(struct llc), M_DONTWAIT);
455 if (m == NULL)
456 return;
457
458 llc = mtod(m, struct llc *);
459 llc->llc_dsap = llc->llc_ssap = LLC_SNAP_LSAP;
460 llc->llc_control = LLC_UI;
461 memcpy(llc->llc_org_code, aarp_org_code, sizeof(aarp_org_code));
462 llc->llc_ether_type = htons(ETHERTYPE_AARP);
463
464 memcpy(ea->aarp_tpnet, ea->aarp_spnet, sizeof(ea->aarp_tpnet));
465 memcpy(ea->aarp_spnet, &ma.s_net, sizeof(ea->aarp_spnet));
466 eh->ether_type = 0; /* if_output will treat as 802 */
467 } else {
468 eh->ether_type = htons(ETHERTYPE_AARP);
469 }
470
471 ea->aarp_tpnode = ea->aarp_spnode;
472 ea->aarp_spnode = ma.s_node;
473 ea->aarp_op = htons(AARPOP_RESPONSE);
474
475 sa.sa_len = sizeof(struct sockaddr);
476 sa.sa_family = AF_UNSPEC;
477 (*ifp->if_output) (ifp, m, &sa, NULL); /* XXX */
478 return;
479 }
480
481 static void
482 aarptfree(struct aarptab *aat)
483 {
484
485 if (aat->aat_hold)
486 m_freem(aat->aat_hold);
487 aat->aat_hold = 0;
488 aat->aat_timer = aat->aat_flags = 0;
489 aat->aat_ataddr.s_net = 0;
490 aat->aat_ataddr.s_node = 0;
491 }
492
493 static struct aarptab *
494 aarptnew(const struct at_addr *addr)
495 {
496 int n;
497 int oldest = -1;
498 struct aarptab *aat, *aato = NULL;
499 static int first = 1;
500
501 if (first) {
502 first = 0;
503 callout_init(&aarptimer_callout, 0);
504 callout_reset(&aarptimer_callout, hz, aarptimer, NULL);
505 MOWNER_ATTACH(&aarp_mowner);
506 }
507 aat = &aarptab[AARPTAB_HASH(*addr) * AARPTAB_BSIZ];
508 for (n = 0; n < AARPTAB_BSIZ; n++, aat++) {
509 if (aat->aat_flags == 0)
510 goto out;
511 if (aat->aat_flags & ATF_PERM)
512 continue;
513 if ((int) aat->aat_timer > oldest) {
514 oldest = aat->aat_timer;
515 aato = aat;
516 }
517 }
518 if (aato == NULL)
519 return (NULL);
520 aat = aato;
521 aarptfree(aat);
522 out:
523 aat->aat_ataddr = *addr;
524 aat->aat_flags = ATF_INUSE;
525 return (aat);
526 }
527
528
529 void
530 aarpprobe(void *arp)
531 {
532 struct mbuf *m;
533 struct ether_header *eh;
534 struct ether_aarp *ea;
535 struct ifaddr *ia;
536 struct at_ifaddr *aa;
537 struct llc *llc;
538 struct sockaddr sa;
539 struct ifnet *ifp = arp;
540
541 mutex_enter(softnet_lock);
542
543 /*
544 * We need to check whether the output ethernet type should
545 * be phase 1 or 2. We have the interface that we'll be sending
546 * the aarp out. We need to find an AppleTalk network on that
547 * interface with the same address as we're looking for. If the
548 * net is phase 2, generate an 802.2 and SNAP header.
549 */
550 IFADDR_FOREACH(ia, ifp) {
551 aa = (struct at_ifaddr *)ia;
552 if (AA_SAT(aa)->sat_family == AF_APPLETALK &&
553 (aa->aa_flags & AFA_PROBING))
554 break;
555 }
556 if (ia == NULL) { /* serious error XXX */
557 printf("aarpprobe why did this happen?!\n");
558 mutex_exit(softnet_lock);
559 return;
560 }
561 if (aa->aa_probcnt <= 0) {
562 aa->aa_flags &= ~AFA_PROBING;
563 wakeup(aa);
564 mutex_exit(softnet_lock);
565 return;
566 } else {
567 callout_reset(&aa->aa_probe_ch, hz / 5, aarpprobe, arp);
568 }
569
570 if ((m = m_gethdr(M_DONTWAIT, MT_DATA)) == NULL) {
571 mutex_exit(softnet_lock);
572 return;
573 }
574
575 MCLAIM(m, &aarp_mowner);
576 m->m_len = sizeof(*ea);
577 m->m_pkthdr.len = sizeof(*ea);
578 MH_ALIGN(m, sizeof(*ea));
579
580 ea = mtod(m, struct ether_aarp *);
581 memset(ea, 0, sizeof(*ea));
582
583 ea->aarp_hrd = htons(AARPHRD_ETHER);
584 ea->aarp_pro = htons(ETHERTYPE_ATALK);
585 ea->aarp_hln = sizeof(ea->aarp_sha);
586 ea->aarp_pln = sizeof(ea->aarp_spu);
587 ea->aarp_op = htons(AARPOP_PROBE);
588 memcpy(ea->aarp_sha, CLLADDR(ifp->if_sadl), sizeof(ea->aarp_sha));
589
590 eh = (struct ether_header *) sa.sa_data;
591
592 if (aa->aa_flags & AFA_PHASE2) {
593 memcpy(eh->ether_dhost, atmulticastaddr,
594 sizeof(eh->ether_dhost));
595 eh->ether_type = 0; /* if_output will treat as 802 */
596 M_PREPEND(m, sizeof(struct llc), M_DONTWAIT);
597 if (!m) {
598 mutex_exit(softnet_lock);
599 return;
600 }
601
602 llc = mtod(m, struct llc *);
603 llc->llc_dsap = llc->llc_ssap = LLC_SNAP_LSAP;
604 llc->llc_control = LLC_UI;
605 memcpy(llc->llc_org_code, aarp_org_code, sizeof(aarp_org_code));
606 llc->llc_ether_type = htons(ETHERTYPE_AARP);
607
608 memcpy(ea->aarp_spnet, &AA_SAT(aa)->sat_addr.s_net,
609 sizeof(ea->aarp_spnet));
610 memcpy(ea->aarp_tpnet, &AA_SAT(aa)->sat_addr.s_net,
611 sizeof(ea->aarp_tpnet));
612 ea->aarp_spnode = ea->aarp_tpnode =
613 AA_SAT(aa)->sat_addr.s_node;
614 } else {
615 memcpy(eh->ether_dhost, etherbroadcastaddr,
616 sizeof(eh->ether_dhost));
617 eh->ether_type = htons(ETHERTYPE_AARP);
618 ea->aarp_spa = ea->aarp_tpa = AA_SAT(aa)->sat_addr.s_node;
619 }
620
621 #ifdef NETATALKDEBUG
622 printf("aarp: sending probe for %u.%u\n",
623 ntohs(AA_SAT(aa)->sat_addr.s_net),
624 AA_SAT(aa)->sat_addr.s_node);
625 #endif /* NETATALKDEBUG */
626
627 sa.sa_len = sizeof(struct sockaddr);
628 sa.sa_family = AF_UNSPEC;
629 (*ifp->if_output) (ifp, m, &sa, NULL); /* XXX */
630 aa->aa_probcnt--;
631 mutex_exit(softnet_lock);
632 }
633
634 void
635 aarp_clean(void)
636 {
637 struct aarptab *aat;
638 int i;
639
640 callout_stop(&aarptimer_callout);
641 for (i = 0, aat = aarptab; i < AARPTAB_SIZE; i++, aat++)
642 if (aat->aat_hold)
643 m_freem(aat->aat_hold);
644 }
645