这是我一个毕业几年的师兄写的一个ip层的并发传输模块，没看懂怎么并发传输的?

九阳神功爱喝茶

1. #include <linux/module.h>
   
2. #include <linux/kernel.h>
   
3. #include <linux/skbuff.h>
   
4. #include <linux/ip.h>
   
5. #include <linux/netfilter.h>
   
6. #include <linux/netfilter_ipv4.h>
   
7. #include <linux/if_ether.h>
   
8. #include <linux/if_packet.h>
   
9. #include <linux/netdevice.h>
   
10. #include <net/tcp.h>
    
11. #include <net/udp.h>
    
12. #include <net/ip.h>
    
13. 
    
14. extern int ip_rcv_finish(struct sk_buff *skb);
    
15. 
    
16. MODULE_LICENSE("Dual BSD/GPL");
    
17. MODULE_AUTHOR("伍鹏飞");
    
18. MODULE_DESCRIPTION("多径路由并发模块");
    
19. MODULE_VERSION("0.0.1");
    
20. 
    
21. static unsigned char rule_ip[4] = {192,168,1,0}; // target capture ip default parameter
    
22. static unsigned char rule_mask[4] = {255,255,255,0};//MUSTget local host ip
    
23. static unsigned int  mirule_ip;
    
24. static unsigned int  mimask;
    
25. static unsigned int  anum = 4;
    
26.        
    
27. module_param_array(rule_ip, byte,&anum, S_IRUSR|S_IWUSR);       
    
28. module_param_array(rule_mask, byte,&anum, S_IRUSR|S_IWUSR);
    
29. 
    
30. unsigned int nf_hook_pre(unsigned int hooknum, struct sk_buff *skb,
    
31.                                 const struct net_device *in,     
    
32.                                 const struct net_device *out,                        
    
33.                                 int (*okfn)(struct sk_buff *))
    
34. 
    
35. {
    
36.         struct sk_buff *skb2;
    
37.         struct iphdr *iph = ip_hdr(skb);
    
38.         struct iphdr *iph2;
    
39.         mirule_ip = *(unsigned int *)rule_ip;
    
40.         mimask = *(unsigned int *)rule_mask;
    
41.         if((iph->saddr^mirule_ip) & mimask) //如果源地址不是同一子网的，直接进行后面的处理，不进行并发
    
42.                 return NF_ACCEPT;
    
43.         else
    
44.         {
    
45.                 skb2 = skb_clone(skb,GFP_ATOMIC);
    
46.                 iph2 = ip_hdr(skb2);
    
47. 
    
48.                 iph2->tos = 0x04;
    
49.                 iph2->check = 0;
    
50.                 iph2->check = ip_fast_csum((unsigned char*)iph2, iph2->ihl);
    
51. 
    
52.                 ip_rcv_finish(skb2);
    
53. 
    
54.                 iph->tos = 0x08;
    
55.                 iph->check = 0;
    
56.                 iph->check = ip_fast_csum((unsigned char*)iph, iph->ihl);
    
57.         }
    
58.         return NF_ACCEPT;
    
59. }
    
60. 
    
61. unsigned int nf_hook_in(unsigned int hooknum, struct sk_buff *skb,
    
62.                                 const struct net_device *in,     
    
63.                                 const struct net_device *out,                        
    
64.                                 int (*okfn)(struct sk_buff *))
    
65. {
    
66.         struct iphdr *iph = ip_hdr(skb);
    
67.         if(iph->tos == 0x04)
    
68.                 return NF_DROP;
    
69.         else
    
70.                 return NF_ACCEPT;
    
71. }
    
72. 
    
73. static struct nf_hook_ops nf_pre =
    
74. {
    
75.         .hook = nf_hook_pre,
    
76.         .hooknum = NF_INET_PRE_ROUTING,
    
77.         .pf = PF_INET,
    
78.         .priority = NF_IP_PRI_FIRST,
    
79. };
    
80. 
    
81. static struct nf_hook_ops nf_in =
    
