为什么 execvp() 中的 wc 命令在从 shell 中的管道获取输入时返回错误的结果？

如何解决为什么 execvp() 中的 wc 命令在从 shell 中的管道获取输入时返回错误的结果？

为了学习目的，我正在用 C 编写一个 shell，我正在尝试允许可变数量的管道。总的来说，它似乎工作得很好。但我注意到 wc 命令有问题。

当我将另一个程序的某些输出通过管道传输到 wc 时，例如 ls | wc，它总是返回
1 3 35 无论我输入什么。当我通过管道输入它们时，其他命令按预期工作。在我正常的 zsh shell wc 中工作正常。我正在努力寻找问题。我试过在叉子后添加 waitpid 但没有骰子。

这是 main 函数中的主要 shell 循环：

while (1) {
        printf("\033[31;1mshell:\033[0m ");

        line = read_cmds();

        if (strstr(line,"|")) {
            // check for pipes first
            pipe_exec(line);
        } else {
            // we have a single command
            tokens = split(line," \t\r\n");
            if (*tokens != NULL) shell_exec(tokens);
            free(tokens);
        }
    }

这是循环遍历命令的函数：

void pipe_exec(char *line)
{
    int in,status;
    int pipe_no; // keep track of ptr to bring it back to free 
    int pfd[2];
    pid_t rc;
    char **cmd,**pipe_cmds;
    
    // split takes a string and splits into array of strings based on delimiter
    pipe_cmds = split(line,"|"); 

    in = 0;
    pipe_no = 0;
    while (*pipe_cmds) {
        cmd = split(*pipe_cmds," \t\r\n");

        if (pipe(pfd) < 0) perror("pipe");

        make_proc(in,pfd[1],cmd);
        close(pfd[1]);
        in = pfd[0];
        pipe_cmds++; // move ptr ahead one
        pipe_no++;
    }
    // move pointer back and free
    pipe_cmds -= pipe_no;
    free(pipe_cmds);

    rc = fork();
    if (rc == 0) {
        if (in != 0) dup2(in,STDIN_FILENO);
        execvp(*cmd,cmd);
    } 
}

然后是上面函数调用的make_proc函数：

void make_proc(int in,int out,char **cmd)
{
    pid_t rc;
    rc = fork();
    if (rc  == 0) {
        if (in != STDIN_FILENO) {
            dup2(in,STDIN_FILENO);
            close(in);
        }
        if (out != STDOUT_FILENO) {
            dup2(out,STDOUT_FILENO);
            close(out);
        }
        execvp(*cmd,cmd);
    } 
}

我去掉了一些错误检查以节省空间。 任何帮助表示赞赏！

解决方法

您执行最后一个命令两次并将其第一个实例通过管道传输到第二个。添加如下内容：

    while (*pipe_cmds) { 
        cmd = split(*pipe_cmds," \t\r\n");
        if (!pipe_cmds[1]) {
            break;
        }

        if (pipe(pfd) < 0) perror("pipe");

        make_proc(in,pfd[1],cmd);
        close(pfd[1]);
        in = pfd[0];
        pipe_cmds++; // move ptr ahead one
        pipe_no++;
    }

会阻止不必要的实例，尽管我宁愿稍微重构一下这个函数。