linux串口poll多路读取的数据被截断问题

stm32f103vct

1. /****************************************************************************
   
2. *                                                                          *
   
3. * Copyright (c) 2014 Nuvoton Technology Corp. All rights reserved.         *
   
4. *                                                                          *
   
5. ****************************************************************************/
   
6. 
   
7. /****************************************************************************
   
8. *
   
9. * FILENAME
   
10. *     uart_test.c
    
11. *
    
12. * VERSION
    
13. *     1.0
    
14. *
    
15. * DESCRIPTION
    
16. *     This is the test program used to test the UARTs on NUC970 EV board
    
17. *
    
18. * DATA STRUCTURES
    
19. *     None
    
20. *
    
21. * FUNCTIONS
    
22. *     None
    
23. *
    
24. * HISTORY
    
25. *     
    
26. *
    
27. * REMARK
    
28. *     None
    
29. ****************************************************************************/
    
30. #include     <stdio.h>
    
31. #include     <stdlib.h>
    
32. #include     <unistd.h>
    
33. #include     <sys/types.h>
    
34. #include     <sys/stat.h>
    
35. #include     <fcntl.h>
    
36. #include     <termios.h>  
    
37. #include     <errno.h>
    
38. #include     <string.h>
    
39. #include         <signal.h>
    
40. #include    <pthread.h>
    
41. 
    
42. #define FALSE 0
    
43. #define TRUE  1
    
44. 
    
45. int fd[2];
    
46. 
    
47. pthread_t threads[10];
    
48. char ucbuff[50];
    
49. char buf[] = "hello ZLG!";
    
50. 
    
51. static struct termios newtios,oldtios; /*termianal settings */
    
52. static int saved_portfd=-1;            /*serial port fd */
    
53. 
    
54. 
    
55. static void reset_tty_atexit(void)
    
56. {
    
57.         if(saved_portfd != -1)
    
58.         {
    
59.                 tcsetattr(saved_portfd,TCSANOW,&oldtios);
    
60.         }
    
61. }
    
62. 
    
63. /*cheanup signal handler */
    
64. static void reset_tty_handler(int signal)
    
65. {
    
66.         if(saved_portfd != -1)
    
67.         {
    
68.                 tcsetattr(saved_portfd,TCSANOW,&oldtios);
    
69.         }
    
70.         _exit(EXIT_FAILURE);
    
71. }
    
72. 
    
73. static int open_port(const char *portname)
    
74. {
    
75.         struct sigaction sa;
    
76.         int portfd;
    
77. 
    
78.         printf("opening serial port:%s\n",portname);
    
79.         /*open serial port */
    
80.         if((portfd=open(portname,O_RDWR | O_NOCTTY)) < 0 )
    
81.         {
    
82.                    printf("open serial port %s fail \n ",portname);
    
83.                    return portfd;
    
84.         }
    
85. 
    
86.         /*get serial port parnms,save away */
    
87.         tcgetattr(portfd,&newtios);
    
88.         memcpy(&oldtios,&newtios,sizeof newtios);
    
89.         /* configure new values */
    
90.         cfmakeraw(&newtios); /*see man page */
    
91.         newtios.c_iflag |=IGNPAR; /*ignore parity on input */
    
92.         newtios.c_oflag &= ~(OPOST | ONLCR | OLCUC | OCRNL | ONOCR | ONLRET | OFILL);
    
93.         newtios.c_cflag = CS8 | CLOCAL | CREAD;
    
94.         newtios.c_cc[VMIN]=1; /* block until 1 char received */
    
95.         newtios.c_cc[VTIME]=0; /*no inter-character timer */
    
96.         /* 115200 bps */
    
97.         cfsetospeed(&newtios,B115200);
    
98.         cfsetispeed(&newtios,B115200);
    
99.         /* register cleanup stuff */
    
100.         atexit(reset_tty_atexit);
     
101.         memset(&sa,0,sizeof sa);
     
102.         sa.sa_handler = reset_tty_handler;
     
103.         sigaction(SIGHUP,&sa,NULL);
     
104.         sigaction(SIGINT,&sa,NULL);
     
105.         sigaction(SIGPIPE,&sa,NULL);
     
106.         sigaction(SIGTERM,&sa,NULL);
     
107.         /*apply modified termios */
     
108.         saved_portfd=portfd;
     
109.         tcflush(portfd,TCIFLUSH);
     
110.         tcsetattr(portfd,TCSADRAIN,&newtios);
     
111.         return portfd;
     
112. }
     
