无法从多个 fifo 读取

Question

我在尝试读取多个 fifo 时遇到了一个非常烦人的问题。我有 1 个进程等待来自 fifo 的结构，并且很少有进程向他发送这些结构的信号。第一次阅读后，我无法从任何信号中读取更多内容。看起来程序冻结了。

发送进程在 main 中有这个

myfifo = '/tmp/myfifo{0}' //{0} is a number that every process has individual.
mkfifo(myfifo, 0666);
fd = open(myfifo, O_WRONLY);
write(fd, &demon1 , sizeof(demon1));
close(fd);
while (1)
{
}

这在 signal_handler 中

void signal_handler(int signum)
{
    if (signum == SIGUSR1)
    {
        //some declarations here
        mkfifo(myfifo, 0666);
        fd = open(myfifo, O_WRONLY | O_NONBLOCK);
        write(fd, &demon1 , sizeof(demon1));
    }
}

虽然阅读过程有

myfifo[i] = /tmp/myfifo{0} // {0} is i which is the number of process that sends.

 while(1)
 {
    for(i=0;i<n;i++)
    {
       fd = open(myfifo[i], O_RDONLY | O_NONBLOCK);
       r = read(fd, &demon1, sizeof(demon1));
       if(r > 1)
       {
           //printf struct elements
       }

    }
  }

Answer 1

您打开循环内的管道。这样一来，您很快就会用完文件描述符（如果您检查了open() 的结果是否有错误，您会看到）。

我建议打开循环外的所有 FIFO，将文件描述符存储在一个数组中，然后读取它们中的每一个，但是……读取会阻塞。请参阅select(2) 找出哪个 FIFO 有数据。

另一种解决方案是单个 FIFO，写入过程应在消息中发送它的 ID。这样，主进程只需要监听一个 FIFO。如果它想知道是谁发送的消息，它可以查看消息中的 ID。这里的问题：您需要某种锁定，否则多个进程将同时写入 FIFO，并且它们的数据可能混淆（这取决于 FIFO 缓冲区）。

Answer 2

打开阅读后不要关闭文件描述符：

while(1)
{
    for(i=0;i<n;i++)
    {
       fd = open(myfifo[i], O_RDONLY | O_NONBLOCK);
       r = read(fd, &demon1, sizeof(demon1));
       if(r > 1)
       {
           //printf struct elements
       }

这里缺少close(fd)。

    }
}

由于打开是非阻塞的，很快就会达到每个进程的最大 fd 数，后续打开会失败。