[求助]skb_copy_expand擴展報文頭

newand

現在程序中使用skb_copy_expand步驟是這樣的
1. 調用skb_copy_expand多增加一塊內容，返回new_skb。
2. 使用skb_put將tail指針下移，增加skb的len。
3. 用memcpy將skb中前40個字節(jié)的IP header復制到new_skb中。
4. 用memcpy將skb中40字節(jié)往后的內容復制到new_skb的第40+extend header地址處。
5. 設置extend header的值。

但是運行的結果是，每次抓包，報文的長度不會改變，只是因為第5步改變的內容導致報文出錯。

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. 
   
8. #include <linux/netfilter.h>
   
9. #include <linux/netfilter_ipv6.h>
   
10. #include <linux/netfilter_ipv6/ip6_tables.h>
    
11. #include <linux/module.h>
    
12. #include <linux/moduleparam.h>
    
13. #include <linux/kernel.h>
    
14. #include <linux/inet.h>
    
15. #include <linux/ip.h>
    
16. #include <linux/udp.h>
    
17. #include <net/checksum.h>
    
18. #include <net/udp.h>
    
19. #include <net/ipv6.h>
    
20. #include <linux/time.h>
    
21. 
    
22. #include <asm/byteorder.h>
    
23. 
    
24. MODULE_LICENSE("GPL");
    
25. MODULE_AUTHOR("qj");
    
26. MODULE_DESCRIPTION("Change the header of ipv6 packet");
    
27. 
    
28. #define PRINT(fmt,args...) printk("INFO: " fmt, ##args)
    
29. 
    
30. 
    
31. /* IP6 Hooks */
    
32. /* After promisc drops#include <asm/byteorder.h>
    
33. , checksum checks. */
    
34. #define NF_IP6_PRE_ROUTING  0
    
35. /* If the packet is destined for this box. */
    
36. #define NF_IP6_LOCAL_IN     1
    
37. /* If the packet is destined for another interface. */
    
38. #define NF_IP6_FORWARD      2
    
39. /* Packets coming from a local process. */
    
40. #define NF_IP6_LOCAL_OUT        3
    
41. /* Packets about to hit the wire. */
    
42. #define NF_IP6_POST_ROUTING 4
    
43. 
    
44. 
    
45. /*sequence of measeure#include <asm/byteorder.h>
    
46. sample packet*/
    
47. static int sample_seq = 0;
    
48. 
    
49. /*Next header destination header*/
    
50. struct ip6_dst_hdr
    
51. {
    
52.                 uint8_t ip6d_nxt;
    
53.                 uint8_t ip6d_len;
    
54.                 uint8_t ip6d_opt_type;
    
55.                 uint8_t ip6d_opt_len;
    
56.                 uint32_t ip6d_ssn;
    
57.                 uint32_t ip6d_sec;
    
58.                 uint32_t ip6d_usec;
    
59. };
    
60. 
    
61. 
    
62. inline
    
63. void print_6addr(const struct in6_addr *addr)
    
64. {
    
65.     PRINT("%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x\n",
    
66.                  (int)addr->s6_addr[0], (int)addr->s6_addr[1],
    
67.                  (int)addr->s6_addr[2], (int)addr->s6_addr[3],
    
68.                  (int)addr->s6_addr[4], (int)addr->s6_addr[5],
    
69.                  (int)addr->s6_addr[6], (int)addr->s6_addr[7],
    
70.                  (int)addr->s6_addr[8], (int)addr->s6_addr[9],
    
71.                  (int)addr->s6_addr[10], (int)addr->s6_addr[11],
    
72.                  (int)addr->s6_addr[12], (int)addr->s6_addr[13],
    
73.                  (int)addr->s6_addr[14], (int)addr->s6_addr[15]);
    
74. }
    
75. char *in_ntoa(__u32 in)
    
76.   {
    
77.           static char buff[18];
    
78.           char *p;
    
79.   
    
80.           p = (char *) &in;
    
81.           sprintf(buff, "%d.%d.%d.%d",
    
82.                   (p[0] & 255), (p[1] & 255), (p[2] & 255), (p[3] & 255));
    
83.           return(buff);
    
84.   }
    
