Основы программирования в Linux - Мэтью Нейл

На практике все гораздо проще. Если вы просто хотите получать сообщения в порядке их отправления, задайте msgtype, равным 0. Если нужно извлекать сообщения только с определенным типом, задайте msgtype, равным этому значению. Если вам необходимо получать сообщения с типом не превышающим n, задайте msgtype, равным -n.

Четвертый параметр msgflg управляет действиями в случае отсутствия сообщения подходящего типа, которое ожидает извлечения. Если в параметре msgflg установлен флаг IPC_NOWAIT, вызов вернет управление программе немедленно с возвращаемым значением -1. Если флаг IPC_NOWAIT в msgflg сброшен, процесс будет приостановлен в ожидании прибытия сообщения подходящего типа.

В случае успешного завершения функция msgrcv вернет количество байтов, помещенных в буфер приема, сообщение копируется в выделяемый пользователем буфер, на который указывает msg_ptr, и данные удаляются из очереди сообщений. В случае ошибки функция вернет -1.

msgctl

Последняя функция обработки очереди сообщений msgctl очень похожа на функцию управления для совместно используемой памяти:

int msgctl(int msqid; int command, struct msqid_ds *buf);

Структура msqid_ds содержит, как минимум, следующие элементы:

<b>struct msqid_ds {</b>

<b> uid_t msg_perm.uid;</b>

<b> uid_t msg_perm.gid;</b>

<b> mode_t msg_perm.mode;</b>

<b>}</b>

Первый параметр msqid — идентификатор, возвращаемый функцией msgget.

Второй параметр command задает предпринимаемое действие. Он может принимать три значения, перечисленные в табл. 14.3.

Таблица 14.3

Значение Описание IPC_STAT Задает данные в структуре msqid_ds, отображающие значения, связанные с очередью сообщений IPC_SET Если у процесса есть на это право, это действие устанавливает значения, связанные с очередью сообщений, в соответствии с данными структуры msqid_ds IPC_RMID Удаляет очередь сообщений

В случае успешного завершения возвращает 0, в случае аварийного — -1. Если очередь сообщений удаляется, когда процесс ожидает в функции msgsnd или msgrcv, функция отправки или получения сообщения завершается аварийно.

Выполните упражнение 14.3.

Упражнение 14.3. Очереди сообщений

Теперь, когда вы познакомились с объявлениями, относящимися к очередям сообщений, можно посмотреть, как они действуют на практике. Как и раньше, вы напишите две программы: msg1.c для получения и msg2.c для отправки сообщений. Вы разрешите обеим программам создавать очередь сообщений, но используете для удаления очереди программу-приемник после того, как она получит последнее сообщение.

1. Далее приведена программа-приемник msg1 .с:

#include &lt;stdlib.h&gt;

#include &lt;stdio.h&gt;

#include &lt;string.h&gt;

#include &lt;errno.h&gt;

#include &lt;unistd.h&gt;

#include &lt;sys/msg.h&gt;

struct my_msg_st {

 long int my_msg_type;

 char some_text[BUFSIZ];

};

int main() {

 int running = 1;

 int msgid;

 struct my_msg_st some_data;

 long int msg_to_receive = 0;

2. Прежде всего, задайте очередь сообщений:

 msgid = msgget((key_t)1234, 0666 | IPC_CREAT);

 if (msgid == -1) {

  fprintf(stderr, &quot;msgget failed with error: %dn&quot;, errno);

  exit(EXIT_FAILURE);

 }

3. Далее сообщения извлекаются из очереди до тех пор, пока не будет обнаружено сообщение end. В конце очередь сообщений удаляется.

 while (running) {

  if (msgrcv(msgid, (void *)&amp;some_data, BUFSIZ, msg_to_receive, 0) == -1) {

   fprintf(stderr, &quot;msgrcv failed with error: %dn&quot;, errno);

   exit(EXIT_FAILURE);

  }

  printf(&quot;You wrote: %s&quot;, some_data.some_text);

  if (strncmp(some_data.some_text, &quot;end&quot;, 3) == 0) {

   running = 0;

  }

 }

 if (msgctl(msgid, IPC_RMID, 0) == -1) {

  fprintf(stderr, &quot;msgctl(IPC_RMID) failedn&quot;);

  exit(EXIT_FAILURE);

 }

 exit(EXIT_SUCCESS);

}

4. Программа-отправитель msg2.c очень похожа на программу msg1.с. В функции main удалите объявление msg_to_receive и замените его переменной buffer[BUFSIZ]. Уберите из программы удаление очереди и внесите следующие изменения в цикл с управляющей переменной running. Теперь у вас появился вызов функции msgsnd для отправки введенного текста в очередь сообщений. Далее приведена программа msg2.c с отличиями от программы msg1.с, выделенными цветом.

#include &lt;stdlib.h&gt;

#include &lt;stdio.h&gt;