Инициализация транспорта до клиента, подготовка структур запроса и ответа, а также назначение файла server.edl.h рассматриваются более подробно в комментариях к файлу server.c в примере echo.
server.c
#include <stdio.h>
#include <stdlib.h>
#include <stdbool.h>
#include <assert.h>
#include <coresrv/nk/transport-kos.h>
#include <coresrv/sl/sl_api.h>
#include "server.edl.h"
/* Тип объекта, реализующего интерфейс. */
typedef struct IPingImpl {
struct IPing base;
int step;
} IPingImpl;
/* Реализация метода Ping. */
static nk_err_t Ping_impl(struct IPing *self, const struct IPing_Ping_req *req, const struct nk_arena* req_arena, struct IPing_Ping_res* res, struct nk_arena* res_arena)
{
IPingImpl *impl = (IPingImpl *)self;
/* К аргументу value, пришедшему в запросе, прибавляем step и помещаем
* результат в аргумент result. */
res->result = req->value + impl->step;
return NK_EOK;
}
/* Реализация метода Pong. */
static nk_err_t Pong_impl(struct IPing *self, const struct IPing_Pong_req *req, const struct nk_arena* req_arena, struct IPing_Pong_res* res, struct nk_arena* res_arena)
{
IPingImpl *impl = (IPingImpl *)self;
/* К аргументу value, пришедшему в запросе, прибавляем step и помещаем
* результат в аргумент result. */
res->result = req->value + impl->step;
return NK_EOK;
}
/* Конструктор объекта IPing.
* step - число, на которое увеличивается входящее значение. */
struct IPing *CreateIPingImpl(int step)
{
/* Таблица реализаций методов интерфейса IPing. */
static const struct IPing_ops ops = {
.Ping = Ping_impl,
.Pong = Pong_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);
/* Подготавливаем структуры запроса: фиксированную часть и арену. */
union server_entity_req req;
char req_buffer[server_entity_req_arena_size];
struct nk_arena req_arena = NK_ARENA_INITIALIZER(req_buffer, req_buffer + sizeof(req_buffer));
/* Подготавливаем структуры ответа: фиксированную часть и арену. */
union server_entity_res res;
char res_buffer[server_entity_res_arena_size];
struct nk_arena res_arena = NK_ARENA_INITIALIZER(res_buffer, res_buffer + sizeof(res_buffer));
/* Инициализируем диспетчер компонента ping. 3 – значение "шага",
* которое будет прибавляться к входному аргументу value. */
struct ping_component component;
ping_component_init(&component, CreateIPingImpl(3));
/* Инициализируем диспетчер сущности server. */
struct server_entity entity;
server_entity_init(&entity, &component);
fprintf(stderr, "Server: 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, (struct nk_message *)&req, &req_arena) != NK_EOK)
fprintf(stderr, "nk_transport_recv error\n");
else
/* Обрабатываем полученный запрос, вызывая реализацию
* запрошенного метода Ping (Ping_impl). */
server_entity_dispatch(&entity, &req, &req_arena, &res, &res_arena);
/* Отправляем ответ. */
if (nk_transport_reply(&transport.base, (struct nk_message *)&res, &res_arena) != NK_EOK)
fprintf(stderr, "nk_transport_reply error\n");
} while (true);
return EXIT_SUCCESS;
}
В начало