Основы операционных систем. Практикум
Example.9.1a
/* Программа 09-1a.c для иллюстрации работы с
очередями сообщений */
/* Эта программа получает доступ к очереди
сообщений, отправляет в нее 5 текстовых сообщений с типом 1 и одно
пустое сообщение с типом 255, которое будет служить для программы
09-1b.c сигналом прекращения работы. */
#include
#include
#include
#include
#include
#define LAST_MESSAGE 255 /* Тип сообщения для
прекращения работы программы 09-1b.c */
int main()
{
int msqid; /* IPC дескриптор для очереди сообщений */
char pathname[] = "09-1a.c"; /* Имя файла,
использующееся для генерации ключа. Файл с таким
именем должен существовать в текущей директории */
key_t key; /* IPC ключ */
int i,len; /* Счетчик цикла и длина
информативной части сообщения */
/* Ниже следует пользовательская структура для
сообщения */
struct mymsgbuf
{
long mtype;
char mtext[81];
} mybuf;
/* Генерируем IPC ключ из имени файла 09-1a.c в текущей
директории и номера экземпляра очереди сообщений 0. */
if((key = ftok(pathname,0)) < 0){
printf("Can\'t generate key\n");
exit(-1);
}
/* Пытаемся получить доступ по ключу к очереди сообщений,
если она существует, или создать ее, с правами доступа
read & write для всех пользователей */
if((msqid = msgget(key, 0666 | IPC_CREAT)) < 0){
printf("Can\'t get msqid\n");
exit(-1);
}
/* Посылаем в цикле 5 сообщений с типом 1
в очередь сообщений, идентифицируемую msqid.*/
for (i = 1; i <= 5; i++){
/* Сначала заполняем структуру для нашего
сообщения и определяем длину информативной части */
mybuf.mtype = 1;
strcpy(mybuf.mtext, "This is text message");
len = strlen(mybuf.mtext)+1;
/* Отсылаем сообщение. В случае ошибки сообщаем об
этом и удаляем очередь сообщений из системы. */
if (msgsnd(msqid, (struct msgbuf *) &mybuf,
len, 0) < 0){
printf("Can\'t send message to queue\n");
msgctl(msqid, IPC_RMID,
(struct msqid_ds *) NULL);
exit(-1);
}
}
/* Отсылаем сообщение, которое заставит получающий процесс
прекратить работу, с типом LAST_MESSAGE и длиной 0 */
mybuf.mtype = LAST_MESSAGE;
len = 0;
if (msgsnd(msqid, (struct msgbuf *) &mybuf,
len, 0) < 0){
printf("Can\'t send message to queue\n");
msgctl(msqid, IPC_RMID,
(struct msqid_ds *) NULL);
exit(-1);
}
return 0;
}
