2

我知道已经有人问过类似的问题，但没有一个答复对我有帮助。我正在尝试实现一个微型 Linux shell 并被困在多个管道上。带有单个管道（例如ls | wc）的命令可以工作，但是如果我添加第二个管道，控制台上不会显示任何内容。这是我的代码。

void ExecuteCommand(NODE *cHead,NODE *oHead)
{
    int fd[10][2];  // file descriptors' array
    int nfdCnt = 0 ;    // file descriptors counter
    string strCmd;      // command
    string strOp = "";  // operator
    int nOpCnt = 0 ;    // operator count

    while(1)
    {
        if (cHead != NULL)  // cHead is head pointer to the linked list of commands.
        {
            strCmd =  GetCmdOROperator(&cHead); // get command
        }
        if (oHead == NULL)  // oHead is head pointer to the linked list of operators.
        {
            strOp = "";
        }
        else
        {
            strOp = GetCmdOROperator(&oHead);   // get operator
        }

        if (strOp.empty())  // no operator exists. single or last command in the chain.
        {
            // Fork the child process
            pid_t child_id = fork();

            if(child_id == 0)
            {
                // Execute the command

                if (nOpCnt) // if we previously encountered any operator
                {
                    close(fd[nfdCnt-1][FD_WRITE]);
                    dup2(fd[nfdCnt-1][FD_READ], FD_READ);   // read from pipe updated by previous command
                }

                // call execvp()

                exit(-1);
            }
            else
            {
                for (int i = 0 ; i < nfdCnt; i++)
                {
                    close(fd[nfdCnt][0]);
                    close(fd[nfdCnt][1]);
                }
                wait(NULL);
                break;
            }
        }

        if (strOp == "|")
        {
            nOpCnt++ ;

            if (pipe (fd[nfdCnt]) < 0)
            {
                printf("\npipe error");
                return ;
            }

            pid_t child_id = fork();
            if (child_id == 0)
            {
                close(fd[nfdCnt][FD_READ]); // we dont need this
                dup2(fd[nfdCnt][FD_WRITE], FD_WRITE);

                if(nOpCnt > 1) // if we have already encountered a pipe before
                {
                    dup2(fd[nfdCnt-1][FD_READ],FD_READ);
                    close(fd[nfdCnt-1][FD_WRITE]);
                }

                // call execvp()
                exit (-1);
            }
            else
            {
                nfdCnt++;
            }

        }

    }
}
4

2 回答 2

2

我没有仔细查看您的代码，但看起来您正在打开文件描述符，在这种情况下，由于有人打开了写入端，即使您认为您已经关闭了它，进程也会在读取时阻塞。尝试在每个 dup2 之后添加关闭：

 dup2( fd[ nfdCnt - 1 ][ FD_READ ], FD_READ );
 close( fd[ nfdCnt - 1 ][ FD_READ ])

（另外，添加一些错误检查。 dup2, fork,close等都可能失败。在向论坛发布问题时跳过错误检查有时很方便，但请确保在实际代码中不要省略它。）

于 2012-09-08T17:57:03.163 回答
1

这个

 if (strOp == "|")

在 C 中不起作用；用于strcmp比较字符串。或者也许你把你的问题弄错了 C 而不是 C++？你使用什么语言编译器？

于 2012-09-08T18:13:20.507 回答