c - C 中管道的两种方式进程通信

Question

我正在尝试用 c 语言编写一个程序，该程序 fork 一个子进程，并使用两个单独的管道进行双向通信。

总结；

1. 父亲写入pipe1
2. 子进程从 pipeline1 读取数据并进行计算
3. child 将答案写在pipe2中
4. 父亲从pipe2读取信息

一切进展顺利，直到第3步，如果我从第4点注释代码，那么一切都有效，我什至检查对pipe2的写入，它似乎工作，但是当我尝试从父亲的pipe2读取时它挂起的代码甚至不执行子计算，步骤 2 和 3。请帮助我。这是我到目前为止的代码。

int main(int argc, char *argv[]) {

pid_t pid;
pid_t* trabajadores;

int nHijos = 1;

trabajadores = (pid_t*)malloc(sizeof(pid_t) * nHijos);

int** aHijos;
int links = 0;

// Matriz de pipes
aHijos = (int **) malloc(sizeof(int *) * nHijos);
for (i = 0; i < nHijos; i++) {
    aHijos[i] = (int *) malloc(sizeof(int)*2);
}

int alPadre[2];
pipe(alPadre);

// Se crea el pool de procesos
for (i = 0; i < nHijos; i++) {

    pipe(aHijos[i]);
    pid = fork();

    if (pid == 0) {

        int j;
        FILE* salidaHijo;
        FILE* entradaHijo;
        char buffer2[1024];
        close(alPadre [0]);
        for (j = 0; j<i; j++) {
            close(aHijos[j][0]);
            close(aHijos[j][1]);
        }
        close(aHijos[i][1]);

        entradaHijo = fdopen(aHijos[i][0], "r");


        // STEP 2
        while ( !feof (entradaHijo) &&  fgets (buffer2, sizeof (buffer2), entradaHijo) != NULL) {
            buffer2[strcspn(buffer2, "\n")] = 0;
        }

        char* resultado;


        /* CALCULATIONS */





// STEP 3
        salidaHijo = fdopen(alPadre[1], "w");
        printf("%i\n", fprintf(salidaHijo, "%s\n", resultado));
        fflush (salidaHijo);

        exit(0);

    } else {
        trabajadores[i] = 0;
        close(alPadre[1]);
        close(aHijos[i][0]);


        // STEP 1
        FILE** salidaPadre;
        salidaPadre = (FILE**)malloc(sizeof(FILE*) * nHijos);
        for (i = 0; i < nHijos; i++) {
            salidaPadre[i] = fdopen(aHijos[i][1], "w");
        }
        fprintf(salidaPadre[j], "%s\n", DesencolarT(trabajos));
        trabajadores[j] = 1;


        sleep(5);


        // STEP 4
        char buffer[1024];
        entradaPadre = fdopen(alPadre[0], "r");
        read(alPadre[0], buffer, sizeof(buffer));
        while ( !feof (entradaPadre) &&  fgets (buffer, sizeof (buffer), entradaPadre) != NULL) {
            printf("%s\n", buffer);

        }
    }
}
return 0; 
}

无法编译的只是我代码的粘贴部分，这是两个进程的 strace -ff -o test.log ./myProg 的输出。

getdents(4, /* 0 entries */, 32768)     = 0
fstat64(1, {st_mode=S_IFCHR|0620, st_rdev=makedev(136, 0), ...}) = 0
mmap2(NULL, 4096, PROT_READ|PROT_WRITE, MAP_PRIVATE|MAP_ANONYMOUS, -1, 0) = 0xb7761000
write(1, ". 160\n", 6)                  = 6
fcntl64(6, F_GETFL)                     = 0x1 (flags O_WRONLY)
fstat64(6, {st_mode=S_IFIFO|0600, st_size=0, ...}) = 0
mmap2(NULL, 4096, PROT_READ|PROT_WRITE, MAP_PRIVATE|MAP_ANONYMOUS, -1, 0) = 0xb7760000
_llseek(6, 0, 0xbfb8895c, SEEK_CUR)     = -1 ESPIPE (Illegal seek)
read(3, 0xbfb89738, 1024)               = ? ERESTARTSYS (To be restarted)
--- SIGINT (Interrupt) @ 0 (0) ---
+++ killed by SIGINT +++

并且

close(3)                                = 0
close(6)                                = 0
fcntl64(5, F_GETFL)                     = 0 (flags O_RDONLY)
fstat64(5, {st_mode=S_IFIFO|0600, st_size=0, ...}) = 0
mmap2(NULL, 4096, PROT_READ|PROT_WRITE, MAP_PRIVATE|MAP_ANONYMOUS, -1, 0) = 0xb7761000
_llseek(5, 0, 0xbfb8895c, SEEK_CUR)     = -1 ESPIPE (Illegal seek)
read(5, 0xb7761000, 4096)               = ? ERESTARTSYS (To be restarted)
--- SIGINT (Interrupt) @ 0 (0) ---

谢谢，很抱歉西类牙文的长帖子和糟糕的格式。

<小时/>

在第 1 步和第 3 步之后使用 fflush()，我发现如果我在第 1 步之后关闭 pipeline1() 一切正常，问题是我需要在将来继续写信给那个 child ，这样我就可以'不要关闭它。

Answer 1

在您的父级中，您不想关闭父级管道的写入端 close(alPadre[1]); 因为这样您的后续子级将无法说话使用该管道发送给父级。

事实上，您在以后的循环迭代中对 close(alPadre[1]); 的后续调用可能会无意中关闭父级中的其他“随机”文件描述符，因为它将关闭任何文件描述符编号alPadre[1] 恰好是在那个时候。关闭任何文件描述符后，您可能希望将该变量的值设置为 -1，以便使用该变量的进一步调用不会产生任何影响。

再举一个例子，在您的子进程中，您对所有 j < i 调用 close(aHijos[j][0]);。同样，这些文件描述符中的大多数在 fork 之前已被父级关闭，因此您再次“随机”关闭所有恰好在 aHijos[j][0] 处的文件描述符编号j

此外，您的父级最终需要关闭用于与每个子级通信的管道的写入端，否则子级将永远等待其输入循环中的更多输入。这可能就是您的父级在步骤 #4 挂起的原因，因为您的子级在步骤 #2 挂起，等待来自父级的管道上的 EOF。