刚学netlink，第一次写netlink程序，有些疑问

mrpre

主要的目的是用户态发送消息给内核，内核回复消息给用户态。
我内核尝试了用2种方式回复。
一种是正常的处理，另一种是用kernel_thread一个线程，然后这个线程处理。
前一种用户态能正常收到，后一种用户态收不到数据，不知道问题在哪里。

1. 
   
2. 用户态程序：
   
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，内核回复消息的时候需要
    
13.                 int data_len;
    
14.                 char data[0];
    
15.         };
    
16. 
    
17.    u8 buf[1024] = {0};//存放内核传回的数据
    
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.             // 发送消息给内核
    
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;
    

复制代码

在内核中我用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.             /*打印出用户态传来的数据*/
    
15.         printk("kernel recv data:%s\n",msg->data);
    
16.         printk("kernel recv pid :%d\n",msg->pid);
    
17. 
    
18.              /*构造回复的数据*/
    
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.              /*发出去*/
    
29.         netlink_unicast(netlinkfd, skb, msg->pid, MSG_DONTWAIT);
    
30.        
    
31.         printk("kernel send over\n");
    
32.              kfree(needtosend);
    
33.         return 0;
    
34. }
    
35. 这个方法用户态recv的时候能收到数据，并且打印出来。
    

复制代码

但是这种方法不行：

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. }
   

复制代码

这个方法不行，用户态一直阻塞的在recv。
不知道哪位能帮兄弟解决一下疑惑

mrpre

打了调试信息吓我一跳：
在用kernel_thread的情况下，我新alloc_skb的data指针指向的地址，和入参旧的skbdata指向的地址是一样的。。

所以可否理解：
A线程创建B线程，A线程的skb当做B线程的入参，A线程skb的data指向的缓冲区被释放，所以B线程alloc_skb的skb指向的data就用之前的缓冲区了。