socket 通信，ARM上和PC上跑的结果不一样，一个能立即响应最新命令，一个不能立即响应

sasinop

UDP

相同的代码：
ARM 和PC上，唯一区别就是 交叉编译了一下
在PC上的表现结果：
1ms定时发 一组命令，发一段时间后，换一个新命令，能立即返回新命令的结果；
ARM上的表现结果：
1ms定时发一组命令，发一段时间后，换一个新命令，不能立即返回新命令的结果，总要先执行几条前面一条命令的结果，也是就要多发几次新命令，才是想要的结果。





查看了两个系统的缓冲区大小如下：

1. [root@FORLINX6410]# sysctl -a | grep rmem
   
2. net.core.rmem_max = 108544
   
3. net.core.rmem_default = 108544
   
4. sysctl: error reading key 'net.ipv4.route.flush': Permission denied
   
5. net.ipv4.tcp_rmem = 4096        87380   260096
   
6. net.ipv4.udp_rmem_min = 4096
   
7. [root@FORLINX6410]#
   
8. 
   
9. 
   
10. 
    
11. root@ubuntu:/mnt/hgfs/vmshare# sysctl -a | grep rmem
    
12. error: permission denied on key 'vm.compact_memory'
    
13. error: "Invalid argument" reading key "fs.binfmt_misc.register"
    
14. error: "Invalid argument" reading key "dev.parport.parport0.autoprobe"
    
15. error: "Invalid argument" reading key "dev.parport.parport0.autoprobe0"
    
16. error: "Invalid argument" reading key "dev.parport.parport0.autoprobe1"
    
17. error: "Invalid argument" reading key "dev.parport.parport0.autoprobe2"
    
18. error: "Invalid argument" reading key "dev.parport.parport0.autoprobe3"
    
19. net.core.rmem_max = 131071
    
20. net.core.rmem_default = 163840
    
21. error: permission denied on key 'net.ipv4.route.flush'
    
22. net.ipv4.tcp_rmem = 4096        87380        905792
    
23. net.ipv4.udp_rmem_min = 4096
    
24. error: permission denied on key 'net.ipv6.route.flush'
    
25. root@ubuntu:/mnt/hgfs/vmshare#

复制代码

cjaizss

回复 1# sasinop
个人怀疑是写代码不注意，导致优化之后结果与预期有差距
无代码无真相


   

sasinop

回复 2# cjaizss

1. 
   
2. void* udpReadata()
   
3. {
   
4.         char c;        //        test spi error temp
   
5.         int i;       
   
6.   unsigned char recvbuf[MAXBUF];
   
7.   unsigned char sendbuf[MAXBUF];
   
8.   unsigned char queuecmd[4];
   
9.   int  ret;   
   
10.   // command queue
    
11.   Queue q;
    
12.   ElemType e_tmp;
    
13.   InitQueue(&q);
    
14.   
    
15.   bzero(recvbuf, MAXBUF );
    
16.   bzero(sendbuf, MAXBUF );
    
17. 
    
18. 
    
19. /* 创建 EPOLL 句柄，把监听 socket 加入到 epoll 集合里 */
    
20.   kdpfd = epoll_create(MAXEPOLLSIZE);
    
21.   len = sizeof(struct sockaddr_in);
    
22.   ev.events = EPOLLIN | EPOLLET;
    
23.   ev.data.fd = listener;
    
24.   if (epoll_ctl(kdpfd, EPOLL_CTL_ADD, listener, &ev) < 0)
    
25.   {
    
26.     fprintf(stderr, "epoll set insertion error: fd=%d \n", listener);   
    
27.   }
    
28.   else
    
29.   {
    
30.     printf("Listen socket added in  epoll success \n");   
    
31.   }
    
32.   while (1)
    
33.   {   
    
34.     nfds = epoll_wait(kdpfd, events_udp, 10,-1 );
    
35.     printf("nfds values: %d ",nfds);       
    
36.     if (nfds == -1)
    
37.     {
    
38.       perror("epoll_wait \n");
    
39.       break;
    
40.     }
    
41.     printf(" epoll wait ok \n");
    
42.    
    
43.     for (n = 0; n < nfds; ++n)
    
44.     {
    
45.       if (events_udp[n].data.fd == listener)
    
46.       {
    
47.               new_fd=events_udp[n].data.fd;                          
    
48.                           int optudp =0; //设接收缓冲区为0 ，，，如果这地方不设置为0，PC上跑，在持续发一个命令一段时间后，再发新命令也不能立即响应。
    
49.                           setsockopt(new_fd, SOL_SOCKET, SO_RCVBUF, &optudp, sizeof(optudp));
    
50.                           ret = recvfrom(new_fd, recvbuf, MAXBUF, 0, (struct sockaddr *)&client_addr, &cli_len);                          
    
51.                           if (ret > 0)
    
52.                                   {                                  
    
53.                                     printf("\n");
    
54.                                     printf("revc Data length from PC:%d \n",ret);
    
55.                                     for(i=0;i<ret;i++)
    
56.                                             printf("%02X ",recvbuf[i]);                                            
    
57.                                     printf("\n");       
    
58.                                                                                  
    
59.                                     Receive_Process(ret,recvbuf);//处理命令包函数
    
60.                                         }
    
61.                                   else
    
62.                                   {
    
63.                                     printf("received failed! error code %d ??message : %s \n",errno, strerror(errno));   
    
64.                                   }
    
65.           
    
66.                                   fflush(stdout);  
    
67.                         }
    
68.                 }
    
69.         }
    
70. }
    

复制代码

在交叉编译时，开启了不优化操作，还是不能，但是发现一个奇怪现象，

持续发一个命令，比如10W次， 再换新命令，待新命令发到第7次后，新命令才能被正确执行...
这个现象很有规律，尝试了很多次，都是7次后，新命令得到执行



   

sasinop

准备加队列，所有命令入队列，还未完成