signal(SIGINT, empty);
// создается канал для обмена низкоуровневыми сообщениями
data.chid = ChannelCreate(0);
// и запускается отдельным потоком ретранслятор с этого канала
if (pthread_create(NULL, NULL, msginout, NULL) != EOK)
exit("message thread");
// запускается менеджер ресурса
if (pthread_create(NULL, NULL, install, NULL) != EOK)
exit("manager thread");
// ... все! Мы свое дело сделали и ожидаем ^C ...
pause();
cout << "\rFinalization... " << endl;
// ... очистка, завершение ...
ChannelDestroy(data.chid);
return EXIT_SUCCESS;
}
Первая клиентская программа (-b) и ожидает от него ретрансляции, после чего замеряет время ответа от сервера. Этот процесс повторяется многократно (ключ -m).
#include "common.h"
static uint64_t *tim;
static int num = 10;
// вывод результатов с оценкой статистики: среднее, С.К.О...
static void outtim(void) {
double m = 0., s = 0.;
for (int i = 0; i < num; i++) {
double d = (double)tim[i];
m += d;
s += d * d;
}
m /= num;
s = sqrt(s / num - m * m);
cout << '\t' << (uint64_t)floor(m + 5) << "\t~" << (uint64_t)floor(s + .5) <<
"\t{" << (uint64_t)floor(s / m * 100 + .5) << "%}" << endl;
}
int main(int argc, char **argv) {
cout << "SRR client: " << VERSION << endl;
int opt, val;
unsigned int blk = 100;
char PATH[_POSIX_PATH_MAX] = "";
while ((opt = getopt(argc, argv, "n:b:m:")) != -1) {
switch (opt) {
case 'n': // имя хоста сервера
strcpy(PATH, "/net/");
strcat(PATH, optarg);
break;
case 'b': // размер блока обмена (байт)
if (sscanf(optarg, "%i", &blk) != 1)
exit("parse command line failed");
break;
case 'm': // число повторений таких блоков
if (sscanf(optarg, "%i", #) != 1)
exit("parse command line failed");
break;
default:
exit(EXIT_FAILURE);
}
}
// "составить" полное имя менеджера
strcat(PATH, DEVNAME);
cout << "server path. " << PATH << ", block size = "
<< blk << " bytes, repeat = " << num << endl;
// при инициализации мы сразу получаем скорость процессора клиента
result data;
cout << "CPU speed [с.p.s ]: client = " << data.cps;
// пытаемся подключиться к серверу-менеджеру
int fd = open(PATH, O_RDONLY);
if (fd < 0) exit("server not found");
// читаем его параметры
if (read(fd, &data, sizeof(result)) == -1)
exit("parameter block read");
cout << ", server = " << data.cps << endl;
tim = new uint64_t[num];
uint64_t tim2;
uint8_t *bufin = new uint8_t[blk];
*bufou = new uint8_t[blk];
// определяем дескриптор сетевого узла
int32_t node = netmgr_strtond(PATH, NULL);
// это интересное место: если в имени нет сетевого префикса пути,
// но это имя удается открыть, то это локальный хост!
