從C：中讀取FIFO：select（）不返回？

Question

我正在寫一個C程序。下面介紹一下它的作用：

• 創建N使用mkfifo
• 打開它們讀取（與O_NONBLOCK標誌）
• 打開他們寫
• 產生一個線程

在FIFO的線程運行在一個循環中：

• 創建一個fd_set描述文件對於所有n FIFO的職權範圍
• 通話選擇（N，& my_set，NULL，NULL，NULL）
• 對於每一個的fd準備好進行I/O（FD_ISSET（FD，& my_set））：
  • 閱讀從FD字符串（讀（FD，BUF，buf_len））
  • 打印字符串
  • 如果字符串== 「殺」，標誌着FD已經死了，從列表中刪除（N--）
  • 如果n == 0，則終止線程

在主程序：

• 對於i = 0至n
  • 寫入FDS [I]與一個字符串（寫（FDS [I]，buf中，buf_len） ）
• 對於i = 0至n
  • 寫入FDS [I]與字符串 「殺」
• 加入的線程上，我創建
• 退出

我所看到的行爲是選擇（）將與長度1回一次，是在列表中的第一個FD。通過循環第二次，選擇將永遠坐在那裏。

這裏是我的輸出：

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

正如蘭斯·理查森說，第一個問題是，你需要傳遞的最大文件描述符的數量加一，而不是文件描述符的數量。

然後你必須清理在偵聽線程管家 - 我大部分的數據，但最終聽6個文件描述符，而不是4（報告的數量是目前規模最大的FD，不文件描述符的個數）

你也有一個問題，你寫一個字符串加一個空字節到每個管道，然後是第二個字符串加一個空字節。由於調度是非確定性的，因此主程序實際上會將其字符串寫入每個fifo，因此當偵聽器線程讀取它時，它會讀取這兩個字符串。當我打印出長度時，總長度爲41（read_len），但每strlen()的字符串長度爲31.換句話說，第一次讀取包括'殺死'部分，但您沒有注意到由於第一條消息結尾處的結尾爲空，打印輸出。因此，你在等待那永不會發生的事情。

Answer 2

在呼叫中的第一個參數來選擇（）應該是最高編號的文件描述符加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;