从 C 中的 FIFO 读取：select() 不返回？

Question

我正在编写一个 C 程序。 它的作用如下：

• 使用 mkfifo 创建 n 个 fifo
• 打开它们以供读取（设置 O_NONBLOCK 标志）
• 打开它们以进行写入
• 生成一个线程

在线程中，循环运行：

• 为所有 n 个 fifo 创建文件描述符的 fd_set
• 调用 select (n, &my_set, NULL, NULL, NULL)
• 对于每个准备好 I/O 的 fd (FD_ISSET(fd, &my_set))：
• 从 fd 读取一个字符串 (read(fd, buf, buf_len))
• 打印string
• 如果 string == "kill"，则将该 fd 标记为死亡，并将其从列表中删除 (n--)
• 如果 n == 0，则终止线程

在主程序中：

• 对于 i = 0 到 n
• 写入 fds[i ] 带有字符串 (write(fds[i], buf, buf_len))
• 对于 i = 0 到 n
• 用字符串“kill”写入 fds[i]
• 加入我创建的线程
• Exit

我看到的行为是select() 将返回一次，长度为 1，即列表中的第一个 fd。 第二次循环时， select 将永远坐在那里。

这是我的输出：

thread created
Waiting on 4 file descriptors
> Wrote 'Hello to target 0 from writer 0' to 0
> Wrote 'Hello to target 0 from writer 1' to 1
> Wrote 'Hello to target 1 from writer 0' to 2
> Wrote 'Hello to target 1 from writer 1' to 3
> Sending kill to 0:0 (#0)
> Sending kill to 0:1 (#1)
> Sending kill to 1:0 (#2)
> Sending kill to 1:1 (#3)
< Got string: 'Hello to target 0 from writer 0'
Waiting on 4 file descriptors
^C

操作系统是 Linux，以防万一。

代码链接： https://dl.getdropbox.com/u/188590/fifotest .c （抱歉有点恶心）

Answer 1

正如 Lance Richardson 所说，第一个问题是您需要传递最大文件描述符的数量加一，而不是文件描述符的数量。

然后你必须清理侦听器线程中的内务工作 - 我获得了大部分数据，但最终侦听了 6 个文件描述符，而不是 4 个。（报告的数字现在是最大的fd，而不是文件描述符的数量。）

您还遇到一个问题，即向每个管道写入一个字符串加一个空字节，然后再写入一个字符串加一个空字节。 由于调度是不确定的，主程序实际上将其两个字符串写入每个 fifo，因此当侦听器线程开始读取它时，它会读取两个字符串。 当我打印长度时，我得到的总长度为 41 个 read (read_len)，但每个 strlen() 的字符串长度是 31。换句话说，第一次阅读包含“kill”部分，但您在打印输出中没有注意到，因为第一条消息末尾有尾随空值。 因此，你在等待永远不会发生的事情。

Answer 2

调用 select() 时的第一个参数应该是编号最大的文件描述符加 1，而不是 fd_set 中文件描述符的数量。

以下是我为解决此问题所做的更改：

--- fifotest-1.c        2009-05-22 23:44:03.000000000 -0400
+++ fifotest.c  2009-05-22 23:34:00.000000000 -0400
@@ -34,19 +34,22 @@
     sim_arg_t* ifs = arg;
     uint32_t num_ifs;
     uint32_t select_len;
+    int maxfd;

        num_ifs = ifs->num_ifs;
     while (num_ifs > 0) {
                FD_ZERO (&set);
                select_len = 0;
-               for (i = 0; i < ifs->num_ifs; ++i) {
+               for (maxfd=0, i = 0; i < ifs->num_ifs; ++i) {
                        if (ifs->if_list[i].valid) {
                                FD_SET(ifs->if_list[i].fh, &set);
-                               ++select_len;
+                               if (ifs->if_list[i].fh > maxfd)
+                                   maxfd = ifs->if_list[i].fh;
+                               select_len++;
                        }
                }
                printf("Waiting on %d file descriptors\n", select_len);
-               ret = select(select_len, &set, NULL, NULL, NULL);
+               ret = select(maxfd+1, &set, NULL, NULL, NULL);
                if (ret < 0) {
                        fprintf(stderr, "Select returned error!\n");
                        continue;