[求助]利用netfilter对sk_buff做更改的问题

newand

利用netfilter在NF_IP6_PRE_ROUTING挂载点对经过的指定组播报文报头做更改。
现在的问题是，更改报头之后发送的组播报文接收端却接收不到，除非卸载此模块。
所以我考虑是不是检验的问题，但IPV6报文不需要检验，MAC层的头部也没有校验，只剩UDP的校验。
代码如下：

1. /*
   
2. * this programe is working as plugin of netfilter which will pin a timestamp to
   
3. * the destination header of ipv6 packet every x seconds when the packet is
   
4. * the object multicast packet.
   
5. */
   
6. 
   
7. #include <linux/netfilter.h>
   
8. #include <linux/netfilter_ipv6.h>
   
9. #include <linux/netfilter_ipv6/ip6_tables.h>
   
10. #include <linux/module.h>
    
11. #include <linux/moduleparam.h>
    
12. #include <linux/kernel.h>
    
13. #include <linux/inet.h>
    
14. #include <linux/ip.h>
    
15. #include <linux/udp.h>
    
16. #include <net/checksum.h>
    
17. #include <net/udp.h>
    
18. #include <net/ipv6.h>
    
19. #include <linux/time.h>
    
20. 
    
21. 
    
22. #define PRINT(fmt,args...) printk("Marker: " fmt, ##args)
    
23. 
    
24. 
    
25. /* IP6 Hooks */
    
26. /* After promisc drops, checksum checks. */
    
27. #define NF_IP6_PRE_ROUTING  0
    
28. /* If the packet is destined for this box. */
    
29. #define NF_IP6_LOCAL_IN     1
    
30. /* If the packet is destined for another interface. */
    
31. #define NF_IP6_FORWARD      2
    
32. /* Packets coming from a local process. */
    
33. #define NF_IP6_LOCAL_OUT        3
    
34. /* Packets about to hit the wire. */
    
35. #define NF_IP6_POST_ROUTING 4
    
36. 
    
37. /*test begin*/
    
38. /*原本打算使用skb_copy来拷贝一个sk_buff，然后再修改其中的某一项，最后kfree_skb原来的
    
39. 但是不能free的总是出错，于是创新的，直接在原来的sk_buff的ip报头进行修改，结果却是接收端不能收到报文
    
40. */
    
41. struct sk_buff *
    
42. ip6_encapsulate_pkt_t(struct sk_buff *skb)
    
43. {
    
44.         struct sk_buff *new_skb, *temp_skb;
    
45.         struct ipv6hdr * ipv6h;
    
46.         struct udphdr *udph;
    
47. 
    
48.         //copy from the *skb to new_skb
    
49.         /*new_skb = skb_copy(skb, GFP_ATOMIC);
    
50.         if(new_skb == NULL)
    
51.         {
    
52.                 PRINT("Allocate new sk_buffer error!\n");
    
53.                 //kfree_skb(skb);
    
54.                 return NULL;
    
55.         }*/
    
56.         udph = udp_hdr(skb);
    
57.         ipv6h->nexthdr = 0x60;//set next header as 60 which means next destination header.
    
58. 
    
59.         udph->check = csum_ipv6_magic(&ipv6h->saddr,&ipv6h->daddr, udplen,IPPROTO_UDP, csum_partial((char*)udph,udplen,0));
    
60.         printk(" skb sum %u,CheckSum  = %u\n",skb->ip_summed,udph->check);
    
61.         
    
62.         //kfree_skb(skb);
    
63.         //        skb = new_skb;//skb pointer to new_skb
    
64.    
    
65.         return skb;
    
66. }
    
67. /*test end*/
    
68. 
    
69. /*Hook which will call the encapsulate func when condition satisfied
    
70. *condition1: IPv6 Multicast packets
    
71. *condition2: every 20ms
    
72. */
    
73. static unsigned int
    
74. ip6_multi_modify(unsigned int hooknum,
    
75.                                 struct sk_buff *skb,
    
76.                                 const struct net_device *in,
    
77.                                 const struct net_device *out,
    
78.                                 int (*okfn)(struct sk_buff*))
    
