Блог

     for (int i = 0; i < number_processes; i  ){

        while (read(fps[i][0], amp;each_record_read, sizeof(struct rec)) > 0){
            if (records_container[i] == NULL){
                records_container[i] = amp;each_record_read;
            }
        } // I want to do something to records_container here.
    }
  

У меня есть программа, предназначенная для того, чтобы родительский процесс считывал данные из каждого канала, который подключается к нескольким дочерним процессам.

Я определил массив с именем records_container, который содержит каждый тип данных, которые я собираюсь прочитать из канала, и я хочу что-то сделать с этим массивом после цикла while.

Мой вопрос заключается в следующем: когда родительский процесс загружает данные в records_container этот массив, достаточно ли высока скорость загрузки родительского процесса, чтобы, когда я хочу что-то сделать с records_container, я всегда мог убедиться, что все данные уже загружены идеально?

Давайте предположим, что records_container в этом случае равен {0, 0, 0, 0} (я знаю, что хочу загрузить struct rec, но на самом деле это не имеет значения), идеальная ситуация, в которой я хочу, чтобы это произошло, заключается в том, что я хочу иметь дело с загруженным массивом, который равен {1, 2, 3, 4} в этом случае, будет ли родительский процесс достаточно быстро считывать каждое число (которое в данном случае равно 1, 2, 3, 4 из каждого канала), так что я не буду иметь дело с чем-то вроде {1, 2, 0, 0}, или {1, 0, 0, 0} … что-то в этом роде?

Это не работает.

 while (read(fps[i][0], amp;each_record_read, sizeof(struct rec)) > 0)
  

неверно, и вы можете получить короткое чтение. При работе со структурированным каналом мы обычно используем что-то вроде этого:

 ssize_t read_block(int source, void *buffer, ssize_t len)
{
    char *work = buffer;
    while (len) {
        ssize_t delta = read(source, work, len);
        if (delta < 0) return -1; /* ERROR */
        if (delta == 0) return 0; /* EOF */
        work  = delta;
        len -= delta;
    }
}

/* ... */

    while (read_block(fps[i][0], amp;each_record_read, sizeof(struct rec)) > 0){
  

Теперь это работает.