对在 shell 中实现多管道感到困惑

Question

所以我一直在尝试在自己的shell程序中实现管道，以便我能够真正理解UNIX在做什么。我现在非常接近，但由于某种原因，当我使用管道时，我的程序会进入无限循环。我很确定我的问题源于我的 waitpid 参数永远不会让最后一个管道关闭，因为如果我在下面的代码中进行最后一个循环，则 i 小于 count-1 而不是 i 小于 count 它将运行管道左侧的命令。但是一旦我把它放回 i 小于 count 它就会永远循环。

           if(pipes)
                   {
            for (i=0;i<count-1;i++)
            {

                 if( pipe(fd) ==-1)
                 {
                 perror("Pipe failure");
                 return;
                 }

                read[i+1] = fd[0];
                write[i] = fd[1];
            }
        }

    for(i=0;i<count;i++)
    {
        pid = fork();

        if(pid < 0)
        {printf("fork failed");}

        else if(pid>0)
        {pids[i] = pid;}
        else
        { 
            if(write[i] != -1)
            {
                if(dup2(write[i],STDOUT_FILENO) ==-1)
                {
                perror("dup2 failure");
                exit(1);
                }
            }
            if(read[i] !=-1)
            {
                if (dup2(read[i], STDIN_FILENO)==-1)
                {
                perror("dup2 failure");
                exit(1);
                }
            }
        for (j=0; j<count; j++)
            {
            close(write[j]);
            close(read[j]);
            }

    execvp(input[i], input);
    exit(1);
        }//end else
    }//end for


  for(i=0; i < count; i++){


  if(write[i] != -1)
  close(write[i]);

  if( read[i] != -1)
  close (read [i]);

  waitpid(pids[i], &status,0);
 }
           }
    return (status);}

我认为我真的非常接近解决方案，但目前我陷入困境。我对管道进行了大量研究，但我想我只是不太明白。感谢您的任何帮助。

Answer 1

请格式化您的代码。现在是无法读取的。

话虽这么说，但有一些错误：

• 您没有设置 write[0]。您正在设置 write[count-1] 和 read[count]。
• 您正在等待 pids[i]，而父级仍打开 read[i]。如果 input[i] 想要在标准输入上获得 EOF 之前不会退出，那么它永远不会发生。