79. {
    
80.     struct sk_buff *sk = skb;
    
81.         struct ipv6hdr *ip6_hdr = ipv6_hdr(skb);//header
    
82. 
    
83.         if(ip6_hdr->version == 6)
    
84.         {
    
85.                 struct in6_addr destip = ip6_hdr->daddr;//destination ip
    
86.           
    
87.                 if(destip.s6_addr[0] == 0xff && destip.s6_addr[1] == 0x15)
    
88.                 {
    
89.                         if(skb_tailroom(sk) >= 40)
    
90.                         {
    
91.                                 //expand
    
92.                                 PRINT("tailroom is enough\n");
    
93.                         }
    
94.                         else
    
95.                         {
    
96.                                 //modify
    
97.                                 PRINT("not enough\n");
    
98.                         }
    
99.                         //print before change
    
100.                         PRINT("before change %x", ip6_hdr->nexthdr);
     
101.                         skb = ip6_encapsulate_pkt_t(skb);
     
102.                         if(skb == NULL)
     
103.                         {
     
104.                                 PRINT("Allocate new sk_buffer error!\n");
     
105.                                 return NF_STOLEN;
     
106.                         }
     
107.                         ip6_hdr= ipv6_hdr(skb);
     
108.                         PRINT("after change %x \n", ip6_hdr->nexthdr);
     
109. 
     
110.                 }
     
111. 
     
112.         }
     
113. 
     
114.         return NF_ACCEPT;
     
115. }
     
116. 
     
117. 
     
118. /*Initialize the hook*/
     
119. static struct nf_hook_ops nf_out_modify =
     
120. {
     
121.         .hook = ip6_multi_modify,
     
122.         .hooknum = NF_IP6_PRE_ROUTING,//Check all the forwarded packets
     
123.         .pf = PF_INET6,
     
124.         .priority = NF_IP6_PRI_FIRST,
     
125. };
     
126. 
     
127. /*Initialize the module*/
     
128. static int __init ip6_multi_init(void)
     
129. {
     
130.         int ret;
     
131.         ret = nf_register_hook(&nf_out_modify);
     
132.         PRINT("IPV6 multicast packet modify module init.\n");
     
133.         return 0; //success
     
134. }
     
135. 
     
136. /*Clear the module*/
     
137. static void __exit ip6_multi_exit(void)
     
138. {
     
139.         nf_unregister_hook(&nf_out_modify);
     
140.         PRINT("IPV6 multicast packet modify module exit.\n");
     
141. }
     
142. 
     
143. module_init(ip6_multi_init);
     
144. module_exit(ip6_multi_exit);

复制代码

请各位帮忙看下。

luoyan_xy

在本机和对端抓一下包吧，ipv6的4层头计算校验和也是需要添加三层的伪头部的，如果真是校验和的问题是可以在网卡抓到包的

Godbach

回复 2# luoyan_xy
四层校验和出错不应该导致报文发布出去。


   

newand

回复 3# Godbach


    是的，后来看了，确实不是那个问题。
   谢谢两位。
   现在又遇到个问题，用skb_cpy_expand时会分配不了新的空间。

1. PRINT("SKB SIZE:%u;",sizeof(*skb));
   
2.         //copy from the *skb to new_skb
   
3.         new_skb = skb_copy_expand(skb, skb_headroom(skb),
   
4.                                 skb_tailroom(skb) + 16
   
5.                                 GFP_ATOMIC);
   
6. PRINT("NEW SKB SIZE:%u;",sizeof(*new_skb));

复制代码

打印的结果是：
SKB SIZE:192;   NEW SKB SIZE:192
空间没有变大，但是地址确实是不同的。
请问怎么会这样呢？

newand

我打印skb_copy_expand前后skb的内容，结果如下：
SKB SIZE:192,skb->len:60;
head room:24,tailroom:235,add:16.
NEW SKB SIZE:192,newskb->len:60;
head room:24,tailroom:747,add:16.
为什么tailroom也增了，而sizeof(*skb)不增呢？

whaaat

回复 5# newand
LZ大意了吧，用sizeof()会改变么？

   

newand

回复 6# whaaat


what兄说的对，sizeof是不能查看到动态分配的。   
是我PRINT位置不对，一楼的这段代码没有问题的。

whaaat

回复 7# newand
如果要free掉skb，hook需要返回NF_STOLEN。
udp_hdr在hook中是不能用的，还没有到4层。