Open () с блоками O_WRONLY, хотя я открываю () с O_RDONLY на другом конце - PullRequest
Новая
       9

Open () с блоками O_WRONLY, хотя я открываю () с O_RDONLY на другом конце

0 голосов
/ 28 апреля 2018

Я столкнулся с точной проблемой, о которой говорится в названии.

код 

pid_t childpid;
int childfdRead, childfdWrite; // file descriptors for childs
int parentfdsRead[numWorker], parentfdsWrite[numWorker]; // file descriptors for parent

// store the fifo filenames
char *childPipeNameRead[numWorker];
char *childPipeNameWrite[numWorker];

// helper string to construct fifo filenames
char *suffix = (char*)malloc(20*sizeof(char));
char *fifoname = (char*)malloc(20*sizeof(char));

for(i = 0; i < numWorker; i++){
    // Fifo filename structure read
    sprintf(fifoname, "%s", PATH);
    sprintf(suffix, "_childRead%d", i);
    childPipeNameRead[i] = strdup(strcat(fifoname, suffix));
    mkfifo(childPipeNameRead[i], 0666);

    // Fifo filename structure write
    sprintf(fifoname, "%s", PATH);
    sprintf(suffix, "_childWrite%d", i);
    childPipeNameWrite[i] = strdup(strcat(fifoname, suffix));
    mkfifo(childPipeNameWrite[i], 0666);

    childpid = fork();

    if(childpid < 0){
        perror("fork\n");
    }

    else if(childpid == 0){
        // Open read and write pipes on childs.
        if((childfdRead = open(childPipeNameRead[i], O_RDONLY | O_NONBLOCK)) < 0)
            perror("child pipe:");

        printf("Child with id %d opened pipe with name %s\n", getpid(), childPipeNameRead[i]);

        if((childfdWrite = open(childPipeNameWrite[i], O_WRONLY)) < 0)
            perror("child pipe:");

        printf("Child with id %d opened pipe with name %s\n", getpid(), childPipeNameWrite[i]);
        break;
    }
    else{
        // Open read and write pipes for each child in the parent process.
        if((parentfdsRead[i] = open(childPipeNameRead[i], O_RDONLY | O_NONBLOCK)) < 0)
            perror("parent pipe:");
        printf("Parent with id %d opened pipe with name %s\n", getpid(), childPipeNameRead[i]);

        if((parentfdsWrite[i] = open(childPipeNameWrite[i], O_WRONLY)) < 0)
            perror("parent pipe:");
        printf("Parent with id %d opened pipe with name %s\n", getpid(), childPipeNameWrite[i]);
    }
}

Программа зависает после того, как родитель и один дочерний элемент открывают канал чтения (родительский элемент открывает только один из них). Это нормальное поведение? Я ожидал, что он откроет все каналы, так как я использую O_RDONLY | O_NONBLOCK как для родителя, так и для ребенка.

1 Ответ

0 голосов
/ 28 апреля 2018

Проблема в том, что вы открываете childPipeNameRead[i] для чтения в и дочернего и родительского процесса. И точно так же вы открываете childPipeNameWrite[i] для записи в обоих процессах.

Вы должны сделать обратное в одном из процессов.

...