Труба: Как я могу убедиться, что я успешно пишу в трубу? - PullRequest
Новая
       14

Труба: Как я могу убедиться, что я успешно пишу в трубу?

0 голосов
/ 18 марта 2019 
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/wait.h>
#include <string.h>
#define SIZE 50

struct record {
    int freq;
    char word[SIZE];
};

int main(){

int number_process = 3;
int pipes[number_process][2];

struct record r1;
r1.freq = 10;
strcpy(r1.word, "Cat");

struct record r2;
r2.freq = 20;
strcpy(r2.word, "Elephant");

struct record r3;
r3.freq = 30;
strcpy(r3.word, "Dragon");

struct record records_array[3] = {r1, r2, r3}; 

for (int i = 0; i < number_process; i++){

    if (pipe(pipes[i]) == -1){
        perror("pipe");
        exit(1);
    }

    // Create children.
    pid_t fork_result = fork();
    if (fork_result == -1){
        perror("Parent fork");
        exit(1);
    } else if (fork_result == 0){

        if (close(pipes[i][0]) == -1){
            perror("Child closes reading port");
            exit(1);
        }

        // Later children is going to close all reading port from pipe that parent creates.
        for (int child_no = 0; child_no < i; child_no++) {
            if (close(pipes[child_no][0]) == -1) {
                perror("close reading ends of previously forked children");
                exit(1);
            }
        }

        // Now, I am trying to write each strct record member from the above array into the pipe
        // when I run the program, it won't allow me to do so because of bad file descriptor exception.
        for (int j = 0; j < number_process; i++){
            if (write(pipes[i][1], &(records_array[j]), sizeof(struct record)) == -1){
                perror("write from child to pipe");
                exit(1);
            }
        }

        // Finishing writing, close the writing end in pipe.
        if (close(pipes[i][1]) == -1){
            perror("Child closes writing port");
            exit(1);
        }
        // Terminate the process.
        exit(0);

    } else {
        // Parent is closing all the writing ends in pipe.
        if (close(pipes[i][1]) == -1){
            perror("Parent close writing");
            exit(1);
        }

    }

}

struct record buffer;

for (int i = 0; i < number_process; i++){
    // Parent reads from the pipe.
    if (read(pipes[i][0], &buffer, sizeof(struct record)) == -1){
        perror("parent read");
        exit(1);
    }

    printf("buffer.freq = %d\n", buffer.freq);
    printf("buffer.word = %s\n", buffer.word);

}


    return 0;

}

Я новичок в системном программировании, следующий код - это некоторая практика, которую я реализую, чтобы увидеть функциональность канала.У меня есть несколько вопросов к моему коду:

1) Есть ли какой-либо системный вызов или вызов библиотеки, который поможет мне убедиться, что контент, который я хочу записать в канал, действительно был успешно записан в канал?Другими словами, есть ли у меня какие-либо методы для проверки содержимого / данных, которые я записал в канал?

2) Я чувствую, что моя родительская часть чтения не реализована правильно, когда я запускаю этот код, мой родительЧитающая часть читает последовательно 3 одинаковые вещи, хотя каждый раз, когда она читает, это должно быть по-разному.

3) Я столкнулся с проблемой плохих адресов, когда я пытаюсь что-то прочитать из конвейера в моем родительском процессе.причина возникновения этой ошибки?

Может кто-нибудь помочь мне разобраться в этом?Очень ценят.

1 Ответ

2 голосов
/ 18 марта 2019

Вы получили простую ошибку вырезания и вставки.for (int j = 0; j < number_process; i++){

Вам нужно увеличить j.

...