Простая вилка и трубопровод

Question

Я стараюсь понять, что касается форкирования и трубопроводов в классе моих операционных систем. Я не уверен, почему второй дочерний процесс не распечатает meminfo. Кажется, он пишет в трубу, если я распечатаю его, но во втором дочернем процессе он ничего не прочитает. Я что-то упустил, чтобы второй процесс мог читать из трубы?

#include <stdlib.h> 
#include <stdio.h> 
#include <unistd.h> 
#include <fcntl.h> 
#include <errno.h> 
#include <sys/wait.h> 

#define R_FILE "/proc/meminfo" 
#define BSIZE 256 
#define READ_END 0 
#define WRITE_END 1 

int main() 
{ 
    int status; 
    pid_t pid_1, pid_2; 

    int pipefd[2]; 
    pipe(pipefd); 

    pid_1 = fork(); 
    if (pid_1 == 0) { 
    /* process a */ 

    int rfd; 
    size_t rsize; 
    char buf[BSIZE]; 
    close(pipefd[READ_END]); 
    if ((rfd = open(R_FILE, O_RDONLY)) < 0) { 
     fprintf(stderr, "\nError opening file: %s. ERROR#%d\n", R_FILE, errno); 
     return EXIT_FAILURE; 
    } 

    /* read contents of file and write it out to a pipe */ 
    while ((rsize = read(rfd, buf, BSIZE)) > 0) { 
     /* This should write to a pipe */ 
     write(pipefd[1], buf, rsize); 
    } 

    close(pipefd[WRITE_END]); 
    close(rfd); 
    return 0; 
    } 

    pid_2 = fork(); 
    if (pid_2 == 0) { 
    /* process b */ 
    size_t rsize; 
    char buf[BSIZE]; 
    /* read from pipe and write out contents to the terminal */ 
    close(pipefd[WRITE_END]); 
    /* Thishis should read from a pipe */ 

     while ((rsize = read(pipefd[1], buf,BSIZE)) > 0) { 
     write(STDOUT_FILENO, buf, rsize); 

     } 

    close(pipefd[READ_END]); 

    return 0; 
    } 

    /* shell process */ 
    if ((waitpid(pid_1, &status, 0)) == -1) { 
    fprintf(stderr, "Process 1 encountered an error. ERROR%d", errno); 
    return EXIT_FAILURE; 
    } 

    if ((waitpid(pid_2, &status, 0)) == -1) { 
    fprintf(stderr, "Process 2 encountered an error. ERROR%d", errno); 
    return EXIT_FAILURE; 
    } 

    return 0; 
} 

Answer 1

В процессе b вы, вероятно, читаете с неправильного fd read(pipefd[1], buf,BSIZE). Замените его на read(pipefd[READ_END], buf,BSIZE).