linux多线程问题求助！！

js001sdx

回复 8# happy_fish100

感谢你的提醒！！
加上对nread的判断后！！单独跑的错误率比原来低些了！！
但在线程里基本没什么变化！！

js001sdx

以前做个一个类似的项目，LED，LCD，KEYBOARD,GPIO，RS232
1，丢数据的可能原因：
  一，线程调度有问题， ...
消失的地平線 发表于 2010-03-11 15:03

    觉得你的分析很有可能。我也一直在找这类原因，但因为刚接触线程，对线程的了解还很浅，所以一直没有头绪！！
另外贴一下我的串口初始化代码：
#define SERIAL1     "/dev/ttyAT1"   //CONNECT TO MCU FOR PS2 KEYBOARD
#define SERIAL2     "/dev/ttyAT2"
#define SERIAL3     "/dev/ttyAT3"

static int speed_arr[] = {B230400, B115200, B57600, B38400, B19200, B9600, B4800, B2400, B1800, B1200, B600, B300};
static int name_arr[]  = {230400,  115200,  57600,  38400,  19200,  9600,  4800,  2400,  1800,  1200,  600,  300};

int set_speed(int fd, int speed)
{
    int   i;
    int   status;
    struct termios   Opt;
    tcgetattr(fd, &Opt);

    for ( i= 0;  i < sizeof(speed_arr) / sizeof(int);  i++)
    {
        if (speed == name_arr)
        {     
            tcflush(fd, TCIOFLUSH);     
            cfsetispeed(&Opt, speed_arr);  
            cfsetospeed(&Opt, speed_arr);   
            status = tcsetattr(fd, TCSANOW, &Opt);  
            /*if  (status != 0)
            {        
                perror("tcsetattr fd");  
                return -1;     
            }*/
            tcflush(fd,TCIOFLUSH);   
            return 0;
        }  
    }
    return -1;
}

int set_other_attribute(int fd, int databits, int stopbits, int parity)
{
    struct termios options;

    if (tcgetattr(fd, &options) != 0)
    {
        perror("SetupSerial 1");     
        return -1;  
    }
    options.c_cflag &= ~CSIZE;
    switch (databits)
    {   
        case 7:     
            options.c_cflag |= CS7;
            break;
        case 8:     
            options.c_cflag |= CS8;
            break;   
        default:   
            fprintf(stderr,"Unsupported data size\n");
            return -1;  
    }
    switch (parity)
    {   
        case 'n':
        case 'N':   
            options.c_cflag &= ~PARENB;   
            options.c_iflag &= ~INPCK;     
            break;  
        case 'o':   
        case 'O':   
        case 1:
            options.c_cflag |= (PARODD | PARENB);
            options.c_iflag |= INPCK;           
            break;  
        case 'e':  
        case 'E':   
        case 2:
            options.c_cflag |= PARENB;      
            options.c_cflag &= ~PARODD;
            options.c_iflag |= INPCK;      
            break;
        case 'S':
        case 's':   
        case 0:
            options.c_cflag &= ~PARENB;
            options.c_cflag &= ~CSTOPB;
            break;  
        default:   
            fprintf(stderr,"Unsupported parity\n");   
            return -1;  
    }  
    switch (stopbits)
    {   
        case 1:   
            options.c_cflag &= ~CSTOPB;  
            break;  
        case 2:   
            options.c_cflag |= CSTOPB;  
            break;
        default:   
            fprintf(stderr,"Unsupported stop bits\n");  
            return -1;
    }
    options.c_cflag &= ~CRTSCTS;
   
    if (parity != 'n')   
        options.c_iflag |= INPCK;
    tcflush(fd,TCIFLUSH);
   
    options.c_oflag = 0;
    options.c_lflag = 0;  
    options.c_cc[VTIME] = 150;
    options.c_cc[VMIN] = 0;

if (tcsetattr(fd,TCSANOW,&options) != 0)   
    {
        perror("SetupSerial 3");   
        return -1;  
    }

#if 0   
    tcgetattr(fd, &options);
    printf("c_iflag: %x\rc_oflag: %x\n", options.c_iflag, options.c_oflag);
    printf("c_cflag: %x\nc_lflag: %x\n", options.c_cflag, options.c_lflag);
    printf("c_line: %x\nc_cc[VTIME]: %d\nc_cc[VMIN]: %d\n", options.c_line, options.c_cc[VTIME], options.c_cc[VMIN]);
#endif
    return 0;  
}

js001sdx

回复 10# 消失的地平線


    按照各位的提醒，已经加上了对nread 的判断！！但是在线程中任然存在相同的问题！！

消失的地平線

1. 
   
2. #define SERIAL1     "/dev/ttyAT1"   //CONNECT TO MCU FOR PS2 KEYBOARD
   
3. #define SERIAL2     "/dev/ttyAT2"
   
4. #define SERIAL3     "/dev/ttyAT3"
   
5. 
   
6. static int speed_arr[] = {B230400, B115200, B57600, B38400, B19200, B9600, B4800, B2400, B1800, B1200, B600, B300};
   
7. static int name_arr[]  = {230400,  115200,  57600,  38400,  19200,  9600,  4800,  2400,  1800,  1200,  600,  300};
   
8. 
   
9. int set_speed(int fd, int speed)
   
