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

// Таблица клиентов

#define MAX_CLIENT 16 // Максимум клиентов

// одновременно

struct {

int in_use; // Элемент используется?

int rcvid; // Идентификатор

// отправителя клиента

int timeout; // Оставшийся клиенту

//тайм-аут

} clients[MAX_CLIENT]; // Таблица клиентов

int chid; // Идентификатор канала

// (глобальный)

int debug = 1; // Режим отладки, 1 ==

// вкл, 0 == выкл

char *progname = "time1.c";

// Предопределенные прототипы

static void setupPulseAndTimer(void);

static void gotAPulse(void);

static void gotAMessage(int rcvid, ClientMessageT *msg);

Следующий раздел кода является основным и отвечает за следующее:

• создание канала с помощью функции ChannelCreate() ;

• вызов подпрограммы setupPulseAndTimer() (для настройки периодического таймера, срабатывающего раз в секунду и использующего импульс в качестве способа доставки события;

• и, наконец, бесконечный цикл ожидания импульсов и сообщений и их обработки.

Обратите внимание на проверку значения, возвращаемого MsgReceive() — нуль указывает, что был принят импульс (здесь мы не делаем никакой дополнительной проверки, наш ли это импульс), ненулевое значение говорит о том, что было принято сообщение.

Обработка импульсов и сообщений выполняется функциями gotAPulse() и gotAMessage() .

int main void) // Игнорировать аргументы

// командной строки

{

int rcvid; // PID отправителя

MessageT msg; // Само сообщение

if ((chid = ChannelCreate(0)) == -1) {

fprintf(stderr, "%s: не удалось создать канал!\n",

progname);

perror(NULL);

exit(EXIT_FAILURE);

}

// Настроить импульс и таймер

setupPulseAndTimer();

// Прием сообщений

for(;;) {

rcvid = MsgReceive(chid, &msg, sizeof(msg), NULL));

// Определить, от кого сообщение

if (rcvid == 0) {

// Здесь неплохо бы еще проверить поле «code»...

gotAPulse();

} else {

gotAMessage(rcvid, &msg.msg);

}

}

// Сюда мы никогда не доберемся

return (EXIT_SUCCESS);

}

В функции setupPulseAndTimer() вы видите код, в котором определяется тип таймера и схема уведомления. Когда мы рассуждали о таймерных функциях выше, я говорил, что таймер может выдать сигнал или импульс, либо создать поток. Решение об этом принимается именно здесь, в функции setupPulseAndTimer() . Обратите внимание, что здесь мы использовали макроопределение SIGEV_PULSE_INIT(). Используя это макроопределение, мы реально присвоили элементу sigev_notify значение SIGEV_PULSE. (Если бы мы использовали одно из макроопределений семейства SIGEV_SIGNAL*_INIT(), мы получили бы уведомление при помощи соответствующего сигнала). Отметьте, что при настройке импульса мы с помощью вызова ConnectAttach() устанавливаем соединение с самим собой и даем ему уникальный код (здесь — константа CODE_TIMER; мы ее определили сами)

Последний параметр в инициализации структуры события — это приоритет импульса; здесь мы выбрали SIGEV_PULSE_PRIO_INHERIT (константа, равная -1). Это предписывает ядру не изменять приоритет принимающего импульс потока.

В конце описания функции мы вызываем timer_create() для создания таймера в ядре, после чего настраиваем его на срабатывание через одну секунду (поле it_value ) и на периодическую перезагрузку односекундными интервалами (поле it_interval ). Отметим, что таймер включается только по вызову timer_settime() , а не при его создании.

Схема уведомления по типу SIGEV_PULSE — расширение, свойственное только QNX/Neutrino. Концепция импульсов в POSIX отсутствует.

/*

* setupPulseAndTimer

*

* Эта подпрограмма отвечает за настройку импульса, чтобы

* тот отправлял сообщение с кодом MT_TIMER.

* Затем устанавливается

* периодический таймер с периодом в одну секунду.

*/

void setupPulseAndTimer(void) {

timer_t timerid; // Идентификатор таймера

struct sigevent event; // Генерируемое событие

struct itimerspec timer; // Структура данных

// таймера

int coid; // Будем соединяться с

// собой

// Создать канал к себе

coid = ConnectAttach(0, 0, chid, 0, 0);

if (coid == -1) {

fprintf(stderr, "%s: ошибка ConnectAttach!\n", progname);

perror(NULL);

exit(EXIT_FAILURE);

}

// Установить, какое событие мы хотим сгенерировать

// - импульс

SIGEV_PULSE_INIT(&event, coid, SIGEV_PULSE_PRIO_INHERIT,