Глобальное прерывание, возможно ли? Опции

[Yaumen]

В очередной раз натолкнулся на проблему. В этот раз связанную с прерываниями.

В частности, для обмена через CAN, я организовал очередь сообщений, которая пополняется вызовом метода AddMessage, а освобождается по прерыванию от CAN. Проблема возникла из-за того, что и метод AddMessage и обработчик модифицируют одну и ту же область памяти, поэтому встречается случай когда они пытаются сделать это одновременно, а это недопустимо. Как одно из решений - это запретить прерывание на момент работы метода AddMessage, однако я не смог найти флаг глобального разрешения и запрещения прерывания. Попытка "игры" с флагами прерывания CAN приводит к тому, что события происходящие во время запрета прерываний, не фиксируются вовсе, т.е. в этом процессоре флаги прерывания выставляются только если установлено разрешение по прерыванию.

Есть ли решение в этой ситуации или надо полностью менять подход при работе с очередью?

[defunct]

Есть ли решение в этой ситуации или надо полностью менять подход при работе с очередью?

Очереди (направленные очереди если быть точнее) можно организовать так, что запрет прерываний непотребуется.
Для этого необходимо и достаточно чтобы к очереди доступ имели не более двух потоков, один строго пишет, второй строго читает. Как раз Ваш случай.

Код

typedef struct tagQUEUE
{
     volatile int put;
     volatile int get;
     int cnt;
     PVOID *pStorage;
} TQUEUE, *PQUEUE;

void queue_define( PQUEUE pq, PVOID storage, int storage_size)
{
    pq->cnt = storage_size / sizeof( PVOID );
    pq->put = pq->get = 0;
    pq->pStorage = storage;
}

PVOID queue_read( PQUEUE pq )
{
    PVOID retval = NULL;
    if (pq->get != pq->put)
    {  // got smth to read
         int new_index = pq->get + 1;
         if (new_index >= pq->cnt)
             new_index = 0;
         retval = pq->pStorage[ pq->get ];
         pq->get = new_index;
     }
     return retval;
}

void queue_write( PQUEUE pq, PVOID msg )
{
     int new_index = pq->put + 1;
     if (new_index >= pq->cnt)
         new_index = 0;
     pq->pStorage[ pq->put ] = msg;  // <-- эта операция защищена, т.к. индекс put еще не изменился, функция чтения не знает о наличии новой записи
     pq->put = new_index;  // <-- здесь требуется атомарная модификация индекса, т.е. чтобы переменная  put записалась одной асм командой (отсюда переменная put не может быть разрядностью больше чем разрядность регистров процессора).
}