Введение в QNX/Neutrino 2. Руководство по программированию приложений реального времени в QNX Realtime Platform

 timer.it_value.tv_nsec = 0;
 timer.it_interval.tv_sec = 1;
 timer.it_interval.tv_nsec = 0;
 // ...и запустить его!
 timer_settime(timerid, 0, &timer, NULL);
}

gotAPulse

В функции gotAPulse вы можете видеть, как мы реализовали способность сервера обеспечивать тайм-ауты для клиентов. Мы последовательно просматриваем список клиентуры и, поскольку мы знаем, что импульс выдается один раз в секунду, просто уменьшаем число секунд, которое остается клиенту до тайм-аута. Если эта величина достигает нулевого значения, мы отвечаем этому клиенту сообщением «Извините, тайм-аут» (тип сообщения MT_TIMEDOUT). Обратите внимание, что мы подготавливаем это сообщение заранее (вне цикла for), а затем посылаем его по мере необходимости. Этот прием — по существу вопрос стиля: если вы предполагаете отвечать часто, возможно, имело бы смысл выполнить настройку однажды и загодя. Если же множество ответов не ожидается, то имело бы больший смысл делать настройки по мере необходимости.

Если значение оставшегося времени еще не достигло нуля, мы не делаем ничего — клиент по-прежнему заблокирован в ожидании сообщения.

/*
 * gotAPulse
 *
 * Эта подпрограмма отвечает за обработку тайм-аутов.
 * Она проверяет список клиентов на предмет тайм-аута
 * и отвечает соответствующим сообщением тем клиентам,
 * у которых тайм-аут произошел.
*/
void gotAPulse(void) {
 ClientMessageT msg;
 int i;
 if (debug) {
 time_t now;
 time(&now);
 printf("Получен импульс, время %s", ctime(&now));
 }
 // Подготовить ответное сообщение
 msg.messageType = MT_TIMEDOUT;
 // Просмотреть список клиентов
 for (i = 0; i < MAX_CLIENT; i++) {
 // Элемент используется?
 if (clients[i].in_use) {
 // Тайм-аут?
 if (--clients[i].timeout == 0) {
 // Ответить
 MsgReply(clients[i].rcvid, EOK, &msg, sizeof(msg));
 // Освободить элемент
 clients[i].in_use = 0;
 }
 }
 }
}

gotAMessage

В функции gotAMessage вы видите другую половину заданной функциональности, где мы добавляем клиента в список клиентуры, ожидающей данные (если получено сообщение типа MT_WAIT_DATA), или сопоставляем клиента с сообщением, которое было только что получено (если это сообщение типа MT_SEND_DATA). Заметьте, что для простоты мы здесь не реализуем очередь клиентов, находящихся в ожидании передачи данных, получатель для которых еще не доступен — это вопрос управления очередями, оставьте его для себя в качестве упражнения.

/*
 * gotAMessage
 *
 * Эта подпрограмма вызывается при каждом приеме
* сообщения. Проверяем тип
 * сообщения (либо «жду данных», либо «вот данные»),
 * и действуем
 * соответственно. Для простоты предположим, что данные
 * никогда не ждут.
 * Более подробно об этом см. в тексте.
*/
void gotAMessage(int rcvid, ClientMessageT *msg) {
 int i;
 // Определить тип сообщения
 switch (msg->messageType) {
 // Клиент хочет ждать данных
 case MT_WAIT_DATA:
 // Посмотрим, есть ли пустое место в таблице клиентов
 for (i = 0; i < MAX_CLIENT; i++) {
 if (!clients[i].in_use) {
 // Нашли место - пометить как занятое,
 // сохранить rcvid
 // и установить тайм-аут
 clients[i].in_use = 1;
 clients[i].rcvid = rcvid;
 clients[i].timeout = 5;
 return;
 }
 }
 fprintf(stderr,
 "Таблица переполнена, сообщение от rcvid %d"
 " игнорировано, клиент заблокирован\n", rcvid);
 break;
 // Клиент с данными
 case MT_SEND_DATA:
 // Посмотрим, есть ли другой клиент, которому можно ответить
 // данными от этого клиента
 for (i = 0; i < MAX CLIENT; i++) {
 if (clients[i].in_use) {
 // Нашли - использовать полученное сообщение
 // в качестве ответного
 msg->messageType = MT_OK;
 // Ответить ОБОИМ КЛИЕНТАМ!
 MsgReply(clients[i].rcvid, EOK, msg, sizeof(*msg));
 MsgReply(rcvid, EOK, msg, sizeof(*msg));
 clients[i].in_use = 0;
 return;
 }
 }
 fprintf(stderr,
 "Таблица пуста, сообщение от rcvid %d игнорировано,"
 " клиент заблокирован\n", rcvid);
 break;
 }
}

Примечания

Несколько общих замечаний по тексту программы:

• Если сообщение с данными прибывает, когда либо никто не ждет, либо список ожидающих клиентов переполнен, в стандартный поток ошибок выводится сообщение, но клиенту при этом мы не отвечаем ничего. Это означает, что ряд клиентов может оказаться в REPLY-блокированном состоянии навсегда — идентификаторы отправителей мы потеряли, а значит, и ответ им дать не можем.

Это сделано намеренно. Вы можете изменить это, добавив соответственно сообщения MT_NO_WAITERS и MT_NO_SPACE, которыми можно было бы отвечать всякий раз при обнаружении ошибок данного типа.