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
445 hash=sa->s_node%(AARP_HASH_SIZE-1);
446 save_flags(flags);
447 cli();
448
449
450
451
452
453 if(sa->s_node==ATADDR_BCAST)
454 {
455 ddp_dl->datalink_header(ddp_dl, skb, ddp_eth_multicast);
456 if(skb->sk==NULL)
457 dev_queue_xmit(skb, skb->dev, SOPRI_NORMAL);
458 else
459 dev_queue_xmit(skb, skb->dev, skb->sk->priority);
460 restore_flags(flags);
461 return 1;
462 }
463 a=aarp_find_entry(resolved[hash],dev,sa);
464 if(a!=NULL)
465 {
466
467
468
469
470 a->expires_at=jiffies+AARP_EXPIRY_TIME*10;
471 ddp_dl->datalink_header(ddp_dl, skb, a->hwaddr);
472 if(skb->sk==NULL)
473 dev_queue_xmit(skb, skb->dev, SOPRI_NORMAL);
474 else
475 dev_queue_xmit(skb, skb->dev, skb->sk->priority);
476 restore_flags(flags);
477 return 1;
478 }
479
480
481
482
483
484 a=aarp_find_entry(unresolved[hash],dev,sa);
485 if(a!=NULL)
486 {
487
488
489
490
491 skb_queue_tail(&a->packet_queue, skb);
492 restore_flags(flags);
493 return 0;
494 }
495
496
497
498
499
500 a=aarp_alloc();
501 if(a==NULL)
502 {
503
504
505
506
507 restore_flags(flags);
508 return -1;
509 }
510
511
512
513
514
515 skb_queue_tail(&a->packet_queue, skb);
516 a->expires_at=jiffies+AARP_RESOLVE_TIME;
517 a->dev=dev;
518 a->next=unresolved[hash];
519 a->target_addr= *sa;
520 a->xmit_count=0;
521 unresolved[hash]=a;
522 unresolved_count++;
523 restore_flags(flags);
524
525
526
527
528
529 aarp_send_query(a);
530
531
532
533
534
535
536 if(unresolved_count==1)
537 {
538 del_timer(&aarp_timer);
539 aarp_timer.expires=jiffies+AARP_TICK_TIME;
540 add_timer(&aarp_timer);
541 }
542
543
544
545
546
547 return 0;
548 }
549
550
551
552
553
554
555 static void aarp_resolved(struct aarp_entry **list, struct aarp_entry *a, int hash)
556 {
557 struct sk_buff *skb;
558 while(*list!=NULL)
559 {
560 if(*list==a)
561 {
562 unresolved_count--;
563 *list=a->next;
564
565
566
567
568
569 a->next=resolved[hash];
570 resolved[hash]=a;
571
572
573
574
575
576 while((skb=skb_dequeue(&a->packet_queue))!=NULL)
577 {
578 a->expires_at=jiffies+AARP_EXPIRY_TIME*10;
579 ddp_dl->datalink_header(ddp_dl,skb,a->hwaddr);
580 if(skb->sk==NULL)
581 dev_queue_xmit(skb, skb->dev, SOPRI_NORMAL);
582 else
583 dev_queue_xmit(skb, skb->dev, skb->sk->priority);
584 }
585 }
586 else
587 list=&((*list)->next);
588 }
589 }
590
591
592
593
594
595
596 static int aarp_rcv(struct sk_buff *skb, struct device *dev, struct packet_type *pt)
597 {
598 struct elapaarp *ea=(struct elapaarp *)skb->h.raw;
599 struct aarp_entry *a;
600 struct at_addr sa, *ma;
601 unsigned long flags;
602 int hash;
603 struct atalk_iface *ifa;
604
605
606
607
608
609
610 if(dev->type!=ARPHRD_ETHER)
611 {
612 kfree_skb(skb, FREE_READ);
613 return 0;
614 }
615
616
617
618
619
620 if(!skb_pull(skb,sizeof(*ea)))
621 {
622 kfree_skb(skb, FREE_READ);
623 return 0;
624 }
625
626 ea->function=ntohs(ea->function);
627
628
629
630
631
632 if(ea->function<AARP_REQUEST || ea->function > AARP_PROBE || ea->hw_len != ETH_ALEN || ea->pa_len != AARP_PA_ALEN ||
633 ea->pa_src_zero != 0 || ea->pa_dst_zero != 0)
634 {
635 kfree_skb(skb, FREE_READ);
636 return 0;
637 }
638
639
640
641
642
643 hash=ea->pa_src_node%(AARP_HASH_SIZE-1);
644
645
646
647
648
649 sa.s_node=ea->pa_src_node;
650 sa.s_net=ea->pa_src_net;
651
652
653
654
655
656 save_flags(flags);
657
658
659
660
661
662 ifa=atalk_find_dev(dev);
663 if(ifa==NULL)
664 {
665 restore_flags(flags);
666 kfree_skb(skb, FREE_READ);
667 return 1;
668 }
669 if(ifa->status&ATIF_PROBE)
670 {
671 if(ifa->address.s_node==ea->pa_dst_node && ifa->address.s_net==ea->pa_dst_net)
672 {
673
674
675
676
677 ifa->status|=ATIF_PROBE_FAIL;
678 restore_flags(flags);
679 kfree_skb(skb, FREE_READ);
680 return 1;
681 }
682 }
683
684 switch(ea->function)
685 {
686 case AARP_REPLY:
687 if(unresolved_count==0)
688 break;
689
690
691
692
693 cli();
694 if((a=aarp_find_entry(unresolved[hash],dev,&sa))==NULL || dev != a->dev)
695 break;
696
697
698
699
700 memcpy(a->hwaddr,ea->hw_src,ETH_ALEN);
701 aarp_resolved(&unresolved[hash],a,hash);
702 if(unresolved_count==0)
703 {
704 del_timer(&aarp_timer);
705 aarp_timer.expires=jiffies+AARP_EXPIRY_TIME;
706 add_timer(&aarp_timer);
707 }
708 break;
709
710 case AARP_REQUEST:
711 case AARP_PROBE:
712
713
714
715
716
717
718 ma=&ifa->address;
719 sa.s_node=ea->pa_dst_node;
720 sa.s_net=ea->pa_dst_net;
721
722 if(sa.s_node!=ma->s_node)
723 break;
724 if(sa.s_net && ma->s_net && sa.s_net!=ma->s_net)
725 break;
726
727 sa.s_node=ea->pa_src_node;
728 sa.s_net=ea->pa_src_net;
729
730
731
732
733
734 aarp_send_reply(dev,ma,&sa,ea->hw_src);
735 break;
736 }
737 restore_flags(flags);
738 kfree_skb(skb, FREE_READ);
739 return 1;
740 }
741
742 static struct notifier_block aarp_notifier={
743 aarp_device_event,
744 NULL,
745 0
746 };
747
748
749 void aarp_proto_init(void)
750 {
751 static char aarp_snap_id[]={0x00,0x00,0x00,0x80,0xF3};
752 if((aarp_dl=register_snap_client(aarp_snap_id, aarp_rcv))==NULL)
753 printk("Unable to register AARP with SNAP.\n");
754 init_timer(&aarp_timer);
755 aarp_timer.function=aarp_expire_timeout;
756 aarp_timer.data=0;
757 aarp_timer.expires=jiffies+AARP_EXPIRY_TIME;
758 add_timer(&aarp_timer);
759 register_netdevice_notifier(&aarp_notifier);
760 }
761 #endif