Роб Кёртен - Введение в QNX/Neutrino 2. Руководство по программированию приложений реального времени в QNX Realtime Platform

Аргументами функции MsgSend() являются :

• идентификатор соединения с целевым сервером ( coid );

• указатель на передаваемое сообщение ( smsg );

• размер передаваемого сообщения ( sbytes );

• указатель на буфер для ответного сообщения ( rmsg );

• размер ответного сообщения ( rbytes );

Что может быть проще!

Передадим сообщение процессу с идентификатором 77 по каналу 1:

#include

char *smsg = "Это буфер вывода";

char rmsg[200];

int coid;

// Установить соединение

coid = ConnectAttach(0, 77, 1, 0, 0);

if (coid == -1) {

fprintf(stderr, "Ошибка ConnectAttach к 0/77/1!\n");

perror(NULL);

exit(EXIT_FAILURE);

}

// Послать сообщение

if (MsgSend(

coid, smsg, strlen(smsg) + 1, rmsg, sizeof(rmsg)) == -1) {

fprintf (stderr, "Ошибка MsgSend\n");

perror(NULL);

exit (EXIT_FAILURE);

}

if (strlen(rmsg) > 0) {

printf("Процесс с ID 77 возвратил \"%s\"\n", rmsg);

}

Предположим, что процесс с идентификатором 77 был действительно активным сервером, ожидающим сообщение именно такого формата по каналу с идентификатором 1. После приема сообщения сервер обрабатывает его и в некоторый момент времени выдает ответ с результатами обработки. В этот момент функция MsgSend() должна возвратить ноль (0), указывая этим, что все прошло успешно. Если бы сервер послал нам в ответ какие-то данные, мы смогли бы вывести их на экран с помощью последней строки в программе (с тем предположением, что обратно мы получаем корректную ASCIIZ-строку).

Теперь, когда мы рассмотрели клиента, перейдем к серверу. Клиент использовал функцию ConnectAttach() для создания соединения с сервером, а затем использовал функцию MsgSend() для передачи сообщений.

Под этим подразумевается, что сервер должен создать канал — то, к чему присоединялся клиент, когда вызывал функцию ConnectAttach() . Обычно сервер, однажды создав канал, приберегает его «впрок».

Канал создается с помощью функции ChannelCreate() и уничтожается с помощью функции ChannelDestroy() :

#include

int ChannelCreate(unsigned flags);

int ChannelDestroy(int chid);

Мы еще вернемся к обсуждению аргумента flags (в разделе «Флаги каналов», см. ниже), а покамест будем использовать для него значение 0 (ноль). Таким образом, для создания канала сервер должен сделать так:

int chid;

chid = ChannelCreate(0);

Теперь у нас есть канал. В этом пункте клиенты могут подсоединиться (с помощью функции ConnectAttach() ) к этому каналу и начать передачу сообщений:

Связь между каналом сервера и клиентским соединением.

В терминах обмена сообщениями, сервер отрабатывает схему обмена в два этапа — этап «приема» (receive) и этап «ответа» (reply).

Взаимосвязь функций клиента и сервера при обмене сообщениями.

Обсудим сначала два простейших варианта соответствующих функций, MsgReceive() и MsgReply() , а далее посмотрим, какие есть варианты.

#include

int MsgReceive(int chid, void *rmsg, int rbytes,

struct _msg_info *info);

int MsgReply(int rcvid, int status, const void *msg,

int nbytes);

Посмотрим, как соотносятся параметры:

Поток данных при обмене сообщениями.

Как видно из рисунка, имеются четыре элемента, которые мы должны обсудить:

1. Клиент вызывает функцию MsgSend() и указывает ей на буфер передачи (указателем smsg и длиной sbytes ). Данные передаются в буфер функции MsgReceive() на стороне сервера, по адресу rmsg и длиной rbytes . Клиент блокируется.

2. Функция MsgReceive() сервера разблокируется и возвращает идентификатор отправителя rcvid , который будет впоследствии использован для ответа. Теперь сервер может использовать полученные от клиента данные.

3. Сервер завершил обработку сообщения и теперь использует идентификатор отправителя rcvid , полученный от функции MsgReceive() , передавая его функции MsgReply() . Заметьте, что местоположение данных для передачи функции MsgReply() задается как указатель на буфер ( smsg ) определенного размера ( sbytes ). Ядро передает данные клиенту.