Programm, lesen Sie die Datei und senden Sie es an den übergeordneten Prozess mit Rohr

Question

Ich muss ein Programm schreiben, die Pipe senden Dateiname von der Befehlszeile zu untergeordneten Prozess erstellen. Im Kind lesen Sie diese Datei und senden Sie sie mit Hilfe der Pipe zurück. Übergeordneter Prozess sollte die Datei drucken. Wenn ein Fehler im untergeordneten Prozess auftritt, muss der Fehler an den übergeordneten Prozess gesendet werden.

Hier ist mein Code, es drucken einige Junk-Datei Datei (und auch deaktivieren Scrollen im Terminalemulator, wenn ich es ausführen).

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

void main(int argc, char *argv[]) { 
    int pipefd[2]; 
    char buff[100]; 
    int childpid; 
    int size; 
    FILE *file; 

    if (argc != 2) { 
     printf("usage:\n%s <filename>\n", argv[0]); 
     exit(1); 
    } 
    if (pipe(pipefd) < 0) { 
     perror("can't open pipe\n"); 
    } 
    if ((childpid = fork()) == 0) { 
     sleep(1); 
     size = read(pipefd[0], buff, sizeof(buff)); 
     file = fopen(buff, "r"); 
     if (file == NULL) { 
     write(pipefd[1], "Can't open file", 15); 
     exit(1); 
     } 
     while (!feof(file)) { 
     if (fgets(buff, sizeof(buff), file) == NULL) { 
      write(pipefd[1], "Error reading file", 18); 
     } else { 
      write(pipefd[1], buff, sizeof(buff)); 
     } 
     } 
    } else if (childpid > 0) { 
     size = strlen(argv[1]); 
     if (write(pipefd[1], argv[1], size) != size) { 
     perror("Error writing to pipe\n"); 
     } 
     wait(NULL); 
     while ((size = read(pipefd[0], buff, sizeof(buff))) > 0) { 
     write(1, buff, size); 
     } 
    } 
    exit(0); 
} 

Answer 1

Ihr Programm funktioniert nach einigen Änderungen wie gewünscht. Lets list, was alle Änderungen benötigt werden und warum -

I) Sowohl im Kind und Eltern, schließen Sie die entsprechenden Rohre, sobald Sie mit ihnen fertig sind. Von man page von read(3),

Wenn einige Verfahren das Rohr zum Schreiben geöffnet hat und O_NONBLOCK ist klar, read() wird der aufrufende Thread blockiert, bis einige Daten geschrieben oder das Rohr durch alle Prozesse geschlossen ist, der hatte das Rohr offen für Schreiben.

Also überall in Ihrem Code so etwas tun, wo die Arbeit Rohre vorbei ist,

size = read(pipefd[0], buff, sizeof(buff)); 
    close(pipefd[0]); 

    write(pipefd[1], buff, strlen(buff)); 
    close(pipefd[1]); 

    if (write(pipefd[1], argv[1], size) != size) { 
    perror("Error writing to pipe\n"); 
    } 
    close(pipefd[1]); 

    while ((size = read(pipefd[0], buff, sizeof(buff))) > 0) 
    { 
    write(1, buff, size); 
    } 
    close(pipefd[0]); 

Sie hatte das Schreibende des Rohrs in das Kind nicht geschlossen und Ihre Eltern versperrte in den read

II) Sie sind mit so etwas wie while(fgets(...)) in einer Schleife Daten aus der Datei zu lesen. Dies wird bombardieren, wenn es neue Zeilen in der Datei und fgets mehrfach zurückgibt, während des Prozesses der buffer jedes Mal überschreiben

Ich benutze immer einfach fgetc und feof Kombination aus einer Datei zu lesen.So ändern Sie Ihre Datei Lesemechanismus zu so etwas wie

unsigned count=0; 
while (!feof(file) && count < sizeof(buff)) 
    buff[count++]=fgetc(file); 
if (feof(file)) 
    buff[--count]=0; 
else 
    buff[sizeof(buff)-1]=0; 

III) Während die Dateidaten von dem Kind zu schreiben, Sie strlen verwenden sollten (wie wir bereits sicher Puffer null beendet wird, siehe oben) und nicht sizeof als der Puffer möglicherweise nicht voll und Sie werden am Ende schreiben Müll. So ändern

write(pipefd[1], buff, sizeof(buff)); 

zu

write(pipefd[1], buff, strlen(buff)); 

IV) ein sicheres exit von dem Kind folgen und Eltern nach ihrer Arbeit erledigt ist. So etwas wie

close(pipefd[1]); 
_exit(EXIT_SUCCESS); // in child 

und

close(pipefd[0]); 
exit(EXIT_SUCCESS); // in parent 

PS: Ich habe die Datei zu lesen Logik geändert, so dass Ihr Compiler-Fehler ist jetzt weg und folgen den gegebenen Ratschläge von n.m.

Answer 2

Dieser Code nicht kompiliert:

while (fgets(buff, sizeof(buff), file) != NULL) { 
     write(pipefd[1], "Error reading file", 18); 
    } else { 
     write(pipefd[1], buff, sizeof(buff)); 
    } 

Sie keine else Klausel dort haben kann.

Answer 3

Sie können sizeof(buf) sinnvolle Bytes nicht schreiben, wenn fgets weniger zurückgegeben wird. Der Rest wird mit Müll gefüllt sein.

Darüber hinaus ist die Mischung String-orientierte fgets mit binären read/write ein schlechter Stil. Verwenden Sie read oder fread, um die Datei zu lesen. Sie geben die Anzahl der gelesenen Bytes zurück und verwenden diese Zahl als Argument für write.