QNX/UNIX: Анатомия параллелизма
QNX/UNIX: Анатомия параллелизма читать книгу онлайн
Книга адресована программистам, работающим в самых разнообразных ОС UNIX. Авторы предлагают шире взглянуть на возможности параллельной организации вычислительного процесса в традиционном программировании. Особый акцент делается на потоках (threads), а именно на тех возможностях и сложностях, которые были привнесены в технику параллельных вычислений этой относительно новой парадигмой программирования. На примерах реальных кодов показываются приемы и преимущества параллельной организации вычислительного процесса. Некоторые из результатов испытаний тестовых примеров будут большим сюрпризом даже для самых бывалых программистов. Тем не менее излагаемые техники вполне доступны и начинающим программистам: для изучения материала требуется базовое знание языка программирования C/C++ и некоторое понимание «устройства» современных многозадачных ОС UNIX.
В качестве «испытательной площадки» для тестовых фрагментов выбрана ОСРВ QNX, что позволило с единой точки зрения взглянуть как на специфические механизмы микроядерной архитектуры QNX, так и на универсальные механизмы POSIX. В этом качестве книга может быть интересна и тем, кто не использует (и не планирует никогда использовать) ОС QNX: программистам в Linux, FreeBSD, NetBSD, Solaris и других традиционных ОС UNIX.
Внимание! Книга может содержать контент только для совершеннолетних. Для несовершеннолетних чтение данного контента СТРОГО ЗАПРЕЩЕНО! Если в книге присутствует наличие пропаганды ЛГБТ и другого, запрещенного контента - просьба написать на почту [email protected] для удаления материала
Однако важным (по крайней мере, для программистов, не желающих отказываться от такого привычного и эффективного механизма передачи данных, как обмен сообщениями) является тот факт, что этот дескриптор на самом деле является не чем иным, как идентификатором соединения. И поэтому к серверу можно обращаться не только через высокоуровневые функции работы с файлами, но и с помощью элементарных функций обмена сообщениями
MsgSend*()Вместе с тем следует учитывать, что менеджер ресурсов поставляется для программиста фактически в готовом виде — как шкаф, то есть уже имеются все отделения, полки, ножки, дверцы, и задача разработчика - лишь заполнить его своим содержимым. Однако «навесить» на него свою полочку уже невозможно. Иными словами, при передаче сообщений с использованием менеджера ресурсов необходимо применять уже имеющиеся средства менеджера ресурсов, благо их вполне достаточно.
Самым очевидным и наиболее простым способом передачи сообщений к серверу является инкапсуляция сообщений в «сообщения управления устройством» — сообщения типа
devctl()devctl()К радости разработчиков, менеджер ресурсов предлагает функцию приватных сообщений
io_msg()_IO_MSG0x1ffНиже приводится код процесса-клиента и процесса-сервера. Последний представляет собой стандартный менеджер ресурсов — в таком виде, в каком он, так сказать, поставляется разработчику. Единственная шляпа, помещаемая в этот шкаф, — это обработчик приватных сообщений. Здесь вы и должны поместить специфический код обработки принятого сообщения.
В остальном все достаточно тривиально. Более подробно о том, как писать менеджеры ресурсов, можно прочитать в главе «Writing a Resource Manager» технической документации QNX, а также в книгах [1] и [4] (глава Олега Цилюрика «Драйверы»).
Пример обмена сообщениями с помощью менеджера ресурсов
Код файла заголовков
#define NET_OPER "/net/904-3"
#define NET_REG "/net/Bed-Test"
// Максимальная длина обычного стандартного сообщения.
#define MESSIZE_MAX 100
// Максимальная длина инвентаризационного имени процесса
#define PROC_NAME_MAX 100
struct IdLabel_t { // Структура, содержащая,
int id; // -.инвентаризационную метку процесса
char name[PROC_NAME_MAX]; // - инвентаризационное имя процесса
} IdLabel[] = {
/* диапазон выделенный Группе # 1: от 0x5000 до 0x50ff */
0x5001, "пробный менеджер ресурсов",
0x5002, "первый тестовый клиент для менеджера ресурсов",
0x5003, "второй тестовый клиент для менеджера ресурсов",
0x5004, "третий тестовый клиент для менеджера ресурсов",
0x50ff, "четвертый тестовый клиент для менеджера ресурсов"
/* диапазон, выделенный Группе # 2: от 0x5100 до 0x51ff */
/* диапазон, выделенный Группе # 3: от 0x5200 до 0x52ff */
};
char Anonymous[] = "чуждый процесс";
int ALLNUM_MYPROC = sizeof(IdLabel) /
sizeof(IdLabel[0]);Код процесса-клиента
Как было сказано, клиент открывает файл (функция
open()MsgSend()
#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <sys/neutrino.h>
#include <sys/iomsg.h>
#include <locale.h>
#include <string.h>
#include "/home/ZZZ/TESTS/MR/MessTest.h"
int main() {
int fdRM; // Дескриптор соединения с менеджером ресурсов
char BufferSend[MESSIZE_MAX], BufferReply[MESSIZE_MAX];
setlocale(LC_CTYPE, "C-TRADITIONAL");
if (fdRM = open(strcat(strcpy(BufferSend, NET_REG),
"/dev/MESSTEST/RM"), O_RDWR)) == -1)) {
printf("Клиент не нашел имени менеджера!n");
fflush(stdout);
return(-1);
}
/* Заполнение заголовка - первых 4-х байт сообщения, содержащего
инвентаризационную метку данного процесса (описаны в "IRL32.h") */
((int *)(BufferSend))[0] = 0x5002;
/* Заполнение сообщения */
strcpy(BufferSend + 4, "Так вот ты какой, Менеджер Ресурсов!");
if (MsgSend(fdRM, BufferSend, 100, BufferReply, 100) == -1)
