剛學netlink，第一次寫netlink程序，有些疑問

mrpre

主要的目的是用戶態(tài)發(fā)送消息給內(nèi)核，內(nèi)核回復消息給用戶態(tài)。
我內(nèi)核嘗試了用2種方式回復。
一種是正常的處理，另一種是用kernel_thread一個線程，然后這個線程處理。
前一種用戶態(tài)能正常收到，后一種用戶態(tài)收不到數(shù)據(jù)，不知道問題在哪里。

1. 
   
2. 用戶態(tài)程序：
   
3. int main()
   
4. {
   
5.        
   
6.     struct sockaddr_nl src_addr;
   
7.     s32 ret;
   
8. 
   
9.    //我用自己的結構以體
   
10.     struct struReq_s
    
11.         {
    
12.                 int pid;         //存放當前進程的pid，內(nèi)核回復消息的時候需要
    
13.                 int data_len;
    
14.                 char data[0];
    
15.         };
    
16. 
    
17.    u8 buf[1024] = {0};//存放內(nèi)核傳回的數(shù)據(jù)
    
18. 
    
19.     struct struReq_s *struReq = NULL;
    
20.     netlink_socket = socket(AF_NETLINK, SOCK_RAW, NL_ADX);
    
21.     if(netlink_socket < 0)
    
22.     {
    
23.         return -1;
    
24.     }
    
25. 
    
26.     memset(&src_addr, 0, sizeof(src_addr));
    
27.     src_addr.nl_family = AF_NETLINK;
    
28.     src_addr.nl_pid = getpid();
    
29.     src_addr.nl_groups = 1;
    
30.                
    
31.     ret = bind(netlink_socket, (struct sockaddr *)&src_addr, sizeof(src_addr));
    
32.     if(ret < 0)
    
33.     {
    
34.         return -1;
    
35.     }
    
36. 
    
37. 
    
38.         struReq = malloc(sizeof( struct struReq_s) + 10);
    
39.         if(struReq == NULL)
    
40.         {
    
41.                 printf("malloc fail\n");
    
42.                 return 0;
    
43.         }
    
44.         memset(struReq, 0, sizeof(struct struReq_s) +  10);
    
45. 
    
46.         struReq->pid = getpid();
    
47.         struReq->data_len  = 10;
    
48.         memcpy(struReq->data,"nihao",strlen("nihao"));
    
49.        
    
50.         memset(&src_addr, 0, sizeof(src_addr));       
    
51.         src_addr.nl_family = AF_NETLINK;       
    
52.         src_addr.nl_pid = 0;       
    
53.         src_addr.nl_groups = 0;
    
54.    
    
55.             // 發(fā)送消息給內(nèi)核
    
56.         if(sendto(netlink_socket, struReq, struReq->data_len + sizeof(struct struReq_s), 0,               
    
57.                 (struct sockaddr *)&src_addr, sizeof(src_addr)) < 0)       
    
58.         {
    
59.                 return -1;         
    
60.         }
    
61.        
    
62.         printf("user recv\n");
    
63.         /*阻塞的讀*/
    
64.         recv(netlink_socket,buf,1024,0);
    
65.         printf("recv from kernel len : %d\n",((struct struReq_s *)buf)->data_len);
    
66.         printf("recv from kernel data: %s\n",((struct struReq_s *)buf)->data);
    
67.        
    
68.         free(struReq);
    
69.         return 0;
    

復制代碼

在內(nèi)核中我用2種方法回復，但是其中一個不行。
netlinkfd = netlink_kernel_create(&init_vrf, NL_ADX, 0, kernel_receive, NULL, THIS_MODULE);

可行的方法如下：

1. 
   
2. void kernel_receive(struct sk_buff *skb)
   
3. {
   
4.         printk("#########recv###########\n");
   
5.         process_message_thread(skb);
   
6.         printk("#########leave###########\n");
   
7. }
   
8. int process_message_thread(void *arg)
   
9. {
   
10.         struct sk_buff *skb = (struct sk_buff *)(arg);
    
11.        
    
12.         struct struReq_s  *msg = (struct struReq_s *) skb->data;
    
13.             
    
14.             /*打印出用戶態(tài)傳來的數(shù)據(jù)*/
    
15.         printk("kernel recv data:%s\n",msg->data);
    
16.         printk("kernel recv pid :%d\n",msg->pid);
    
17. 
    
18.              /*構造回復的數(shù)據(jù)*/
    
19.         struct struReq_s *needtosend = kmalloc(sizeof(struct struReq_s) + strlen("niyehao"),GFP_KERNEL);
    
20.         needtosend->data_len = strlen("niyehao");
    
21.         memcpy(needtosend->data,"niyehao", needtosend->data_len);
    
22. 
    
23.              /*構造回復用的skb*/
    
24.         skb = alloc_skb(sizeof(struct struReq_s) + strlen("niyehao"), GFP_ATOMIC);
    
25.         skb_put(skb,sizeof(struct struReq_s) + strlen("niyehao"));
    
26.         memcpy(skb->data,needtosend,sizeof(struct struReq_s) + strlen("niyehao"));
    
27.             
    
28.              /*發(fā)出去*/
    
29.         netlink_unicast(netlinkfd, skb, msg->pid, MSG_DONTWAIT);
    
30.        
    
31.         printk("kernel send over\n");
    
32.              kfree(needtosend);
    
33.         return 0;
    
34. }
    
35. 這個方法用戶態(tài)recv的時候能收到數(shù)據(jù)，并且打印出來。
    

復制代碼

但是這種方法不行：

1. void kernel_receive(struct sk_buff *skb)
   
2. {
   
3.         printk("#########recv###########\n");
   
4.         kernel_thread(process_message_thread, skb, CLONE_KERNEL);
   
5.         printk("#########leave###########\n");
   
6. }
   

復制代碼

這個方法不行，用戶態(tài)一直阻塞的在recv。
不知道哪位能幫兄弟解決一下疑惑

mrpre

打了調(diào)試信息嚇我一跳：
在用kernel_thread的情況下，我新alloc_skb的data指針指向的地址，和入?yún)⑴f的skbdata指向的地址是一樣的。。

所以可否理解：
A線程創(chuàng)建B線程，A線程的skb當做B線程的入?yún)�，A線程skb的data指向的緩沖區(qū)被釋放，所以B線程alloc_skb的skb指向的data就用之前的緩沖區(qū)了。