В заголовке (IPC — Interprocess Communication) объявляется тип данных struct ipc_perm, который используется для хранения идентификаторов создателя, владельца, их групп, имени (ключа) очереди и прав на чтение и запись для той или иной очереди сообщений.

Запись таблицы сообщений имеет тип данных struct msqid_ds, определяемый в :

Поле	Данные
msg_perm	Данные, хранящиеся в записи типа struct ipc_perm;
msg_first	Указатель на первое (самое старое) сообщение в очереди;
msg_last	Указатель на последнее (самое новое) сообщение в очереди;
msg_cbyte	Общее число байтов во всех сообщениях очереди;
msg_qnum	Общее число сообщений очереди на данный момент;
msg_qbytes	Максимальное число байтов всех сообщений очереди;
msg_lspid	Идентификатор процесса, который последним передал в очередь сообщение;
msg_lrpid	Идентификатор процесса, который последним прочитал из очереди сообщение;
msg_stime	Время, когда в очередь было передано самое последнее сообщение;
msg_rtime	Время, когда из очереди было прочитано самое последнее сообщение;
msg_ctime	Время последнего изменения управляющих параметров очереди (права доступа, идентификатор владельца, группы).

Структура struct msg, определенная в , — это тип данных для записи сообщения.

Все эти структуры используются в таблице сообщений и записях сообщений следующим образом:

• 
  msgget (open) — открытие для доступа и создание (при необходимости) очереди сообщений.
  
• 
  msgsnd (write) — передача сообщения из очереди.
  
• 
  msgrcv (read) — прием сообщения из очереди.
  
• 
  msgctl (stat, unlink, chmod, chown) — манипулирование управляющими параметрами очереди сообщений.
  

Если key — положительное число, этот системный вызов требует открыть очередь сообщений, идентификатор который совпадает с данным значением. Если же значением key является IPC_PRIVATE, системный вызов создает новую очередь сообщений.

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

int fd;

fd = msgget (15, IPC_ CREAT | 0664);
В случае неудачи системный вызов msgget возвращает -1.
int msgget(int msgfd, const void *obbuf, int len, int flag);
Системный вызов передает сообщение, на которое указывает obbuf, в очередь, обозначенную дескриптором msgfd.

obbuf — указатель на объект, который содержит реальный текст и тип сообщения, подлежащего передаче, например:

};
Значение len — размер в байтах поля text объекта. flag может иметь значение 0. Это означает, что при необходимости процесс можно блокировать до тех пор, пока системный вызов не будет успешно выполнен. Если flag = IPC_NOWAIT, то при блокировании процесса выполнение системного вызова прерывается.

В случае успешного выполнения msgsnd возвращает 0, в случае передачи -1.
int msgrcv (int msgfd, const void* obbuf, int len, int mtype, int flag);
Этот системный вызов принимает сообщение типа mtype из очереди сообщений, обозначенной дескриптором msgfd. Полученное сообщение хранится в объекте, на который указывает аргумент obbuf. Аргумент len — максимальный размер (в байтах) текста сообщения. Аргумент mtype — это тип сообщения, подлежащего приему:

• 
  0 — принять из очереди самое старое сообщение любого типа;
  
• 
  полож. целое > 0 — принять самое старое сообщение указанного типа;
  
• 
  полож. целое < 0 — принять сообщение, тип которого меньше абсолютного значения mtype или равен ему. Если таких сообщений в очереди несколько, принять то, которое является самым старым и имеет наименьшее значение типа.
  

Если flag == IPC_NOWAIT, то вызов будет неблокирующим. Если к IPC_NOWAIT установлен и флаг MSG_NOERROR, то сообщение, находящееся в очереди, можно читать, даже если его размер превышает len байтов. Системный вызов возвращает вызывающему процессу первые len байтов текста сообщения, а остальные данные отбрасывает.

Системный вызов msgrcv возвращает количество байтов, записанных в буфер text объекта, на который указывает аргумент obbuf или -1.
Пример.
#include

#include

#include

#include

#include

#ifndef MSGMAX

#define MSGMAX 1024

#endif
struct mbuf

{

long mtype;

char text[MSGMAX];

} buf = { 8, "Happy birthday to you" };
int main()

{

int perm, fd;

perm = S_IRUSR | S_IWUSR | S_IRGRP | S_IWOTH;

fd = msgget(15, IPC_CREAT | perm);

if (fd == -1 || msgsnd(fd, &buf, strlen(buf.text) + 1, IPC_NOWAIT))

perror("Ошибка в посылке сообщения");

else if (msgrcv(fd, &buf, MSGMAX, 8, IPC_NOWAIT | MSG_NOERROR) != -1)

printf("%s\n", buf.text);

else

printf("Ошибка msgrcv\n");

}
После создания очереди сообщений с идентификатором 15, процесс передает в эту очередь сообщение “Happy birthday to you”, тип которого 8 и указывает, что данный вызов неблокирующий. Далее процесс вызывает системный вызов msgrcv, который ждет и выбирает из очереди сообщение типа 8. Если вызов завершается успешно, процесс направляет выбранное сообщение на стандартный вывод, в противном случае сообщает об ошибке.
int msgctl(int msgfd, int cmd, struct msqid_ds *obbuf);
С помощью этого системного вызова можно запрашивать управляющие параметры очереди сообщений, обозначенной msgfd, изменять информацию в управляющих параметрах очереди, удалять очередь из системы. Аргумент msgfd берется из вызова msgget. Возвращает 0 в случае успешного завершения, -1 — ошибки.

Значения аргумента cmd следующие:

• 
  IPC_STAT — копировать управляющие параметры очереди в объект, указанный obbuf.
  
• 
  IPC_SET — заменить управляющие параметры очереди параметрами, содержащимися в объекте, на который указывает obbuf.
  
• 
  IPC_RMID — удалить очередь из системы.