0

我正在尝试在 c 中创建一个程序，该程序分叉一个孩子并使用两个单独的管道进行双向通信。

总结；

  1. 父亲写入 pipe1
  2. 孩子从 pipe1 中读取数据并进行计算
  3. 孩子在 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 步之后关闭 pipe1() 一切正常，问题是我需要在未来继续写信给那个孩子，所以我不能关闭它.

4

1 回答 1

1

在您的父级中，您不希望将管道的写入端关闭到父级close(alPadre[1]);，因为这样您的后续子级将无法使用该管道与父级交谈。

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

作为另一个例子，在您的子进程中，您调用close(aHijos[j][0]);所有 j < i。同样，这些文件描述符中的大多数以前在分叉之前由父级关闭，因此您再次“随机”关闭aHijos[j][0]所有 j < i 发生的任何文件描述符编号。

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

于 2015-03-05T06:29:05.150 回答