cbb
a52d94687b
- 配置DMA0_CH1用于SPI0_RX接收，替代原有的RBNE中断逐字节处理 - 添加startSpiRxDma、stopSpiDmas、drainSpiRxHw等DMA控制函数 - 在CS空闲期预装下一笔DMA传输，避免EXTI CS下降沿相对于SCK偏晚导致收0字节 - 与BOOT工程SpiOta的DMA配置对齐，确保通信稳定性 refactor(SPI): 优化CS边沿处理逻辑和命令解析时机 - 移除原有的EXTI5_9_IRQHandler用于SPI Ready引脚处理 - 将命令处理从异步任务调度改为在CS释放中断中同步完成 - 重构onCsAssert和onCsRelease逻辑，简化DMA启停流程 - 删除TASK_SPI_CMD_PROCESS任务类型，减少不必要的任务调度 feat(CANFD): 修改transmitFrame返回类型为枚举值以提供详细错误信息 - 将CanFd::transmitFrame返回类型从bool改为CanTxResult枚举 - 新增CanTxResult枚举定义，包含kOk、kErrBusOff、kErrTecHigh、kErrMailbox、kErrInvalid - 更新SPI桥接命令处理中对transmitFrame返回值的处理逻辑 - 枚举值设计与SPI错误响应码对齐，便于直接透传错误信息 refactor(SPI): 实现全双工DMA传输以提升通信可靠性 - 配置DMA0_CH1用于SPI0_RX接收，替代原有的RBNE中断逐字节处理 - 添加startSpiRxDma、stopSpiDmas、drainSpiRxHw等DMA控制函数 - 在CS空闲期预装下一笔DMA传输，避免EXTI CS下降沿相对于SCK偏晚导致收0字节 - 与BOOT工程SpiOta的DMA配置对齐，确保通信稳定性 refactor(SPI): 优化CS边沿处理逻辑和命令解析时机 - 移除原有的EXTI5_9_IRQHandler用于SPI Ready引脚处理 - 将命令处理从异步任务调度改为在CS释放中断中同步完成 - 重构onCsAssert和onCsRelease逻辑，简化DMA启停流程 - 删除TASK_SPI_CMD_PROCESS任务类型，减少不必要的任务调度 feat(OTA): 添加BOOT版本号读取功能并优化版本信息获取 - 在ota_boot_request模块中添加readBootVersion函数 - 从OTA配置页Flash读取BOOT版本号信息 - 在SPI PING命令响应中使用新的版本读取接口 - 统一版本号获取方式，避免裸指针访问Flash地址 refactor(task): 调整诊断打印任务调度周期为5秒间隔 - 新增div_diag_print调度分频计数器用于诊断打印 - 将诊断打印任务从心跳任务中分离，独立控制执行周期 - 修改诊断打印函数注释，明确其由5秒节拍触发 - 优化任务调度逻辑，提高系统运行效率
394 lines
15 KiB
C++
394 lines
15 KiB
C++
/**
|
||
* @file task_runner.cpp
|
||
* @brief 任务执行器实现。
|
||
*/
|
||
|
||
#include "main.h"
|
||
#include "device/adc.h"
|
||
#include "device/watchdog.h"
|
||
#include "device/spi/app_spi_command.h"
|
||
#include "device/canfd.h"
|
||
#include "device/temp_sensor.h"
|
||
#include "sys/config.h"
|
||
#include "sys/ota_boot_request.h"
|
||
#include "sys/task_manager.h"
|
||
#include "sys/task_runner.h"
|
||
#include "comm/ethercat_slave.h"
|
||
|
||
namespace {
|
||
constexpr uint32_t kAdcFilterWindow = CONFIG_ADC_FILTER_SIZE + 1U;
|
||
|
||
/**
|
||
* @brief Push one sample into a fixed-size sliding window buffer.
|
||
* @param[in,out] buffer Sample buffer with `kAdcFilterWindow` elements.
|
||
* @param[in] value New sample value.
|
||
*/
|
||
static void pushSample(float *buffer, float value)
|
||
{
|
||
for(uint32_t i = 0U; i < CONFIG_ADC_FILTER_SIZE; ++i) {
|
||
buffer[i] = buffer[i + 1U];
|
||
}
|
||
buffer[CONFIG_ADC_FILTER_SIZE] = value;
|
||
}
|
||
|
||
/**
|
||
* @brief Apply median filtering to a fixed-size sample window.
|
||
* @param[in] buffer Sample buffer with `kAdcFilterWindow` elements.
|
||
* @return Median value in the current window.
|
||
*/
|
||
static float medianFilter(const float *buffer)
|
||
{
|
||
float sorted[kAdcFilterWindow];
|
||
|
||
for(uint32_t i = 0U; i < kAdcFilterWindow; ++i) {
|
||
sorted[i] = buffer[i];
|
||
}
|
||
|
||
for(uint32_t i = 1U; i < kAdcFilterWindow; ++i) {
|
||
const float key = sorted[i];
|
||
uint32_t j = i;
|
||
while((j > 0U) && (sorted[j - 1U] > key)) {
|
||
sorted[j] = sorted[j - 1U];
|
||
--j;
|
||
}
|
||
sorted[j] = key;
|
||
}
|
||
|
||
return sorted[kAdcFilterWindow / 2U];
|
||
}
|
||
} // namespace
|
||
|
||
struct TaskRunner::Runtime {
|
||
temp_sensor_data_t sample{};
|
||
float temperature_samples[kAdcFilterWindow] = {0.0f};
|
||
float vdda_samples[kAdcFilterWindow] = {0.0f};
|
||
float vin_adc_samples[kAdcFilterWindow] = {0.0f};
|
||
uint16_t last_vin_raw = 0U;
|
||
uint16_t last_vref_raw = 0U;
|
||
uint16_t last_temp_raw = 0U;
|
||
uint8_t last_rx_channel = 0U;
|
||
uint32_t last_rx_id = 0U;
|
||
uint8_t last_rx_len = 0U;
|
||
uint8_t last_rx_data[64] = {0};
|
||
};
|
||
|
||
TaskRunner::Runtime TaskRunner::s_runtime;
|
||
|
||
/**
|
||
* @brief 采样 VIN 与 VREF 原始 ADC 数值。
|
||
* @param[in] 无。
|
||
* @param[out] 无。
|
||
* @retval 无返回值。
|
||
* @note 从 ADC DMA 缓冲中读取外部 VIN_ADC 与内部 VREFINT 通道最新值。
|
||
*/
|
||
void TaskRunner::taskAdcVrefSample()
|
||
{
|
||
s_runtime.last_vin_raw = Adc::readVinRaw();
|
||
s_runtime.last_vref_raw = Adc::readVrefRaw();
|
||
}
|
||
|
||
/**
|
||
* @brief 采样内部温度通道原始 ADC 数值。
|
||
* @param[in] 无。
|
||
* @param[out] 无。
|
||
* @retval 无返回值。
|
||
* @note 读取 ADC DMA 缓冲中的内部温度通道最新值。
|
||
*/
|
||
void TaskRunner::taskAdcTempSample()
|
||
{
|
||
s_runtime.last_temp_raw = Adc::readTempRaw();
|
||
}
|
||
|
||
/**
|
||
* @brief 根据原始采样值计算工程量结果。
|
||
* @param[in] 无。
|
||
* @param[out] 无。
|
||
* @retval 无返回值。
|
||
* @note 输出 `vin_adc_v`、`vdda` 和 `temperature` 等可直接使用的工程值。
|
||
*/
|
||
void TaskRunner::taskAdcProcess()
|
||
{
|
||
auto &s = s_runtime.sample;
|
||
const float vdda = Adc::calculateVdda(s_runtime.last_vref_raw);
|
||
const float vin_adc_v = Adc::calculateVinAdcVoltage(s_runtime.last_vin_raw, vdda);
|
||
const float temperature = Adc::calculateTemperature(s_runtime.last_temp_raw, vdda);
|
||
const bool sampleValid = (s_runtime.last_vref_raw > 0U) &&
|
||
(s_runtime.last_vref_raw < 4095U) &&
|
||
(s_runtime.last_temp_raw > 0U) &&
|
||
(s_runtime.last_temp_raw < 4095U) &&
|
||
(vdda >= 2.7f) && (vdda <= 3.6f) &&
|
||
(temperature >= -40.0f) && (temperature <= 125.0f);
|
||
|
||
if(sampleValid) {
|
||
pushSample(s_runtime.vdda_samples, vdda);
|
||
pushSample(s_runtime.vin_adc_samples, vin_adc_v);
|
||
pushSample(s_runtime.temperature_samples, temperature);
|
||
}
|
||
|
||
s.vin_raw = s_runtime.last_vin_raw;
|
||
s.vref_raw = s_runtime.last_vref_raw;
|
||
s.temp_raw = s_runtime.last_temp_raw;
|
||
s.vdda = medianFilter(s_runtime.vdda_samples);
|
||
s.vin_adc_v = medianFilter(s_runtime.vin_adc_samples);
|
||
s.temperature = medianFilter(s_runtime.temperature_samples);
|
||
s.valid = sampleValid ? 1U : 0U;
|
||
}
|
||
|
||
/**
|
||
* @brief 执行兼容保留的 CAN 接收轮询任务。
|
||
* @param[in] 无。
|
||
* @param[out] 无。
|
||
* @retval 无返回值。
|
||
* @note 当前三路 CANFD 接收已由 RX0 中断驱动，该任务仅保留接口兼容性。
|
||
*/
|
||
void TaskRunner::taskCanRxPoll() { CanFd::poll(); }
|
||
|
||
/**
|
||
* @brief 执行 CAN 周期发送任务：每 1ms 在每个使能通道上发送一帧 CANFD 测试帧。
|
||
* @param[in] 无。
|
||
* @param[out] 无。
|
||
* @retval 无返回值。
|
||
* @note 帧格式：扩展帧 29-bit ID，CAN-FD，DLC=64，BRS 受 CONFIG_CAN_FD_BRS_ENABLE 控制。
|
||
* 载荷布局：
|
||
* [0] 固定标识 0xC0
|
||
* [1] 通道号
|
||
* [2..5] 发送序号（小端 uint32）
|
||
* [6..7] 系统运行秒数低 16 位
|
||
* [8..63] 填充 0xA0 + (index & 0x0F)
|
||
* periodic=true：仅允许一个邮箱保持自动重发，不主动 abort 旧帧，
|
||
* 跳过 TEC 保护以匹配诊断行为。
|
||
*/
|
||
void TaskRunner::taskCanTxSend()
|
||
{
|
||
static uint32_t seq = 0U;
|
||
|
||
for (uint8_t ch = 0U; ch < 3U; ++ch) {
|
||
if (!CanFd::isChannelEnabled(ch)) {
|
||
continue;
|
||
}
|
||
|
||
uint8_t data[64];
|
||
data[0] = 0xC0U;
|
||
data[1] = ch;
|
||
const uint32_t s = seq;
|
||
data[2] = static_cast<uint8_t>(s & 0xFFU);
|
||
data[3] = static_cast<uint8_t>((s >> 8) & 0xFFU);
|
||
data[4] = static_cast<uint8_t>((s >> 16) & 0xFFU);
|
||
data[5] = static_cast<uint8_t>((s >> 24) & 0xFFU);
|
||
data[6] = static_cast<uint8_t>(g_app_uptime_sec & 0xFFU);
|
||
data[7] = static_cast<uint8_t>((g_app_uptime_sec >> 8) & 0xFFU);
|
||
for (uint8_t i = 8U; i < 64U; ++i) {
|
||
data[i] = static_cast<uint8_t>(0xA0U + (i & 0x0FU));
|
||
}
|
||
|
||
const uint32_t extId = 0x18FF5000U | static_cast<uint32_t>(ch);
|
||
if (CanFd::transmitFrame(ch, extId, data, sizeof(data), true) == CanFd::CanTxResult::kOk) {
|
||
seq++;
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* @brief 批量解析并消费待处理的 CAN 接收报文。
|
||
* @param[in] 无。
|
||
* @param[out] 无。
|
||
* @retval 无返回值。
|
||
* @note 一次任务按预算尽量清空软件接收队列；若仍有积压，则重新置位解析任务。
|
||
*/
|
||
void TaskRunner::taskCanRxParse()
|
||
{
|
||
uint32_t consumed = 0U;
|
||
while(consumed < CONFIG_CAN_RX_PARSE_BUDGET) {
|
||
if(!CanFd::consumeRxFrame(&s_runtime.last_rx_id, s_runtime.last_rx_data, &s_runtime.last_rx_len, &s_runtime.last_rx_channel)) {
|
||
break;
|
||
}
|
||
if(OtaBootRequest::handleCanFrame(s_runtime.last_rx_channel,
|
||
s_runtime.last_rx_id,
|
||
s_runtime.last_rx_data,
|
||
s_runtime.last_rx_len)) {
|
||
OtaBootRequest::process();
|
||
return;
|
||
}
|
||
consumed++;
|
||
}
|
||
|
||
if(CanFd::hasRxFrame()) {
|
||
TaskManager::set(1UL << TASK_CAN_RX_PARSE);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* @brief 执行状态灯维护任务。
|
||
* @param[in] 无。
|
||
* @param[out] 无。
|
||
* @retval 无返回值。
|
||
* @note 当前仅保留任务入口。
|
||
*/
|
||
void TaskRunner::taskStatusLed() { /* 预留 */ }
|
||
|
||
/**
|
||
* @brief 执行系统心跳维护任务。
|
||
* @param[in] 无。
|
||
* @param[out] 无。
|
||
* @retval 无返回值。
|
||
* @note 当前仅保留任务入口。
|
||
*/
|
||
void TaskRunner::taskHeartbeat() { OtaBootRequest::process(); CanFd::refreshFeedbackSnapshot(); canFeedbackStartRound(); }
|
||
|
||
/**
|
||
* @brief 输出当前温度、电压与 CAN 诊断信息。
|
||
* @param[in] 无。
|
||
* @param[out] 无。
|
||
* @retval 无返回值。
|
||
* @note 由 5 秒节拍触发，通过 UART 打印当前温度、电压；采用定点整数格式，避免依赖浮点 `printf` 支持。
|
||
*/
|
||
void TaskRunner::taskDiagnosticPrint()
|
||
{
|
||
const auto *diag = CanFd::diag();
|
||
const auto &s = s_runtime.sample;
|
||
const int32_t temp_x100 = static_cast<int32_t>(s.temperature * 100.0f);
|
||
const uint32_t vdda_mV = static_cast<uint32_t>(s.vdda * 1000.0f);
|
||
const uint32_t vin_adc_mV = static_cast<uint32_t>(s.vin_adc_v * 1000.0f);
|
||
|
||
#if (CONFIG_UART_DIAG_LEVEL == 0)
|
||
printf("[APP] uptime=%lus valid=%u, temp_raw=%u, vref_raw=%u, temp=%ld.%02ld C, vdda=%lu.%03lu V, vin_adc=%lu.%03lu V\r\n",
|
||
(unsigned long)g_app_uptime_sec,
|
||
static_cast<unsigned int>(s.valid),
|
||
static_cast<unsigned int>(s.temp_raw),
|
||
static_cast<unsigned int>(s.vref_raw),
|
||
static_cast<long>(temp_x100 / 100),
|
||
static_cast<long>((temp_x100 >= 0 ? temp_x100 : -temp_x100) % 100),
|
||
static_cast<unsigned long>(vdda_mV / 1000U),
|
||
static_cast<unsigned long>(vdda_mV % 1000U),
|
||
static_cast<unsigned long>(vin_adc_mV / 1000U),
|
||
static_cast<unsigned long>(vin_adc_mV % 1000U));
|
||
#else
|
||
printf("[APP] uptime=%lus valid=%u, temp=%ld.%02ld C, vdda=%lu.%03lu V, vin_adc=%lu.%03lu V, rx_ch=%u, rx_id=0x%08lX, rx_len=%u, tx_ch=%u, can_tx=%lu, can_rx=%lu, sw_drop=%lu, hw_full=%lu, hw_over=%lu, tx_drop=%lu, tx_abort=%lu, can_err=%lu\r\n",
|
||
(unsigned long)g_app_uptime_sec,
|
||
static_cast<unsigned int>(s.valid),
|
||
static_cast<long>(temp_x100 / 100),
|
||
static_cast<long>((temp_x100 >= 0 ? temp_x100 : -temp_x100) % 100),
|
||
static_cast<unsigned long>(vdda_mV / 1000U),
|
||
static_cast<unsigned long>(vdda_mV % 1000U),
|
||
static_cast<unsigned long>(vin_adc_mV / 1000U),
|
||
static_cast<unsigned long>(vin_adc_mV % 1000U),
|
||
static_cast<unsigned int>(s_runtime.last_rx_channel),
|
||
static_cast<unsigned long>(s_runtime.last_rx_id),
|
||
static_cast<unsigned int>(s_runtime.last_rx_len),
|
||
static_cast<unsigned int>(diag->last_tx_channel),
|
||
static_cast<unsigned long>(diag->tx_count),
|
||
static_cast<unsigned long>(diag->rx_count),
|
||
static_cast<unsigned long>(diag->rx_drop_count),
|
||
static_cast<unsigned long>(diag->rx_fifo_full_count),
|
||
static_cast<unsigned long>(diag->rx_fifo_overfull_count),
|
||
static_cast<unsigned long>(diag->tx_drop_count),
|
||
static_cast<unsigned long>(diag->tx_abort_count),
|
||
static_cast<unsigned long>(diag->error_count));
|
||
#endif
|
||
|
||
{
|
||
if (EthercatSlave::isEscReady()) {
|
||
uint32_t maxCyc = 0U, avgCyc = 0U, cnt = 0U;
|
||
EthercatSlave::getIsrStats(&maxCyc, &avgCyc, &cnt);
|
||
/* 180MHz: cycles / 180 = µs;用 *1000/180 获得毫微秒精度避免浮点 */
|
||
const uint32_t maxUs_x1000 = maxCyc * 1000U / 180U;
|
||
const uint32_t avgUs_x1000 = avgCyc * 1000U / 180U;
|
||
printf("[ECAT] periodicIsr cnt=%lu max=%lu.%03luus avg=%lu.%03luus\r\n",
|
||
(unsigned long)cnt,
|
||
(unsigned long)(maxUs_x1000 / 1000U), (unsigned long)(maxUs_x1000 % 1000U),
|
||
(unsigned long)(avgUs_x1000 / 1000U), (unsigned long)(avgUs_x1000 % 1000U));
|
||
} else {
|
||
printf("[ECAT] ESC not detected (chip id=0x%08lX), EtherCAT disabled\r\n",
|
||
(unsigned long)EthercatSlave::getChipId());
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* @brief 执行 EtherCAT 周期/事件处理(非实时应用层 PDO 映射)。
|
||
* @param[in] 无。
|
||
* @param[out] 无。
|
||
* @retval 无返回值。
|
||
* @note 由周期 ISR(EXTI0 SYNC0)或 ESC 事件 ISR(EXTI1 IRQ)置位 TASK_ETHERCAT_PROCESS。
|
||
*/
|
||
void TaskRunner::taskEthercatProcess()
|
||
{
|
||
EthercatSlave::process();
|
||
}
|
||
|
||
/**
|
||
* @brief 初始化任务执行器运行时上下文。
|
||
* @param[in] 无。
|
||
* @param[out] 无。
|
||
* @retval 无返回值。
|
||
* @note 执行一次完整 ADC 采样，并同步填充运行时缓存的原始值起点。
|
||
*/
|
||
void TaskRunner::init()
|
||
{
|
||
Adc::collectSample(&s_runtime.sample);
|
||
s_runtime.last_vin_raw = s_runtime.sample.vin_raw;
|
||
s_runtime.last_vref_raw = s_runtime.sample.vref_raw;
|
||
s_runtime.last_temp_raw = s_runtime.sample.temp_raw;
|
||
|
||
for(uint32_t i = 0U; i < kAdcFilterWindow; ++i) {
|
||
s_runtime.temperature_samples[i] = s_runtime.sample.temperature;
|
||
s_runtime.vdda_samples[i] = s_runtime.sample.vdda;
|
||
s_runtime.vin_adc_samples[i] = s_runtime.sample.vin_adc_v;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* @brief 执行当前所有已置位的待处理任务。
|
||
* @param[in] 无。
|
||
* @param[out] 无。
|
||
* @retval 无返回值。
|
||
* @note 先原子取出任务位图；若当前没有待处理任务则直接返回。
|
||
*/
|
||
void TaskRunner::runPending()
|
||
{
|
||
Watchdog::feed();
|
||
|
||
/* poll() 含按铃超时看门狗(cancelRing)，必须每轮无条件执行。
|
||
* 否则日志关闭时(CONFIG_SPI_APP_LOG_ENABLE=0) m_logPending 永远为 false，
|
||
* TASK_SPI_LOG 永不置位，poll() 永不执行，m_ringPending 卡死导致
|
||
* canFeedbackPushStep() 永久 return -> SPI 反馈链路死锁。
|
||
* 放在 canFeedbackPushStep() 前确保卡死的按铃先被清掉再推送下一帧。 */
|
||
AppSpiCommandBus.poll();
|
||
|
||
/* 0xB0 进 BOOT：必须每圈检查，不能只靠 1Hz TASK_HEARTBEAT。
|
||
* 否则 Flash 写/复位被拖到下一秒，ESP32 HELLO 一直 role=app 超时。 */
|
||
if (OtaBootRequest::isRebootPending()) {
|
||
OtaBootRequest::process();
|
||
}
|
||
|
||
/* CAN 反馈主动推送：GD32 APP 循环推送 3 通道 × 2 页反馈帧到 ESP32，
|
||
* 替代 ESP32 主动轮询。非阻塞：上一帧未读走时立即返回。
|
||
* 每次主循环迭代调用一次，ESP32 读走一帧后 CS 释放中断唤醒主循环继续推送。 */
|
||
canFeedbackPushStep();
|
||
|
||
/* 周期路径( SYNC0 ISR preempt=0 )用 s_periodicSeq 序列号通知主循环,
|
||
* 不再走 task_flags,避免 BASEPRI 临界区与 preempt=0 的 RMW 竞态。
|
||
* 优先于 takePending() 处理,确保周期数据及时消费。
|
||
* ESC 未焊接时 selfTest 失败,isEscReady()=false,中断未使能,
|
||
* s_periodicSeq 不会递增,此分支自然不触发——双重守卫仅为防御性编程。 */
|
||
if (EthercatSlave::isEscReady() && EthercatSlave::hasPendingPeriodic()) {
|
||
EthercatSlave::markPeriodicProcessed();
|
||
taskEthercatProcess();
|
||
}
|
||
|
||
const uint32_t pending = TaskManager::takePending();
|
||
if(pending == 0U) return;
|
||
|
||
if(pending & (1UL << TASK_ADC_VREF_SAMPLE)) taskAdcVrefSample();
|
||
if(pending & (1UL << TASK_ADC_TEMP_SAMPLE)) taskAdcTempSample();
|
||
if(pending & (1UL << TASK_ADC_PROCESS)) taskAdcProcess();
|
||
if(pending & (1UL << TASK_CAN_RX_POLL)) taskCanRxPoll();
|
||
if(pending & (1UL << TASK_CAN_RX_PARSE)) taskCanRxParse();
|
||
if(pending & (1UL << TASK_CAN_TX_SEND)) taskCanTxSend();
|
||
if(pending & (1UL << TASK_STATUS_LED)) taskStatusLed();
|
||
if(pending & (1UL << TASK_HEARTBEAT)) taskHeartbeat();
|
||
if(pending & (1UL << TASK_DIAGNOSTIC_PRINT)) taskDiagnosticPrint();
|
||
/* TASK_SPI_LOG 的 poll() 已移至 runPending() 开头无条件调用（含按铃看门狗） */
|
||
if(pending & (1UL << TASK_ETHERCAT_PROCESS)) taskEthercatProcess();
|
||
}
|