Pipes zwischen drei Kindern

Question

Ich würde diesen Befehl ls -al/| tr a-j A-J | tr k-z K-Z ausführen und ich würde drei Kinder aus Vater Prozess erstellen.

Ich weiß, dass ich habe zwei Rohre zu öffnen, lassen Vater für alle seine Kinder wartet (alle Leitungen zu schließen) und in den Kindern ich habe

• schließen STDIN auf dem ersten Kind
• schließen STDOUT auf dem ersten Rohr und STDIN auf dem zweiten Rohr, auf das zweite Kind
• schließen STDOUT auf dem dritten Kind

Nun, dies ist mein Code. Wenn ich es mit nur zwei Kindern benutze, funktioniert es. Aber wenn ich versuche, es mit drei Kindern zu laufen, funktioniert es nicht.

// command is ls -al/| tr a-j A-J | tr k-z K-Z 

#include <stdio.h> 
#include <stdlib.h> 
#include <unistd.h> 

int main(int argc, char **argv) { 
int fd1[2]; 
int fd2[2]; 
pid_t pid = 0; 

pipe(fd1); 
pipe(fd2); 

pid = fork(); 
if(pid == 0) { 
    close(fd1[0]); 
    dup2(fd1[1], 1); 
    close(fd1[1]); 

    execlp("ls", "ls", "-al", "/", NULL); 
} 

pid = fork(); 
if(pid == 0) { 
    close(fd1[1]); 
    dup2(fd1[0], 0); 
    close(fd1[0]); 

    close(fd2[0]); 
    dup2(fd2[1], 1); 
    close(fd2[1]); 

    execlp("tr", "tr", "a-j", "A-J", NULL); 
} 

pid = fork(); 
if(pid == 0) { 
    close(fd2[1]); 
    dup2(fd2[0], 0); 
    close(fd2[0]); 

    execlp("tr", "tr", "k-z", "K-Z", NULL); 
} 

close(fd1[0]); 
close(fd1[1]); 
close(fd2[0]); 
close(fd2[1]); 

while ((pid = wait(NULL)) != -1); 

exit(0); 
} 

Vielen Dank im Voraus.

Answer 1

Sie könnten pipe2() mit close_on_exec Flag verwenden. Der folgende Code funktioniert:

#include <stdio.h> 
#include <stdlib.h> 
#include <unistd.h> 
#include <fcntl.h> 

int main(int argc, char **argv) { 
    int fd1[2]; 
    int fd2[2]; 
    pid_t pid = 0; 

    pipe2(fd1,O_CLOEXEC); 
    pipe2(fd2,O_CLOEXEC); 

    pid = fork(); 
    if(pid == 0) { 
    dup2(fd1[1],1); 
    execlp("ls", "ls", "-al", "/", NULL); 
    } 

    pid = fork(); 
    if(pid == 0) { 
    dup2(fd1[0],0); 
    dup2(fd2[1],1); 
    execlp("tr", "tr", "a-j", "A-J", NULL); 
    } 

    pid = fork(); 
    if(pid == 0) { 
    dup2(fd2[0],0); 
    execlp("tr", "tr", "k-z", "K-Z", NULL); 
    } 

    close(fd1[0]); 
    close(fd1[1]); 
    close(fd2[0]); 
    close(fd2[1]); 

    while ((pid = wait(NULL)) != -1); 

    exit(0); 
} 

Es ist möglich, auch Rohr() Aufruf zu verwenden, aber Sie sollten darauf achten, Deskriptoren überall manuell zu schließen, das ist fehleranfällig (Sie gezeigt, dass durch dieses Problem Entsendung; -)):

#include <stdio.h> 
#include <stdlib.h> 
#include <unistd.h> 

int main(int argc, char **argv) { 
    int fd1[2]; 
    int fd2[2]; 
    pid_t pid = 0; 

    pipe(fd1); 
    pipe(fd2); 

    pid = fork(); 
    if(pid == 0) { 
    close(fd1[0]); 
    dup2(fd1[1], 1); 
    close(fd1[1]); 

    execlp("ls", "ls", "-al", "/", NULL); 
    } 

    pid = fork(); 
    if(pid == 0) { 
    close(fd1[1]); 
    dup2(fd1[0], 0); 
    close(fd1[0]); 

    close(fd2[0]); 
    dup2(fd2[1], 1); 
    close(fd2[1]); 

    execlp("tr", "tr", "a-j", "A-J", NULL); 
    } 

    pid = fork(); 
    if(pid == 0) { 
    close(fd1[0]); 
    close(fd1[1]); 
    close(fd2[1]); 
    dup2(fd2[0], 0); 
    close(fd2[0]); 

    execlp("tr", "tr", "k-z", "K-Z", NULL); 
    } 

    close(fd1[0]); 
    close(fd1[1]); 
    close(fd2[0]); 
    close(fd2[1]); 

    while ((pid = wait(NULL)) != -1); 
}