Блокирование задач на время i/o операции Опции

[amaora]

Пытаюсь сделать драйвер или полегче говоря hal модуль i2c. Надо как-то реализовать такие функции как запись/чтение в/из i2c slave. Есть конечный автомат вызываемый из прерывания, обрабатывающий состояния i2c, передача стартов, стопов, адреса, данных и т.п.. В начале надо дождаться того, что этот автомат будет свободен, это первая точка блокирования. Отдать задание и затем дождаться его выполнения, это вторая точка блокирования.

В голову приходит, только конструкция из одной очереди запросов и пула очередей для ответов на запросы. Как-то громоздко, нельзя ли попроще? Использовать "короткие" очереди, чтобы сократить тот пул до одной очереди ответов, зная, что только одна задача может находится в состоянии ожидания ответа? Как еще?

Код

int i2c_write_reg(int addr, int reg, int val)
{
    halI2C_MSG_t        xMSG, *pMSG;
    unsigned char        msg_data[1];

    pMSG = &xMSG;
    xMSG.xTask = xTaskGetCurrentTaskHandle();
    xMSG.msg_addr = addr << 1;
    xMSG.msg_sreg = reg;
    xMSG.len_data = 1;
    xMSG.msg_data = msg_data;

    msg_data[0] = val;

    xQueueSendToBack(pI2C->xQueueReq, &pMSG, portMAX_DELAY);

    NVIC_SetPendingIRQ(I2C1_EV_IRQn);
    //ulTaskNotifyTake(pdTRUE, portMAX_DELAY);

    return xMSG.errno;
}

Вариант с TaskNotify отбросил, по той причине, что этот механизм будет использован на уровне выше, для запуска задачи которая пользуется i2c.

Спасибо.

[Valentine Logino...]

Вы хотите использовать нотифаи в качестве бинарного семафора? Тогда может быть попробовать перед записью в очередь его точно сбросить (ulTaskNotifyTake(pdTRUE, 0) ?
И без кода прерывания сложно сказать, но я думаю у вас там корректно делаются vTaskNotifyGiveFromISR и portYIELD_FROM_ISR?

[amaora]

Проверил еще раз, вот весь код. Если убрать Notify и раскомментировать семафоры, то работает. А так останавливается все, не только эти задачи, но и не относящаяся к этому коду задача обработки команд по usart.

CODE

#include <stddef.h>

#include "hal/hal.h"
#include "hal/i2c.h"
#include "hal/mpu6050.h"
#include "hal/timebase.h"
#include "hal/usart.h"

#include "freertos/FreeRTOS.h"
#include "freertos/task.h"
#include "freertos/queue.h"
#include "freertos/semphr.h"

#include "fp/im.h"

#include "main.h"
#include "lib.h"
#include "sh.h"

i2c_mpu6050_t i2c_mpu6050;

fp_im_t __CCM__ fp_im;

TaskHandle_t tIM;

void timebaseIRQ()
{
BaseType_t xWoken = pdFALSE;

//xSemaphoreGiveFromISR(glob.xSemIM, &xWoken);
vTaskNotifyGiveFromISR(tIM, &xWoken);

portYIELD_FROM_ISR(xWoken);
}

void taskFP_IM(void *pvParameters)
{
int rc = 0;

rc = i2c_mpu6050_enable(&i2c_mpu6050, 1, 1);

do {
//xSemaphoreTake(glob.xSemIM, portMAX_DELAY);
ulTaskNotifyTake(pdTRUE, portMAX_DELAY);

rc = i2c_mpu6050_read(&i2c_mpu6050);

if (rc == 0) {

fp_im_main( &fp_im,
i2c_mpu6050.accel,
i2c_mpu6050.gyro,
i2c_mpu6050.temp);

if (fp_im.refresh_flag) {

fp_im.refresh_flag = 0;
xSemaphoreGive(glob.xSem100HZ);
}
}
else {
}
}
while (1);
}

void taskFP_100HZ(void *pvParameters)
{
int i = 0;

do {
xSemaphoreTake(glob.xSem100HZ, portMAX_DELAY);

i++;

if (i >= 10) {

i = 0;
xSemaphoreGive(glob.xSem10HZ);
}

}
while (1);
}

void taskFP_10HZ(void *pvParameters)
{
do {
xSemaphoreTake(glob.xSem10HZ, portMAX_DELAY);

printf("%f %f %f (%f %f %f) %f" EOL,
&fp_im.sv[0],
&fp_im.sv[1],
&fp_im.sv[2],
&fp_im.sq[1],
&fp_im.sq[2],
&fp_im.sq[3],
&fp_im.temp);

}
while (1);
}

void taskFP_INIT(void *pvParameters)
{
i2cEnable();

glob.xSemIM = xSemaphoreCreateBinary();
glob.xSem100HZ = xSemaphoreCreateBinary();
glob.xSem10HZ = xSemaphoreCreateBinary();

xTaskCreate(taskFP_IM, "tFP_IM", 1024, NULL, 4, &tIM);
xTaskCreate(taskFP_100HZ, "tFP_100HZ", 4 * 1024, NULL, 3, NULL);
xTaskCreate(taskFP_10HZ, "tFP_10HZ", 4 * 1024, NULL, 2, NULL);

timebaseEnable(IM_FREQ_HZ);

vTaskDelete(NULL);
}

Внутри i2c_* функций использовать Notify наверно не стоит, если я их вот так снаружи уже использую. Даже если бы это работало.