Андрей Робачевский - Операционная система UNIX

#include

#include "shmem.h"

main() {

Message* msgptr;

key_t key;

int shmid, semid;

/* Получим ключ, Один и тот же ключ можно использовать как

для семафора, так и для разделяемой памяти */

if ((key = ftok("server", 'A')) < 0) {

printf("Невозможно получить ключ\n");

exit(1);

}

/* Создадим область разделяемой памяти */

if ((shmid = shmget(key, sizeof(Message),

PERM | IPC_CREAT)) < 0) {

printf("Невозможно создать область\n");

exit(1);

}

/* Присоединим ее */

if ((msgptr = (Message*)shmat(shmid, 0, 0)) < 0) {

printf("Ошибка присоединения\n");

exit(1);

}

/* Создадим группу из двух семафоров:

Первый семафор - для синхронизации работы

с разделяемой памятью. Второй семафор -

для синхронизации выполнения процессов */

if ((semid = semget(key, 2, PERM | IPC_CREAT)) < 0) {

printf("Невозможно создать семафор\n");

exit(1);

}

/* Ждем, пока клиент начнет работу и заблокирует разделяемую память */

if (semop(semid, &proc_wait[0], 1) < 0) {

printf("Невозможно выполнить операции\n");

exit(1);

}

/* Ждем, пока клиент закончит запись в разделяемую память

и освободит ее. После этого заблокируем ее */

if (semop(semid, &mem_lock[0], 2) < 0) {

printf("Невозможно выполнить операцию\n");

exit(1);

}

/* Выведем сообщение на терминал */

printf(%s, msgptr->buff);

/* Освободим разделяемую память */

if (semop(semid, &mem_unlock[0], 1) < 0 {

printf("Невозможно выполнить операцию\n");

exit(1);

}

/* Отключимся от области */

if (shmdt(msgptr) < 0) {

printf("Ошибка отключения\n");

exit(1);

}

/* Всю остальную работу по удалению объектов сделает клиент */

exit(0);

}

#include

#include

#include

#include

#include "shmem.h"

main() {

Message *msgptr;

key_t key;

int shmid, semid;

/* Получим ключ. Один и тот же ключ можно использовать как

для семафора, так и для разделяемой памяти */

if ((key = ftok("server", 'A')) < 0) {

printf("Невозможно получить ключ\n");

exit(1);

}

/* Получим доступ к разделяемой памяти */

if ((shmid = shmget(key, sizeof(Message), 0)) < 0) {

printf("Ошибка доступа\n");

exit(1);

}

/* Присоединим ее */

if ((msgptr = (Message*)shmat(shmid, 0, 0)) < 0) {

prinf("Ошибка присоединения\n);

exit(1);

}

/* Получим доступ к семафору */

if ((semid = semget(key, 2, PERM)) < 0) {

printf("Ошибка доступа\n");

exit(1);

}

/* Заблокируем разделяемую память */

if (semop(semid, &mem_lock[0], 2) < 0) {

printf("Невозможно выполнить операцию\n");

exit(1);

}

/* Уведомим сервер о начале работы */

if (semop(semid, &proc_start[0], 1) < 0) {

printf("Невозможно выполнить операцию\n");

exit(1);

}

/* Запишем в разделяемую память сообщение */

sprintf(msgptr->buff, "Здравствуй, Мир!\n");

/* Освободим разделяемую память */

if (semop(semid, &mem_unlock[0], 1) < 0) {

printf("Невозможно выполнить операцию\n");

exit(1);

}

/* Ждем, пока сервер в свою очередь не освободит

разделяемую память */

if (semop(semid, &mem_lock[0], 2) < 0) {

printf(Невозможно выполнить операцию\n");

exit(1);

}

/* Отключимся от области */

if (shmdt(msgptr) < 0) {

printf("Ошибка отключения\n");

exit(1);

}

/* Удалим созданные объекты IPC */

if (shmctl(shmid, IPC_RMID, 0) < 0) {

printf("Невозможно удалить область\n");

exit(1);

}

if (semctl(semid, 0, IPC_RMID) < 0) {

printf("Невозможно удалить семафор\n");

exit(1);

}

exit(0);

}

Разработчики системы межпроцессного взаимодействия BSD UNIX руководствовались рядом соображений:

Во-первых, взаимодействие между процессами должно быть унифицировано, независимо от того, выполняются ли они на одном компьютере или на разных хостах сети. Наиболее оптимальная реализация межпроцессного взаимодействия, удовлетворяющего этому требованию, должна иметь модульную структуру и базироваться на общей подсистеме поддержки сети UNIX. При этом могут быть использованы различные схемы адресации объектов, их расположение, протоколы передачи данных и т.д. В этой связи было введено понятие коммуникационный домен (communication domain), описывающее набор обозначенных характеристик взаимодействия.