从管道读取值不起作用
reading a value from a pipe isn't working
我有一个程序,其中创建了属于同一个父亲的两个 child 进程。现在程序通过点击控制 C 开始,然后每次按控制 Z 运行。
目的是让child1写两个数到child2然后child两个数相除然后把结果写回child1显示出来.因此需要两个管道(fd 和 sd)。
我的第一个管道工作正常,所以数字正在发送...在 child 2(用于调试)它显示正确的数字所以如果它有 8 和 2.... child 2 中显示了 4 的正确答案。现在我似乎无法得到这个“4”或任何结果返回到 child 1。
#include <stdio.h>
#include <signal.h>
#include <fcntl.h>
#include <unistd.h>
#include <time.h>
#include <string.h>
#include <stdlib.h>
void handleSignal(int sig)
{
if (sig == SIGTSTP)
{
return;
}
}
int main()
{
int fd[2];
int sd[2];
int pipe1 = 0;
int pipe2 = 0;
pid_t fork1 = 0;
pid_t fork2 = 0;
int num1, num2, result;
int myJump = 0;
int returnResult = 99;
signal(SIGINT, handleSignal);
printf("Waiting for interrupt\n");
pause();
signal(SIGINT, SIG_IGN);
pipe1 = pipe(fd);
pipe2 = pipe(sd);
//pipe checks been omitted...for simplicity
fork1 = fork();
//fork check been omited..for simplicity
signal(SIGTSTP, handleSignal); //wait till control Z is pressed
if (fork1 == 0)
{
dup2(fd[1], 1);
dup2(sd[0], 0);
close(fd[0]);
close(sd[1]);
while(1)
{
pause();
int randNum1 = rand() % 9 + 1;
fprintf(stderr, "Child 1: %d\n", randNum1);
printf("%d\n", randNum1);
fflush(stdout);
scanf("%d", &returnResult);
fprintf(stderr, "result in A :%d \n", returnResult);
}
}
else if (fork1 > 0)
{
fork2 = fork();
if (fork2 == 0)
{
signal(SIGTSTP, handleSignal);
dup2(fd[0], 0);
dup2(sd[1], 1);
close(fd[1]);
close(sd[0]);
if (myJump == 0)
{
pause();
scanf("%d", &num1);
printf("CHild 2: %d\n", num1);
myJump = 1;
}
if (myJump == 1)
{
while (1)
{
pause();
scanf("%d", &num2);
result = num2 / num1;
fprintf(stderr, "result from B: %d \n", result);
num1 = num2;
printf("%d \n", result);
}
}
}
else
{
wait();
}
}
else
{
printf("errror \n");
}
return 0;
}
如果有人能看出问题所在,如果您要 运行 它...它的工作原理是先点击控制 C,然后您必须继续点击控制 Z。然后您可以看到来自 child A 与 B 不匹配,如下所示
Waiting for interrupt
^C^ZChild 1: 2
result in A :99
^ZChild 1: 8
result in A :99
result from B: 4
^ZChild 1: 1
result in A :99
result from B: 0
管道实际上工作正常...是 scanf()
出了问题。当您的第二个子进程启动时,它会调用:
if (myJump == 0)
{
pause();
scanf("%d", &num1);
printf("CHild 2: %d\n", num1); /* <== problem here */
myJump = 1;
}
...printf()
留下 "CHild 2: " 作为 sd[]
管道中的下一个数据。因此,当您的第一个子进程调用 scanf()
以读取第二个子进程的结果时,scanf()
失败并保持 returnResult
不变。由于 scanf()
失败,数据将保留在流中,并且以后对 scanf()
结果的尝试也会以同样的方式失败。
如何修复取决于您的需要。如果您希望您的第二个子进程只 return 它读取的数字作为第一遍的结果,那么只需修改有问题的 printf()
以只写没有文本的数字:
if (myJump == 0)
{
pause();
scanf("%d", &num1);
printf("%d\n", num1); /* <== Changed: number only, no text */
myJump = 1;
}
我要补充一点,虽然上述更改会解决问题,但您通常应该检查 scanf()
中的 return 是否成功,如果不成功则采取适当的措施。
我有一个程序,其中创建了属于同一个父亲的两个 child 进程。现在程序通过点击控制 C 开始,然后每次按控制 Z 运行。
目的是让child1写两个数到child2然后child两个数相除然后把结果写回child1显示出来.因此需要两个管道(fd 和 sd)。
我的第一个管道工作正常,所以数字正在发送...在 child 2(用于调试)它显示正确的数字所以如果它有 8 和 2.... child 2 中显示了 4 的正确答案。现在我似乎无法得到这个“4”或任何结果返回到 child 1。
#include <stdio.h>
#include <signal.h>
#include <fcntl.h>
#include <unistd.h>
#include <time.h>
#include <string.h>
#include <stdlib.h>
void handleSignal(int sig)
{
if (sig == SIGTSTP)
{
return;
}
}
int main()
{
int fd[2];
int sd[2];
int pipe1 = 0;
int pipe2 = 0;
pid_t fork1 = 0;
pid_t fork2 = 0;
int num1, num2, result;
int myJump = 0;
int returnResult = 99;
signal(SIGINT, handleSignal);
printf("Waiting for interrupt\n");
pause();
signal(SIGINT, SIG_IGN);
pipe1 = pipe(fd);
pipe2 = pipe(sd);
//pipe checks been omitted...for simplicity
fork1 = fork();
//fork check been omited..for simplicity
signal(SIGTSTP, handleSignal); //wait till control Z is pressed
if (fork1 == 0)
{
dup2(fd[1], 1);
dup2(sd[0], 0);
close(fd[0]);
close(sd[1]);
while(1)
{
pause();
int randNum1 = rand() % 9 + 1;
fprintf(stderr, "Child 1: %d\n", randNum1);
printf("%d\n", randNum1);
fflush(stdout);
scanf("%d", &returnResult);
fprintf(stderr, "result in A :%d \n", returnResult);
}
}
else if (fork1 > 0)
{
fork2 = fork();
if (fork2 == 0)
{
signal(SIGTSTP, handleSignal);
dup2(fd[0], 0);
dup2(sd[1], 1);
close(fd[1]);
close(sd[0]);
if (myJump == 0)
{
pause();
scanf("%d", &num1);
printf("CHild 2: %d\n", num1);
myJump = 1;
}
if (myJump == 1)
{
while (1)
{
pause();
scanf("%d", &num2);
result = num2 / num1;
fprintf(stderr, "result from B: %d \n", result);
num1 = num2;
printf("%d \n", result);
}
}
}
else
{
wait();
}
}
else
{
printf("errror \n");
}
return 0;
}
如果有人能看出问题所在,如果您要 运行 它...它的工作原理是先点击控制 C,然后您必须继续点击控制 Z。然后您可以看到来自 child A 与 B 不匹配,如下所示
Waiting for interrupt
^C^ZChild 1: 2
result in A :99
^ZChild 1: 8
result in A :99
result from B: 4
^ZChild 1: 1
result in A :99
result from B: 0
管道实际上工作正常...是 scanf()
出了问题。当您的第二个子进程启动时,它会调用:
if (myJump == 0)
{
pause();
scanf("%d", &num1);
printf("CHild 2: %d\n", num1); /* <== problem here */
myJump = 1;
}
...printf()
留下 "CHild 2: " 作为 sd[]
管道中的下一个数据。因此,当您的第一个子进程调用 scanf()
以读取第二个子进程的结果时,scanf()
失败并保持 returnResult
不变。由于 scanf()
失败,数据将保留在流中,并且以后对 scanf()
结果的尝试也会以同样的方式失败。
如何修复取决于您的需要。如果您希望您的第二个子进程只 return 它读取的数字作为第一遍的结果,那么只需修改有问题的 printf()
以只写没有文本的数字:
if (myJump == 0)
{
pause();
scanf("%d", &num1);
printf("%d\n", num1); /* <== Changed: number only, no text */
myJump = 1;
}
我要补充一点,虽然上述更改会解决问题,但您通常应该检查 scanf()
中的 return 是否成功,如果不成功则采取适当的措施。