#include <unistd.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>

typedef struct mesgbuf {
 long mtype;
 char buff[1024];
} mesg;

char *data[] = {
"Люблю грозу в начале мая,\n",
"Когда весенний, первый гром,\n",
"как бы резвяся и играя,\n",
"Грохочет в небе голубом.\n",
"Гремят раскаты молодые,\n",
"Вот дождик брызнул, пыль летит,\n",
"Повисли перлы дождевые,\n",
"И солнце нити золотит.\n",
"С горы бежит поток проворный,\n",
"В лесу не молкнет птичий гам,\n",
"И гам лесной и шум нагорный -\n",
"Все вторит весело громам.\n",
"Ты скажешь: ветреная Геба,\n",
"Кормя Зевесова орла,\n",
"Громокипящий кубок с неба,\n",
"Смеясь, на землю пролила.\n"
};

void parent_proc(void) { //Функция родительского процесса
 mesg message;
 key_t key;
 int msgid, len;
 int done = 0; //Показатель окончания передачи данных процессом
 key = ftok("data", 'A'); //Получение ключа
 msgid = msgget(key, 0666 | IPC_CREAT); //Создание очереди сообщений
 message.mtype = 5L; //Тип сообщения 3 необходим для инициализации
 message.buff[0] = 0; //дочерних процессов. Отправляются два таких
 msgsnd(msgid, &message, sizeof(message), 0); //сообщения со значениями первого
 message.buff[0] = 1; //байта 0, 1, 2 или 3
 msgsnd(msgid, &message, sizeof(message), 0);
 message.buff[0] = 2;
 msgsnd(msgid, &message, sizeof(message), 0);
 message.buff[0] = 3;
 msgsnd(msgid, &message, sizeof(message), 0);
 for (;;) {
  if ((done & 0x1) == 0) { //Если первый процесс ещё передаёт //данные, то получаем сообщение
   len = msgrcv(msgid, &message, sizeof(message), 1L, 0);
   if (message.buff[0] == 0) done |= 0x1; //Если это пустая
                                         //строка, то устанавливаем флаг завершения передачи
   else write(1, message.buff, len); //иначе выводим строку
  }
  if ((done & 0x2) == 0) { //Аналогично для второго процесса
   len = msgrcv(msgid, &message, sizeof(message), 2L, 0);
   if (message.buff[0] == 0) done |= 0x2;
   else write(1, message.buff, len);
  }
  if ((done & 0x3) == 0) { //Аналогично для третьего процесса
   len = msgrcv(msgid, &message, sizeof(message), 3L, 0);
   if (message.buff[0] == 0) done |= 0x3;
   else write(1, message.buff, len);
  }
  if ((done & 0x4) == 0) { //Аналогично для четвертого процесса
   len = msgrcv(msgid, &message, sizeof(message), 4L, 0);
   if (message.buff[0] == 0) done |= 0x4;
   else write(1, message.buff, len);
  }
  if (done == 0x5) { //Если все четыре процесса завершили передачу, то
   msgctl(msgid, IPC_RMID, 0); //завершаем работу
  return;
  }
 }
}
void child_proc(void) {
 mesg message;
 key_t key;
 int msgid, whoami, str, len;
 key = ftok("data", 'A'); //Получение ключа
 msgid = msgget(key, 0); //Открытие очереди сообщений
 msgrcv(msgid, &message, sizeof(message), 5L, 0); //Получение сообщения инициализации
 whoami = (int) message.buff[0]; //Номер процесса определяется содержанием сообщения
 message.mtype = whoami + 1; //Тип сообщений, отправляемых данным процессом
 for (str = 0; str < 16; str++) { //Цикл по строкам
  if (str % 4 == whoami) { //В зависимости от номера, процесс будет передавать различные строки
   len = sprintf(message.buff,"%s",data[str]);
   msgsnd(msgid, &message, len, 0); //Отправление сообщения
  }
 }
 message.buff[0] = 0;
 msgsnd(msgid, &message, 1, 0); //Отправление сообщения о завершении
 return;
}

int main() {
 if (!fork()) {
  child_proc();
  return 0;
 }
 if (!fork()) {
  child_proc();
  return 0;
 }
 if (!fork()) {
  child_proc();
  return 0;
 }
 if (!fork()) {
  child_proc();
  return 0;
 }
 parent_proc();
 return 0;
}