linux – 使用EOF在未命名的管道上发送信号

我有一个测试程序,它使用用pipe()创建的未命名管道在 Linux系统上使用fork()创建的父进程和子进程之间进行通信.

通常,当发送进程关闭管道的写入fd时,接收进程从read()返回值0,表示EOF.

但是,似乎如果我在管道中填充了大量数据(在接收器开始读取之前可能是100K字节0),接收器在读取管道中的所有数据后就会阻塞 – 即使发送器已关闭它.

我已经验证发送过程已经用lsof关闭了管道,并且看起来非常清楚接收器被阻塞了.

这导致了一个问题：关闭管道的一端是一个可靠的方法让接收器知道没有更多的数据？

如果是,并且没有条件可以导致空的,关闭的FIFO上的read()阻塞,那么我的代码就会出错.如果不是,这意味着我需要找到一种发信号通知数据流结束的替代方法.

解析度

我很确定最初的假设是正确的,关闭管道导致阅读器侧的EOF,这个问题只是在黑暗中拍摄 – 想想可能有一些我忽略的微妙的管道行为.几乎你用管道看到的每个例子都是一个发送几个字节并退出的玩具.当您不再进行原子操作时,事情通常会有所不同.

无论如何,我试图简化我的代码以清除问题并成功找到我的问题.在伪代码中,我最终做了这样的事情：

create pipe1
if ( !fork() ) {
    close pipe1 write fd
   do some stuff reading pipe1 until EOF
}
create pipe2
if ( !fork() )  {
   close pipe2 write fd
   do some stuff reading pipe2 until EOF
}
close pipe1 read fd
close pipe2 read fd
write data to pipe1
get completion response from child 1
close pipe1 write fd
write data to pipe2
get completion response from child 2
close pipe2 write fd
wait for children to exit

子进程读取管道1挂起,但只有当管道中的数据量变得很大时才会挂起.即使我关闭了child1正在阅读的管道,这种情况仍在发生.

查看源代码可以看出问题所在.当我分叉第二个子进程时,它抓取了自己的pipe1文件描述符副本,这些描述符保持打开状态.尽管只有一个进程应该写入管道,但在第二个进程中打开它会使其无法进入EOF状态.

这个问题没有出现在小型数据集中,因为child2正在迅速完成业务并退出.但是对于更大的数据集,child2没有快速返回,我最终陷入僵局.

解决方法

当写入器关闭写入结束时,read应返回EOF.

既然你做了一个管道,然后是一个fork,那么两个进程都会打开write fd.可能是在读者进程中你忘记关闭管道的写入部分.

警告：自从我在Unix上编程以来已经有很长一段时间了.所以它可能是不准确的.

以下是一些代码：http://www.cs.uml.edu/~fredm/courses/91.308/files/pipes.html.请查看下面的“关闭未使用”评论.

#include <stdio.h>

/* The index of the "read" end of the pipe */
#define READ 0

/* The index of the "write" end of the pipe */
#define WRITE 1

char *phrase = "Stuff this in your pipe and smoke it";

main () {
  int fd[2],bytesRead;

  char message [100]; /* Parent process message buffer */

  pipe ( fd ); /*Create an unnamed pipe*/

  if ( fork ( ) == 0 ) {
    /* Child Writer */
    close (fd[READ]); /* Close unused end*/
    write (fd[WRITE],phrase,strlen ( phrase) +1); /* include NULL*/
    close (fd[WRITE]); /* Close used end*/
    printf("Child:  Wrote '%s' to pipe!\n",phrase);

  } else {

    /* Parent Reader */
    close (fd[WRITE]); /* Close unused end*/ 
    bytesRead = read ( fd[READ],message,100);
    printf ( "Parent: Read %d bytes from pipe: %s\n",bytesRead,message);
    close ( fd[READ]); /* Close used end */
  } 
}

linux – 使用EOF在未命名的管道上发送信号

解决方法

猜你在找的Linux相关文章