我正在编写一个程序,其中父进程需要能够与另一个子进程通信,因此我编写了一个函数,将子进程的标准输出和输入重定向到管道.
int create_child_piped_io(int* pipe_in, int* pipe_out, const char* program, char* argv[], char* envp[])
{
int stdin_pipe[2];
int stdout_pipe[2];
int child;
if(pipe(stdin_pipe) < 0)
{
return -1;
}
if(pipe(stdout_pipe) < 0)
{
close(stdin_pipe[0]);
close(stdin_pipe[1]);
}
child = fork();
if(child == 0)
{
close(stdin_pipe[1]);
close(stdout_pipe[0]);
if(dup2(stdin_pipe[0], STDIN_FILENO) < 0)
{
close(stdin_pipe[0]);
close(stdout_pipe[1]);
exit(errno);
}
if(dup2(stdout_pipe[1], STDOUT_FILENO) < 0)
{
close(stdin_pipe[0]);
close(stdout_pipe[1]);
exit(errno);
}
close(stdin_pipe[0]);
close(stdout_pipe[1]);
execve(program, argv, envp);
exit(1);
}
else if(child > 0)
{
close(stdin_pipe[0]);
close(stdout_pipe[1]);
*pipe_in = stdin_pipe[1];
*pipe_out = stdout_pipe[0];
return child;
}
else
{
close(stdin_pipe[0]);
close(stdin_pipe[1]);
close(stdout_pipe[0]);
close(stdout_pipe[1]);
exit(errno);
}
return child;
}
int main()
{
int input, output;
char* argv[] = {"program"};
char* envp[] = {NULL};
int cpid = create_child_piped_io(&input, &output, "/home/jaden/dev/c++/pipes/program", argv, envp);
char c;
while(read(output, &c, 1) == 1)
{
printf("%c", c);
}
printf("done\n");
int status;
waitpid(cpid, &status, 0);
close(input);
close(output);
}
这很好,但我注意到,当从子进程向标准输出写入时,它不会立即被发送到管道.这是子进程将运行的程序.
int main()
{
// i < 1025 gets sent to pipe after sleep(10)
// i > 1025 send first 1024 bytes to pipe immediately
for(int i = 0; i < 1024; i++)
{
write(1, "a", 1);
}
sleep(10);
return 0;
}
只有在子进程结束后,输出才会被发送到管道.我try 发送不同数量的数据.事实证明,每次我向stdout写入超过1024个字符时,它都会被发送到管道中.这让我相信它正在被缓冲.我不明白为什么会这样,因为管道也是内存中的缓冲区,所以它只是缓冲缓冲区.如果这是标准行为,有没有办法将其关闭,因为我希望在写入数据后尽快获取数据.
我正在使用linux mint 20.3.