82. {
    
83.         .hook = nf_hook_in,
    
84.         .hooknum = NF_INET_LOCAL_IN,
    
85.         .pf = PF_INET,
    
86.         .priority = NF_IP_PRI_FIRST,
    
87. };       
    
88. 
    
89. static int __init init(void)
    
90. {
    
91.         nf_register_hook(&nf_pre);
    
92.         nf_register_hook(&nf_in);  
    
93.     printk(KERN_ALERT "insmod mulpath successful!\n");  
    
94.         return 0;
    
95. }
    
96. 
    
97. static void __exit exit(void)
    
98. {     
    
99.         nf_unregister_hook(&nf_pre);
    
100.         nf_unregister_hook(&nf_in);   
     
101.         printk(KERN_ALERT "rmmod mulpath successful!\n");
     
102. }
     
103. 
     
104. module_init(init);
     
105. module_exit(exit);
     

复制代码

九阳神功爱喝茶

钩子函数我理解，但是我很不理解这怎么成了多径并发的？

nswcfd

跟基于tos的路由配合吧（策略路由ip route xxx）。
相当于一个报文，先按照tos=4路由一次，再按照tos=8路由一次。
并且tos=4的时候不希望本地接收。

由于只进行了skb_clone，data部分还是被原始skb和新的skb1共享的，如果skb被缓存在队列上（tc qdisc或者网卡的ring），
理论上对skb1的修改（比如tos/check/以及后续的dest mac）还是有可能体现到原始skb上的。

九阳神功爱喝茶

谢谢，我刚分析的也是这个差不多的意思。但是我很不理解这个地方

比如当数据包第一次被拦截进入nf_hook_pre函数之后，如果TOS=4，那么数据包被路由或者被本地接收，当然在被本地接受后悔在nf_hook_in中丢掉数据包；也就是数据包在TOS=4的时候要么会被丢弃，要么会被路由出去；
而在TOS=8的时候要么被接收，要么被路由出去。
是这样的吗？
如果TOS=4的时候被路由出去，TOS=8时候被接收，这我还能理解是多径传输，其他的情况都不是吧、

回复 3# nswcfd


   

nswcfd

不一定非得“本地 + 转发”才叫多路，“转发1 + 转发2”也可以吧。
只要命中不同的路由（比如选择不同的出口，或者使用不同的下一跳）不就是multi path了么，
虽然它们在netfilter下的code path都是一样的……（严格说来也有区别）

至于“多径”传输的本义和既定应用场景，估计还得找作者本人问问。

九阳神功爱喝茶

好，我已经在给这位师兄发邮件了。谢谢你回复 5# nswcfd


   

xlhl3

回复 1# 九阳神功爱喝茶
你好， 我想问下你问的结果是什么呀？
我的理解是：
如果数据包的tos == 4 且目的地址是本地的话，该数据包则丢弃；
如果数据包的tos == 4 且目的地址不是本地的话，则该数据包转发；
如果数据包的tos == 8 则该数据包要么被接受，要么被转发

如果TOS == 4的时候被路由出去，TOS == 8时候被接收的情况不会发生吧？
因为在 TOS==4 和 TOS == 8 的时候，目的地址是确定的呀？除非在tos == 8 的时候改变目的地址为本机，这样才会发生吧，但是在代码中没有对目的地址做更改呀？ 所以我认为不会发生（除非在其他地方做了处理）。

   

nswcfd

揣测作者的原意，在代码之外，在命令行配置层面，至少有两条基于tos的策略路由（ip rule + ip route）。

路由不改变目的IP，只是选择不同的出口或下一跳（体现在对目的MAC的改变上，ARP子系统）

xlhl3

回复 8# nswcfd

嗯 嗯，很有可能是这样做的！


   

九阳神功爱喝茶

厉害，我仔细看了下他的论文，确是是这个意思。不过他这样设计我觉得有个问题:接收方最后还是只能收到TOS=8的这条路来的数据包，所以并不是传统意义上只要有一个OK就可以了的。

nswcfd 发表于 2015-05-27 16:52
揣测作者的原意，在代码之外，在命令行配置层面，至少有两条基于tos的策略路由（ip rule + ip route）。

...