#include <stdio.h>

#include <stdlib.h>

#include <stdint.h>

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

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

#include <coresrv/sl/sl_api.h>

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

#include <echo/Ping.idl.h>

#include <assert.h>

#define EXAMPLE_VALUE_TO_SEND 777

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

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

{

NkKosTransport transport;

struct echo_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);

/* Получаем Runtime Interface ID (RIID) для интерфейса echo.Ping.ping.

* Здесь ping – имя экземпляра компонента echo.Ping,

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

nk_iid_t riid = ServiceLocatorGetRiid(handle, "echo.Ping.ping");

assert(riid != INVALID_RIID);

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

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

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

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

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

echo_Ping_Ping_req req;

echo_Ping_Ping_res res;

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

req.value = EXAMPLE_VALUE_TO_SEND;

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

{

/* Вызываем интерфейсный метод Ping.

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

* ping_comp.ping_impl с аргументом value. Вызывающий поток блокируется

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

if (echo_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 echo.Ping.Ping()\n");

}

return EXIT_SUCCESS;

}

#include <stdio.h>

#include <stdlib.h>

#include <stdbool.h>

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

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

#include <coresrv/sl/sl_api.h>

/* Описания сущности-сервера на языке EDL. */

#include <echo/Server.edl.h>

#include <assert.h>

/* Тип объекта реализующего интерфейс. */

typedef struct IPingImpl {

struct echo_Ping base; // базовый интерфейс объекта

int step; // дополнительные параметры

} IPingImpl;

/* Реализация метода Ping. */

static nk_err_t Ping_impl(struct echo_Ping *self,

const echo_Ping_req *req,

const struct nk_arena* req_arena,

echo_Ping_res* res,

struct nk_arena* res_arena)

{

IPingImpl *impl = (IPingImpl *)self;

/* Значение value, пришедшее в запросе от клиента, инкрементируем на

* величину шага step и помещаем в аргумент result, который будет

* отправлен клиенту в составе ответа от сервера. */

res->Ping.result = req->Ping.value + impl->step;

return NK_EOK;

}

/* Конструктор объекта IPing.

* step - шаг, то есть число, на которое будет увеличиваться входящее значение. */

static struct echo_Ping *CreateIPingImpl(int step)

{

/* Таблица реализаций методов интерфейса IPing. */

static const struct echo_Ping_ops ops = {

.Ping = Ping_impl

};

/* Объект, реализующий интерфейс. */

static struct IPingImpl impl = {

.base = {&ops}

};

impl.step = step;

return &impl.base;

}

/* Точка входа в сервер. */

int main(void)

{

NkKosTransport transport;

ServiceId iid;

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

Handle handle = ServiceLocatorRegister("server_connection", NULL, 0, &iid);

assert(handle != INVALID_HANDLE);

/* Инициализируем транспорт до клиента. */

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

/* Подготавливаем структуры запроса к сущности server: фиксированную

* часть и арену. Поскольку ни у одного из методов сущности server нет

* аргументов типа sequence, используются только фиксированные части

* запроса и ответа. Арены фактически не используются. Однако в серверные

* методы транспорта (nk_transport_recv, nk_transport_reply) и

* dispatch-метод server_entity_dispatch необходимо передать валидные

* арены запроса и ответа. */

echo_Server_entity_req req;

char req_buffer[echo_Server_entity_req_arena_size];

struct nk_arena req_arena = NK_ARENA_INITIALIZER(req_buffer, req_buffer + sizeof(req_buffer));

/* Подготавливаем структуры ответа: фиксированную часть и арену. */

echo_Server_entity_res res;

char res_buffer[echo_Server_entity_res_arena_size];

struct nk_arena res_arena = NK_ARENA_INITIALIZER(res_buffer, res_buffer + sizeof(res_buffer));

/* Инициализируем диспетчер компонента ping. 3 – величина шага,

* то есть число, на которое будет увеличиваться входящее значение. */

echo_Ping_component component;

echo_Ping_component_init(&component, CreateIPingImpl(3));

/* Инициализируем диспетчер сущности server. */

echo_Server_entity entity;

echo_Server_entity_init(&entity, &component);

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

/* Реализация цикла обработки запросов. */

do

{

/* Сбрасываем буферы с запросом и ответом. */

nk_req_reset(&req);

nk_arena_reset(&req_arena);

nk_arena_reset(&res_arena);

/* Ожидаем поступление запроса к сущности-серверу. */

if (nk_transport_recv(&transport.base, &req.base_, &req_arena) != NK_EOK) {

fprintf(stderr, "nk_transport_recv error\n");

} else {

/* Обрабатываем полученный запрос, вызывая реализацию Ping_impl

* запрошенного интерфейсного метода Ping. */

echo_Server_entity_dispatch(&entity, &req.base_, &req_arena, &res.base_, &res_arena);

}

/* Отправка ответа. */

if (nk_transport_reply(&transport.base, &res.base_, &res_arena) != NK_EOK) {

fprintf(stderr, "nk_transport_reply error\n");

}

}

while (true);

return EXIT_SUCCESS;

}