85. 
    
86. struct sk_buff *
    
87. ip6_reconstruct_pkt(struct sk_buff *skb)
    
88. {
    
89.         struct sk_buff *new_skb, *temp_skb;
    
90.         struct ipv6hdr * ip6_hdr = ipv6_hdr(skb);
    
91.         struct ip6_dst_hdr *ip6_dst;
    
92.         struct timeval tv;//get time
    
93. 
    
94.         ip6_hdr->nexthdr = 0x60;
    
95. 
    
96.         //copy from the *skb to new_skb
    
97.         new_skb = skb_copy_expand(skb, skb_headroom(skb),
    
98.                                 skb_tailroom(skb) + sizeof(struct ip6_dst_hdr),
    
99.                                 GFP_ATOMIC);
    
100. 
     
101.         if(new_skb == NULL)
     
102.         {
     
103.                 PRINT("Allocate new sk_buffer error!\n");
     
104.                 return NULL;
     
105.         }
     
106. 
     
107.         //set the new_skb
     
108.         if(skb->sk != NULL)
     
109.                 skb_set_owner_w(new_skb, skb->sk);
     
110. 
     
111.         //move tail to tail + sizeof(ip6_dst_hdr)
     
112.         skb_put(new_skb,sizeof(struct ip6_dst_hdr));
     
113.   
     
114.         //insert a ip6_dst_hdr between the memory
     
115.         memcpy (new_skb->data, skb->data, 40);//the ip header has 40 bytes
     
116.              memcpy (new_skb->data + 40 + sizeof (struct ip6_dst_hdr),
     
117.                                   skb->data + 40, skb->len - 40);
     
118. 
     
119.         skb = new_skb;//skb pointer to new_skb
     
120. 
     
121.             //turn the space to ip6_dst struct
     
122.         ip6_dst = (struct ip6_dst_hdr *)(new_skb->data + 40);
     
123.         memset(ip6_dst,0,sizeof(struct ip6_dst_hdr));
     
124.         //add ipv6 destination header
     
125.         ip6_dst->ip6d_nxt = htonl(0x17);
     
126.         ip6_dst->ip6d_len = htonl(0x15);
     
127.         ip6_dst->ip6d_opt_type = htonl(0x00);// type of option
     
128.         ip6_dst->ip6d_opt_len = htonl(0x0C);
     
129.        
     
130.         do_gettimeofday(&tv);
     
131.              ip6_dst->ip6d_sec = htonl(tv.tv_sec);
     
132.         ip6_dst->ip6d_usec = htonl(tv.tv_usec);
     
133.         sample_seq++;
     
134.         if(sample_seq==0xffffffff)//if overflow ，reset
     
135.         {
     
136.            sample_seq=0;
     
137.         }
     
138.         ip6_dst->ip6d_ssn = htonl(sample_seq);
     
139. 
     
140.         return skb;
     
141. }
     
142. 
     
143. /*Hook which will call the encapsulate func when condition satisfied
     
144. *condition1: IPv6 Multicast packets
     
145. *condition2: every 20ms
     
146. */
     
147. static unsigned int
     
148. ip6_multi_modify(unsigned int hooknum,
     
149.                                 struct sk_buff *skb,
     
150.                                 const struct net_device *in,
     
151.                                 const struct net_device *out,
     
152.                                 int (*okfn)(struct sk_buff*))
     
153. {
     
154.     struct sk_buff *sk = skb;
     
155.         struct ipv6hdr *ip6_hdr = ipv6_hdr(skb);//header
     
156. 
     
157.         //because nh only supportted in kernels below 2.6
     
158.         //after 2.6, it often use network_header to express nh
     
159.         //struct ipv6hdr *ip6_hdr = (struct ipv6hdr*)skb->nh.ipv6h;
     
160.         if(ip6_hdr->version == 6)
     
161.         {
     
162.                 struct in6_addr destip = ip6_hdr->daddr;//destination ip
     
163.                 //TODO:use module_para or /proc to replace here
     
164.                 if(destip.s6_addr[0] == 0xff && destip.s6_addr[1] == 0x15)
     
165. 
     
166.                 {
     
167.                         if(skb_tailroom(sk) >= 40)
     
168.                         {
     
169.                                 PRINT("tailroom is enough\n");
     
170.                         }
     
171.                         else
     
172.                         {
     
173.                                 PRINT("not enough\n");
     
174.                         }
     
175.                    skb = ip6_reconstruct_pkt(skb);
     
176.                         if(skb == NULL)
     
177.                         {
     
178.                                 return NF_STOLEN;
     
179.                         }
     
180.                         ip6_hdr= ipv6_hdr(skb);
     
181. 
     
182.                         if(!skb)
     
183.                                 return NF_STOLEN;
     
184.                 }
     
185.         }
     
186.         return NF_ACCEPT;
     
187. }
     
