为什么执行 uniq -d 的子进程不打印管道通过标准输入传递的重复项?

Why does the child process executing uniq -d not print duplicates passed by pipe over stdin?

我目前正在编写一个使用 fork() 创建子进程的程序。此子进程应执行带有选项“-d”的 shell 命令 "uniq",以便它从标准输入读取。在执行命令后,我想通过管道为 "uniq" 程序发送字符串作为标准输入。因此,在我依次发送相同的字符串后,该字符串应该打印在标准输出上(参见 uniq 手册页:https://linux.die.net/man/1/uniq)。但是没有打印任何内容。

到目前为止,这是我的代码:

void execute_uniq_process()
{
    //create pipe
    int pipefd[2];
    if(pipe(pipefd)<0)
    {
        //error handling
    }

    //create argv for command:
    char *argv[] = {"uniq","-d",(char *)0};

    //create child process
    pid_t pid = fork();
    int status;

    switch(pid)
    {
        case -1:
        //error handling
        break;

        case 0:
            //child process
            //close writing end in pipe
            close(pipefd[1]);

            //duplicate stdin
            dup2(pipefd[0],STDIN_FILENO);
            close(pipefd[0]);

            execvp("uniq",argv);
            exit(errno);
        break;

        default:
            //parent process
            //close reading end in pipe
            close(pipefd[0]);

            //write all commands to pipe
            write(pipefd[1],"test1",5);
            write(pipefd[1],"test1",5);
            write(pipefd[1],"test2",5);
            //edited:
            close(pipefd[1]);

            //waits till child is finished
            wait(&status);

            if(WEXITSTATUS(status) != EXIT_SUCCESS)
            {
                //error handling
            }
        break;
    } 
}

所以我希望 shell 中印有 "test1"。我也想知道如何干净地终止 uniq 进程。我认为写入可能存在问题,因此我必须在管道中写入的每个字符串之后模拟一个 "enter"。

您必须在等待 uniq 完成之前关闭管道,因为在您关闭管道之前它不会知道它有 EOF。而且您甚至没有向 uniq 的标准输入写入一行,因为写入的数据中没有换行符。 write() 系统调用只写你告诉它写的东西;它当然不会根据自己的意愿添加任何换行符。

这些变化和各种琐事导致:

#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/wait.h>
#include <unistd.h>

int main(void)
{
    int pipefd[2];
    if (pipe(pipefd) < 0)
    {
        fprintf(stderr, "Failed to create pipe\n");
        return 1;
    }

    char *argv[] = {"uniq", "-d", (char *)0};

    pid_t pid = fork();

    switch (pid)
    {
    case -1:
        fprintf(stderr, "Failed to fork\n");
        return 1;

    case 0:
        close(pipefd[1]);
        dup2(pipefd[0], STDIN_FILENO);
        close(pipefd[0]);
        execvp(argv[0], argv);
        fprintf(stderr, "Failed to exec %s\n", argv[0]);
        exit(errno);

    default:
        close(pipefd[0]);
        write(pipefd[1], "test1\n", 6);
        write(pipefd[1], "test1\n", 6);
        write(pipefd[1], "test2\n", 6);
        close(pipefd[1]);
        int status;
        int corpse = wait(&status);

        if (WEXITSTATUS(status) != EXIT_SUCCESS)
        {
            fprintf(stderr, "Child (%s) exited (PID %d, status 0x%.4X)\n", argv[0], corpse, status);
        }
        break;
    }
    return 0;
}

当它是 运行 时输出 test1