10. {
    
11.     int   i;
    
12.     int   status;
    
13.     struct termios   Opt;
    
14.     [color=Red]tcgetattr(fd, &Opt); /**/[/color]
    
15. 
    
16.     for ( i= 0;  i < sizeof(speed_arr) / sizeof(int);  i++)
    
17.     {
    
18.         if (speed == name_arr)
    
19.         {     
    
20.             tcflush(fd, TCIOFLUSH);     
    
21.             cfsetispeed(&Opt, speed_arr);  
    
22.             cfsetospeed(&Opt, speed_arr);   
    
23.             status = tcsetattr(fd, TCSANOW, &Opt);  
    
24.             /*if  (status != 0)
    
25.             {        
    
26.                 perror("tcsetattr fd");  
    
27.                 return -1;     
    
28.             }*/
    
29.             tcflush(fd,TCIOFLUSH);   
    
30.             return 0;
    
31.         }  
    
32.     }
    
33.     return -1;
    
34. }
    
35. 
    
36. int set_other_attribute(int fd, int databits, int stopbits, int parity)
    
37. {
    
38.     struct termios options;
    
39. 
    
40.     if (tcgetattr(fd, &options) != 0)
    
41.     {
    
42.         perror("SetupSerial 1");     
    
43.         return -1;  
    
44.     }
    
45.     options.c_cflag &= ~CSIZE;
    
46.     switch (databits)
    
47.     {   
    
48.         case 7:     
    
49.             options.c_cflag |= CS7;
    
50.             break;
    
51.         case 8:     
    
52.             options.c_cflag |= CS8;
    
53.             break;   
    
54.         default:   
    
55.             fprintf(stderr,"Unsupported data size\n");
    
56.             return -1;  
    
57.     }
    
58.     switch (parity)
    
59.     {   
    
60.         case 'n':
    
61.         case 'N':   
    
62.             options.c_cflag &= ~PARENB;   
    
63.             options.c_iflag &= ~INPCK;     
    
64.             break;  
    
65.         case 'o':   
    
66.         case 'O':   
    
67.         case 1:
    
68.             options.c_cflag |= (PARODD | PARENB);
    
69.             options.c_iflag |= INPCK;           
    
70.             break;  
    
71.         case 'e':  
    
72.         case 'E':   
    
73.         case 2:
    
74.             options.c_cflag |= PARENB;      
    
75.             options.c_cflag &= ~PARODD;
    
76.             options.c_iflag |= INPCK;      
    
77.             break;
    
78.         case 'S':
    
79.         case 's':   
    
80.         case 0:
    
81.             options.c_cflag &= ~PARENB;
    
82.             options.c_cflag &= ~CSTOPB;
    
83.             break;  
    
84.         default:   
    
85.             fprintf(stderr,"Unsupported parity\n");   
    
86.             return -1;  
    
87.     }  
    
88.     switch (stopbits)
    
89.     {   
    
90.         case 1:   
    
91.             options.c_cflag &= ~CSTOPB;  
    
92.             break;  
    
93.         case 2:   
    
94.             options.c_cflag |= CSTOPB;  
    
95.             break;
    
96.         default:   
    
97.             fprintf(stderr,"Unsupported stop bits\n");  
    
98.             return -1;
    
99.     }
    
100.     options.c_cflag &= ~CRTSCTS;
     
101.    
     
102.     if (parity != 'n')   
     
103.         options.c_iflag |= INPCK;
     
104.     tcflush(fd,TCIFLUSH);
     
105.    
     
106.     options.c_oflag = 0;
     
107.     options.c_lflag = 0;  
     
108.    [color=Red] options.c_cc[VTIME] = 150;／＊15s ??＊／[/color]
     
109.     options.c_cc[VMIN] = 0;
     
110. 
     
111. if (tcsetattr(fd,TCSANOW,&options) != 0)   
     
112.     {
     
113.         perror("SetupSerial 3");   
     
114.         return -1;  
     
115.     }
     
116. 
     
117. #if 0   
     
118.     tcgetattr(fd, &options);
     
119.     printf("c_iflag: %x\rc_oflag: %x\n", options.c_iflag, options.c_oflag);
     
120.     printf("c_cflag: %x\nc_lflag: %x\n", options.c_cflag, options.c_lflag);
     
121.     printf("c_line: %x\nc_cc[VTIME]: %d\nc_cc[VMIN]: %d\n", options.c_line, options.c_cc[VTIME], options.c_cc[VMIN]);
     
122. #endif
     
123.     return 0;  
     
124. }

复制代码

这是我的疑问；
1 是检测是否读取到了配置；
2 如果没记错的话 VTIME单位是1/10s 150太大了；
3，选择了VTIME VMIN 那么意味着你将使用阻塞模式来操作VART，那么OPEN是设备时的对选项O_NDELAY的操作

ferris2005

顺便想问下，你这串口读数据是怎么跳出大循环的。。。

ferris2005

不好意思，没看清楚代码。。。

js001sdx

顺便想问下，你这串口读数据是怎么跳出大循环的。。。
ferris2005 发表于 2010-03-12 10:15

    在数据流里收到0x16时，跳出循环的！！

ferris2005

数据流里面0x16不是退出while（read）么?

js001sdx

数据流里面0x16不是退出while（read）么?
ferris2005 发表于 2010-03-12 10:40

    谢谢你！！我传程序上来时没有while（read），后面在各位的提醒下，加上了while（read），但是忘记把while（1）去掉了，非常不好意思！！现在我已经把while（1）去掉了！！

js001sdx

这是我的疑问；
1 是检测是否读取到了配置；
2 如果没记错的话 VTIME单位是1/10s 150太大了；
3，选择了 ...
消失的地平線 发表于 2010-03-11 15:47

按照你的疑问，我正在仔细排查我的串口初始化！！不过我觉的现在的问题主要是线程切换机制问题吧！！因为我的串口部分单独跑过没啥问题！！偶尔会有收错的情况，但大部分是能收对的，主要是一把这部分合到大程序里，单独做线程就不行了！！
我会把近期的调试结果，尽可能详细的发上来，请大家指教！！