☰

为什么 grep 在这里返回 SIGPIPE（信号 13）？

tag-icon • tag-icon linux pipe c signals
为什么 grep 在这里返回 SIGPIPE（信号 13）？

我必须创建一个程序，其中 P0 作为父进程，P1,...,PN 子进程。每个孩子都必须在文件中执行 grep 并在管道中返回输出。然后 P0 必须读取消息并计算行数，并将包含该数字的句子打印到 stdout 中。问题是每个孩子都会因信号13而被非自愿地终止。为什么会发生这种情况？这是我的代码：

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

//eventuali define
#define MAXDIM 255
#define MAXPID 30

//global var declaration
int fd;
int pipefd[MAXPID][2];

//func declaration
void print_usage(char* prog_name);
void wait_child();
void codice_figlio(int index, char *word, char *filename);
void handler(int signo);
int conta_righe(char *str);

int main(int argc, char *argv[]) {
//    local var declaration
    int N = argc - 2;
    int pid[MAXPID];
    int i, num;
    char buf[MAXDIM];

    if (argc < 3) {
        fprintf(stderr, "Numero di parametri non valido\n");
        print_usage(argv[0]);
        exit(EXIT_FAILURE);
    }
    for (i = 1; i <= N; i++) {
        if ((fd = open(argv[i], O_RDONLY)) < 0) {
            perror("Errore nell'apertura del file");
            exit(EXIT_FAILURE);
        }
        close(fd);
    }
    signal(SIGUSR1, handler);
    for (i = 0; i < N; i++) {
        pid[i] = fork();
        if (pipe(pipefd[i]) < 0) exit(-3);
        if (!pid[i]) {
            pause();
            codice_figlio(i, argv[argc - 1], argv[i + 1]);
        }
        else if (pid[i] < 0) {
            perror("fork error");
            exit(-3);
        }
        sleep(1);
        kill(pid[i], SIGUSR1);
        close(pipefd[i][1]);
        read(pipefd[i][0], buf, sizeof(int));
        num = conta_righe(buf);
        printf("Nel file %s sono state trovate %d occorrenze di %s.\n", argv[i + 1], num, argv[argc - 1]);
    }
    for (i = 0; i < N; i++) {
        wait_child();
        close(pipefd[i][0]);
        close(pipefd[i][1]);
    }
    return 0;
}

void print_usage(char* prog_name){
    fprintf(stderr, "Usage:\n\t%s file1 file2 ... fileN parola\n", prog_name);
}

void wait_child() {
    int status, pid;
    pid = wait(&status);
    printf("*P0 (pid = %d): Terminato processo figlio PID = %d: ", getpid(), pid);
    if ((char)status == 0) printf("Terminazione volontaria con stato %d\n", status>>8);
    else printf("Terminazione involontaria per segnale %d\n", (char)status);
}

void codice_figlio(int index, char *word, char *filename) {
    close(pipefd[index][0]);
    close(1);
    dup(pipefd[index][1]);
    close(pipefd[index][1]);
    execlp("/bin/grep", "grep", word, filename, (char*)0);
    perror("Problemi con la grep");
    exit(EXIT_FAILURE);
}

void handler(int signo) {
    return;
}

int conta_righe(char *str) {
    int res = 0, i = 0;
    while (str[i] != '\0') {
        if (str[i] == '\n') res++;
        i++;
    }
    return res;
}

答案1

将 移到if (pipe(pipefd[i]) < 0)之前fork()。否则，您只是创建两个单独的管道（在父级和子级中），并且SIGPIPE当您关闭子级中管道的写入端（在函数中codice_figlio()）时，您会得到 a ，因为它是对它的唯一引用，不是父级和子级之间共享的描述符。

这不是唯一的问题；read(pipefd[i][0], buf, sizeof(int));已损坏，因为您只能从管道中读取 4 个字节，但您的conta_righe()函数会尝试计算其中的行数。将 更改sizeof(int)为sizeof buf.

之后，你的代码似乎做某物明智的：

$ ./fo fo.c fo.c pipefd
Nel file fo.c sono state trovate 8 occorrenze di pipefd.
Nel file fo.c sono state trovate 8 occorrenze di pipefd.
*P0 (pid = 9541): Terminato processo figlio PID = 9542: Terminazione volontaria con stato 0
*P0 (pid = 9541): Terminato processo figlio PID = 9543: Terminazione volontaria con stato 0

这是您代码的补丁（手动应用，该网站会破坏选项卡）：

--- fo.c~   2020-04-20 20:51:19.540914204 +0300
+++ fo.c    2020-04-20 20:51:22.648914269 +0300
@@ -42,8 +42,8 @@
     }
     signal(SIGUSR1, handler);
     for (i = 0; i < N; i++) {
-        pid[i] = fork();
         if (pipe(pipefd[i]) < 0) exit(-3);
+        pid[i] = fork();
         if (!pid[i]) {
             pause();
             codice_figlio(i, argv[argc - 1], argv[i + 1]);
@@ -55,7 +55,7 @@
         sleep(1);
         kill(pid[i], SIGUSR1);
         close(pipefd[i][1]);
-        read(pipefd[i][0], buf, sizeof(int));
+        read(pipefd[i][0], buf, sizeof(buf));
         num = conta_righe(buf);
         printf("Nel file %s sono state trovate %d occorrenze di %s.\n", argv[i + 1], num, argv[argc - 1]);
     }

相关内容