为什么从我的 shell 中的管道获取输入时,execvp() return 中的 wc 命令会产生错误的结果?

Why does wc command in execvp() return the wrong results when taking input from a pipe in my shell?

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

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

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

while (1) {
        printf("3[31;1mshell:3[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);
    } 
}

这里我拿出一些错误检查来保存space。 感谢您的帮助!

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

    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++;
    }

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