113. 
     
114. 
     
115. /**
     
116. *@breif         main()
     
117. */
     
118. int main(int argc, char **argv)
     
119. {
     
120.          fd_set  recv_fds;  /* 定义接收fds  一个存放文件描述符(file descriptor)，即文件句柄的聚合，实际上是一long类型的数组 */
     
121.             int     maxfd   = 0;    /* 定义最大句柄 */
     
122.          int     fd_result;
     
123.          struct  timeval tv;       /* 超时时间 */
     
124.         char *dev[10]={"/dev/ttyS1", "/dev/ttyS2"};
     
125.         unsigned int i,len;
     
126. 
     
127.         printf("\n demo uart1/uart2 external loop back function \n");
     
128. 
     
129.         for(i = 0; i < 2; i++)
     
130.         {
     
131.                 if((fd[i] = open_port(dev[i]))<0)
     
132.                            return -1;
     
133.         }
     
134.             tv.tv_sec   = 10;       //设定超时时间
     
135.             tv.tv_usec  = 0;          //10000us = 10ms
     
136.         if(fd[0] > maxfd)                            /* maxfd 为最大值  */
     
137.             {
     
138.                         maxfd = fd[0];
     
139.             }
     
140.             if(fd[1] > maxfd)
     
141.             {
     
142.                 maxfd = fd[1];
     
143.             }
     
144.         for(;;)
     
145.             {   
     
146.                 /* 注意每次都要重新设置 */
     
147.                 FD_ZERO(&recv_fds);
     
148.                 FD_SET(fd[0],&recv_fds);                                /* 分别把句柄加入读监视集合里去   */
     
149.                 FD_SET(fd[1],&recv_fds);                                /* 分别把句柄加入读监视集合里去   */
     
150. 
     
151.                 fd_result = select(maxfd + 1, &recv_fds, NULL, NULL, &tv);  /* 注意是最大值加1                   */
     
152.                 if(fd_result < 0)
     
153.                 {
     
154.                 printf("select err");                               /* select函数出错                 */
     
155.             usleep(10000);
     
156.             continue;
     
157.                 }
     
158.          else if(fd_result == 0)
     
159.          {
     
160.             // printf("select time out \n"); /* 在设定的tv时间内，socket的状态没有发生变化 */
     
161.             usleep(10000);
     
162.             continue;
     
163.          }
     
164.          else                                                        /* 开始读数据 */
     
165.          {
     
166.             if(FD_ISSET(fd[0], &recv_fds))                      /* 先判断一下是哪个句柄可读 */
     
167.                 {
     
168.                 len  = read(fd[0],ucbuff,0xff);               /*  读取串口数据  */
     
169.                 printf("%d \n", len);
     
170.                                 /*
     
171.                                   ** 数据解析
     
172.                                   */        
     
173.             }   
     
174.             if(FD_ISSET(fd[1], &recv_fds))                      /* 先判断一下是哪个句柄可读 */
     
175.                 {
     
176.                 len  = read(fd[1],ucbuff,0xff);                /*  读取串口数据  */
     
177.                                 /*
     
178.                                   ** 数据解析
     
179.                                   */        
     
180.                }
     
181.          }
     
182.         printf("%s \n", ucbuff);
     
183.        }
     
184.         
     
185. 
     
186.         return(0);
     
187.          
     
188. }

复制代码

结果如图数据被截断：