execl() 似乎没有从标准输入读取

Question

我正在尝试用 c 语言重现这个命令：

ls | wc > output.txt

为此，我编写了以下程序：

#include <unistd.h>
#include <stdlib.h>
#include <fcntl.h>
#include <stdio.h>
#include <errno.h>

int main()
{
    pid_t lsFork, wcFork;
    int tube[2];
    pipe(tube);

    lsFork = fork();
    if(lsFork == 0) // ls command
    {
        close(tube[0]);
        dup2(tube[1], STDOUT_FILENO);
        close(tube[1]);
        if(execl("/usr/bin/ls", "ls", NULL) == -1)
            perror("Cannot execute ls");
    }
    else
    {
        wcFork = fork();
        if(wcFork == 0)  // wc command
        {
            sleep(1);
            int file = open("output.txt", O_WRONLY | O_CREAT);
            if(file == -1)
                perror("Cannot open output.txt");

            close(tube[1]);
            dup2(tube[0], STDIN_FILENO);
            close(tube[0]);
            dup2(file, STDOUT_FILENO);
            close(file);

            /*char buffer[BUFSIZ];
            read(STDIN_FILENO, buffer, BUFSIZ);
            write(STDOUT_FILENO, buffer, BUFSIZ);*/

            if(execl("/usr/bin/wc", "wc", NULL) == -1)
                perror("Cannot execute wc");

            close(STDOUT_FILENO);
        }
        else // parent
        {
            int status;
            waitpid(lsFork, &status, 0);
            waitpid(wcFork, &status, 0);
        }
    }

    return EXIT_SUCCESS;
}

但是，程序并没有退出。根据 htop， wc 命令正在阻止程序。为了理解这种行为，我编写了一段代码（在 execl() 之前注释的行），但我不明白这是什么工作，而不是 execl()。我是不是在调用这个函数时忘记了什么？

Answer 1

父进程仍然打开管道，因此wc 正在等待以防父进程决定写入内容（wc 需要计算在内）。

在父节点中也关闭管道的两端：

    else // parent
    {
        int status;
        close(tube[0]); // <---
        close(tube[1]); // <---
        waitpid(lsFork, &status, 0);
        waitpid(wcFork, &status, 0);
    }

Answer 2

当你可以轻松做到时，不要把事情复杂化。 试试下面更简单的代码，看看你能不能理解。

int main(){
    int tube[2];
    int fID;
    pipe(tube);
    if (fork() == 0){
      // this is the child process
      close(tube[0]); // reading end of the pipe
      dup2(tube[1], 1); // stdout ---> pipe writing end
      execlp("ls", "ls", NULL);
    }else{
      if (fork() == 0){
        //umask(0022);
        fID = open("sample.txt", O_WRONLY | O_CREAT, 0644);
        close(tube[1]); // writing end of the pipe
        dup2(tube[0], 0);  // stdin ----> pipe reading end
        dup2(fID, 1);
        execlp("wc", "wc", NULL);
      }
    }
  return 0;
}

注意 如果代码的目的只是实现上述管道，那么您不需要实现任何等待机制。如果有的话，操作系统会自动杀死所有的僵尸孩子。此外execlp("wc", "wc", NULL); 将自动阻止程序结束。因此它不会提前退出

Answer 3

您还需要在父级中关闭管道的写入端。