协同进程问题求助

Question

<code>
/***********************************************************************************/
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <signal.h>
#include <fcntl.h>

#define MAX_LINE        2048

static void sig_pipe(int);

int main(void)
{
    int    n, fd1[2], fd2[2];
    char   line[MAX_LINE];
    pid_t pid;

    if(signal(SIGPIPE, sig_pipe) == SIG_ERR)
    {
        printf("init signal error: %sn", strerror(errno));
        exit(1);
    }

    if((pipe(fd1) < 0) || (pipe(fd2) < 0))
    {
        printf("create pipe error: %sn", strerror(errno));
        exit(1);
    }

    if ((pid = fork()) < 0)
    {
        printf("fork error: %sn", strerror(errno));
        exit(1);
}
else if (pid > 0)
{
   close(fd1[0]);
   close(fd2[1]);
   while (fgets(line, MAX_LINE, stdin) != NULL)
   {
    n = strlen(line);
    if (write(fd1[1], line, n) != n)
    {
     printf("write to pipe failed: %sn", strerror(errno));
     exit(1);
    }
   
    if ((n = read(fd2[0], line, MAX_LINE)) < 0)
    {
     printf("read from pipe failed: %sn", strerror(errno));
     exit(1);
    }
   
    if (n == 0)
    {
     printf("child closed pipen");
     break;
    }
   
    line[n] = 0;
    if (fputs(line, stdout) == EOF)
    {
     printf("fputs error: %sn", strerror(errno));
     exit(1);
    }
   }
   if (ferror(stdin))
   {
    printf("fgets error: %sn", strerror(errno));
    exit(1);
   }
    }
    else
    {
   close(fd1[1]);
   close(fd2[0]);
  
   if (fd1[0] != STDIN_FILENO)
   {
    if (dup2(fd1[0], STDIN_FILENO) != STDIN_FILENO)
    {
     printf("dup2 error: %sn", strerror(errno));
     exit(1);
    }
    close(fd1[0]);
   }
  
   if (fd2[1] != STDOUT_FILENO)
   {
    if (dup2(fd2[1], STDOUT_FILENO) != STDOUT_FILENO)
    {
     printf("dup2 error: %sn", strerror(errno));
     exit(1);
    }
    close(fd2[1]);
   }
  
   if (execl("./add2", "add2", (char *)0) < 0)
   {
    printf("execl error: %sn", strerror(errno));
    exit(1);
   }
}
exit(0);
}

static void
sig_pipe(int signo)
{
printf("SIG_PIPE caughtn");
exit(1);
}
/***********************************************************************************/
</code>

过滤程序：
<code>
/***********************************************************************************/
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>

#define   MAX_LINE   2048

int main(void)
{
int        n, int1, int2;
char        line[MAX_LINE];

while ((n = read(STDIN_FILENO, line, MAX_LINE)) > 0)
{
   if (sscanf(line, "%d%d", &int1, &int2) == 2)
   {
    sprintf(line, "%dn", int1 + int2);
    n = strlen(line);
    if (write(STDOUT_FILENO, line, n) != n) {
     printf("write error: %s", strerror(errno));
     exit(1);
    }
   }
   else
   {
    if(write(STDOUT_FILENO, "Invalid argsn", 13) != 13)
    {
     printf("write error: %s", strerror(errno));
     exit(1);
    }
   }
}
exit(0);
}
/***********************************************************************************/
</code>

我是在linux环境上编译的，父进程可以将读取到的数据传给子进程，子进程能够处理也能够将结果写回管道，问题出现在父进程读取返回结果时，读到的内容长度为0，
    if (n == 0)
    {
          printf("child closed pipen");
          break;
    }
就在这个地方程序退出了。求各位大哥帮忙。

Answer 1

哈哈，自己搞定了