Реализация сущности Client в примере echo

В коде сущности Client используются транспортные типы и методы, которые будут сгенерированы во время сборки решения компилятором NK на основе IDL-описания интерфейса Ping.

Однако чтобы получить необходимые для реализации сущности описания типов и сигнатуры методов, вы можете воспользоваться компилятором NK непосредственно после создания EDL-описания сущности, CDL-описаний компонентов и IDL-описаний используемых интерфейсов взаимодействия. В результате необходимые типы и сигнатуры методов будут объявлены в сгенерированных файлах *.h.

В реализации сущности Client необходимо:

1. Получить клиентский IPC-дескриптор соединения (канала), используя функцию локатора сервисов ServiceLocatorConnect().

   На вход нужно передать имя IPC-соединения server_connection, заданное ранее в файле init.yaml.

2. Инициализировать транспорт NkKosTransport, передав полученный IPC-дескриптор в функцию NkKosTransport_Init().
3. Получить идентификатор необходимого интерфейса (RIID), используя функцию локатора сервисов ServiceLocatorGetRiid().

   На вход нужно передать полное имя реализации интерфейса Ping. Оно состоит из имен экземпляра компонента (pingComp) и интерфейса (pingImpl), заданных ранее в Server.edl и Ping.cdl.

4. Инициализировать прокси-объект, передав транспорт и идентификатор интерфейса в функцию Ping_proxy_init().
5. Подготовить структуры запроса и ответа.
6. Вызвать интерфейсный метод Ping_Ping(), передав прокси-объект, а также указатели на запрос и ответ.

client.c

#include <stdio.h>

#include <stdlib.h>

#include <stdint.h>

/* Файлы, необходимые для инициализации транспорта. */

#include <coresrv/nk/transport-kos.h>

#include <coresrv/sl/sl_api.h>

/* Описание интерфейса сервера, по которому обращается клиентская сущность. */

#include <Ping.idl.h>

#include <assert.h>

#define EXAMPLE_VALUE_TO_SEND 777

/* Точка входа в клиентскую сущность. */

int main(int argc, const char *argv[])

{

NkKosTransport transport;

struct Ping_proxy proxy;

int i;

fprintf(stderr, "Hello I'm client\n");

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

* "server_connection". */

Handle handle = ServiceLocatorConnect("server_connection");

assert(handle != INVALID_HANDLE);

/* Инициализируем IPC-транспорт для взаимодействия с серверной сущностью. */

NkKosTransport_Init(&transport, handle, NK_NULL, 0);

/* Получаем идентификатор интерфейса pingComp.pingImpl. Здесь

* pingComp – имя экземпляра компонента Ping,

* pingImpl - имя реализации интерфейса Ping. */

nk_iid_t riid = ServiceLocatorGetRiid(handle, "pingComp.pingImpl");

assert(riid != INVALID_RIID);

/* Инициализируем прокси-объект, указав транспорт (&transport)

* и идентификатор интерфейса сервера (riid). Каждый метод

* прокси-объекта будет реализован как отправка запроса серверу. */

Ping_proxy_init(&proxy, &transport.base, riid);

/* Структуры запроса и ответа */

struct Ping_Ping_req req;

struct Ping_Ping_res res;

/* Тестовый цикл. */

req.value = EXAMPLE_VALUE_TO_SEND;

for (i = 0; i < 10; ++i)

{

/* Вызываем интерфейсный метод Ping_Ping, передав прокси-объект,

* а также указатели на запрос и ответ. При этом серверу будет

* отправлен запрос для вызова метода Ping интерфейса

* pingComp.pingImpl с аргументом value. Поскольку у метода Ping

* нет аргументов типа sequence, арена не используется – вместо нее

* передается NULL.

* Поток блокируется до момента получения ответа от сервера. */

if (Ping_Ping(&proxy.base, &req, NULL, &res, NULL) == rcOk)

{

/* Выводим значение result, содержащееся в ответе

* (result - выходной аргумент метода Ping). */

fprintf(stderr, "result = %d\n", (int) res.result);

/* Помещаем полученное значение result в аргумент value

* для повторной отправки серверу в следующей итерации. */

req.value = res.result;

}

else

fprintf(stderr, "Failed to call Ping.Ping()\n");

}

return EXIT_SUCCESS;

}

В начало