This source file includes following definitions.
- aarp_expire
- aarp_send_query
- aarp_send_reply
- aarp_send_probe
- aarp_expire_timer
- aarp_kick
- aarp_expire_device
- aarp_expire_timeout
- aarp_device_event
- aarp_alloc
- aarp_find_entry
- aarp_send_ddp
- aarp_resolved
- aarp_rcv
- aarp_proto_init
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26 #include <asm/segment.h>
27 #include <asm/system.h>
28 #include <asm/bitops.h>
29 #include <linux/config.h>
30 #include <linux/types.h>
31 #include <linux/kernel.h>
32 #include <linux/sched.h>
33 #include <linux/string.h>
34 #include <linux/mm.h>
35 #include <linux/socket.h>
36 #include <linux/sockios.h>
37 #include <linux/in.h>
38 #include <linux/errno.h>
39 #include <linux/interrupt.h>
40 #include <linux/if_ether.h>
41 #include <linux/if_arp.h>
42 #include <linux/inet.h>
43 #include <linux/notifier.h>
44 #include <linux/netdevice.h>
45 #include <linux/etherdevice.h>
46 #include <linux/skbuff.h>
47 #include <net/sock.h>
48 #include <net/datalink.h>
49 #include <net/psnap.h>
50 #include <linux/atalk.h>
51
52 #ifdef CONFIG_ATALK
53
54
55
56
57 struct aarp_entry
58 {
59
60 unsigned long last_sent;
61 struct sk_buff_head packet_queue;
62 unsigned long expires_at;
63 struct at_addr target_addr;
64 struct device *dev;
65 char hwaddr[6];
66 unsigned short xmit_count;
67 struct aarp_entry *next;
68 };
69
70
71
72
73
74
75 static struct aarp_entry *resolved[AARP_HASH_SIZE], *unresolved[AARP_HASH_SIZE];
76 static int unresolved_count=0;
77
78
79
80
81
82 static struct timer_list aarp_timer;
83
84
85
86
87
88 static void aarp_expire(struct aarp_entry *a)
89 {
90 struct sk_buff *skb;
91
92 while((skb=skb_dequeue(&a->packet_queue))!=NULL)
93 kfree_skb(skb, FREE_WRITE);
94 kfree_s(a,sizeof(*a));
95 }
96
97
98
99
100
101 static void aarp_send_query(struct aarp_entry *a)
102 {
103 static char aarp_eth_multicast[ETH_ALEN]={ 0x09, 0x00, 0x07, 0xFF, 0xFF, 0xFF };
104 struct device *dev=a->dev;
105 int len=dev->hard_header_len+sizeof(struct elapaarp)+aarp_dl->header_length;
106 struct sk_buff *skb=alloc_skb(len, GFP_ATOMIC);
107 struct elapaarp *eah;
108 struct at_addr *sat=atalk_find_dev_addr(dev);
109
110 if(skb==NULL || sat==NULL)
111 return;
112
113
114
115
116
117 skb_reserve(skb,dev->hard_header_len+aarp_dl->header_length);
118 eah = (struct elapaarp *)skb_put(skb,sizeof(struct elapaarp));
119 skb->arp = 1;
120 skb->free = 1;
121 skb->dev = a->dev;
122
123
124
125
126
127 eah->hw_type = htons(AARP_HW_TYPE_ETHERNET);
128 eah->pa_type = htons(ETH_P_ATALK);
129 eah->hw_len = ETH_ALEN;
130 eah->pa_len = AARP_PA_ALEN;
131 eah->function = htons(AARP_REQUEST);
132
133 memcpy(eah->hw_src, dev->dev_addr, ETH_ALEN);
134
135 eah->pa_src_zero= 0;
136 eah->pa_src_net = sat->s_net;
137 eah->pa_src_node= sat->s_node;
138
139 memset(eah->hw_dst, '\0', ETH_ALEN);
140
141 eah->pa_dst_zero= 0;
142 eah->pa_dst_net = a->target_addr.s_net;
143 eah->pa_dst_node= a->target_addr.s_node;
144
145
146
147
148
149 aarp_dl->datalink_header(aarp_dl, skb, aarp_eth_multicast);
150
151
152
153
154
155 dev_queue_xmit(skb, dev, SOPRI_NORMAL);
156
157
158
159
160
161 a->xmit_count++;
162 }
163
164 static void aarp_send_reply(struct device *dev, struct at_addr *us, struct at_addr *them, unsigned char *sha)
165 {
166 int len=dev->hard_header_len+sizeof(struct elapaarp)+aarp_dl->header_length;
167 struct sk_buff *skb=alloc_skb(len, GFP_ATOMIC);
168 struct elapaarp *eah;
169
170 if(skb==NULL)
171 return;
172
173
174
175
176
177 skb_reserve(skb,dev->hard_header_len+aarp_dl->header_length);
178 eah = (struct elapaarp *)skb_put(skb,sizeof(struct elapaarp));
179 skb->arp = 1;
180 skb->free = 1;
181 skb->dev = dev;
182
183
184
185
186
187 eah->hw_type = htons(AARP_HW_TYPE_ETHERNET);
188 eah->pa_type = htons(ETH_P_ATALK);
189 eah->hw_len = ETH_ALEN;
190 eah->pa_len = AARP_PA_ALEN;
191 eah->function = htons(AARP_REPLY);
192
193 memcpy(eah->hw_src, dev->dev_addr, ETH_ALEN);
194
195 eah->pa_src_zero= 0;
196 eah->pa_src_net = us->s_net;
197 eah->pa_src_node= us->s_node;
198
199 if(sha==NULL)
200 memset(eah->hw_dst, '\0', ETH_ALEN);
201 else
202 memcpy(eah->hw_dst, sha, ETH_ALEN);
203
204 eah->pa_dst_zero= 0;
205 eah->pa_dst_net = them->s_net;
206 eah->pa_dst_node= them->s_node;
207
208
209
210
211
212 aarp_dl->datalink_header(aarp_dl, skb, sha);
213
214
215
216
217
218 dev_queue_xmit(skb, dev, SOPRI_NORMAL);
219
220 }
221
222
223
224
225
226 void aarp_send_probe(struct device *dev, struct at_addr *us)
227 {
228 int len=dev->hard_header_len+sizeof(struct elapaarp)+aarp_dl->header_length;
229 struct sk_buff *skb=alloc_skb(len, GFP_ATOMIC);
230 struct elapaarp *eah;
231 static char aarp_eth_multicast[ETH_ALEN]={ 0x09, 0x00, 0x07, 0xFF, 0xFF, 0xFF };
232
233 if(skb==NULL)
234 return;
235
236
237
238
239
240 skb_reserve(skb,dev->hard_header_len+aarp_dl->header_length);
241 eah = (struct elapaarp *)skb_put(skb,sizeof(struct elapaarp));
242
243 skb->arp = 1;
244 skb->free = 1;
245 skb->dev = dev;
246
247
248
249
250
251 eah->hw_type = htons(AARP_HW_TYPE_ETHERNET);
252 eah->pa_type = htons(ETH_P_ATALK);
253 eah->hw_len = ETH_ALEN;
254 eah->pa_len = AARP_PA_ALEN;
255 eah->function = htons(AARP_PROBE);
256
257 memcpy(eah->hw_src, dev->dev_addr, ETH_ALEN);
258
259 eah->pa_src_zero= 0;
260 eah->pa_src_net = us->s_net;
261 eah->pa_src_node= us->s_node;
262
263 memset(eah->hw_dst, '\0', ETH_ALEN);
264
265 eah->pa_dst_zero= 0;
266 eah->pa_dst_net = us->s_net;
267 eah->pa_dst_node= us->s_node;
268
269
270
271
272
273 aarp_dl->datalink_header(aarp_dl, skb, aarp_eth_multicast);
274
275
276
277
278
279 dev_queue_xmit(skb, dev, SOPRI_NORMAL);
280
281 }
282
283
284
285
286
287 static void aarp_expire_timer(struct aarp_entry **n)
288 {
289 struct aarp_entry *t;
290 while((*n)!=NULL)
291 {
292
293 if((*n)->expires_at < jiffies)
294 {
295 t= *n;
296 *n=(*n)->next;
297 aarp_expire(t);
298 }
299 else
300 n=&((*n)->next);
301 }
302 }
303
304
305
306
307
308 static void aarp_kick(struct aarp_entry **n)
309 {
310 struct aarp_entry *t;
311 while((*n)!=NULL)
312 {
313
314
315 if((*n)->xmit_count>=AARP_RETRANSMIT_LIMIT)
316 {
317 t= *n;
318 *n=(*n)->next;
319 aarp_expire(t);
320 }
321 else
322 {
323 aarp_send_query(*n);
324 n=&((*n)->next);
325 }
326 }
327 }
328
329
330
331
332
333
334 static void aarp_expire_device(struct aarp_entry **n, struct device *dev)
335 {
336 struct aarp_entry *t;
337 while((*n)!=NULL)
338 {
339 if((*n)->dev==dev)
340 {
341 t= *n;
342 *n=(*n)->next;
343 aarp_expire(t);
344 }
345 else
346 n=&((*n)->next);
347 }
348 }
349
350
351
352
353
354 static void aarp_expire_timeout(unsigned long unused)
355 {
356 int ct=0;
357 for(ct=0;ct<AARP_HASH_SIZE;ct++)
358 {
359 aarp_expire_timer(&resolved[ct]);
360 aarp_kick(&unresolved[ct]);
361 aarp_expire_timer(&unresolved[ct]);
362 }
363 del_timer(&aarp_timer);
364 if(unresolved_count==0)
365 aarp_timer.expires=jiffies+AARP_EXPIRY_TIME;
366 else
367 aarp_timer.expires=jiffies+AARP_TICK_TIME;
368 add_timer(&aarp_timer);
369 }
370
371
372
373
374
375 static int aarp_device_event(struct notifier_block *this, unsigned long event, void *ptr)
376 {
377 int ct=0;
378 if(event==NETDEV_DOWN)
379 {
380 for(ct=0;ct<AARP_HASH_SIZE;ct++)
381 {
382 aarp_expire_device(&resolved[ct],ptr);
383 aarp_expire_device(&unresolved[ct],ptr);
384 }
385 }
386 return NOTIFY_DONE;
387 }
388
389
390
391
392
393 static struct aarp_entry *aarp_alloc(void)
394 {
395 struct aarp_entry *a=kmalloc(sizeof(struct aarp_entry), GFP_ATOMIC);
396 if(a==NULL)
397 return NULL;
398 skb_queue_head_init(&a->packet_queue);
399 return a;
400 }
401
402
403
404
405
406
407 static struct aarp_entry *aarp_find_entry(struct aarp_entry *list, struct device *dev, struct at_addr *sat)
408 {
409 unsigned long flags;
410 save_flags(flags);
411 cli();
412 while(list)
413 {
414 if(list->target_addr.s_net==sat->s_net &&
415 list->target_addr.s_node==sat->s_node && list->dev==dev)
416 break;
417 list=list->next;
418 }
419 restore_flags(flags);
420 return list;
421 }
422
423
424
425
426
427 int aarp_send_ddp(struct device *dev,struct sk_buff *skb, struct at_addr *sa, void *hwaddr)
428 {
429 static char ddp_eth_multicast[ETH_ALEN]={ 0x09, 0x00, 0x07, 0xFF, 0xFF, 0xFF };
430 int hash;
431 struct aarp_entry *a;
432 unsigned long flags;
433
434
435
436
437
438 if(dev->type!=ARPHRD_ETHER)
439 {
440 return -1;
441 }
442
443 skb->dev = dev;
444 skb->protocol = htons(ETH_P_ATALK);
445
446 hash=sa->s_node%(AARP_HASH_SIZE-1);
447 save_flags(flags);
448 cli();
449
450
451
452
453
454 if(sa->s_node==ATADDR_BCAST)
455 {
456 ddp_dl->datalink_header(ddp_dl, skb, ddp_eth_multicast);
457 if(skb->sk==NULL)
458 dev_queue_xmit(skb, skb->dev, SOPRI_NORMAL);
459 else
460 dev_queue_xmit(skb, skb->dev, skb->sk->priority);
461 restore_flags(flags);
462 return 1;
463 }
464 a=aarp_find_entry(resolved[hash],dev,sa);
465 if(a!=NULL)
466 {
467
468
469
470
471 a->expires_at=jiffies+AARP_EXPIRY_TIME*10;
472 ddp_dl->datalink_header(ddp_dl, skb, a->hwaddr);
473 if(skb->sk==NULL)
474 dev_queue_xmit(skb, skb->dev, SOPRI_NORMAL);
475 else
476 dev_queue_xmit(skb, skb->dev, skb->sk->priority);
477 restore_flags(flags);
478 return 1;
479 }
480
481
482
483
484
485 a=aarp_find_entry(unresolved[hash],dev,sa);
486 if(a!=NULL)
487 {
488
489
490
491
492 skb_queue_tail(&a->packet_queue, skb);
493 restore_flags(flags);
494 return 0;
495 }
496
497
498
499
500
501 a=aarp_alloc();
502 if(a==NULL)
503 {
504
505
506
507
508 restore_flags(flags);
509 return -1;
510 }
511
512
513
514
515
516 skb_queue_tail(&a->packet_queue, skb);
517 a->expires_at=jiffies+AARP_RESOLVE_TIME;
518 a->dev=dev;
519 a->next=unresolved[hash];
520 a->target_addr= *sa;
521 a->xmit_count=0;
522 unresolved[hash]=a;
523 unresolved_count++;
524 restore_flags(flags);
525
526
527
528
529
530 aarp_send_query(a);
531
532
533
534
535
536
537 if(unresolved_count==1)
538 {
539 del_timer(&aarp_timer);
540 aarp_timer.expires=jiffies+AARP_TICK_TIME;
541 add_timer(&aarp_timer);
542 }
543
544
545
546
547
548 return 0;
549 }
550
551
552
553
554
555
556 static void aarp_resolved(struct aarp_entry **list, struct aarp_entry *a, int hash)
557 {
558 struct sk_buff *skb;
559 while(*list!=NULL)
560 {
561 if(*list==a)
562 {
563 unresolved_count--;
564 *list=a->next;
565
566
567
568
569
570 a->next=resolved[hash];
571 resolved[hash]=a;
572
573
574
575
576
577 while((skb=skb_dequeue(&a->packet_queue))!=NULL)
578 {
579 a->expires_at=jiffies+AARP_EXPIRY_TIME*10;
580 ddp_dl->datalink_header(ddp_dl,skb,a->hwaddr);
581 if(skb->sk==NULL)
582 dev_queue_xmit(skb, skb->dev, SOPRI_NORMAL);
583 else
584 dev_queue_xmit(skb, skb->dev, skb->sk->priority);
585 }
586 }
587 else
588 list=&((*list)->next);
589 }
590 }
591
592
593
594
595
596
597 static int aarp_rcv(struct sk_buff *skb, struct device *dev, struct packet_type *pt)
598 {
599 struct elapaarp *ea=(struct elapaarp *)skb->h.raw;
600 struct aarp_entry *a;
601 struct at_addr sa, *ma;
602 unsigned long flags;
603 int hash;
604 struct atalk_iface *ifa;
605
606
607
608
609
610
611 if(dev->type!=ARPHRD_ETHER)
612 {
613 kfree_skb(skb, FREE_READ);
614 return 0;
615 }
616
617
618
619
620
621 if(!skb_pull(skb,sizeof(*ea)))
622 {
623 kfree_skb(skb, FREE_READ);
624 return 0;
625 }
626
627 ea->function=ntohs(ea->function);
628
629
630
631
632
633 if(ea->function<AARP_REQUEST || ea->function > AARP_PROBE || ea->hw_len != ETH_ALEN || ea->pa_len != AARP_PA_ALEN ||
634 ea->pa_src_zero != 0 || ea->pa_dst_zero != 0)
635 {
636 kfree_skb(skb, FREE_READ);
637 return 0;
638 }
639
640
641
642
643
644 hash=ea->pa_src_node%(AARP_HASH_SIZE-1);
645
646
647
648
649
650 sa.s_node=ea->pa_src_node;
651 sa.s_net=ea->pa_src_net;
652
653
654
655
656
657 save_flags(flags);
658
659
660
661
662
663 ifa=atalk_find_dev(dev);
664 if(ifa==NULL)
665 {
666 restore_flags(flags);
667 kfree_skb(skb, FREE_READ);
668 return 1;
669 }
670 if(ifa->status&ATIF_PROBE)
671 {
672 if(ifa->address.s_node==ea->pa_dst_node && ifa->address.s_net==ea->pa_dst_net)
673 {
674
675
676
677
678 ifa->status|=ATIF_PROBE_FAIL;
679 restore_flags(flags);
680 kfree_skb(skb, FREE_READ);
681 return 1;
682 }
683 }
684
685 switch(ea->function)
686 {
687 case AARP_REPLY:
688 if(unresolved_count==0)
689 break;
690
691
692
693
694 cli();
695 if((a=aarp_find_entry(unresolved[hash],dev,&sa))==NULL || dev != a->dev)
696 break;
697
698
699
700
701 memcpy(a->hwaddr,ea->hw_src,ETH_ALEN);
702 aarp_resolved(&unresolved[hash],a,hash);
703 if(unresolved_count==0)
704 {
705 del_timer(&aarp_timer);
706 aarp_timer.expires=jiffies+AARP_EXPIRY_TIME;
707 add_timer(&aarp_timer);
708 }
709 break;
710
711 case AARP_REQUEST:
712 case AARP_PROBE:
713
714
715
716
717
718
719 ma=&ifa->address;
720 sa.s_node=ea->pa_dst_node;
721 sa.s_net=ea->pa_dst_net;
722
723 if(sa.s_node!=ma->s_node)
724 break;
725 if(sa.s_net && ma->s_net && sa.s_net!=ma->s_net)
726 break;
727
728 sa.s_node=ea->pa_src_node;
729 sa.s_net=ea->pa_src_net;
730
731
732
733
734
735 aarp_send_reply(dev,ma,&sa,ea->hw_src);
736 break;
737 }
738 restore_flags(flags);
739 kfree_skb(skb, FREE_READ);
740 return 1;
741 }
742
743 static struct notifier_block aarp_notifier={
744 aarp_device_event,
745 NULL,
746 0
747 };
748
749
750 void aarp_proto_init(void)
751 {
752 static char aarp_snap_id[]={0x00,0x00,0x00,0x80,0xF3};
753 if((aarp_dl=register_snap_client(aarp_snap_id, aarp_rcv))==NULL)
754 printk("Unable to register AARP with SNAP.\n");
755 init_timer(&aarp_timer);
756 aarp_timer.function=aarp_expire_timeout;
757 aarp_timer.data=0;
758 aarp_timer.expires=jiffies+AARP_EXPIRY_TIME;
759 add_timer(&aarp_timer);
760 register_netdevice_notifier(&aarp_notifier);
761 }
762 #endif