Mr_Fang/Power-Pico
1
0
Fork 0
mirror of https://github.com/No-Chicken/Power-Pico.git synced 2026-04-03 13:02:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

取消全局变量通知更新固件，改为osThreadFlagsWait

Browse Source
This commit is contained in:
不吃油炸鸡
2026-03-25 16:00:47 +08:00
parent 58b3446ef5
commit 26b6bded24
4 changed files with 33 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
software/Power_Pico/User/Tasks/Src/user_MessageTask.c
View File

@@ -3,7 +3,6 @@
#include "adc.h"
#include "user_TasksInit.h"
#include "user_MessageTask.h"
#include "usbd_cdc_if.h"
#include "usb_device.h"
#include "BL24C02.h"
@@ -13,6 +12,9 @@
/* Private variables ---------------------------------------------------------*/
/* 10kHz / 100 / 10 = 10Hz UI data refresh rate */
#define UI_UPDATE_DIV 10
/* Private function prototypes -----------------------------------------------*/
@@ -23,12 +25,14 @@
*/
void MessageReceiveTask(void *argument)
{
uint32_t flags;
while(1)
{
if(get_update_request()) {
flags = osThreadFlagsWait(FLAG_USB_UPDATE_REQ,
osFlagsWaitAny,
osWaitForever);
// clear the flag
set_update_request(false);
if ((flags & 0x80000000U) == 0U) {
// set the EEPROM flag
EEPROM_UpdateCommand_Write(true);
HAL_Delay(100);
@@ -38,7 +42,7 @@ void MessageReceiveTask(void *argument)
// reset
NVIC_SystemReset();
}
osDelay(500);
HAL_Delay(500);
}
}
@@ -49,6 +53,7 @@ void MessageReceiveTask(void *argument)
void MessageSendTask(void *argument)
{
uint32_t flags;
uint32_t ui_div_cnt = 0;
while (1)
{
// 1. 等待两个标志中的任意一个 (osFlagsWaitAny)
@@ -72,19 +77,21 @@ void MessageSendTask(void *argument)
Process_ADC_Chunk(&adc_raw_buffer[ADC_TIMES][0], 1);
}
// 发送数据给UI层进行显示
PowerData_t newData;
Data_Monitor_Get_Values(&newData.voltage, &newData.current);
// 4. 限频：每 UI_UPDATE_DIV 次才往队列写一次
if (++ui_div_cnt >= UI_UPDATE_DIV)
{
ui_div_cnt = 0;
// 尝试发送，如果不等待直接返回错误，说明队列可能满了
osStatus_t status = osMessageQueuePut(PowerDataQueue, &newData, 0, 0);
PowerData_t newData;
Data_Monitor_Get_Values(&newData.voltage, &newData.current);
if (status == osErrorResource) {
PowerData_t dummy;
// 1. 强行从队列头部取出一个旧数据（丢弃）
osMessageQueueGet(PowerDataQueue, &dummy, NULL, 0);
// 2. 再次存入新数据
osMessageQueuePut(PowerDataQueue, &newData, 0, 0);
osStatus_t status = osMessageQueuePut(PowerDataQueue, &newData, 0, 0);
if (status == osErrorResource) {
PowerData_t dummy;
// 队列满：丢弃旧数据，写入新数据
osMessageQueueGet(PowerDataQueue, &dummy, NULL, 0);
osMessageQueuePut(PowerDataQueue, &newData, 0, 0);
}
}
}
}