Сущность Client для вызывает методы Ping и Pong в различной последовательности.
Инициализация транспорта до сервера, использование прокси-объекта и интерфейсных методов, а также назначение файла Ping.idl.h рассматриваются более подробно в комментариях к файлу client.c в примере echo.
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
static struct Ping_proxy proxy;
static uint32_t ping(uint32_t value)
{
/* Структуры запроса и ответа */
struct Ping_Ping_req req;
struct Ping_Ping_res res;
req.value = value;
/* Вызываем интерфейсный метод Ping_Ping.
* Серверу будет отправлен запрос для вызова метода Ping интерфейса
* pingComp.pingImpl с аргументом value. Вызывающий поток блокируется
* до момента получения ответа от сервера. */
if (Ping_Ping(&proxy.base, &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;
}
static uint32_t pong(uint32_t value)
{
/* Структуры запроса и ответа */
struct Ping_Pong_req req;
struct Ping_Pong_res res;
req.value = value;
/* Вызываем интерфейсный метод Ping_Pong.
* Серверу будет отправлен запрос для вызова метода Pong интерфейса
* ping_comp.ping_impl с аргументом value. Вызывающий поток блокируется
* до момента получения ответа от сервера. */
if (Ping_Pong(&proxy.base, &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;
uint32_t value;
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. */
nk_iid_t riid = ServiceLocatorGetRiid(handle, "pingComp.pingImpl");
assert(riid != INVALID_RIID);
/* Инициализируем прокси-объект, указав транспорт (&transport)
* и идентификатор интерфейса сервера (riid). Каждый метод
* прокси-объекта будет реализован как отправка запроса серверу. */
Ping_proxy_init(&proxy, &transport.base, riid);
/* Тестовый цикл. */
value = EXAMPLE_VALUE_TO_SEND;
for (i = 0; i < 5; ++i)
{
value = ping(value);
value = pong(value);
}
value = ping(value);
value = ping(value);
value = pong(value);
value = pong(value);
return EXIT_SUCCESS;
}
В начало