Chinaunix

标题: 非阻塞FIFO读的时候产生的错误,请教为什么? [打印本页]
作者: grt8000    时间: 2006-06-22 17:11
标题: 非阻塞FIFO读的时候产生的错误,请教为什么?
非阻塞读FIFO的程序: read_fifo.c


  2. #include <sys/types.h>
  3. #include <sys/stat.h>
  4. #include <unistd.h>
  5. #include <fcntl.h>
  6. #include <errno.h>

  8. #define FIFO_PATH   "/tmp/test_fifo"
  9. #define LEN  1000

  11. int main(void)
  12. {
  13.      int fd, n;
  14.      char buf[LEN] ;

  16.      if (mkfifo(FIFO_PATH, 0600) < 0) {        // 创建FIFO
  17.           if (errno != EEXIST) {
  18.                perror("mkfifo");
  19.                exit(-1);
  20.           }
  21.      }

  23.      if ((fd = open(FIFO_PATH, O_RDONLY|O_NONBLOCK)) < 0) {     // 非阻塞读打开FIFO
  24.           perror("open fifo");
  25.           exit(-1);
  26.      }

  28.      while(1) {                     // 循环读FIFO
  29.           n = read(fd, buf, LEN);
  30.           printf("n = %d\n", n);

  32.           if (n < 0) {              // 读错误,退出
  33.                perror("read");
  34.                exit(-1);
  35.           }

  37.           if (n == 0) {             // 未读到数据, 休眠2秒, 继续读
  38.                sleep(2);
  39.                continue;
  40.           }
  41.      }

  43.      close(fd);

  45.      return 0;
  46. }
复制代码



阻塞写FIFO的程序: write_fifo.c


  2. #include <sys/types.h>
  3. #include <sys/stat.h>
  4. #include <unistd.h>
  5. #include <fcntl.h>
  6. #include <errno.h>

  8. #define FIFO_PATH   "/tmp/test_fifo"
  9. #define LEN 6800

  11. int main(void)
  12. {
  13.      int fd, n;
  14.      int sum = 0;
  15.      char buf[LEN] ;

  17.      if ((fd = open(FIFO_PATH, O_WRONLY)) < 0) {         // 阻塞只写方式打开FIFO
  18.           perror("open fifo");
  19.           exit(-1);
  20.      }

  22. // 循环写,直到把全部数据写完
  23.      while(1) {
  24.           n = write(fd, &buf[sum], LEN-sum);         // 写FIFO
  25.           printf("n = %d\n", n);

  27.           if (n < 0) {                         // 写错误退出
  28.                perror("read");
  29.                exit(-1);
  30.           }

  32.           sum += n;                 //  累加已经写的字节数

  34.           if (sum == LEN)           // 如果已经写完,退出
  35.                break;
  36.      }

  38.      printf("sum = %d\n", sum);

  40.      close(fd);

  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    时间: 2006-06-22 17:17
应该是linux系统下的吧
有一个系统默认的PIPE_BUF = 4096

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

[ 本帖最后由 yeehya 于 2006-6-22 17:22 编辑 ]
作者: grt8000    时间: 2006-06-22 17:27
是在Linux平台.
FIFO好象有点不一样, 为什么会报错呢? 看起来象是读先错了, 是什么原因?
而且程序有时会运行正常,有时会出这种错误.
作者: grt8000    时间: 2006-06-22 17:29
如果把非阻塞读换成阻塞读,即是去掉read_fifo.c中的O_NONBLOCK, 程序运行就没出过错.
作者: yeehya    时间: 2006-06-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
作者: grt8000    时间: 2006-06-23 09:58
原帖由 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    时间: 2006-07-03 23:09
fifo的读写和socket的读写基本是一样的，你的程序的可靠性也就是前几次了。
作者: FH    时间: 2006-07-04 08:25
对非阻塞的管道就是有这个问题，编程解决。
作者: ping17909    时间: 2006-07-04 20:30
读得比写得快，当然读不到



欢迎光临 Chinaunix (http://bbs.chinaunix.net/) Powered by Discuz! X3.2