Отправка сообщений с использованием pipe - C

Question

Я хочу сделать процессы NO_PROC, чтобы каждый процесс читал сообщения от своего родителя, а затем записывал эти сообщения и еще одно сообщение своему дочернему элементу, за исключением случая последнего процесса, который пишет его сообщений до stdout. Таким образом, процесс i'th получит i-1 сообщения и отправит ребенку i сообщений. Я должен использовать канал для связи между процессами. Я написал код, но что-то не так, и я не могу найти ошибку: /. Когда NO_PROC = 5 Я хочу, чтобы результат выглядел как 4 строки с «моим сообщением», но на выходе у меня есть одна строка: «мое сообщение» и 3 пустые строки, например 3 сообщения - пустая строка: /. Примечание. err.h - это моя библиотека, которая дает мне функцию syserr(), когда что-то пошло не так.

#include <stdio.h> 
#include <stdlib.h> 
#include <unistd.h> 
#include <sys/types.h> 
#include <sys/wait.h> 
#include "err.h" 

#define NO_PROC 5 
#define BUF_SIZE 20 

char message[] = "my message"; 
int parent; 
char buf[BUF_SIZE]; 

int main() 
{ 
    for (int i = 0; i < NO_PROC; ++i) { 
     int pipe_dsc[2], buf_len; 
     if (pipe(pipe_dsc) == -1) 
      syserr("Error in pipe\n"); 
     pid_t pid = fork(); 
     if (pid == -1) 
      syserr("Error in fork\n"); 
     else if (pid == 0) 
      parent = pipe_dsc[0]; 
     else { 
      for (int j = 0; j < i; ++j) { 
       if ((buf_len = read(parent, buf, BUF_SIZE - 1)) == -1) 
        syserr("Error in read\n"); 
       buf[buf_len < BUF_SIZE - 1 ? buf_len : BUF_SIZE - 1] = '\0'; 
       if (i == NO_PROC - 1) 
        printf("%s\n", buf); 
       else if (write(pipe_dsc[1], buf, sizeof(buf)) != sizeof(buf)) 
        syserr("Error in write\n"); 
      } 
      if (i < NO_PROC - 1 && write(pipe_dsc[1], message, sizeof(message)) != sizeof(message)) 
       syserr("Error in write\n"); 
      if (wait(0) == -1) 
       syserr("Error in wait\n"); 
      return 0; 
     } 
    } 
} 

Answer 1

Я думаю, что вы слишком усложняете и/или используете неправильный подход. Вам не нужно отправлять i сообщениям на ith процесс. Поскольку процесс ith является копией (fork) процесса i-1th, он уже получил сообщение i-1 и просто нуждается в еще одном. Это довольно симметричная (и академическая) проблема.

Ниже приведен пример (), надежная проверка ошибок опущена). Обратите внимание, это зависит от пишет атомная труба, которая хорошо до тех пор, пока вы не пишете сообщение более, что PIPE_BUF (см man pipe):

#include <stdio.h> 
#include <stdlib.h> 
#include <unistd.h> 
#include <string.h> 
#include <sys/types.h> 
#include <sys/wait.h> 

void syserr(char * msg) { printf("%s\n", msg); exit(1); } 
#define NO_PROC 5 
#define BUF_SIZE 100 
char message[] = "my message "; 

int main() { 
    int message_len = 0; 
    char buf[BUF_SIZE]; 
    for (int i = 0; i < NO_PROC; ++i) { 
     int pipe_dsc[2], buf_len; 
     if (pipe(pipe_dsc) == -1) { 
      syserr("Error in pipe\n"); 
     } 
     pid_t pid = fork(); 
     if (pid == -1) { 
      syserr("Error in fork\n"); 
     } 
     else if (pid == 0) { 
      close(pipe_dsc[1]); 
      int n = read(pipe_dsc[0], buf+message_len, sizeof(buf)); 
      message_len = strlen(buf); // Assume message is null terminated string. 
      if(i == NO_PROC -1) { 
       printf("Process %i: received '%s'\n", i+1, buf); 
      } 
     } 
     else { 
      close(pipe_dsc[0]); 
      write(pipe_dsc[1], message, sizeof(message)); 
      wait(0); 
      return 0; 
     } 
    } 
}