自定义 shell 多个管道成功,但没有输出到标准输出

问题描述 投票:0回答:2

我正在创建一个自定义 shell,目前正在努力让多个管道工作。例如,

ls -al | wc -l
返回当前目录中所有文件目录的数量。我正在密切关注此 link 上的“解决方案代码”。

这是我的实现,具有非常相似的命令输入结构:

// every command is a 
// struct command
// with their arguments attached
struct command
{
    char **cmd; // argument list for execvp(eg: {"ls", "-al"})
    int numArgs; // number of total arguments in current line 
};

// my implementation of multiple pipes based on link supplied with slight modifications
void runPipedCommands(struct command *commands)
{
    // this code just counds the number of pipes in commands
    int numPipes = 0;
    for (int i = 0; i < commands->numArgs; i++)
    {
        if (!strcmp(commands[i].cmd[0], "|"))
            numPipes++;
    }
    printf("number of pipes: %d\n", numPipes);

    int status;
    int i = 0;
    pid_t pid;

    int pipefds[2 * numPipes];
    // create the pipes
    for (i = 0; i < (numPipes); i++)
    {
        if (pipe(pipefds + i * 2) < 0)
        {
            perror("couldn't pipe");
            exit(EXIT_FAILURE);
        }
    }

    int j = 0;
    int c = 0;
    while (commands[c].cmd)
    {
        // skip the pipe operators
        if (!strcmp(commands[c].cmd[0], "|"))
            c++;
        pid = fork();
        if (pid == 0)
        {

            printf("cmd to execute: %s\n", commands[c].cmd[0]);
            //if not last command
            if (commands[c + 1].cmd[0])
            {
                // everyone even fd gets this, set stdout to write
                // end of pipe
                if (dup2(pipefds[j + 1], STDOUT_FILENO) < 0)
                {
                    perror("dup2");
                    exit(EXIT_FAILURE);
                }
            }
            else
            {
                exit(EXIT_SUCCESS);
            }

            //if not first command&& j!= 2*numPipes
            if (j != 0)
            {
                // every odd fd gets this, set stdin to
                // read end of pipe
                if (dup2(pipefds[j - 2], STDIN_FILENO) < 0)
                {
                    perror(" dup2");
                    exit(EXIT_FAILURE);
                }
            }

            // close dup2ed fds
            for (i = 0; i < 2 * numPipes; i++)
            {
                close(pipefds[i]);
            }
            // execvp
            if (execvp(commands[c].cmd[0], commands[c].cmd) < 0)
            {
                perror(commands[c].cmd[0]);
                exit(EXIT_FAILURE);
            }
        }
        else if (pid < 0)
        {
            perror("error");
            exit(EXIT_FAILURE);
        }

        c++;
        j += 2;
    }
    /**Parent closes the pipes and wait for children*/

    for (i = 0; i < 2 * numPipes; i++)
    {
        close(pipefds[i]);
    }

    for (i = 0; i < numPipes + 1; i++)
        wait(&status);
}

// my main function with my test input:
int main(int argc, char *argv[])
{
    // my parseW function simply returns a list of struct commands
    struct command *results = parseW("ls -al | wc -l");

    runPipedCommands(results);
    return 0;
}

上面省略了

parseW
的代码导致终端输出为:

在管道的执行中一切看起来都是正确的,我已经检查了文件描述符(在我的特定测试用例中只有 2 个需要考虑)。我不确定我做错了什么。

c shell pipe fork dup2
2个回答
2
投票

不发布

parseW()
commands[]
数组的内容是未知的。
runPipedCommands()
while 循环中,有 3 个地方需要修改:

提供一个

commands[x].cmd[]
可能私下包含一个管道,没有什么可执行的 无需 fork() 并退出;而是添加一个
continue

// skip the pipe operators
if (!strcmp(commands[c].cmd[0], "|")) {
    c++;
    continue;
}

fork()
之后,子进程尝试测试下一个元素
commands[]
,假设成员
.cmd
是非 NULL 和引用 与
.cmd[0]
;假设
commands[]
的最后一个元素包含 NULL
.cmd
, 孩子会在这里崩溃:

if (commands[c + 1].cmd[0])

相反,在不取消引用的情况下更新测试:

if (commands[c + 1].cmd)

与上面添加的

continue
有关,当这个更新的
.cmd
测试为false时,不需要退出和阻止 孩子从到达
execvp()
;删除此块:

else {
    exit(EXIT_SUCCESS);
}

另外:当父母打电话给

wait()
时,
status
可以用 宏并指示孩子是否正常终止,请参阅 等待手册


-1
投票

您是否在管道之间使用重定向命令实现了这段代码?

© www.soinside.com 2019 - 2024. All rights reserved.