经典的C语言：在execvp函数中使用管道，进行标准输入和输出重定向。

Question

经典的C语言：在execvp函数中使用管道，进行标准输入和输出重定向。

16

我想在我的Linux C程序中使用管道和execvp函数模拟bash。

ls -l | wc -l

这是我的程序：

if(pipe(des_p) == -1) {perror("Failed to create pipe");}

if(fork() == 0) {    //first fork
  close(1);          //closing stdout
  dup(des_p[1]);     //replacing stdout with pipe write 
  close(des_p[0]);   //closing pipe read
  close(des_p[1]);   //closing pipe write

  if(execvp(bash_args[0], bash_args)) // contains ls -l
    /* error checking */
}
else {
  if(fork() == 0) {  //creating 2nd child
    close(0);        //closing stdin
    dup(des_p[0]);   //replacing stdin with pipe read
    close(des_p[1]); //closing pipe write
    close(des_p[0]); //closing pipe read

    if(execvp(bash_args[another_place], bash_args)) //contains wc -l
      /* error checking */
  }

  close(des_p[0]);
  close(des_p[1]);
  wait(0);
  wait(0);
}

这段代码实际上可以运行，但是没有达到预期的效果。有什么问题吗？它不起作用，而我不知道为什么。

- krzakov

2个回答

1

了解一下wait函数的作用。它会等待直到一个子进程存在。在启动第二个子进程之前，您正在等待第一个子进程退出。第一个子进程可能不会退出，直到有一些进程从管道的另一端读取。

- Art

当我删除第一个wait()时，屏幕上会出现混乱。Execvp在主程序结束后启动。那么如何更改呢？ - krzakov

创建带有管道的进程，然后使用wait等待两个进程都完成。 - Art

1

@krzakov，你需要在父进程中关闭管道文件描述符，否则第二个子进程将无法接收到EOF并会挂起（除非第一个子进程非常热心并调用shutdown()来关闭其端口）。 - Nicholas Wilson

@krzakov 看起来很熟悉...那是我的答案，除了你没有像Art指出的那样等待两个子进程。如果它能做到你想要的，那就是正确的。我只能保证我的代码可以编译并且能够实现我认为你想要的功能！（我撤销了你对问题所做的更改，因为否则会令人困惑。） - Nicholas Wilson

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Nicholas Wilson · Accepted Answer

你需要在父进程中关闭管道文件描述符，否则子进程将无法收到EOF信号，因为在父进程中，该管道仍然处于写入状态。这将导致第二个wait()挂起。以下方法可行：

#include <unistd.h>
#include <stdlib.h>


int main(int argc, char** argv)
{
        int des_p[2];
        if(pipe(des_p) == -1) {
          perror("Pipe failed");
          exit(1);
        }

        if(fork() == 0)            //first fork
        {
            close(STDOUT_FILENO);  //closing stdout
            dup(des_p[1]);         //replacing stdout with pipe write 
            close(des_p[0]);       //closing pipe read
            close(des_p[1]);

            const char* prog1[] = { "ls", "-l", 0};
            execvp(prog1[0], prog1);
            perror("execvp of ls failed");
            exit(1);
        }

        if(fork() == 0)            //creating 2nd child
        {
            close(STDIN_FILENO);   //closing stdin
            dup(des_p[0]);         //replacing stdin with pipe read
            close(des_p[1]);       //closing pipe write
            close(des_p[0]);

            const char* prog2[] = { "wc", "-l", 0};
            execvp(prog2[0], prog2);
            perror("execvp of wc failed");
            exit(1);
        }

        close(des_p[0]);
        close(des_p[1]);
        wait(0);
        wait(0);
        return 0;
}