命名管道创建

Question

我正在尝试使用命名管道。我有一个读取信息的进程和另一个将信息写入管道的进程。

这是我的阅读器进程的简化代码：

main (int argc, char *argv[]) {
  int fd, mkn;
  char message[100];

  if(unlink("aPipe") == -1) {
      perror("Error unlinking:");
  }


  if((mkn = mknod("aPipe", S_IFIFO, 0)) < 0){
    perror("Error mknod:");
  }

  if(chmod("aPipe", 0660)) {
    perror("Error chmod:");
   }

  if(fd = open("aPipe", O_RDONLY) < 0) {
    perror("Error abriendo el PIPE");
   }

    printf("going to read..\n");

close(fd);
}

但它永远卡在这一行： if(fd = open("aPipe", O_RDONLY) <0) ，我真的不明白为什么。

如果您知道哪个手册页说明了这里发生的情况，请告诉我:)

Answer 1

FIFO 有点奇怪； open() 作为写入者将阻塞，直到有读取者为止，反之亦然。更糟糕的是，就像真正的管道一样，当写入器关闭其末端时，读取端将永远返回 EOF；您必须关闭并重新打开（阻止下一个读者）。或者您open(fifo, O_RDWR)，然后您需要某种方法来知道编写器何时完成，例如让它仅使用单行或具有带内 EOF 数据包。

Answer 2

代码如下：

读者：

#include <stdio.h>
#include <unistd.h> 
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

readline(int fd, char *str) {
int n;
do {
    n = read(fd, str, 1);
    if(n == -1){
        perror("Error reading:");
    }
}
while(n > 0 && (str++) != NULL);

return(n > 0);

}

main (int argc, char *argv[]) {
int fd, mkn;
char message[100];

if(unlink("aPipe") == -1) {
    perror("Error unlinking:");
}

if((mkn = mknod("aPipe", S_IFIFO, 0)) < 0){
    perror("Error mknod:");
}

if(chmod("aPipe", 0660)) {
    perror("Error chmod:");
}

if(fd = open("aPipe", O_RDONLY) < 0) {
    perror("Error abriendo el PIPE");
}
printf("going to read..\n");
while(readline(fd,message))
    printf("%s\n", message);
close(fd);
}

作者：

#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <string.h>

main (int argc, char *argv[]) {
int fd, messagelen,i;
char message[100];

sprintf(message, "Hello from PID %d", getpid());

messagelen = strlen(message) + 1;
do {
    fd = open("aPipe", O_WRONLY|O_NDELAY);
    if (fd == -1) {
        perror("opening aPipe:");
        sleep(1);
    }
}
while(fd == -1);

for (i = 1; i < 4; i++) {
    if(write(fd, message, messagelen) == -1) {
        perror("Error writing:");
    }
    sleep(3);
}
close(fd);
} 

我也必须学习makefifo，但是在我理解了这一点之后。

非常感谢您的宝贵帮助！

Answer 3

是否有进程写入 FIFO？
如果不是，这是预期的行为，因为您在阻塞模式下打开了 FIFO RDONLY，当前进程将不会继续，直到有进程实际写入 FIFO。