c - 管道问题 : first child writes too much in to pipe

Question

我正在尝试用 C 编写一个程序，它创建 2 个子进程，每个子进程都执行一个 execvp。

我的问题是第一个 child 向另一个 child 读取的管道写入了太多输入。

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

//unnamed pipe
int pipeFd[2], statusFirst,statusSecond;
pid_t childPidOne,childPidTwo;

if(pipe(pipeFd) < 0){
    perror("Pipe error:\n");
    exit(EXIT_FAILURE);
}

switch(childPidOne = fork()){
    case -1:
        perror("First Fork error:\n");
        exit(EXIT_FAILURE);
    case 0:
        printf("First child\n");
        close(pipeFd[1]);
        if( (execvp(argv[1], &argv[1])) < 0){
            perror("First execvp error:\n");
        }
        printf("End First cild\n");
        exit(0);
    default:
        //Do nothing
        break;  
}

switch(childPidTwo = fork()){
    case -1:
        perror("Second Fork error:\n");
        exit(EXIT_FAILURE);
    case 0:
        printf("Second cild\n");
        close(pipeFd[0]);
        if( (execvp(argv[3], &argv[3])) < 0){
            perror("Second execvp error:\n");
        }
        printf("End Second cild\n");
        exit(0);
    default:
        //Do nothing
        break;  
}


close(pipeFd[0]);
close(pipeFd[1]);   


if( (waitpid(childPidOne,&statusFirst,WUNTRACED | WCONTINUED)) < 0 ){
    perror("First waitpid error:\n");
}else{
    if (WIFEXITED(statusFirst)) {
       printf("First exited, status=%d\n", WEXITSTATUS(statusFirst));
    } else if (WIFSIGNALED(statusFirst)) {
       printf("First killed by signal %d\n", WTERMSIG(statusFirst));
    } else if (WIFSTOPPED(statusFirst)) {
       printf("First stopped by signal %d\n", WSTOPSIG(statusFirst));
    } else if (WIFCONTINUED(statusFirst)) {
       printf("First continued\n");
    }
}


if( (waitpid(childPidTwo,&statusSecond,WUNTRACED | WCONTINUED)) < 0 ){
    perror("Second waitpid error:\n");
}
if (WIFEXITED(statusSecond)) {
   printf("Second exited, status=%d\n", WEXITSTATUS(statusSecond));
  } else if (WIFSIGNALED(statusSecond)) {
   printf("Second killed by signal %d\n", WTERMSIG(statusSecond));
  } else if (WIFSTOPPED(statusSecond)) {
   printf("Second stopped by signal %d\n", WSTOPSIG(statusSecond));
  } else if (WIFCONTINUED(statusSecond)) {
      printf("Second continued\n");
      }

   exit(0);
return 0;
  }

也许我对 pipe + fork + execvp 的工作方式有错误的理解，所以让我告诉你我在我的代码中做了什么:

1. 我创建了一个未命名的管道——两个 child 都使用同一个管道
2. 我将通过 fork 创建两个 child
3. 因为我这样执行我的程序:./pipeline [FIRST SYSTEM CALL] | [SECOND SYSTEM CALL] 或者只是给你一个例子:./pipeline echo Hello | wc -m 我关闭管道的阅读站点
4. 然后调用execvp(argv[1], &argv[1])

这就是错误发生的地方(我猜):在第二个 child 关闭之前，我永远不会关闭写入端，因为如果成功，execvp 将永远不会返回。

而且我知道 execvp 不会关闭打开的文件描述符(它可以通过在 fcntl 中使用标志来关闭，如 What does the FD_CLOEXEC flag do? 中所述)。

例子

我举个例子。

echo Hello | wc -m

输出结果

6

因为系统调用wc(字数统计)计算给定String中的字符数(-m)

这是正确的，因为 hello = 5 + 1(我猜是 \n 或 \0)，这就是 6。

现在，运行我的程序给出了结果

56

或获取更多信息

echo hello | wc

输出

1 (line) 1 (word) 6 (characters)

和./pipeline echo hello | wc

输出

3 (lines) 9 (word) 56 (characters)

我已经搜索了几天，但我无法弄明白。

有什么想法吗？

非常感谢!

Answer 1

我自己解决了。

忘记使用 dup2。

只需在 close 命令后键入 dup2 命令就可以了。