Книга: Основы программирования в Linux

msgctl

msgctl

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

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

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

struct msqid_ds {
 uid_t msg_perm.uid;
 uid_t msg_perm.gid;
 mode_t msg_perm.mode;
}

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

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

Таблица 14.3

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

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

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

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

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/msg.h>
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, "msgget failed with error: %dn", errno);
  exit(EXIT_FAILURE);
 }

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

 while (running) {
  if (msgrcv(msgid, (void *)&some_data, BUFSIZ, msg_to_receive, 0) == -1) {
   fprintf(stderr, "msgrcv failed with error: %dn", errno);
   exit(EXIT_FAILURE);
  }
  printf("You wrote: %s", some_data.some_text);
  if (strncmp(some_data.some_text, "end", 3) == 0) {
   running = 0;
  }
 }
 if (msgctl(msgid, IPC_RMID, 0) == -1) {
  fprintf(stderr, "msgctl(IPC_RMID) failedn");
  exit(EXIT_FAILURE);
 }
 exit(EXIT_SUCCESS);
}

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

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/msg.h>
#define MAX_TEXT 512
struct my_msg_st {
 long int my_msg_type;
 char some_text[MAX_TEXT];
};
int main() {
 int running = 1;
 struct my_msg_st some_data;
 int msgid;
 char buffer = [BUFSIZ];
 msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
 if (msgid == -1) {
  fprintf(stderr, "msgget failed with error: %dn", errno);
  exit(EXIT_FAILURE);
 }
 while (running) {
  printf("Enter some text: ");
  fgets(buffer, BUFSIZ, stdin);
  some_data.my_msg_type = 1;
  strcpy(some_data.some_text, buffer);
  if (msgsnd(msgid, (void*)&some_data, MAX_TEXT, 0)) == -1) {
   fpintf(stderr, "msgsnd failedn");
   exit(EXIT_FAILURE);
  }
  if (strncmp(buffer, "end", 3) == 0) {
   running = 0;
  }
 }
 exit(EXIT_SUCCESS);
}

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

Если в очереди сообщений есть место, отправитель может создать очередь, поместить в нее какие-либо данные и завершить выполнение еще до того, как начнет выполняться приемник. Первой следует запускать программу-отправителя msg2. Далее приведен пример вывода:

$ ./msg2
Enter some text: hello
Enter some text: How are you today?
Enter some text: end
$ ./msg1
You wrote: hello
You wrote: How are you today?
You wrote: end

Как это работает

Программа-отправитель создает очередь сообщений с помощью функции msgget; далее она добавляет сообщения в очередь, применяя функцию msgsnd. Программа-приемник получает идентификатор очереди сообщений с помощью функции msgget и получает сообщения до тех пор, пока не будет найден специальный текст end. Затем программа приводит все в порядок, удаляя очередь сообщений с помощью функции msgctl.

Оглавление книги