188. 
     
189. 
     
190. /*Initialize the hook*/
     
191. static struct nf_hook_ops nf_out_modify =
     
192. {
     
193.         .hook = ip6_multi_modify,
     
194.         .hooknum = NF_IP6_PRE_ROUTING,//Check all the forwarded packets
     
195.         .pf = PF_INET6,
     
196.         .priority = NF_IP6_PRI_FIRST,
     
197. };
     
198. 
     
199. /*Initialize the module*/
     
200. static int __init ip6_multi_init(void)
     
201. {
     
202.         int ret;
     
203.         ret = nf_register_hook(&nf_out_modify);
     
204.         PRINT("IPV6 multicast packet modify module init.\n");
     
205.         return 0; //success
     
206. }
     
207. 
     
208. /*Clear the module*/
     
209. static void __exit ip6_multi_exit(void)
     
210. {
     
211.         nf_unregister_hook(&nf_out_modify);
     
212.         PRINT("IPV6 multicast packet modify module exit.\n");
     
213. }
     
214. 
     
215. module_init(ip6_multi_init);
     
216. module_exit(ip6_multi_exit);

復制代碼

實在沒找出問題在哪，請各位大牛幫忙看看。

oscarvei

沒有拿代碼做實驗，至少有一個潛在的問題。
skb_linear.

oscarvei

回復 1# newand


    還有個原有的skb沒有釋放的問題。

newand

回復 2# oscarvei


    你好，剛接觸內核網絡編程，大部分都是看網上的示例或者去github上找代碼。比較少用skb_linear，查了skb_linearize的作用是- convert paged skb to linear one。（我不是特別明白，請問有沒有什么書或者資料推薦嗎？）

另外關于釋放skb的問題
我之前用kfree來在 skb = new_skb;之前釋放skb，不過會導致死機的問題。
是不是還需要其他操作？

還有一個問題就是，抓包時發(fā)現通過skb_copy_expand新產生報文是沒有的，還需要調用什么函數，將它返回的skb加入到隊列嗎？

SCDXMOE

kfree不能釋放skb    skb釋放用__kfree_skb

SCDXMOE

一些操作的函數 可以參考內核代碼

newand

回復 6# SCDXMOE


    請問，我擴展了報文報頭的長度，用skb_put將tail指針下移，然后用memcpy將數據拷貝。除了這些操作還應該有其他能夠設置報文長度的操作嗎？
因為我咋client抓到的報文，長度還是沒有更改之前的長度。

SCDXMOE

你要確定 你用了skb_put之后 要相應的更改skb->len

newand

回復 8# SCDXMOE


    skb_put的函數中會對skb->len做增加操作。

1. unsigned char *skb_put(struct sk_buff *skb, unsigned int len)
   
2. {
   
3.     unsigned char *tmp = skb_tail_pointer(skb);
   
4.     SKB_LINEAR_ASSERT(skb);
   
5.     skb->tail += len;
   
6.     skb->len  += len;
   
7.     if (unlikely(skb->tail > skb->end))
   
8.         skb_over_panic(skb, len, __builtin_return_address(0));
   
9.     return tmp;
   
10. }
    

復制代碼

skb->len的大小是隨著skb->put的調用而變化的，
不過skb->truesize沒變，但是我手動設置了skb->truesize之后，在client抓到的報文，長度不因為增加了ip首部而變化。

SCDXMOE

skb->truesize =len+sizeof（skbuff）是隨著len的長度變化er變化的 怎么可能是沒有變化呢