Архитектура операционной системы UNIX   ::   Бах Морис Дж.

Если какие-либо процессы, ожидавшие получения сообщения, находились в состоянии приостанова из-за отсутствия свободного места в списке, ядро выводит их из этого состояния. Если размер сообщения превышает значение maxcount, указанное пользователем, ядро посылает системной функции уведомление об ошибке и оставляет сообщение в очереди. Если, тем не менее, процесс игнорирует ограничения на размер (в поле flag установлен бит MSG_NOERROR), ядро обрезает сообщение, возвращает запрошенное количество байт и удаляет сообщение из списка целиком.

#include ‹sys/types.h›

#include ‹sys/ipc.h›

#include ‹sys/msg.h›

#define MSGKEY 75

struct msgform {

 long mtype;

 char mtext[256];

};

main() {

 struct msgform msg;

 int msgid, pid, *pint;

 msgid = msgget(MSGKEY, 0777);

 pid = getpid();

 pint = (int *) msg.mtext;

 *pint = pid; /* копирование идентификатора процесса в область текста сообщения */

 msg.mtype = 1;

 msgsnd(msgid, &msg, sizeof(int), 0);

 msgrcv(msgid, &msg, 256, pid, 0);

 /* идентификатор процесса используется в качестве типа сообщения */

 printf("клиент: получил от процесса с pid %d\n", *pint);

}

Рисунок 11.6. Пользовательский процесс

алгоритм msgrcv /* получение сообщения */

входная информация:

 (1) дескриптор сообщения

 (2) адрес массива, в который заносится сообщение

 (3) размер массива

 (4) тип сообщения в запросе

 (5) флаги

выходная информация: количество байт в полученном сообщении

{

 проверить права доступа;

loop:

 проверить правильность дескриптора сообщения;

 /* найти сообщение, нужное пользователю */

 if (тип сообщения в запросе =