编辑:
解决办法是
int c1=dup2(pipes[0][1],STDOUT_FILENO);
int c2=dup2(pipes[1][0],STDIN_FILENO);
setvbuf(stdout,NULL,_IONBF,0);
setvbuf设置stdout为非缓冲。即使我打印的是换行符,如果目的地不是一个实际的屏幕,我想,它会变得缓冲。
编辑:
当我把fflush(stdout)放在1号线之后,fflush(fout)放在4号线之后时,它按预期工作。但是,如果没有第1行之后的fflush(stdout),它就无法工作。问题是我不能在我计划运行的程序中加入fflush。
我正在尝试从我的进程启动另一个程序。我无法访问它的代码,但我知道它使用stdin和stdout进行用户交互。我试图通过创建两个管道来启动该程序,分叉并将孩子的stdin/stdout重定向到正确的管道末端。关键是父节点应该能够通过文件描述符与子节点通信,而其stdin/stdout应该是完整的。popen系统调用只打开单向管道。下面的代码几乎可以工作。
有4行标记为1..4行。
1号线是发送到管道的子节点,
2号线是从管道接收的子线,
第3行是父级发送到管道,
4号线是从管道接收的主管道,
这只是一个玩具的例子,以确保工作。问题是所有的4行第1..4行都没有注释我在终端上看到的输出是
PARENT1: -1
FD: 1 0 4 5 0 1
DEBUG1: 0
DEBUG2: 0
而如果取消对第1行和第3行的注释,则只能看到连续的数据流。如果只有第2行和第4行未注释,则会发生同样的情况。但是,我想要一个完全双向的通信。同时添加评论的睡眠不会改变行为。
这里有什么问题。我想知道为什么没有双向popen。
int pid;
int pipes[2][2];
pipe(pipes[0]);
pipe(pipes[1]);
pid=fork();
if(pid==0)
{
//usleep(1000000);
close(pipes[0][0]);
close(pipes[1][1]);
int c1=dup2(pipes[0][1],STDOUT_FILENO);
int c2=dup2(pipes[1][0],STDIN_FILENO);
//int c2=dup2(STDIN_FILENO,pipes[1][0]);
fprintf(stderr,"FD: %d %d %d %d %d %d\n",c1,c2,pipes[0][1],pipes[1][0],STDIN_FILENO,STDOUT_FILENO);
//FILE*fout=fdopen(pipes[0][1],"w");
//FILE*fin =fdopen(pipes[1][0],"r");
while(1)
{
static int c1=0;
fprintf(stderr,"DEBUG1: %d\n",c1);
printf("%d\n",c1); // LINE 1
fprintf(stderr,"DEBUG2: %d\n",c1);
scanf("%d",&c1); // LINE 2
fprintf(stderr,"DEBUG3: %d\n",c1);
c1++;
}
//fclose(fout);
//fclose(fin);
return 0;
}
close(pipes[0][1]);
close(pipes[1][0]);
char buffer[100];
FILE*fin=fdopen(pipes[0][0],"r");
FILE*fout=fdopen(pipes[1][1],"w");
while(1)
{
int c1=-1;
printf("PARENT1: %d\n",c1);
fscanf(fin,"%d",&c1); // LINE 3
printf("Recv: %d\n",c1);
fprintf(fout,"%d\n",c1+1); // LINE 4
printf("PARENT3: %d\n",c1+1);
}
fclose(fin);
fclose(fout);
最佳答案
您的代码很长,所以我不确定是否已经理解了所有内容,但为什么不使用select?
是否要在TIRD进程中重定向子进程的输出,或在父进程中使用它?
下面的例子是在子进程中使用cat。
#include <unistd.h>
#include <stdlib.h>
int main()
{
pid_t pid;
int p[2];
pipe(p);
pid = fork();
if (pid == 0)
{
dup2(p[1], 1); // redirect the output (STDOUT to the pipe)
close(p[0]);
execlp("cat", "cat", NULL);
exit(EXIT_FAILURE);
}
else
{
close(p[1]);
fd_set rfds;
char buffer[10] = {0};
while (1)
{
FD_ZERO(&rfds);
FD_SET(p[0], &rfds);
select(p[0] + 1, &rfds, NULL, NULL, NULL); //wait for changes on p[0]
if(FD_ISSET(p[0], &rfds))
{
int ret = 0;
while ((ret = read(p[0], buffer, 10)) > 0) //read on the pipe
{
write(1, buffer, ret); //display the result
memset(buffer, 0, 10);
}
}
}
}
}