非阻塞FIFO读的时候产生的错误,请教为什么?

grt8000

非阻塞读FIFO的程序: read_fifo.c

1. 
   
2. #include <sys/types.h>
   
3. #include <sys/stat.h>
   
4. #include <unistd.h>
   
5. #include <fcntl.h>
   
6. #include <errno.h>
   
7. 
   
8. #define FIFO_PATH   "/tmp/test_fifo"
   
9. #define LEN  1000
   
10. 
    
11. int main(void)
    
12. {
    
13.      int fd, n;
    
14.      char buf[LEN] ;
    
15. 
    
16.      if (mkfifo(FIFO_PATH, 0600) < 0) {        // 创建FIFO
    
17.           if (errno != EEXIST) {
    
18.                perror("mkfifo");
    
19.                exit(-1);
    
20.           }
    
21.      }
    
22. 
    
23.      if ((fd = open(FIFO_PATH, O_RDONLY|O_NONBLOCK)) < 0) {     // 非阻塞读打开FIFO
    
24.           perror("open fifo");
    
25.           exit(-1);
    
26.      }
    
27. 
    
28.      while(1) {                     // 循环读FIFO
    
29.           n = read(fd, buf, LEN);
    
30.           printf("n = %d\n", n);
    
31. 
    
32.           if (n < 0) {              // 读错误,退出
    
33.                perror("read");
    
34.                exit(-1);
    
35.           }
    
36. 
    
37.           if (n == 0) {             // 未读到数据, 休眠2秒, 继续读
    
38.                sleep(2);
    
39.                continue;
    
40.           }
    
41.      }
    
42. 
    
43.      close(fd);
    
44. 
    
45.      return 0;
    
46. }
    

复制代码

阻塞写FIFO的程序: write_fifo.c

1. 
   
2. #include <sys/types.h>
   
3. #include <sys/stat.h>
   
4. #include <unistd.h>
   
5. #include <fcntl.h>
   
6. #include <errno.h>
   
7. 
   
8. #define FIFO_PATH   "/tmp/test_fifo"
   
9. #define LEN 6800
   
10. 
    
11. int main(void)
    
12. {
    
13.      int fd, n;
    
14.      int sum = 0;
    
15.      char buf[LEN] ;
    
16. 
    
17.      if ((fd = open(FIFO_PATH, O_WRONLY)) < 0) {         // 阻塞只写方式打开FIFO
    
18.           perror("open fifo");
    
19.           exit(-1);
    
20.      }
    
21. 
    
22. // 循环写,直到把全部数据写完
    
23.      while(1) {
    
24.           n = write(fd, &buf[sum], LEN-sum);         // 写FIFO
    
25.           printf("n = %d\n", n);
    
26. 
    
27.           if (n < 0) {                         // 写错误退出
    
28.                perror("read");
    
29.                exit(-1);
    
30.           }
    
31. 
    
32.           sum += n;                 //  累加已经写的字节数
    
33. 
    
34.           if (sum == LEN)           // 如果已经写完,退出
    
35.                break;
    
36.      }
    
37. 
    
38.      printf("sum = %d\n", sum);
    
39. 
    
40.      close(fd);
    
41. 
    
42.      return 0;
    
43. }
    

复制代码

运行结果:
read_fifo的输出:
n = 0
n = 1000
n = 1000
n = 1000
n = 1000
n = 96
n = -1
read: Resource temporarily unavailable

write_fifo的输出:
n = 4096
断开的管道

请教什么原因产生的这种错误?

PS: 也不是总是产生错误, 有时也会正确运行

[ 本帖最后由 grt8000 于 2006-6-22 17:13 编辑 ]

yeehya

应该是linux系统下的吧
有一个系统默认的PIPE_BUF = 4096

一种可以避免的法子是在read 和 write之前,用select进行判断是否可读写.

[ 本帖最后由 yeehya 于 2006-6-22 17:22 编辑 ]

grt8000

是在Linux平台.
FIFO好象有点不一样, 为什么会报错呢? 看起来象是读先错了, 是什么原因?
而且程序有时会运行正常,有时会出这种错误.

grt8000

如果把非阻塞读换成阻塞读,即是去掉read_fifo.c中的O_NONBLOCK, 程序运行就没出过错.

yeehya

O_NONBLOCK enabled, n <= PIPE_BUF
If there is room to write n bytes to the pipe, then write(2) succeeds immediately, writing all n bytes; otherwise write(2) fails, with errno set to EAGAIN

grt8000

原帖由 yeehya 于 2006-6-23 09:03 发表
O_NONBLOCK enabled, n <= PIPE_BUF
If there is room to write n bytes to the pipe, then write(2) succeeds immediately, writing all n bytes; otherwise write(2) fails, with errno set to EAGAIN

写FIFO的时候是阻塞写的,只是在读的时候为非阻塞读

yuanyawei

fifo的读写和socket的读写基本是一样的，你的程序的可靠性也就是前几次了。

FH

对非阻塞的管道就是有这个问题，编程解决。

ping17909

读得比写得快，当然读不到