Command disabled: backlink
 
Available Languages?:

OSA : Очереди сообщений

Введение

Очереди сообщений являются самым универсальным и очень полезным инструментом ОС для обмена информацией между задачами. Очереди позволяют передавать следующее сообщение, не дожидаясь освобождения предыдущего. Очереди сообщений поддерживаются и для указателей на сообщения и для коротких сообщений. Для использования очередей сообщений в программе нужно в файл OSAcfg.h вставить определение констант:

#define OS_ENABLE_QUEUE
                          // Если собираемся использовать очереди
                          // указателей на сообщения
#define OS_ENABLE_SQUEUE
                          // Если собираемся использовать очереди
                          // коротких сообщений

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

В программе очереди объявляются через типы OST_QUEUE и OST_SQUEUE:

OST_QUEUE  queue;    // Очередь указателей на сообщения
OST_SQUEUE squeue;   // Очередь коротких сообщений

Эти определения создают в памяти дескрипторы для работы с очередями, которые содержат информацию о размере очереди, ее заполненности, а также сам указатель на очередь. Для работы с очередями нужно также выделять RAM-память для самой очереди (буфер, куда будут помещаться сообщения).

OST_MSG   msg_queue[10];         // Буфер для очереди из 10 сообщений
OST_SMSG  smsg_queue[15];        // Буфер для очереди из 15 коротких сообщений

Перед работой с очередью, она должна быть создана, т.е. должен быть инициализирован дескриптор очереди:

    OS_Queue_Create(queue, msg_queue, 10);  // Создаем очередь queue на 10 сообщений.
                                         // Сообщения, отправляемые в очередь, будут
                                         // храниться в массиве msg_queue.

Только после вызова этого сервиса можно отправлять сообщения в очередь и принимать их.

Для PIC16 дескриптор очереди и буфер очереди могут находиться только в банках bank0 и bank1.

Объединение

Если в программе предполагается использование очередей обоих типов и есть уверенность в том, что размерности OST_MSG и OST_SMSG одинаковы, то можно в OSAcfg.h определить константу:

#define OS_QUEUE_SQUEUE_IDENTICAL

Это объединит функции обработки очередей разных типов, тем самым сэкономится ROM-память.

Сервисы для работы с очередями сообщений

Очередь сообщений

Сервис Аргументы Описание Свойства
Создание
OS_Queue_Create (queue, buffer, size) Создаем очередь сообщений queue, указывая буфер и его размер Нельзя вызывать из прерывания
Отправка
OS_Queue_Send (queue, message) Отправляем сообщение с содержимым message в очередь queue с ожиданием свободной ячейки Разрешен вызов только в контексте задачиПереключает контекст
OS_Queue_Send_TO (queue, message, timeout) То же, что и OS_Queue_Send, но с выходом по таймауту Разрешен вызов только в контексте задачиПереключает контекстИспользует системный таймер
OS_Queue_Send_Now (queue, message) Отправляем сообщение с содержимым message в очередь queue без ожидания свободной ячейки Есть расширенный сервис с суффиксом _I для работы в прерывании
Проверка
bool
OS_Queue_Check
(queue) Проверить, есть ли сообщение в очереди. Есть расширенный сервис с суффиксом _I для работы в прерывании
bool
OS_Queue_IsFull
(queue) Проверка переполненности буфера Есть расширенный сервис с суффиксом _I для работы в прерывании
Ожидание
OS_Queue_Wait (queue, os_msg_type_var) Ожидаем сообщение из очереди queue Разрешен вызов только в контексте задачиПереключает контекст
OS_Queue_Wait_TO (queue, os_msg_type_var, timeout) То же, что и OS_Queue_Wait, но с выходом по таймауту Разрешен вызов только в контексте задачиПереключает контекстИспользует системный таймер

Очередь коротких сообщений

Сервис Аргументы Описание Свойства
Создание
OS_Squeue_Create (squeue, buffer, size) Создаем очередь коротких сообщений squeue, указывая буфер и его размер Нельзя вызывать из прерывания
Отправка
OS_Squeue_Send (squeue, smessage) Отправляем сообщение с содержимым smessage в очередь squeue с ожиданием свободной ячейки Разрешен вызов только в контексте задачиПереключает контекст
OS_Squeue_Send_TO (squeue, smessage, timeout) То же, что и OS_Squeue_Send, но с выходом по таймауту Разрешен вызов только в контексте задачиПереключает контекстИспользует системный таймер
OS_Squeue_Send_Now (squeue, smessage) Отправляем сообщение с содержимым smessage в очередь squeue без ожидания свободной ячейки Есть расширенный сервис с суффиксом _I для работы в прерывании
Проверка
bool
OS_Squeue_Check
(squeue) Проверить, есть ли сообщение в очереди. Есть расширенный сервис с суффиксом _I для работы в прерывании
bool
OS_Squeue_IsFull
(squeue) Проверка переполненности буфера. Возвращает true, если в очереди нет места. Есть расширенный сервис с суффиксом _I для работы в прерывании
Ожидание
OS_Squeue_Wait (squeue, os_smsg_type_var) Ожидаем сообщение из очереди squeue Разрешен вызов только в контексте задачиПереключает контекст
OS_Squeue_Wait_TO (squeue, os_smsg_type_var, timeout) То же, что и OS_Squeue_Wait, но с выходом по таймауту Разрешен вызов только в контексте задачиПереключает контекстИспользует системный таймер
 
osa/ref/services/mesage_queues.txt · Последние изменения: 07.10.2010 13:54 (внешнее изменение)
 
Creative Commons License Powered by PHP Valid XHTML 1.0 Valid CSS Driven by DokuWiki