在命名管道中使用 open 函数

Question

我有两个进程。
先读后写。
其他人会先写然后读。
我想用两个管道来实现它。

这是我的实现

/***READ BEFORE WRITE*****/
#include <fcntl.h>
#include <stdio.h>
#include <sys/stat.h>
#include <unistd.h>
#define MAX_BUF 1024

int main()
{
 int fd,fd1;
 char buf[MAX_BUF];
 char * myfifo = "/home/aditya/Desktop/myfifo";
 char * mynewfifo = "/home/aditya/Desktop/mynewfifo";

 mkfifo(mynewfifo, 0666);

 printf("Read before writing\n");   
 printf("Before opening\n");

 fd = open(myfifo, O_RDONLY);
 fd1 = open(mynewfifo, O_WRONLY);
 printf("After opening\n");


 read(fd, buf, MAX_BUF);
 printf("Received: %s\n", buf);
 close(fd);

 printf("reader is writing\n"); 
 write(fd1, "Hi", sizeof("Hi"));
 close(fd1);    

unlink(mynewfifo);  

return 0;
}


/**** Wriiting after Reading ******/              
#include <fcntl.h>
#include <stdio.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>

int main()
{
 int fd,fd1;
 char * myfifo = "/home/aditya/Desktop/myfifo";
 char * mynewfifo = "/home/aditya/Desktop/mynewfifo";
 char buf[1024];    

 mkfifo(myfifo, 0666);

 printf("writing before reading\n");

 printf("Before opening\n");

 fd = open(myfifo, O_WRONLY);
 fd1=open(mynewfifo,O_RDONLY);  
 printf("After opening\n");

 write(fd, "Hi", sizeof("Hi"));
 close(fd);

 printf("Writer is reading\n"); 
 read(fd1, buf, 1024);
 printf("Received: %s\n", buf);
 close(fd1);

/* remove the FIFO */
unlink(myfifo);

return 0;
}

当我先运行“读后写”然后“写后读”时，它似乎工作。
但是当我反之亦然（即运行“写入后读取”）时，它们会打印“打开前”并继续运行。

请解释我做错了什么。

Answer 1

问题是您的 READ AFTER WRITE 程序从尚未创建的命名管道 myfifo 读取。当您首先尝试执行 READ AFTER WRITE 程序时。我在您的程序中添加了以下两个条件（请参见下面的代码），以检查您的名称管道中是否存在问题，并且在您第一次执行 READ AFTER WRITE 程序时确实弹出了一个问题，即您的 myfifo 管道未创建。

现在发生的情况是，由于未创建管道，因此您的 READ AFTER WRITE 一直在等待其他一些进程写入，以便可以读取某些内容。另外，另一方面，您的第二个程序也一直处于“正在打开...”，因为另一方面没有阅读器来阅读它应该写的内容。

现在，当您首先执行第二个程序时，这个问题得到解决，因为已经创建了 myfifo 管道以供 READ AFTER WRITE 程序读取。这是真正合乎逻辑的，因为您试图从创建于你的第二个程序。

因此，请务必在您的程序中检查您正在使用的管道是否已创建。

/***READ AFTER WRITE*****/
#include <fcntl.h>
#include <stdio.h>
#include <sys/stat.h>
#include <unistd.h>
#define MAX_BUF 1024

int main()
{
 int fd,fd1;
 char buf[MAX_BUF];
 char * myfifo = "/home/aisha/Desktop/myfifo";
 char * mynewfifo = "/home/aisha/Desktop/mynewfifo";

 mkfifo(mynewfifo, 0666);

 printf("Read before writing\n");   
 printf("Before opening\n");

 fd = open(myfifo, O_RDONLY);
 if(fd<0)
 {
    printf("MYFIFO NOT MADE\n");
 }
 fd1 = open(mynewfifo, O_WRONLY);
 if(fd1<0)
 {
    printf("MYNEWFIFO NOT MADE\n");
 }

 sleep (2);
 printf("After opening\n");

 read(fd, buf, MAX_BUF);
 printf("Received: %s\n", buf);
 close(fd);

 printf("reader is writing\n"); 
 write(fd1, "Hi", sizeof("Hi"));
 close(fd1);    

unlink(mynewfifo);  


return 0;
}