Ajout exo3

ANALE-1/EXO3/RESOLUTION/pipeline.c

@@ -0,0 +1,83 @@
+// pipeline.c
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <fcntl.h>
+#include <sys/wait.h>
+
+int main(void) {
+    int tube1[2],tube2[2];
+    int res1 = pipe(tube1);
+    if (res1 == -1){
+    perror("Création Pipe 1"); exit(-1);
+    }
+    int res2 = pipe(tube2);
+    if (res2 == -1){
+    perror("Création Pipe 1"); exit(-1);
+    }
+
+    // --- CUT ---
+    pid_t pid_cut = fork();
+    if (pid_cut == -1) { perror("fork cut"); exit(EXIT_FAILURE); }
+    if (pid_cut == 0) {
+        close(tube1[1]);
+        close(tube2[0]);
+        if (dup2(tube1[0], STDIN_FILENO) == -1) { perror("dup2 cut in"); _exit(1); }
+        if (dup2(tube2[1], STDOUT_FILENO) == -1) { perror("dup2 cut out"); _exit(1); }
+        close(tube1[0]);
+        close(tube2[1]);
+        execlp("cut", "cut", "-d,", "-f3", NULL);
+        perror("execlp cut");
+        _exit(127);
+    }
+
+
+    // SORT 
+    pid_t pid_sort = fork();
+    if (pid_sort == -1) { perror("fork sort"); exit(EXIT_FAILURE); }
+    if (pid_sort == 0) {
+    close(tube1[0]); close(tube1[1]);
+    close(tube2[1]);
+    if (dup2(tube2[0], STDIN_FILENO) == -1) { perror("dup2 sort in"); _exit(1); }
+       close(tube2[0]);
+
+        int fd = open("sortie", O_CREAT | O_WRONLY | O_TRUNC, 0644);
+        if (fd == -1) { perror("open sortie"); _exit(1); }
+        if (dup2(fd, STDOUT_FILENO) == -1) { perror("dup2 sortie"); _exit(1); }
+        close(fd);
+
+        execlp("sort", "sort", NULL);
+        perror("execlp sort");
+        _exit(127);
+    }
+    
+    // --- GREP ---
+    pid_t pid_grep = fork();
+    if (pid_grep == -1) { perror("fork grep"); exit(EXIT_FAILURE); }
+    if (pid_grep == 0) {
+        close(tube2[0]); close(tube2[1]);
+        close(tube1[0]);
+
+        int fd = open("server.log", O_RDONLY);
+        if (fd == -1) { perror("open server.log"); _exit(1); }
+        if (dup2(fd, STDIN_FILENO) == -1) { perror("dup2 grep in"); _exit(1); }
+        close(fd);
+
+        if (dup2(tube1[1], STDOUT_FILENO) == -1) { perror("dup2 grep out"); _exit(1); }
+        close(tube1[1]);
+
+        execlp("grep", "grep", "invalid credentials", NULL);
+        perror("execlp grep");
+        _exit(127);
+    }
+    
+    // Parent
+    close(tube1[0]); close(tube1[1]);
+    close(tube2[0]); close(tube2[1]);
+
+    int status;
+    waitpid(pid_grep, &status, 0);
+    waitpid(pid_cut,  &status, 0);
+    waitpid(pid_sort, &status, 0);
+    return 0;
+}