test(NET/lftpd): lftpd_inet 模块(28 条,127/127 = 100%)

FTP 的 socket 适配层吃满——全仓第一个 **100% 行覆盖**的文件(127/127)。
新增 test/host/lftpd_inet/,28 条断言全部 MSVC 编译通过并 PASS。

钉住的契约:
- 端口字节序:bind 前必须过 net_htons(sin_port 的注释就写着"网络字节序"),问名字
  回来要 ntohs 还原;问不到名字报 -1,不拿脏端口当结果。
- 失败路径一律关 socket:建口失败不 bind;bind 失败关口不 listen;listen 失败关口
  并各留一条 ERROR(漏关就是白占一个号,CH395F 只有 8 个)。
- accept 每轮失败都让出 CPU(同一段里也喂狗),直到成功;**网络代次一变立刻撤掉
  accept**——否则改了 IP 之后监听还挂在旧代次上,端口在新地址上根本不通。这是现场
  最常见的自愈路径,台架上要凑"对面正连着我顺手改 IP"极难。
- 带超时的 accept:监听门撤防时**立即放弃**,不对着死监听耗满窗口;对端一直不开
  数据通道就按 100ms 步进等满再 INFO 收场。
- read_line:CRLF 就地截成结束符(FTP 命令行的边界);跨包分片要能拼出整行;读到 0
  (对端关闭)立刻失败;-2 表示这一片超时继续等;其它负值**原样返回**(错误码不许被
  吞成 -1);等待按 200ms 分片、30 s 总预算到点退出(分片写错就饿死看门狗);缓冲
  填满仍无行尾要失败且**不越界写**(最后一格留给结束符)。
- 短写续传:net_send 可以只写一部分,续传必须从正确偏移接着写(少半条响应就是协议
  错乱);写 0 字节按失败处理;二进制写成功时回请求长度。

桩的口径:private/lftpd_inet.h 与 net_types.h 用真实头;net_socket.h 是桩但函数原型
与真实头逐字一致,并**照做真实头对 FreeRTOS.h / task.h 的 include**(lftpd_inet.c 的
TickType_t / vTaskDelay / pdMS_TO_TICKS 就是从那条链上拿的,桩少这一行就是 C2065)。
lftpd_task_wd_beat 是 __weak 空实现、主机侧替换不掉,因此用同段代码里的"睡 100ms"
次数当喂狗轮数的代理(写进桩注释,不假装能直接数到喂狗)。accept 循环带 100 轮跑飞
保险(net_select 批次被挂死教训换来的)。

覆盖率与台账:套件 25 → 26 全绿;files_tested 29 → 30;未触及 .c 37 → 36;分母
3,945 → 4,072 行;line=3599/4072(**88.4%**,连涨三批)、func=272/299(91.0%)。
恒等式 36 = 2(P1 剩:lftpd.c 与 iec104_serv.c) + 5(P2) + 29(P3) 仍咬合。编号补建
TC-HOST-LFTINET(游标 070),族数 19 → 20。

