Описание

#include <sys/msg.h>

int msgsnd(int mqid, const void *message, size_t size, int flags);

int msgrcv(int mqid, void *message, size_t size, long msg_type, int flags);

Первый из вызовов, msgsnd, используется для добавления сообщения в оче­редь, обозначенную идентификатором mqid.

Сообщение содержится в структуре message - шаблоне, определенном пользо­вателем и имеющем следующую форму:

struct mymsg

{

long mtype; /* Тип сообщения */

char mtext[SOMEVALUE]; /* Текст сообщения */

};

Значение поля mtype может использоваться программистом для разбиения сообщений на категории. При этом значимыми являются только положительные значения; отрицательные или нулевые не могут использоваться (это будет видно из дальнейшего описания операций передачи сообщений). Массив mtext служит для хранения данных сообщения (постоянная SOMEVALUE выбрана совершенно произвольно). Длина посылаемого сообщения задается параметром size вызова msgsnd и может быть в диапазоне от нуля до меньшего из двух значений SOMEVALUE и максимального размера сообщения, определенного в системе.

Параметр flsgs вызова msgsnd может нести только один флаг: IPC_NOWAIT. При неустановленном параметре IPC_NOWAIT вызывающий процесс приостано­вит работу, если для посылки сообщения недостаточно системных ресурсов. На практике это произойдет, если полная длина сообщений в очереди превысит мак­симум, заданный для очереди или всей системы. Если флаг IPC_NOWAIT установ­лен, тогда при невозможности послать сообщение возврат из вызова произойдет немедленно. Возвращаемое значение будет равно -1, и переменная errno будет иметь значение EAGAIN, означающее необходимость повторения попытки.

Вызов msgsend также может завершиться неудачей из-за установленных прав доступа. Например, если ни действующий идентификатор пользователя, ни дей­ствующий идентификатор группы процесса не связаны с очередью, и установлен код доступа к очереди 0660, то вызов msgsnd для этой очереди завершится неуда­чей. Переменная errno получит значение EACCES.

Для чтения из очереди, заданной идентификатором mqid, используется вызов msgrcv. Чтение разрешено, если процесс имеет права доступа к очереди на чтение. Успешное чтение сообщения приводит к удалению его из очереди.

На этот раз переменная message используется для хранения полученного со­общения, а параметр size задает максимальную длину сообщений, которые мо­гут находиться в этой структуре. Успешный вызов возвращает длину полученно­го сообщения.

Параметр msg_type определяет тип принимаемого сообщения, он помогает вы­брать нужное из находящихся в очереди сообщений. Если параметр msg_type равен нулю, из очереди считывается первое сообщение, то есть то, которое было послано первым. При ненулевом положительном значении параметра msg_type считывает­ся первое сообщение из очереди с заданным типом сообщения. Например, если оче­редь содержит сообщения со значениями mtype 999, 5 и 1, а параметр msg_type в вызове msgrcv имеет значение 5, то считывается сообщение типа 5. И, наконец, если параметр msg_type имеет ненулевое отрицательное значение, то считывается первое сообщение с наименьшим значением mtype, которое меньше или равно мо­дулю параметра msg_type. Этот алгоритм кажется сложным, но выражает простое правило: если вернуться к нашему предыдущему примеру с тремя сообщениями со значениями mtype 999, 5 и 1, то при значении параметра msg_type в вызове msgrcv равном -999 и троекратном вызове сообщения будут получены в порядке 1, 5, 999.

Последний параметр flags содержит управляющую информацию. В этом пара­метре могут быть независимо установлены два флага - IPS_NOWAIT и MSG _ NOERROR. Флаг IPC _ NOWAIT имеет обычный смысл - если он не задан, то процесс будет при­остановлен при отсутствии в очереди подходящих сообщений, и возврат из вызо­ва произойдет после поступления сообщения соответствующего типа. Если же этот флаг установлен, то возврат из вызова при любых обстоятельствах произой­дет немедленно.

При установленном флаге MSG _ NOERROR сообщение будет усечено, если его длина больше, чем size байт, без этого флага попытка чтения длинного сообще­ния приводит к неудаче вызова msgrcv. К сожалению, узнать о том, что усечение имело место, невозможно.