QNX/UNIX: Анатомия параллелизма

 }
}
//--------------------------------------------------------
// 'пустой' обработчик реакции на ^C (сигнал SIGINT)
inline static void empty(int signo) {}
//--------------------------------------------------------
// главная программа, которая все это 'хозяйство' установит
// и будет безропотно ждать завершения по ^C ;)
int main(int argc, char *argv[]) {
 cout << 'SRR server: ' << VERSION << endl;
 // открывается менеджер ресурса ...
 int fd = open(DEVNAME, O_RDONLY);
 // если менеджер открылся, то это нам не нужно -
 // дубликаты не создавать!
 if (fd > 0)
  close(fd), cout << 'already in use ' << DEVNAME << endl, exit (EXIT_FAILURE);
 // перехватываем реакцию ^C:
 cout << '. . . . . . waiting ^C. . . . . .' << flush;
 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 << '
Finalization... ' << endl;
 // ... очистка, завершение ...
 ChannelDestroy(data.chid);
 return EXIT_SUCCESS;
}

Первая клиентская программа (файл cli.cc) посылает серверу блок данных указанной длины (длина может изменяться в широких пределах указанием при запуске ключа - 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 << '	' << (uint64_t)floor(m + 5) << '	~' << (uint64_t)floor(s + .5) <<
  '	{' << (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', &num) != 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;