从管道读取值不起作用

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 是否成功,如果不成功则采取适当的措施。