Сущность client использует функцию test() для вызова методов Ping и Pong в различной последовательности и/или в различные моменты времени (в зависимости от используемого семейства политик).
Реализация функции test() содержится в файле test.c. Для каждого используемого в примере семейства политик есть отдельный файл test.c.
Инициализация транспорта до сервера, использование прокси-объекта и интерфейсных методов, а также назначение файла ping.idl.h рассматриваются более подробно в комментариях к файлу client.c в примере echo.
client.c
#include <stdio.h>
#include <stdlib.h>
#include <stdint.h>
#include <assert.h>
#include <coresrv/nk/transport-kos.h>
#include <coresrv/sl/sl_api.h>
#include "ping.idl.h"
/* Реализация функции test() содержится в файле test.c. */
void test(struct IPing *proxy);
uint32_t ping(struct IPing *proxy, uint32_t value)
{
/* Структуры запроса и ответа */
struct IPing_Ping_req req;
struct IPing_Ping_res res;
req.value = value;
/* Вызываем интерфейсный метод IPing_Ping. */
if (IPing_Ping(proxy, &req, NULL, &res, NULL) == rcOk)
{
fprintf(stderr, "Client: Ping(%d), result = %d\n", (int) value, (int) res.result);
value = res.result;
}
else
fprintf(stderr, "Client: Ping(%d), failed\n", (int) value);
return value;
}
uint32_t pong(struct IPing *proxy, uint32_t value)
{
/* Структуры запроса и ответа */
struct IPing_Pong_req req;
struct IPing_Pong_res res;
req.value = value;
/* Вызываем интерфейсный метод IPing_Pong. */
if (IPing_Pong(proxy, &req, NULL, &res, NULL) == rcOk)
{
fprintf(stderr, "Client: Pong(%d), result = %d\n", (int) value, (int) res.result);
value = res.result;
}
else
fprintf(stderr, "Client: Pong(%d), failed\n", (int) value);
return value;
}
int main(int argc, const char *argv[])
{
NkKosTransport transport;
struct IPing_proxy proxy;
fprintf(stderr, "Hello I'm client\n");
/* Получаем клиентский IPC-дескриптор соединения с именем
* "server_connection". */
Handle handle = ServiceLocatorConnect("server_connection");
assert(handle != INVALID_HANDLE);
/* Инициализируем транспорт до сервера. */
NkKosTransport_Init(&transport, handle, NK_NULL, 0);
/* Получаем идентификатор интерфейса ping_comp.ping_impl. */
nk_iid_t riid = ServiceLocatorGetRiid(handle, "ping_comp.ping_impl");
assert(riid != INVALID_RIID);
/* Инициализируем прокси-объект. */
IPing_proxy_init(&proxy, &transport.base, riid);
/* Вызов методов Ping и Pong в различной последовательности и/или в различные моменты времени (в зависимости от используемого семейства политик). */
test(&proxy.base);
return EXIT_SUCCESS;
}
В начало