QNX/UNIX: Анатомия параллелизма - Цилюрик Олег Иванович
На этом ресурсе Вы можете бесплатно читать книгу онлайн QNX/UNIX: Анатомия параллелизма - Цилюрик Олег Иванович. Жанр: Программирование . На сайте e-Knigi.com Вы можете онлайн читать полную версию книги без регистрации и sms. Так же Вы можете ознакомится с содержанием, описанием, предисловием о произведении
printf("Клиенту не удалось передать сообщениеn");
else
printf("Клиент передал сообщение и получил <%s>n", BufferReply);
fflush(stdout);
close(fdRM);
return(0);
}Код процесса-сервера (менеджера ресурсов)
Для запуска сервера на удаленном узле выполните с терминала команду:
# on -f /net/Bed-Test /net/904-3/home/ZZZ/BIN/TestMGRгде
Bed-Test904-3/home/ZZZ/BIN/TestMGRВначале сервер выполняет действия по своей инициализации, специфические для данного процесса. Если они завершились успешно, т.е. сервер готов обслуживать клиентов, он инициализирует себя как администратор устройства (функции
dispatch_create()memset(&resmgr_attr, ...)iofunc_func_init()resmgr_attach()message_attach()dispatch_context_alloc()/dev/MESSTEST/RMПрием сообщений осуществляется функцией
dispatch_block()dispatch_handler()Так, в частности, обрабатываются сообщения на открытие ресурса (пересылаемое клиентом при вызове им функции
open()close()read()write()message_attach()PrivatHandler()При рассмотрении функции обработки приватных сообщений
PrivatHandler()_RESMGR_NOREPLY0prior_read()Еще одна тонкость: при работе с приватными сообщениями в процессе-менеджере необходимо использовать функции диспетчеризации
dispatch_*()dispatch_block()dispatch_handler()resmgr_*()resmgr_block()resmgr_handler()
#include <errno.h>
#include <stdio.h>
#include <stddef.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/iofunc.h>
#include <sys/dispatch.h>
#include <devctl.h>
#include <locale.h>
#include "/home/ZZZ/TESTS/MR/MessTest.h"
int PrivatHandler(message_context_t *ctp, int code,
unsigned flags, void* handle);
char* IdLabelParse(int id);
// Таблица функций связи
static resmgr_connect_funcs_t connect_funcs;
// Таблица функций ввода/вывода
static resmgr_io_funcs_t io_funcs;
// Структура атрибутов устройства
static iofunc_attr_t attr;
main(int args, char **argv) {
resmgr_attr_t resmgr_attr; // Структура атрибутов менеджера ресурсов
dispatch_t *dpp; // Указатель на структуру диспетчеризации,
// содержит идентификатор канала.
dispatch_context_t *ctp; // Контекстная структура; содержит буфер
// сообщений, буфер векторов ввода/вывода
int id;
int result;
char BufferRec[100];
int rcvid;
setlocale(LC_CTYPE, "C-TRADITIONAL");
/* Здесь должны выполняться необходимые действия по инициализации
конкретного сервера */
/* Считаем, что все необходимое теперь выполнено... */
/* Инициализация интерфейса диспетчеризации */
if ((dpp = dispatch_create()) == NULL) {
printf("%s: невозможно разместить обработчик"
" диспетчеризации.n", argv[0]);Похожие книги на "QNX/UNIX: Анатомия параллелизма", Цилюрик Олег Иванович
Книги похожие на "QNX/UNIX: Анатомия параллелизма" читать онлайн бесплатно полные версии.
