程序卡在管道上（執行ls grep排序）

Question

我試圖做一個程序，執行下面的命令，將一個輸出連接到下一個使用管道的輸入並帶兩個參數DIR（directory）和ARG（文件類型，例如：jpg）。

ls DIR -laR | grep ARG |排序

下面的代碼：

int main(int argc, char *argv[]) { 

    if (argc != 3) { 
     printf("Invalid arguments. <dir> <arg>\n"); 
     exit(1); 
    } 

    int pipe_fd1[2]; 
    int pipe_fd2[2]; 
    pid_t ls_pid, grep_pid; 
    int status; 

    pipe(pipe_fd1); 
    pipe(pipe_fd2); 

    ls_pid = fork(); 
    if (ls_pid == 0) { //first child ls DIR -laR 
     dup2(pipe_fd1[1], STDOUT_FILENO); 
     close(pipe_fd1[0]); 

     execlp("ls", "ls", argv[1], "-laR", NULL); 

    } else if (ls_pid > 0) { 
     grep_pid = fork(); 
     if (grep_pid == 0) { //second child grep ARG 
      dup2(pipe_fd1[0], STDIN_FILENO); 
      dup2(pipe_fd2[1], STDOUT_FILENO);  
      close(pipe_fd1[1]); 
      close(pipe_fd2[0]); 

      waitpid(ls_pid, &status, 0);  
      execlp("grep", "grep", argv[2], NULL); 

     } else if (grep_pid > 0) { //parent sort 
      dup2(pipe_fd2[0], STDIN_FILENO); 
      close(pipe_fd2[1]); 

      waitpid(grep_pid, &status, 0); 
      execlp("sort", "sort", NULL); 
     } 

    } 

    return 0; 
} 

它似乎被卡住？不知道爲什麼？

Answer 1

你父從未接近pipe_fd1，所以grep和sort doen't知道何時停止讀取輸入：因爲管道讀取和寫入端永遠不會關閉父，讀者塊等待更多的輸入，將永遠到達。你需要關閉它。

此外，您不需要waitpid()：管道的工作方式可確保輸入線性流動並按順序在整個管道中流動。

下面是這些問題的工作版本解決：

#include <stdio.h> 
#include <stdlib.h> 
#include <unistd.h> 
#include <sys/types.h> 
#include <sys/wait.h> 

int main(int argc, char *argv[]) { 

    if (argc != 3) { 
     printf("Invalid arguments. <dir> <arg>\n"); 
     exit(1); 
    } 

    int pipe_fd1[2]; 
    int pipe_fd2[2]; 
    pid_t ls_pid, grep_pid; 

    pipe(pipe_fd1); 

    ls_pid = fork(); 
    if (ls_pid == 0) { //first child ls DIR -laR 
     dup2(pipe_fd1[1], STDOUT_FILENO); 
     close(pipe_fd1[0]); 
     execlp("ls", "ls", argv[1], "-laR", NULL); 

    } else if (ls_pid > 0) { 
     dup2(pipe_fd1[0], STDIN_FILENO); 
     close(pipe_fd1[1]); 

     pipe(pipe_fd2); 
     grep_pid = fork(); 

     if (grep_pid == 0) { //second child grep ARG 
      dup2(pipe_fd2[1], STDOUT_FILENO); 
      close(pipe_fd2[0]); 
      execlp("grep", "grep", argv[2], NULL); 

     } else if (grep_pid > 0) { //parent sort 
      dup2(pipe_fd2[0], STDIN_FILENO); 
      close(pipe_fd2[1]); 
      execlp("sort", "sort", NULL); 
     } 

    } 

    return 0; 
}