新版本內(nèi)核構(gòu)造包發(fā)送問(wèn)題

買單老

我在工作中和家中運(yùn)行的ubuntu系統(tǒng)是12.04，發(fā)現(xiàn)內(nèi)核版本已經(jīng)是至少是3.11版本了，其中struct sk_buff的結(jié)構(gòu)相較于以前變化了不少，下面是我摘取的
一個(gè)功能模塊，主要是調(diào)用dev_queue_xmit發(fā)送自己構(gòu)造的包

1. #include <linux/kernel.h>
   
2. #include <linux/init.h>
   
3. #include <linux/module.h>
   
4. #include <linux/ip.h>
   
5. #include <linux/tcp.h>
   
6. #include <net/ip.h>
   
7. #include <net/checksum.h>
   
8. 
   
9. 
   
10. int cp_dev_xmit_tcp (const char *dev_name,
    
11.                 const u_char * smac, const u_char * dmac,
    
12.                 u_char * pkt, int pkt_len,
    
13.                 __be32 sip, __be32 dip,
    
14.                 __be16 sport, __be16 dport,
    
15.                 __be32 seq, __be32 ack_seq, u_char psh, u_char fin)
    
16. 
    
17. {
    
18.         struct sk_buff * skb = NULL;
    
19.         struct net_device * dev = NULL;
    
20.         struct ethhdr * ethdr = NULL;
    
21.         struct iphdr * iph = NULL;
    
22.         struct tcphdr * tcph = NULL;
    
23.         u_char * pdata = NULL;
    
24.         int nret = 1;
    
25. 
    
26. 
    
27.         if (NULL == smac || NULL == dmac || !dev_name)
    
28.                 goto out;
    
29. 
    
30.         dev = dev_get_by_name(&init_net,dev_name);
    
31. 
    
32.         if (NULL == dev)
    
33.         {
    
34.                 pr_info("dev is NULL!!!!\n");
    
35.                 goto out;
    
36.         }
    
37. 
    
38.         pr_info("dev->name[%s],mtd[%d]\n",dev->name,dev->mtu);
    
39.         skb = alloc_skb (pkt_len + sizeof (struct iphdr) + sizeof (struct tcphdr) + LL_RESERVED_SPACE (dev), GFP_ATOMIC);
    
40. 
    
41.         if (NULL == skb)
    
42.         {
    
43.                 dev_put (dev);
    
44.                 pr_info("alloc skb is  NULL!!!!\n");
    
45.                 goto out;
    
46.         }
    
47. 
    
48.         memset(skb,0,pkt_len + sizeof (struct iphdr) + sizeof (struct tcphdr) + LL_RESERVED_SPACE (dev));
    
49.         pr_info(" skb is start!!\n");
    
50.         skb_reserve (skb, LL_RESERVED_SPACE (dev));
    
51.         skb->dev = dev;
    
52.         skb->pkt_type = PACKET_OTHERHOST;
    
53.         skb->protocol = __constant_htons(ETH_P_IP);
    
54.         skb->ip_summed = CHECKSUM_NONE;
    
55. 
    
56.         skb->priority = 0;
    
57.         skb_put(skb, sizeof (struct iphdr));
    
58.         skb_put(skb, sizeof (struct tcphdr));
    
59.         skb->network_header = (U8 *)ip_hdr(skb) - skb->head;
    
60.         skb->transport_header = (U8 *)tcp_hdr(skb) - skb->head;
    
61.         pdata = skb_put (skb, pkt_len);
    
62.         {
    
63.                 if (NULL != pkt)
    
64.                         memcpy (pdata, pkt, pkt_len);
    
65. 
    
66.         }
    
67. 
    
68.         pr_info("tcphdr is start!!\n");
    
69.         {
    
70.                 tcph = tcp_hdr(skb);
    
71.                 pr_info("tcphdr is start!!1\n");
    
72.                 memset (tcph, 0, sizeof (struct tcphdr));
    
73.                 pr_info("tcphdr is start!!2\n");
    
74.                 pr_info("tcphdr is start!!2\n");
    
75.                 tcph->source = sport;
    
76.                 pr_info("tcphdr is start!!3\n");
    
77.                 tcph->dest = dport;
    
78.                 pr_info("tcphdr is start!!4\n");
    
79.                 if(seq)
    
80.                         tcph->seq = seq;
    
81.                 if(ack_seq)
    
82.                         tcph->ack_seq = ack_seq;
    
83.                 pr_info("tcphdr is start!!5\n");
    
84.                 tcph->doff = 5;
    
85.                 pr_info("tcphdr is start!!6\n");
    
86.                 tcph->psh = psh;
    
87.                 pr_info("tcphdr is start!!7\n");
    
88.                 tcph->fin = fin;
    
89.                 pr_info("tcphdr is start!!8\n");
    
90.                 tcph->ack = 1;
    
91.                 pr_info("tcphdr is start!!9\n");
    
92.                 tcph->window = __constant_htons (65535);
    
93.                 pr_info("tcphdr is start!!10\n");
    
94.                 skb->csum = 0;
    
95.                 pr_info("tcphdr is start!!11\n");
    
96.                 tcph->check = 0;
    
97.                 pr_info("tcphdr is start!!12\n");
    
98.         }
    
99. 
    
100.         pr_info("iphdr is start!!13\n");
     
101.         {
     
102.                 iph = ip_hdr(skb);
     
103.                 iph->version = 4;
     
104.                 iph->ihl = sizeof(struct iphdr)>>2;
     
105.                 iph->frag_off = 0;
     
106.                 iph->protocol = IPPROTO_TCP;
     
107.                 iph->tos = 0;
     
108.                 iph->daddr = dip;
     
109.                 iph->saddr = sip;
     
110.                 iph->ttl = 0x40;
     
111.                 iph->tot_len = __constant_htons(skb->len);
     
112.                 iph->check = 0;
     
113.         }
     
114. 
     
115.         skb->csum = skb_checksum (skb, iph->ihl*4, skb->len - iph->ihl * 4, 0);
     
116.         tcph->check = csum_tcpudp_magic (sip, dip, skb->len - iph->ihl * 4, IPPROTO_TCP, skb->csum);
     
117.         ip_send_check(iph);
     
118. 
     
119.         skb_push (skb, 14);
     
120.         { //eth header
     
121.                 ethdr = (struct ethhdr *) skb->data;
     
122.                 memcpy (ethdr->h_dest, dmac, ETH_ALEN);
     
123.                 memcpy (ethdr->h_source, smac, ETH_ALEN);
     
124.                 ethdr->h_proto = __constant_htons (ETH_P_IP);
     
125.         }
     
126.         pr_info("fasong is start!!\n");
     
127.         if (0 > dev_queue_xmit(skb))
     
128.                 goto out;
     
129.         nret = 0;
     
130. out:
     
131.         if (0 != nret && NULL != skb) {
     
132.                 dev_put (dev);
     
133.                 kfree_skb (skb);
     
134.         }
     
135.         return (nret);
     
136. 
     
137. }
     