自查:test-cppcheck Passed;check_ids --strict 通过;doc-links 35 处(= 存量);
9 个新增/改动文件 BOM/CR/U+FFFD/行尾逐项净。零生产代码改动,未跑 @build。
--all-files 仍只有 mem-numbers / mem-budget(.map 台账漂移,等 Lead 合并后统一回填)
与 ui-golden(ref/*.bin 不入库,新 worktree 天生没有黄金参考)三条失败,与本分支无关。
This commit is contained in:
2026-10-23 22:58:48 +08:00
parent 59e6d77224
commit 8aaf9bbb0e
9 changed files with 657 additions and 17 deletions
@@ -222,9 +222,9 @@
|---|---|---|---|
| 配置与工具 4 块 | ✅ 完成 | `test/host/{net_cfg,ftp_cfg,prot_set_store,task_prof}`(104 条) |
`net_cfg.c` 108/112、`task_prof.c` 88/93、`ftp_cfg.c` 35/36、`prot_set_store.c` 27/29 |
| FTP 一套(4 块里 2 块) | 🟡 部分 | `test/host/lftpd_io`(33 条,含 `lftpd_string.c`) |
`lftpd_io.c` **85/159 = 53.5%**、`lftpd_string.c` 8/10;`read/write/close/stat/unlink/readdir`
未测(要先把假 `FIL/FILINFO` 的字段语义做实,否则断言落在假件自己写的规则上) |
| FTP 一套(4 块里 3 块) | ✅ 大部分 | `test/host/lftpd_io`(33 条)、`test/host/lftpd_inet`(28 条) |
`lftpd_inet.c` **127/127 = 100%**(全仓第一个满覆盖文件)、`lftpd_string.c` 8/10、
`lftpd_io.c` 85/159(`read/write/close/stat/unlink/readdir` 待假 `FIL/FILINFO` 字段语义) |
| NET 四块之一:`net_select.c` | ✅ 完成 | `test/host/net_select`(21 条) | `net_select.c` 97/114 = **85.1%** |
| `lftpd.c` / `lftpd_inet.c` | ⬜ 未开始 | — | 需假 `net_socket` 层(`time_sync`/stub 那份可扩展) |
| NET 三块之一:`net_listener.c` | ✅ 完成(**125/126 = 99.2%**) |
+22
View File
@@ -1812,6 +1812,28 @@
"subitem_ok": true,
"owner_note": "B 层口径(2026-10-21 批 3 定:这些号在代码目录外零消费者,属主登记处 = 单测代码本身,不逐号补文档);2026-10-23 随覆盖率口径 §9 假 CH395F 第三批补登记",
"cursor_note": "游标按实测最大号收录(2026-10-23):越界即视为未登记的冒号牌"
},
{
"name": "TC-HOST-LFTINET",
"class": "TC",
"title": "主机侧单测用例号:FTP 的 socket 适配层(test/host/lftpd_inet)",
"pattern": "\\bTC-LFTINET-[0-9]{1,4}[a-z]?\\b",
"digit_width": [
2,
4
],
"owner_docs_glob": [
"test/host/lftpd_inet/*"
],
"scope": "global",
"frozen": false,
"cursor": "TC-LFTINET-070",
"cursor_owner_only": true,
"check_dangling": true,
"allow_orphans": true,
"subitem_ok": true,
"owner_note": "B 层口径(2026-10-21 批 3 定:这些号在代码目录外零消费者,属主登记处 = 单测代码本身,不逐号补文档);2026-10-23 随覆盖率口径 §9 P1 FTP 批次补登记",
"cursor_note": "游标按实测最大号收录(2026-10-23):越界即视为未登记的冒号牌"
}
],
"unmanaged_bare": {
+26 -14
View File
@@ -168,6 +168,14 @@
"lines_covered": 37,
"lines_valid": 38
},
"Drivers/BSP/NET/lftpd/lftpd_inet.c": {
"func_rate": 1.0,
"funcs_covered": 9,
"funcs_valid": 9,
"line_rate": 1.0,
"lines_covered": 127,
"lines_valid": 127
},
"Drivers/BSP/NET/lftpd/lftpd_io.c": {
"func_rate": 0.3846,
"funcs_covered": 5,
@@ -294,6 +302,13 @@
"lines_total": 1193,
"ok": true
},
"lftpd_inet": {
"files": {
"Drivers/BSP/NET/lftpd/lftpd_inet.c": 127
},
"lines_total": 127,
"ok": true
},
"lftpd_io": {
"files": {
"Drivers/BSP/NET/lftpd/lftpd_io.c": 159,
@@ -453,6 +468,7 @@
"App/util/task_watchdog.c",
"Drivers/BSP/GD5F2GQ5UE/nand_ftl.c",
"Drivers/BSP/NET/lftpd/lftpd_auth.c",
"Drivers/BSP/NET/lftpd/lftpd_inet.c",
"Drivers/BSP/NET/lftpd/lftpd_io.c",
"Drivers/BSP/NET/lftpd/lftpd_string.c",
"Drivers/BSP/NET/net_events.c",
@@ -464,16 +480,16 @@
],
"totals": {
"files_generated_excluded": 5,
"files_tested": 29,
"files_untested": 115,
"func_rate": 0.9069,
"funcs_covered": 263,
"funcs_valid": 290,
"line_rate": 0.8801,
"lines_covered": 3472,
"lines_valid": 3945,
"modules_ok": 25,
"modules_total": 25
"files_tested": 30,
"files_untested": 114,
"func_rate": 0.9097,
"funcs_covered": 272,
"funcs_valid": 299,
"line_rate": 0.8838,
"lines_covered": 3599,
"lines_valid": 4072,
"modules_ok": 26,
"modules_total": 26
},
"untested_sources": [
{
@@ -540,10 +556,6 @@
"code_lines": 171,
"path": "App/task/adc_task.c"
},
{
"code_lines": 171,
"path": "Drivers/BSP/NET/lftpd/lftpd_inet.c"
},
{
"code_lines": 157,
"path": "Drivers/BSP/TPAFE5160/tpafe5160.c"
+456
View File
@@ -0,0 +1,456 @@
/*
* 模块名称:FTP 的 socket 适配层(lftpd_inet)主机侧单元测试
* 模块功能:在 PC 上离线验证 Drivers/BSP/NET/lftpd/lftpd_inet.c 的监听/接受/读写
* 适配:端口必须过 htons、回来的端口要 ntohs 还原;accept 循环每轮喂狗并
* 让出 CPU、**网络代次一变就立刻撤掉 accept**(否则新 IP 生效后监听还挂在
* 旧代次上);带超时的 accept 在监听门撤防时立即放弃;read_line 的 CRLF
* 截断、分片拼接、-2 继续等、其它负值原样返回、200ms 分片与 30 s 总预算;
* 短写续传(FTP 响应少半条就是协议错乱)。
*
* 被测对象:真实源文件 ../../../../Drivers/BSP/NET/lftpd/lftpd_inet.c(#include 纳入)。
* private/lftpd_inet.h 用真实头;net_types.h 用**真实头**(struct
* net_sockaddr_in 的 sin_port 注释就写着"网络字节序",htons/ntohs 的契约
* 靠它才钉得住)。假的是 socket 层本身:accept 序列、bind/listen 返回码、
* 代次变化点、监听门开关、recv 的返回序列 + 字节流、send 的短写序列,
* 外加可控 tick 与 vTaskDelay 计数(带跑飞保险)。
*
* 为什么要主机侧单测(而不是只靠台架):
* 1. 代次撤 accept 与"监听门撤防就放弃"这两条只在**异常时刻**成立(网络重建、
* 客户端连上控制口却迟迟不开数据通道)。台架上要凑"对面正连着我顺手改 IP"
* 这种时序极难,而真机上它是现场最常见的自愈路径。
* 2. 200ms 分片 + 30 s 总预算是 FTP 控制信道的等待结构:分片写错会把看门狗饿到
* 复位(每轮都要喂),预算写错会让 ftpTask 永久卡在一条命令上。两者都需要
* "按毫秒数着"才能验证。
* 3. 短写续传:net_send 可以只写一部分;如果适配层按一次写完处理,FTP 响应就会
* 少半条(客户端表现为协议错乱、卡住),而这种短写在真机上取决于当时缓冲余量。
* 4. lftpd_task_wd_beat 在本文件是 __weak 空实现(真机由 lftpd.c 覆盖),主机侧
* 替换不掉,所以用同一段里的"睡 100ms"次数当喂狗轮数的代理(已在桩里注明)。
*
* 覆盖点:TC-LFTINET-001..004 监听;005/006 端口还原;010..012 accept 与代次;
* 020..022 带超时 accept 与撤防;030..036 read_line;040..043 write_string;
* 050 write;060..062 read;070 close。
*
* 通过:全部 TC PASS(main 返回 0)。
* 入口:int main(void),返回 0=PASS / 1=FAIL(由 run 脚本判读)。
*
* 创建日期:2026-10-23
*/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "private/lftpd_inet.h"
#include "net_types.h"
#include "net_socket.h"
#include "lftpd_inet.c"
static int s_total;
static int s_passed;
static int s_failed;
#define CHECK(cond, name) do { \
s_total++; \
if (cond) { s_passed++; printf(" PASS %s\n", name); } \
else { s_failed++; printf(" FAIL %s (line %d)\n", name, __LINE__); } \
} while (0)
int g_lfi_info_count;
int g_lfi_error_count;
int g_lfi_debug_count;
/* ===================== 可控 socket 层 ===================== */
typedef struct {
int socket_rc;
int bind_rc;
int listen_rc;
int getsock_rc;
uint16_t getsock_port_net;
int accept_seq[16];
int accept_n;
int accept_i;
int accept_calls;
int gen;
int gen_flip_after;
int armed;
int recv_seq[24];
int recv_n;
int recv_i;
int recv_calls;
uint32_t last_recv_timeout;
char rx[512];
int rx_pos;
int send_seq[8];
int send_n;
int send_i;
int send_calls;
int send_off[8];
const char *send_base;
int socket_calls;
int bind_calls;
int listen_calls;
int close_calls;
int last_domain;
int last_type;
uint16_t last_bind_port_net;
int delay_calls;
TickType_t tick;
} lfi_net_t;
static lfi_net_t g_net;
static void net_reset(void)
{
(void)memset(&g_net, 0, sizeof(g_net));
g_net.socket_rc = 3;
g_net.bind_rc = 0;
g_net.listen_rc = 0;
g_net.getsock_rc = 0;
g_net.armed = 1;
g_net.gen = 7;
g_net.tick = 0u;
}
uint32_t net_get_generation(void) { return (uint32_t)g_net.gen; }
int net_listener_armed(int sockfd) { (void)sockfd; return g_net.armed; }
uint16_t net_htons(uint16_t hostshort)
{
return (uint16_t)((uint16_t)((hostshort & 0xFFU) << 8) | (uint16_t)(hostshort >> 8));
}
uint16_t net_ntohs(uint16_t netshort)
{
return net_htons(netshort);
}
int net_socket(int domain, int type)
{
g_net.socket_calls++;
g_net.last_domain = domain;
g_net.last_type = type;
return g_net.socket_rc;
}
int net_bind(int sockfd, const struct net_sockaddr *addr, int addrlen)
{
const struct net_sockaddr_in *a = (const struct net_sockaddr_in *)addr;
(void)sockfd;
(void)addrlen;
g_net.bind_calls++;
g_net.last_bind_port_net = a->sin_port;
return g_net.bind_rc;
}
int net_listen(int sockfd)
{
(void)sockfd;
g_net.listen_calls++;
return g_net.listen_rc;
}
int net_close(int sockfd)
{
(void)sockfd;
g_net.close_calls++;
return 0;
}
int net_accept(int sockfd, struct net_sockaddr *addr, int *addrlen)
{
int r;
(void)sockfd;
(void)addr;
(void)addrlen;
g_net.accept_calls++;
if ((g_net.gen_flip_after > 0) && (g_net.accept_calls >= g_net.gen_flip_after)) {
g_net.gen++; /* 模拟网络在这期间重建(代次 +1) */
}
if (g_net.accept_i < g_net.accept_n) {
r = g_net.accept_seq[g_net.accept_i++];
} else {
r = (g_net.accept_n > 0) ? g_net.accept_seq[g_net.accept_n - 1] : -1;
}
return r;
}
int net_getsockname(int sockfd, struct net_sockaddr *addr, int *addrlen)
{
struct net_sockaddr_in *a = (struct net_sockaddr_in *)addr;
(void)sockfd;
(void)addrlen;
a->sin_port = g_net.getsock_port_net;
return g_net.getsock_rc;
}
int net_recv_to(int sockfd, void *buf, int len, uint32_t timeout_ms)
{
int r;
int i;
(void)sockfd;
g_net.recv_calls++;
g_net.last_recv_timeout = timeout_ms;
/* 每次调用当作耗掉一个 200ms 片:让 30 s 总预算的到点路径可测 */
g_net.tick += 200u;
if (g_net.recv_i < g_net.recv_n) {
r = g_net.recv_seq[g_net.recv_i++];
} else {
r = (g_net.recv_n > 0) ? g_net.recv_seq[g_net.recv_n - 1] : -2;
}
if (r > 0) {
for (i = 0; (i < r) && (i < len) && (g_net.rx_pos < (int)sizeof(g_net.rx)); i++) {
((char *)buf)[i] = g_net.rx[g_net.rx_pos++];
}
}
return r;
}
int net_send(int sockfd, const void *buf, int len, int flags)
{
int r;
(void)sockfd;
(void)flags;
if (g_net.send_base == NULL) {
g_net.send_base = (const char *)buf;
}
g_net.send_calls++;
if (g_net.send_i < 8) {
g_net.send_off[g_net.send_i] = (int)((const char *)buf - g_net.send_base);
}
if (g_net.send_i < g_net.send_n) {
r = g_net.send_seq[g_net.send_i++];
} else {
r = (g_net.send_n > 0) ? g_net.send_seq[g_net.send_n - 1] : len;
}
return r;
}
TickType_t xTaskGetTickCount(void) { return g_net.tick; }
void vTaskDelay(TickType_t xTicksToDelay)
{
(void)xTicksToDelay;
g_net.delay_calls++;
if (g_net.delay_calls > 100) {
/* 跑飞保险:本模块每条用例都必须在有限轮内退出(accept 序列要么成功、
* 要么撤防、要么代次变化)。真跑飞就退出,绝不把挂死留给 pre-commit。 */
printf(" ABORT accept/等待循环跑飞(>100 轮未退出)\n");
fflush(stdout);
exit(2);
}
}
static void logs_clear(void)
{
g_lfi_info_count = 0;
g_lfi_error_count = 0;
g_lfi_debug_count = 0;
}
/* ===================== 监听与端口还原 ===================== */
static void tc_listen(void)
{
printf("-- TC-LFTINET-001..006 listen / port --\n");
net_reset(); logs_clear();
g_net.socket_rc = -1;
CHECK((lftpd_inet_listen(21) == -1) && (g_net.bind_calls == 0) &&
(g_lfi_error_count == 1), "TC-LFTINET-001 建 socket 失败即返回,不再 bind");
net_reset(); logs_clear();
g_net.bind_rc = -1;
CHECK((lftpd_inet_listen(21) == -1) && (g_net.close_calls == 1) &&
(g_net.listen_calls == 0), "TC-LFTINET-002 bind 失败要把 socket 关掉");
net_reset(); logs_clear();
g_net.listen_rc = -1;
CHECK((lftpd_inet_listen(21) == -1) && (g_net.close_calls == 1) &&
(g_lfi_error_count == 1), "TC-LFTINET-003 listen 失败同样关socket 并留痕");
net_reset(); logs_clear();
CHECK((lftpd_inet_listen(21) == 3) && (g_net.last_domain == NET_AF_INET) &&
(g_net.last_type == NET_SOCK_STREAM) &&
(g_net.last_bind_port_net == net_htons(21u)) && (g_net.listen_calls == 1),
"TC-LFTINET-004 流式监听口,且**端口过了 htons**(sin_port 是网络序)");
net_reset(); logs_clear();
g_net.getsock_rc = -1;
CHECK((lftpd_inet_get_socket_port(3) == -1) && (g_lfi_error_count == 1),
"TC-LFTINET-005 问不到名字就报 -1(不拿脏端口当结果)");
net_reset(); logs_clear();
g_net.getsock_port_net = net_htons(8888u);
CHECK(lftpd_inet_get_socket_port(3) == 8888,
"TC-LFTINET-006 端口回来要 ntohs 还原成宿主序");
}
/* ===================== accept:喂狗、代次、撤防 ===================== */
static void tc_accept(void)
{
printf("-- TC-LFTINET-010..012 / 020..022 accept --\n");
net_reset(); logs_clear();
g_net.accept_seq[0] = 9; g_net.accept_n = 1;
CHECK((lftpd_inet_accept(3) == 9) && (g_net.delay_calls == 0),
"TC-LFTINET-010 一击即中不睡不等");
net_reset(); logs_clear();
g_net.accept_seq[0] = -1; g_net.accept_seq[1] = -1; g_net.accept_seq[2] = 9;
g_net.accept_n = 3;
CHECK((lftpd_inet_accept(3) == 9) && (g_net.delay_calls == 2) &&
(g_lfi_info_count == 0),
"TC-LFTINET-011 每轮失败都让出一次 CPU(同段代码里也喂狗),直到成功");
net_reset(); logs_clear();
g_net.accept_seq[0] = -1; g_net.accept_seq[1] = -1; g_net.accept_seq[2] = -1;
g_net.accept_n = 3;
g_net.gen_flip_after = 3; /* 第 3 轮时网络重建 */
CHECK((lftpd_inet_accept(3) == -1) && (g_lfi_info_count == 1) &&
(g_net.accept_calls == 3),
"TC-LFTINET-012 **代次一变立刻撤掉 accept**(否则新 IP 生效后监听还挂在旧代次)");
net_reset(); logs_clear();
g_net.accept_seq[0] = -1; g_net.accept_seq[1] = 9; g_net.accept_n = 2;
CHECK((lftpd_inet_accept_timeout(3, 5000) == 9) && (g_net.delay_calls == 1),
"TC-LFTINET-020 超时窗内等到数据通道");
net_reset(); logs_clear();
g_net.accept_seq[0] = -1; g_net.accept_seq[1] = -1; g_net.accept_n = 2;
g_net.armed = 0; /* 监听门被撤(会话已放弃) */
CHECK((lftpd_inet_accept_timeout(3, 5000) == -1) && (g_net.accept_calls == 1) &&
(g_lfi_error_count == 1),
"TC-LFTINET-021 监听门撤防立即放弃,不对着死监听耗满 5 s");
net_reset(); logs_clear();
g_net.accept_seq[0] = -1; g_net.accept_n = 1;
CHECK((lftpd_inet_accept_timeout(3, 300) == -1) && (g_net.delay_calls == 3) &&
(g_lfi_info_count == 1),
"TC-LFTINET-022 对端一直不开数据通道:按 100ms 步进等满后 INFO 收场");
}
/* ===================== read_line:分片、截断、预算 ===================== */
static void tc_read_line(void)
{
char b[32];
int rc;
printf("-- TC-LFTINET-030..036 read_line --\n");
net_reset(); logs_clear();
(void)strcpy(g_net.rx, "USER admin\r\n");
g_net.recv_seq[0] = 12; g_net.recv_n = 1;
rc = lftpd_inet_read_line(3, b, sizeof(b));
CHECK((rc == 0) && (strcmp(b, "USER admin") == 0),
"TC-LFTINET-030 一次到位:CRLF 就地截成结束符(FTP 命令行的边界)");
net_reset(); logs_clear();
(void)strcpy(g_net.rx, "USER admin\r\n");
g_net.recv_seq[0] = 4; g_net.recv_seq[1] = 8; g_net.recv_n = 2;
rc = lftpd_inet_read_line(3, b, sizeof(b));
CHECK((rc == 0) && (strcmp(b, "USER admin") == 0),
"TC-LFTINET-031 分两片到达也要拼出整行(跨包命令行)");
net_reset(); logs_clear();
g_net.recv_seq[0] = 0; g_net.recv_n = 1;
CHECK(lftpd_inet_read_line(3, b, sizeof(b)) == -1,
"TC-LFTINET-032 读到 0(对端关闭)立刻失败,不进死循环");
net_reset(); logs_clear();
(void)strcpy(g_net.rx, "NOOP\r\n");
g_net.recv_seq[0] = -2; g_net.recv_seq[1] = 6; g_net.recv_n = 2;
rc = lftpd_inet_read_line(3, b, sizeof(b));
CHECK((rc == 0) && (strcmp(b, "NOOP") == 0),
"TC-LFTINET-033 -2 表示这一片超时,继续等而不是当错误");
net_reset(); logs_clear();
g_net.recv_seq[0] = -5; g_net.recv_n = 1;
CHECK(lftpd_inet_read_line(3, b, sizeof(b)) == -5,
"TC-LFTINET-034 其它负值**原样返回**(错误码不许被吞成 -1)");
net_reset(); logs_clear();
g_net.recv_seq[0] = -2; g_net.recv_n = 1; /* 一直超时,每轮耗 200ms */
rc = lftpd_inet_read_line(3, b, sizeof(b));
CHECK((rc == -1) && (g_net.recv_calls == 150) &&
(g_net.last_recv_timeout <= 200u),
"TC-LFTINET-035 30 s 总预算按 200ms 分片累加,到点退出(饿不到看门狗)");
net_reset(); logs_clear();
(void)memset(g_net.rx, 'A', 40); /* 没有 CRLF 的长行 */
g_net.recv_seq[0] = 7; g_net.recv_n = 1;
(void)memset(b, 0, sizeof(b));
rc = lftpd_inet_read_line(3, b, 8);
CHECK((rc == -1) && (b[7] == '\0'),
"TC-LFTINET-036 缓冲填满仍无行尾:失败且**不越界写**(留最后一格给结束符)");
}
/* ===================== 写与读 ===================== */
static void tc_write_read(void)
{
char b[16];
const char msg[] = "220 ready\r\n";
printf("-- TC-LFTINET-040..070 write / read / close --\n");
net_reset(); logs_clear();
g_net.send_seq[0] = 12; g_net.send_n = 1;
CHECK((lftpd_inet_write_string(3, msg) == 0) && (g_net.send_calls == 1),
"TC-LFTINET-040 一次写完");
net_reset(); logs_clear();
g_net.send_seq[0] = 5; g_net.send_seq[1] = 7; g_net.send_n = 2;
CHECK((lftpd_inet_write_string(3, msg) == 0) && (g_net.send_calls == 2) &&
(g_net.send_off[1] == 5),
"TC-LFTINET-041 短写后续传从**正确的偏移**接着写(少半条响应就是协议错乱)");
net_reset(); logs_clear();
g_net.send_seq[0] = 0; g_net.send_n = 1;
CHECK((lftpd_inet_write_string(3, msg) == -1) && (g_lfi_error_count == 1),
"TC-LFTINET-042 写 0 字节按失败处理(不是当成成功写了 0 字节)");
net_reset(); logs_clear();
g_net.send_seq[0] = -1; g_net.send_n = 1;
CHECK(lftpd_inet_write(3, msg, 12) == -1, "TC-LFTINET-043 写失败原样回 -1");
net_reset(); logs_clear();
g_net.send_seq[0] = 4; g_net.send_seq[1] = 6; g_net.send_n = 2;
CHECK((lftpd_inet_write(3, msg, 10) == 10) && (g_net.send_calls == 2),
"TC-LFTINET-050 二进制写也走短写续传,成功时回**请求长度**");
net_reset(); logs_clear();
(void)strcpy(g_net.rx, "STOR\r\n");
g_net.recv_seq[0] = 4; g_net.recv_n = 1;
CHECK(lftpd_inet_read(3, b, sizeof(b)) == 4, "TC-LFTINET-060 读到数据立刻交还");
net_reset(); logs_clear();
g_net.recv_seq[0] = -1; g_net.recv_n = 1;
CHECK(lftpd_inet_read(3, b, sizeof(b)) == -1, "TC-LFTINET-061 -1 直接失败返回");
net_reset(); logs_clear();
g_net.recv_seq[0] = -3; g_net.recv_n = 1;
CHECK((lftpd_inet_read(3, b, sizeof(b)) == -1) && (g_net.recv_calls > 1),
"TC-LFTINET-062 其它负值继续等,直到 30 s 预算耗尽");
net_reset(); logs_clear();
CHECK((lftpd_inet_close(3) == 0) && (g_net.close_calls == 1),
"TC-LFTINET-070 close 就是转 net_close");
}
int main(void)
{
printf("=== LFTPD INET Tests ===\n");
tc_listen();
tc_accept();
tc_read_line();
tc_write_read();
printf("\n=== LFTPD INET Tests: %d/%d PASSED (failed=%d) ===\n",
s_passed, s_total, s_failed);
return (s_failed == 0) ? 0 : 1;
}
+56
View File
@@ -0,0 +1,56 @@
#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""FTP socket 适配层(lftpd_inet)主机侧单元测试运行器(L0.5,纯标准库)。
做什么:
用本机 MSVC 编译 test/host/lftpd_inet/lftpd_inet_test.c(以 #include 纳入生产源
Drivers/BSP/NET/lftpd/lftpd_inet.c),离线验证监听/接受/读写适配:端口过 htons、
accept 每轮喂狗让出、网络代次一变就撤 accept、监听门撤防立即放弃、read_line 的
CRLF 截断与分片拼接与 200ms 分片 + 30s 总预算、错误码原样返回、短写续传。
为什么要主机侧单测(而不是只用台架):
代次撤 accept 与撤防放弃只在异常时刻成立(网络重建、客户端连上控制口却不开数据
通道),台架极难复现而真机上是常见自愈路径;200ms 分片写错会饿死看门狗、30s 预算
写错会让 ftpTask 永久卡在一条命令上;短写没续传就是"FTP 响应少半条"。这些都要
按毫秒与字节数着测。
桩的边界:private/lftpd_inet.h 与 net_types.h 用真实头(struct net_sockaddr_in 的
sin_port 注释就写着"网络字节序",htons/ntohs 契约靠它钉住);net_socket.h 是桩,
函数原型与真实头逐字一致;FreeRTOS.h / task.h 给宿主 tick 与 vTaskDelay(带跑飞
保险)。lftpd_task_wd_beat 是 __weak 空实现、主机侧替换不掉,故用同段代码里的
"睡 100ms"次数当喂狗轮数的代理。
用法(仓库根目录):
python test/host/lftpd_inet/run_unit_test.py
退出码:0=PASS / 1=测试失败 / 2=环境错误。
设计依据:docs/子系统设计/网络配置说明.md §3.4、docs/测试说明/FTP_Test_Guide.md、
docs/测试说明/主机单测覆盖率口径.md §9
创建日期:2026-10-23
"""
import os
import sys
HERE = os.path.dirname(os.path.abspath(__file__))
ROOT = os.path.dirname(os.path.dirname(os.path.dirname(HERE)))
sys.path.insert(0, os.path.join(ROOT, "test", "host", "common"))
from unit_test_harness import TestBuild, run_host_unit_test # noqa: E402
BUILD = TestBuild(
name="LFTPD INET Tests",
src=os.path.join(HERE, "lftpd_inet_test.c"),
include_dirs=[
os.path.join(HERE, "stub"),
os.path.join(ROOT, "Drivers", "BSP", "NET", "lftpd"),
os.path.join(ROOT, "Drivers", "BSP", "NET"),
HERE,
],
extra_flags=["/D_CRT_SECURE_NO_WARNINGS"],
summary_marker="=== LFTPD INET Tests:",
)
if __name__ == "__main__":
sys.exit(run_host_unit_test(BUILD))
+21
View File
@@ -0,0 +1,21 @@
/*
* 模块名称:主机侧单测桩 - FreeRTOS.h(lftpd_inet 模块专用)
* 模块功能:宿主等价类型与 tick 换算。本仓 tick = 1ms,故 pdMS_TO_TICKS 就是原值——
* 这不是偷懒:写成本机换算,测试里的 30000ms 预算与 200ms 分片才可直接读。
* ⚠ 仅供主机侧单测使用,不参与 MCU 构建。
* 创建日期:2026-10-23
*/
#ifndef FREERTOS_H
#define FREERTOS_H
#include <stddef.h>
#include <stdint.h>
typedef uint32_t TickType_t;
typedef long BaseType_t;
typedef unsigned long UBaseType_t;
typedef void *TaskHandle_t;
#define pdMS_TO_TICKS(ms) ((TickType_t)(ms))
#endif /* FREERTOS_H */
+19
View File
@@ -0,0 +1,19 @@
/*
* 模块名称:主机侧单测桩 - dbg_log.h(lftpd_inet 模块专用)
* 模块功能:DBG_* 换成计数,让"建 socket/bind/listen 失败各留一条 ERROR""对端不开
* 数据通道时只 INFO"这些通道可断言。
* ⚠ 仅供主机侧单测使用,不参与 MCU 构建。
* 创建日期:2026-10-23
*/
#ifndef DBG_LOG_H
#define DBG_LOG_H
extern int g_lfi_info_count;
extern int g_lfi_error_count;
extern int g_lfi_debug_count;
#define DBG_INFO(fmt, ...) do { (void)(fmt); g_lfi_info_count++; } while (0)
#define DBG_DEBUG(fmt, ...) do { (void)(fmt); g_lfi_debug_count++; } while (0)
#define DBG_ERROR(fmt, ...) do { (void)(fmt); g_lfi_error_count++; } while (0)
#endif /* DBG_LOG_H */
+34
View File
@@ -0,0 +1,34 @@
/*
* 模块名称:主机侧单测桩 - net_socket.h(lftpd_inet 模块专用)
* 模块功能:给 FTP 的 inet 适配层一个可控的 socket 面。地址结构与 NET_AF_INET /
* NET_SOCK_STREAM 一律取**真实** net_types.h(sin_port 的注释就写着
* "网络字节序",本模块的 htons/ntohs 契约靠它才钉得住);下面这些函数
* 原型与真实 net_socket.h 逐字一致(不一致就会在被测代码的调用点报错)。
* ⚠ 仅供主机侧单测使用,不参与 MCU 构建。真实 net_socket.h 带整条 netTask 消息队列
* 与芯片依赖,PC 上编不动。
* 创建日期:2026-10-23
*/
#ifndef NET_SOCKET_H
#define NET_SOCKET_H
/* 真实 net_socket.h 会把 FreeRTOS.h / task.h 一起带给调用方,
* lftpd_inet.c 正是靠那条链拿 TickType_t / vTaskDelay / pdMS_TO_TICKS,
* 所以桩必须照做同样的 include(少一行就是 C2065 未声明)。 */
#include "FreeRTOS.h"
#include "task.h"
#include "net_types.h"
int net_socket(int domain, int type);
int net_bind(int sockfd, const struct net_sockaddr *addr, int addrlen);
int net_listen(int sockfd);
int net_close(int sockfd);
int net_accept(int sockfd, struct net_sockaddr *addr, int *addrlen);
int net_send(int sockfd, const void *buf, int len, int flags);
int net_recv_to(int sockfd, void *buf, int len, uint32_t timeout_ms);
int net_getsockname(int sockfd, struct net_sockaddr *addr, int *addrlen);
uint16_t net_htons(uint16_t hostshort);
uint16_t net_ntohs(uint16_t netshort);
uint32_t net_get_generation(void);
int net_listener_armed(int sockfd);
#endif /* NET_SOCKET_H */
+20
View File
@@ -0,0 +1,20 @@
/*
* 模块名称:主机侧单测桩 - task.h(lftpd_inet 模块专用)
* 模块功能:只声明两个时间入口:xTaskGetTickCount(read_line / read 的 30 s 总预算
* 时基)与 vTaskDelay(accept 轮的让出点,兼作"这一轮真的等了"的证据)。
* ⚠ 仅供主机侧单测使用,不参与 MCU 构建。
* 为什么用 vTaskDelay 计数而不是直接数喂狗:lftpd_task_wd_beat 在本文件里是
* __weak 空实现(真机由 lftpd.c 覆盖成真实喂狗),ARMCC 的 weak 在 MSVC 下走的是
* 普通定义那条支路,主机侧**替换不掉**它。而每轮 accept 失败后"喂狗 + 睡 100ms"
* 是同一段代码里的相邻两句,所以睡的次数就是喂狗轮数的可靠代理。
* 创建日期:2026-10-23
*/
#ifndef TASK_H
#define TASK_H
#include "FreeRTOS.h"
TickType_t xTaskGetTickCount(void);
void vTaskDelay(TickType_t xTicksToDelay);
#endif /* TASK_H */