wandering1
7f0087d430
check_coding_standard.py 新增 9 条机械检查（S14 并入 S6）： - S10 (3.3.1) 函数名全小写（HAL_ 厂商回调豁免） - S11 (2.3.5) 禁止相对/绝对路径 include - S12 (7.6) 禁止可变参数函数 - S13 (7.7) 禁止递归函数 - S15 (6.1.4) 文件作用域指针须初始化为 NULL - S16 (3.2.2) 非 static 全局变量须 g_ 前缀 - S17 (2.2) 非 static 函数须在配对头文件声明 - S18 (6.3.1) 禁止 Yoda 条件（常量在右） - S19 (4.4.2) 函数定义左大括号与右括号同行 S6 词表扩充 scanf/strtok timeSyncTask 重命名为 time_sync_task（3 处代码引用） 更新 pre-commit 使用说明规则表
323 lines
9.8 KiB
C
323 lines
9.8 KiB
C
/* USER CODE BEGIN Header */
|
||
/**
|
||
******************************************************************************
|
||
* File Name : freertos.c
|
||
* Description : Code for freertos applications
|
||
******************************************************************************
|
||
* @attention
|
||
*
|
||
* Copyright (c) 2026 STMicroelectronics.
|
||
* All rights reserved.
|
||
*
|
||
* This software is licensed under terms that can be found in the LICENSE file
|
||
* in the root directory of this software component.
|
||
* If no LICENSE file comes with this software, it is provided AS-IS.
|
||
*
|
||
******************************************************************************
|
||
*/
|
||
/* USER CODE END Header */
|
||
|
||
/* Includes ------------------------------------------------------------------*/
|
||
#include "FreeRTOS.h"
|
||
#include "task.h"
|
||
#include "main.h"
|
||
#include "cmsis_os.h"
|
||
|
||
/* Private includes ----------------------------------------------------------*/
|
||
/* USER CODE BEGIN Includes */
|
||
#include <string.h>
|
||
#include "net_task.h"
|
||
#include "ch395f.h"
|
||
#include "dbg_log.h"
|
||
#include "net_socket.h"
|
||
#include "usart.h"
|
||
#include "ff.h"
|
||
#include "gd5f2gq5ue.h"
|
||
#include "lftpd.h"
|
||
#include "../test/ch395f_test_task.h"
|
||
#include "../test/ch395f_test.h" /* ENABLE_NET_LAYER_TESTS：netTask 条件创建 */
|
||
#include "time_sync.h"
|
||
#include "sys_events.h"
|
||
/* USER CODE END Includes */
|
||
|
||
/* Private typedef -----------------------------------------------------------*/
|
||
/* USER CODE BEGIN PTD */
|
||
|
||
/* USER CODE END PTD */
|
||
|
||
/* Private define ------------------------------------------------------------*/
|
||
/* USER CODE BEGIN PD */
|
||
/* USER CODE END PD */
|
||
|
||
/* Private macro -------------------------------------------------------------*/
|
||
/* USER CODE BEGIN PM */
|
||
|
||
/* USER CODE END PM */
|
||
|
||
/* Private variables ---------------------------------------------------------*/
|
||
/* USER CODE BEGIN Variables */
|
||
/* 存储测试变量（g_storage_stats / s_perf_buf）已迁至 test/storage_test_task.c */
|
||
osThreadId_t timeSyncTaskHandle;
|
||
const osThreadAttr_t timeSyncTask_attributes = {
|
||
.name = "timeSyncTask",
|
||
.stack_size = 512 * 4,
|
||
.priority = (osPriority_t) osPriorityNormal,
|
||
};
|
||
/* USER CODE END Variables */
|
||
/* Definitions for defaultTask */
|
||
osThreadId_t defaultTaskHandle;
|
||
const osThreadAttr_t defaultTask_attributes = {
|
||
.name = "defaultTask",
|
||
.stack_size = 512 * 4,
|
||
.priority = (osPriority_t) osPriorityNormal,
|
||
};
|
||
/* Definitions for netTask */
|
||
osThreadId_t netTaskHandle;
|
||
const osThreadAttr_t netTask_attributes = {
|
||
.name = "netTask",
|
||
.stack_size = 1024 * 4,
|
||
.priority = (osPriority_t) osPriorityNormal,
|
||
};
|
||
/* Definitions for ftpTask */
|
||
osThreadId_t ftpTaskHandle;
|
||
const osThreadAttr_t ftpTask_attributes = {
|
||
.name = "ftpTask",
|
||
.stack_size = 1024 * 4,
|
||
.priority = (osPriority_t) osPriorityNormal,
|
||
};
|
||
/* Definitions for testTask */
|
||
osThreadId_t testTaskHandle;
|
||
const osThreadAttr_t testTask_attributes = {
|
||
.name = "testTask",
|
||
.stack_size = 1024 * 4,
|
||
.priority = (osPriority_t) osPriorityBelowNormal,
|
||
};
|
||
/* Definitions for uiTask */
|
||
osThreadId_t uiTaskHandle;
|
||
const osThreadAttr_t uiTask_attributes = {
|
||
.name = "uiTask",
|
||
.stack_size = 4096 * 4,
|
||
.priority = (osPriority_t) osPriorityBelowNormal,
|
||
};
|
||
/* Definitions for netMsgQueue */
|
||
osMessageQueueId_t netMsgQueueHandle;
|
||
const osMessageQueueAttr_t netMsgQueue_attributes = {
|
||
.name = "netMsgQueue"
|
||
};
|
||
/* Definitions for sys_evt */
|
||
osEventFlagsId_t sys_evtHandle;
|
||
const osEventFlagsAttr_t sys_evt_attributes = {
|
||
.name = "sys_evt"
|
||
};
|
||
|
||
/* Private function prototypes -----------------------------------------------*/
|
||
/* USER CODE BEGIN FunctionPrototypes */
|
||
void ui_task_func(void *argument);
|
||
/* USER CODE END FunctionPrototypes */
|
||
|
||
void StartDefaultTask(void *argument);
|
||
void StartNetTask(void *argument);
|
||
void StartFtpTask(void *argument);
|
||
void start_test_task(void *argument);
|
||
void StartUiTask(void *argument);
|
||
|
||
void MX_FREERTOS_Init(void); /* (MISRA C 2004 rule 8.1) */
|
||
|
||
/**
|
||
* @brief FreeRTOS initialization
|
||
* @param None
|
||
* @retval None
|
||
*/
|
||
void MX_FREERTOS_Init(void) {
|
||
/* USER CODE BEGIN Init */
|
||
|
||
/* USER CODE END Init */
|
||
|
||
/* USER CODE BEGIN RTOS_MUTEX */
|
||
/* add mutexes, ... */
|
||
/* USER CODE END RTOS_MUTEX */
|
||
|
||
/* USER CODE BEGIN RTOS_SEMAPHORES */
|
||
/* add semaphores, ... */
|
||
/* USER CODE END RTOS_SEMAPHORES */
|
||
|
||
/* USER CODE BEGIN RTOS_TIMERS */
|
||
/* start timers, add new ones, ... */
|
||
/* USER CODE END RTOS_TIMERS */
|
||
|
||
/* Create the queue(s) */
|
||
/* creation of netMsgQueue */
|
||
netMsgQueueHandle = osMessageQueueNew (8, sizeof(net_msg_t), &netMsgQueue_attributes);
|
||
|
||
/* USER CODE BEGIN RTOS_QUEUES */
|
||
/* add queues, ... */
|
||
/* USER CODE END RTOS_QUEUES */
|
||
|
||
/* Create the thread(s) */
|
||
/* creation of defaultTask */
|
||
defaultTaskHandle = osThreadNew(StartDefaultTask, NULL, &defaultTask_attributes);
|
||
|
||
/* creation of netTask */
|
||
netTaskHandle = osThreadNew(StartNetTask, NULL, &netTask_attributes);
|
||
|
||
/* creation of ftpTask */
|
||
ftpTaskHandle = osThreadNew(StartFtpTask, NULL, &ftpTask_attributes);
|
||
|
||
/* creation of testTask */
|
||
testTaskHandle = osThreadNew(start_test_task, NULL, &testTask_attributes);
|
||
|
||
/* creation of uiTask */
|
||
uiTaskHandle = osThreadNew(StartUiTask, NULL, &uiTask_attributes);
|
||
|
||
/* USER CODE BEGIN RTOS_THREADS */
|
||
#ifdef ENABLE_NET_LAYER_TESTS
|
||
/* NET 层测试模式（阶段 6~10）：完整网络栈，netTask 负责轮询与消息处理 */
|
||
netTaskHandle = osThreadNew(StartNetTask, NULL, &netTask_attributes);
|
||
#endif
|
||
|
||
/* 本地时间同步任务（PC 推送 TCP）：依赖 netTask 处理消息队列 */
|
||
timeSyncTaskHandle = osThreadNew(time_sync_task, NULL, &timeSyncTask_attributes);
|
||
/* USER CODE END RTOS_THREADS */
|
||
|
||
/* Create the event(s) */
|
||
/* creation of sys_evt */
|
||
sys_evtHandle = osEventFlagsNew(&sys_evt_attributes);
|
||
|
||
/* USER CODE BEGIN RTOS_EVENTS */
|
||
/* add events, ... */
|
||
/* USER CODE END RTOS_EVENTS */
|
||
|
||
}
|
||
|
||
/* USER CODE BEGIN Header_StartDefaultTask */
|
||
/**
|
||
* @brief Function implementing the defaultTask thread.
|
||
* @param argument: Not used
|
||
* @retval None
|
||
*/
|
||
/* USER CODE END Header_StartDefaultTask */
|
||
void StartDefaultTask(void *argument)
|
||
{
|
||
/* USER CODE BEGIN StartDefaultTask */
|
||
(void)argument;
|
||
|
||
/* 系统启动期挂载 NAND 上的 FatFS 卷，供 FTP 及其它模块访问。
|
||
* f_mount(forced=1) 会触发 disk_initialize() → nand_ftl_init()
|
||
* （dhara_map_resume）。此前默认构建从未挂载，导致 FTP 的
|
||
* LIST/STOR/RETR 全部返回 550（f_opendir 失败）。
|
||
* 若卷为空（FR_NO_FILESYSTEM，如恢复/坏块重建后清空），则首次自动
|
||
* 格式化建卷（MKFS_PARM 与存储测试一致：FM_FAT32 / 无分区表）。 */
|
||
static FATFS default_fatfs;
|
||
FRESULT fr = f_mount(&default_fatfs, "", 1);
|
||
if (fr == FR_NO_FILESYSTEM) {
|
||
DBG_INFO("[FS] no FAT volume, formatting NAND...");
|
||
static uint8_t fs_work[FF_MAX_SS];
|
||
MKFS_PARM opts = { FM_FAT32, 0, 0, 0, 0 };
|
||
fr = f_mkfs("", &opts, fs_work, sizeof(fs_work));
|
||
if (fr == FR_OK) {
|
||
fr = f_mount(&default_fatfs, "", 1);
|
||
} else {
|
||
DBG_ERROR("[FS] f_mkfs failed (fr=%d)", (int)fr);
|
||
}
|
||
}
|
||
if (fr == FR_OK) {
|
||
DBG_INFO("[FS] FATFS mounted");
|
||
/* 广播"存储就绪"，唤醒依赖文件系统的任务 */
|
||
if (sys_evtHandle != NULL) {
|
||
osEventFlagsSet(sys_evtHandle, SYS_EVT_STORAGE_READY);
|
||
}
|
||
} else {
|
||
DBG_ERROR("[FS] f_mount failed (fr=%d)", (int)fr);
|
||
}
|
||
|
||
for (;;) {
|
||
HAL_GPIO_TogglePin(LED1_GPIO_Port, LED1_Pin);
|
||
HAL_GPIO_TogglePin(LED2_GPIO_Port, LED2_Pin);
|
||
HAL_GPIO_TogglePin(LED3_GPIO_Port, LED3_Pin);
|
||
osDelay(500);
|
||
}
|
||
/* USER CODE END StartDefaultTask */
|
||
}
|
||
|
||
/* USER CODE BEGIN Header_StartNetTask */
|
||
/**
|
||
* @brief Function implementing the netTask thread.
|
||
* @param argument: Not used
|
||
* @retval None
|
||
*/
|
||
/* USER CODE END Header_StartNetTask */
|
||
void StartNetTask(void *argument)
|
||
{
|
||
/* USER CODE BEGIN StartNetTask */
|
||
net_task_func(argument);
|
||
/* USER CODE END StartNetTask */
|
||
}
|
||
|
||
/* USER CODE BEGIN Header_StartFtpTask */
|
||
/**
|
||
* @brief Function implementing the ftpTask thread.
|
||
* @param argument: Not used
|
||
* @retval None
|
||
*/
|
||
/* USER CODE END Header_StartFtpTask */
|
||
__weak void StartFtpTask(void *argument)
|
||
{
|
||
/* USER CODE BEGIN StartFtpTask */
|
||
/* 等网络 + 存储都真正就绪后再 listen，取代拍脑袋的 7s 魔法延时 */
|
||
/*
|
||
sys_evtHandle：等待哪个事件组
|
||
SYS_EVT_NET_READY | SYS_EVT_STORAGE_READY：要等哪几位（1u<<0 网络、1u<<1 存储）
|
||
osFlagsWaitAll：请求的位全部置位才唤醒（即"网络且存储都就绪"）
|
||
osWaitForever：无限期等待，不设超时——任务会挂起（让出 CPU，零占用），直到生产者置位对应位才被唤醒
|
||
*/
|
||
if (sys_evtHandle != NULL) {
|
||
(void)osEventFlagsWait(sys_evtHandle,
|
||
SYS_EVT_NET_READY | SYS_EVT_STORAGE_READY,
|
||
osFlagsWaitAll, osWaitForever);
|
||
}
|
||
lftpd_t ftp;
|
||
lftpd_start("/", 21, &ftp);
|
||
/* 广播"FTP 服务就绪"（预留给依赖 FTP 的后续功能） */
|
||
if (sys_evtHandle != NULL) {
|
||
osEventFlagsSet(sys_evtHandle, SYS_EVT_FTP_READY);
|
||
}
|
||
/* USER CODE END StartFtpTask */
|
||
}
|
||
|
||
/* USER CODE BEGIN Header_start_test_task */
|
||
/**
|
||
* @brief Function implementing the testTask thread.
|
||
* @param argument: Not used
|
||
* @retval None
|
||
*/
|
||
/* USER CODE END Header_start_test_task */
|
||
__weak void start_test_task(void *argument)
|
||
{
|
||
/* USER CODE BEGIN start_test_task */
|
||
/* Infinite loop */
|
||
for(;;)
|
||
{
|
||
osDelay(1);
|
||
}
|
||
/* USER CODE END start_test_task */
|
||
}
|
||
|
||
/* USER CODE BEGIN Header_StartUiTask */
|
||
/**
|
||
* @brief Function implementing the uiTask thread.
|
||
* @param argument: Not used
|
||
* @retval None
|
||
*/
|
||
/* USER CODE END Header_StartUiTask */
|
||
void StartUiTask(void *argument)
|
||
{
|
||
/* USER CODE BEGIN StartUiTask */
|
||
ui_task_func(argument);
|
||
/* USER CODE END StartUiTask */
|
||
}
|
||
|
||
/* Private application code --------------------------------------------------*/
|
||
/* USER CODE BEGIN Application */
|
||
|
||
/* USER CODE END Application */
|