138. 
     
139. static int __init hello_kernel(void)
     
140. {
     
141.         cp_dev_queue_xmit(.......);
     
142.         return 0;
     
143. }

復(fù)制代碼

結(jié)果使用dmesg后查看發(fā)現(xiàn)內(nèi)核打印“protocol 0x0800 is buggy, dev eth0” (eth0是我在調(diào)用cp_dev_queue_xmit函數(shù)時(shí)傳遞的參數(shù))

請(qǐng)教各位神牛，新版本的內(nèi)核下，我這個(gè)程序有啥問(wèn)題啊？
謝謝了

nswcfd

這是xmit上抓包接口打印的信息，從很早的版本就有了，并不是新內(nèi)核才有的。
原因是skb->nh設(shè)置的不對(duì)，參見(jiàn)net/dev/core.c里的dev_queue_xmit_nit。

        skb->network_header = (U8 *)ip_hdr(skb) - skb->head;
ip_hdr本來(lái)就是從skb->nh推導(dǎo)出來(lái)的，這里卻用來(lái)設(shè)置skb->nh，有啥意義呢？

買單老

這個(gè)功能我已經(jīng)調(diào)出來(lái)了，還有，新版本內(nèi)核的sk_buff中沒(méi)有nh這個(gè)成員變量。回復(fù) 2# nswcfd


   

