Ошибка канала C ++, pipe_wait навсегда - PullRequest
Новая
       10

Ошибка канала C ++, pipe_wait навсегда

1 голос
/ 26 января 2012

Это мой код 

#include <iostream>
#include <string>
#include <sys/wait.h>
#include <sys/types.h>
#include <unistd.h>
#include <stdlib.h>
#include <vector>
#include <sstream>
#include <stdio.h>
using namespace std;

int main() {

    int pipe_A[2];
    int pipe_B[2];

    pipe(pipe_A);
    pipe(pipe_B);

    pid_t pid_A, pid_B, pid_C;

    if (!(pid_A = fork())) {
        dup2(pipe_A[1], 1); /* redirect standard output to pipe_A write end */

        system("./data");
        exit(0);
    }

    if (!(pid_B = fork())) {
        dup2(pipe_A[0], 0); /* redirect standard input to pipe_A read end */
        dup2(pipe_B[1], 1); /* redirect standard output to pipe_B write end */

        system("grep 5");
        exit(0);
    }

    if (!(pid_C = fork())) {
        dup2(pipe_B[0], 0); /* redirect standard input to pipe_B read end */

        system("grep 2");
        exit(0);
    }

    return 0;
}

. В котором "./data" - мой тестовый образец, который выполняет: 

for(int i=0;i<100;i++){
cout<<i<<endl;
}

Я пытался построить трубу в соответствии с этим ссылка :

Видимо моя программа не работает.После запуска моей программы два процесса будут выполнять pipe_wait навсегда (я видел это по системному монитору).Кажется, что некоторые трубы должны быть закрыты.Как мне это исправить?

1 Ответ

2 голосов
/ 26 января 2012

Каждый ребенок получает свою собственную копию файловых дескрипторов родителя. И dup2 создает еще одну копию. Сторона чтения канала не вернет EOF, пока все копии стороны записи не закроются.

Поэтому после каждого вызова fork + dup2 продолжайте и close все четыре из pipe_A [0], pipe_A [1], pipe_B [0] и pipe_B [1].

Также закройте их в родительском элементе после того, как вы разветвите всех детей. (Это не обязательно в вашем примере, так как они будут закрыты автоматически, когда main () вернется. Но я бы все равно сделал это для чистоты.)

...