Godbach

回復(fù) 1# 買單老

1. skb->protocol = __constant_htons(ETH_P_IP);

復(fù)制代碼

請(qǐng)確認(rèn)一下，skb->protocol 是否需需要使用網(wǎng)絡(luò)字節(jié)序。

結(jié)果使用dmesg后查看發(fā)現(xiàn)內(nèi)核打印“protocol 0x0800 is buggy, dev eth0” (eth0是我在調(diào)用cp_dev_queue_xmit函數(shù)時(shí)傳遞的參數(shù))

從你的報(bào)錯(cuò)結(jié)果，應(yīng)該是 protocol 協(xié)議號(hào)設(shè)置的不對(duì)，系統(tǒng)不認(rèn)識(shí)。

   

買單老

1. skb->protocol = __constant_htons(ETH_P_IP)；

復(fù)制代碼

上面這段語(yǔ)句是正確的，我參照的cu置頂?shù)奈恼吕锩婢褪沁@么寫的。

我是這么修改的

1. 執(zhí)行skb_put(skb, sizeof (struct iphdr));后
   
2. 調(diào)用skb_reset_network_header(skb)；
   
3. 執(zhí)行skb_put(skb, sizeof (struct tcphdr));后
   
4. 調(diào)用skb_reset_transport_header(skb)；
   
5. 執(zhí)行skb_push (skb, 14);后
   
6. skb_reset_mac_header(skb)；

復(fù)制代碼

添加了上面三個(gè)reset函數(shù)后就能發(fā)送UDP數(shù)據(jù)了。

現(xiàn)在有新的問(wèn)題了，我使用原來(lái)的上面的代碼，把

1. dev_queue_xmit(skb)；

復(fù)制代碼

替換成

1. netif_receive_skb(skb)；

復(fù)制代碼

想實(shí)現(xiàn)在pre routing這個(gè)鉤子點(diǎn)之前發(fā)送數(shù)據(jù)，然后希望數(shù)據(jù)稍后流進(jìn)這個(gè)鉤子點(diǎn)，鉤子函數(shù)觸發(fā)。
但是，鉤子函數(shù)沒(méi)有被觸發(fā)，不過(guò)tcpdump 命令卻輸出了這個(gè)UDP報(bào)文數(shù)據(jù)。

想請(qǐng)問(wèn)一下，如果使用netif_receive_skb(skb)；發(fā)送數(shù)據(jù)，還需要注意哪些參數(shù)設(shè)置啊？

麻煩了


回復(fù) 4# Godbach


   

Godbach

回復(fù) 5# 買單老

想請(qǐng)問(wèn)一下，如果使用netif_receive_skb(skb)；發(fā)送數(shù)據(jù)，還需要注意哪些參數(shù)設(shè)置啊

這個(gè)是從網(wǎng)卡驅(qū)動(dòng)中讀取 skb 的。你要發(fā)送數(shù)據(jù)，為什么用這個(gè)函數(shù)？


   

買單老

我想讓自己構(gòu)造的包流進(jìn)協(xié)議棧。
現(xiàn)在有個(gè)疑問(wèn)啊，調(diào)用ip_local_deliver這個(gè)函數(shù)，結(jié)果在內(nèi)核模塊編譯的時(shí)候提示undefined,怎么解決呢？


回復(fù) 6# Godbach


   

Godbach

回復(fù) 7# 買單老

意味著這個(gè)函數(shù)并未 export 出來(lái)，你沒(méi)辦法調(diào)用。你可嘗試把這個(gè)函數(shù) export 出來(lái)，然后重新編譯 kernel。


   

nswcfd

想發(fā)送自己，把dev換成lo，調(diào)用xmit接口。

買單老

好的，我看看去，謝謝持續(xù)支持啊回復(fù) 9# nswcfd