wN2ld9N%E&8Z8|sS9N<4`(l*neM|j=P7Of+{Y46CHBD|(BOX<
zS>P)T%_%yU_VZ8gg&!$|jOAftxo9lEf{QfkvN0=U%n2KFL}LzJVwJHaRw+6$gpA9=
z#$}>$*|5=aQrkE8c;d;#VB+z_&lMwP`^kzEJ1zF|f&BBO&lHG`aw&w26=7qAXsjUr
z+2V37?O!>t;mm5$u@u4ulk^+!1)qC?OzEA`BB_?UDO?4?r3AvYS3QS3>!aCk}
zSLy0!$v-H>%0HN;4K$clA1p{}NKk#K#=;*aC?MrSbCn$;;w%ojB^Kvw9V6T(-Iz9kR=FImG8{5U)sTw90;AR6xovtO`i^
zg+qq;++=Q(X7KsSO?tMR$kvu~qgqnE*0ZPvh(Z};l-uM%JOz_@fG@m)z6
z5!RBY)|Rq%QuV=-^k=w;tYprXdLaqQLxd|XiLg66Q37&<4S>vEH-`%|q;*{}D3vGH
zH99*XhZYvP0E-vI)Vm2=pU3^0AqDkVdTadytdIPzK1U&}gKU!6uo+T!H$1^s5ZU^l
zv3Vr4z#O;@vLakthp+_^74kT5tB>+mVH?)E0|Cl%LJI=QUbiDgd2A74O$aEr-HBK$
zf@TEBd<7ItBFQyU#lUnodUthodigqPV95SE$n_)$$OVNx2=*b^kAQMmcCT=NJhZ{C
z0%p9Yt9>7NWdg@a8Sjrh?H+)-hyfUHp$
zR$Pf-8Ts)Y)s^@Ok8tjM;SeBQs6k5~3B*KUITl-i=|%vOSSRIzVCfcCLLyn&oD--A
z#FI=d7Xq3tg!KR-+Qx>OHO;jvHdd_@HezZcf=vjJ=E7zKNc1VRj;K+L*(Dr2FfPhO
zlqkUX4hl#uYOs*#OKH9y3G7iyB;17sC<&2zLK}hu06LWbBxxini*)gmWswt5ARk2Y
z&ZFe~fDJ^EoWa98e$J7D_iMNh)TAou#lbIHOE`8mDcMz`1pS`vH=tG}3dl{q
zDo+dgwkE1?gTBruP^DVsi|c%#=)?QORGgBQK1m;^wStbX;LW@PRP7gO9D8xpey*M}M!#gJrj%9k^o@9?mLvsV~iq=l<
zOtQs@rA-GdR;rXdvBysS`fqyD<9FnO-G|+->Q+xwEq!^h24UnG@ScT$HclScy;6oa
z=AFwBk_hv@I_eOlhvC`D)k=3pL(w^n|^)WR$&)luQM^E)+icK(s
zOq@G;(Q>_+RE^>DzL0fsWP@0w6GW?4H?(QEQQC@Rm2c-pm^zn
zLOG103k|Nf)vkBfweC3>)wsIwgRb8L7HD@>nOoAe+%+rbE}p;KJ#zlVYd`)TdFkM4
zJ?>Nj?qN4s4@v0A4Acv?m_)e^t}&^K>M}Rg9I=5bICEi8(4`oL?Fl`DKqYMnKzjQP880ZcPy5hmseGxei
z`dNhYm4K4zZQ&0~%t+qC^Fo9>xDU2iU<}k;A7PuJ953y%2B=NiWutJyW;>BpJqhK&
zXvTEPsN$z}h2-gBdAcZ1CqEPBxocU4bwq6xP3u6eT?#)^2&wDC>UvRKKj`SxumSV1
z-YO0KNS`#ugB{jzOnX%OpuSh%L;uEFXj6?3ENpQ)KCAlx-_=;fluqC}eVSw#Vz`u}XcGxmoq+!I8Cb}y7TL6gp
zuFCVZ7t9wjFPOi-3KLwFA&8@!wFJ~UvZKo$DC*A;9YsZl
zV$oPUWV8kqK?SHOhGa=iF_?N+2Yn&EGpu)tGypMz>3x~Obo>jcGs5Z&QJpa($tnis
zJy#~0Dx?rnSBBMb@ODQFmq8Qo!{TcqLh;Q(qMpdJ`z
zjRUI67xZlaEx1v%7f2zl_=D~bVc6^hJ<*Un4u*~PzT&=?e)h3e_$}_=fG}kAgpD52
z=!t#@{1!n)RB^;FLMnDD8%0ZYNSzZ_=ZG|b;$lIK1qc}fptb~y`!)oNgP`I>KM;JQ
ziGfxsgBJi9Q<63P*@2(I8hj(SDr0>j^QOA0q_&KCYY_*Lx5^Uh^s=`#h`+645!WvT
z{AcM^Y4Gz-c~!xx0`A>B8ARSK$Xsny{9KRt&l6e1jnz7cTyj<|sP}LmBw;NdSS*O=
zvxs|g8kQs
zsLpcwJJ%oh9&Gd+7Nmi#TSmhB*`@6BQ#CGGdFNeW=zy$GnNn*zqV(1NtUxGYO|
z<#B;_D;A~u@$HDwjd}-SR8gQB1l@MGV;WTy;`_EoJ3)@6`T&Zs5v>=vO|xXIJBn|C
zbi0BP9>P31p1?`l?@UHF3mV<%>k}<+&%&Ee;s(4(MsT;bY+p_N0Z4XM+=l4nD#VDe`r?VQAEFk;4FZ8;k$?qAec@wOpU7t5?}iY
zdI1tIA_KFiumdZgtPUv{kpVB-El~bP85#Wsw;<*-_&U-Klsu|5byA)tsR&3&;d=4MqW9#K_-V&L}M@?
z6$W{~91jGIes-@S_A=l~@|&Qe!iSPk^x2f%)=vKf#x>;$
z@k&3#tDcaIX{C_YLZeU
z^BZuu2EPJe0vyZTXSD>{7foxauv_a(A8$KKr9{6LMc%2p2d_Z7#7d919P1&-u(YQW
zdMNLY>oN@4-=rh%ADdKqD$mMEOH(qr_hlowV??vV*oD@Lkw+dHIr@ZT`F5j`+AucL7q3u*G)XWXWfb
z&kj_Fy#w}
z9V)xWz;!jZ(9|R^0q?(DQ~CC5MPwMJb|Y$T7d*Qr
z=CUgC#8anPB|Y(nLws4HUlqeuM!ypNROJ4r^9(B9614-Ed}(C3#;N2}8W~?Y`CE;X
z{ORc;V0Ss+*{1a3WL`(A&Mwb{i3+?7*Z4D>a3}mkSYe8#@n64_#cm{~v$MgZ2(P4}
zv?0AByb93V;ZJoMdV0i&e#wP5BB1h{q9UXX{r|1Ny8=oXzwBlQ6R{&nwbs(a=vt@smS8|!63*7@&HO$qucO7Vs
z@xPZaMdjP0!WG^r>?6$sc^+hEu>~w?Z#p=s1OF?@$ao2|7vf4z0W+DGAph0dFH>c4rh~wGgl@SF!poU|}mX3(5
zt=$LX>)7As^RRSpo9LjWZ*J>o_8n}dF9;E+16*RRKRb&x4_cr5HOu~rd~)uz(*o&{
z#O9q{ZTtCVeh)}N9s7L3r;vI#M+TlByoC=EV}WIG$KcT)_H!iovV!bvvXbxnjauqO
zg!ZT`@&qeiFFVxK??*}fX|hSlh}Vq59eyooS)E-AXzFy^7w_yg_zk|&Xg}d+Z+sMdnh)i#=)}IiU@?Sqq
zv>JS?#?yJXU+dQanP2}&D!YV0KV5#qSy+6};sT^kcLJXQTXTAMBFwlP6j7D_1b?D$
zEeXDv&K8kBzUw4=U$d7_^JU_*yNx~+>7&nd^ESBc{khwOQ<(}-)7MaYd=0U^B{Qs+
z^|87cM%u)Ktnix|)kNP
zJik>1Uu~Y>s)nyN&u>-3vT=&vVxD6S|M%wk)Y@mB=awn+JjrjKJkKpt=DBtHJh#T?
zdE!K)e4d{}Q6eyD0!{OQ<2~I*7EUPIe?4VeNBIHLg>TO=QD@$?XWnm7fq>m+>O}ni
z8!mk2|7SN`I3S8Ye1YG@t8x2BK20j#$?+7#GNVqHn`3d9D20*lxC;gVsy@$pA~I%L*|mCBcWruIRJ3
znEY+EgY5s*Kmr$P6)FA{>I`iycTeVkaNQxh+ct@ZOyM%Xm|mkCB!#jjt9>rm5R!Ls
zll2d9S583=6X54fZXhPH!AhJP)dF%St?K!3{N?AC4)Ufu^2eoDL
zpc#_pO(FXC%qj8DqiA%Mh;(T;zpN$JQxv})tju?-9kk9>Zj=cE+I%53$2Zgpid=d47h^)H0I>J>~AK@}q2`9
z50|pFMELOb|GC0na>Oj6!c`;AXE%|%#ce60K`;ol?f4_Z+)!cvzSn#Gh5Ot$$X%gq
z+YJ;l@#v3gAK%0d`~!d+^LoJ#pA&(nmA_iKtc2#3d0~Dru9knM%WP7}KM@a84%DD(b
z-up$~l3&4#k%Wfzo0`|wRW;T%Z(6mkE~3JCU41Q8cBqLo+IY>{Rdw~7q{g?AqOfzx
z-(kZZ1X~d7M9>N#Vwvc$0_Ioht^zeTQp95yyu=qSD}EebSd8FX_?8;3{xtgzcX)*>
znD#qNQypk&Z3Y!m_?RL89Ol9CXZJ%wG5vBNTwWY`OT+n;O)w?T}8}0#vFhb^()ozBU%fa-CT%a
z0S~b&Wa80Sq{QkaFEyo*9lP`#
zjJkAta#H)kNp@qi4}0l!@RsSDD5xA9upHP9mAn()T)
zD!59MVuy<^X!f4QtiV!539T*#qNT!$Ozs;P+43OC7uV~c
z$JSWyCti2(6(bu`r293ziafr@F?En?1?a7l}`3sT7xhR!k*FD%6ft;MedS1Y8CHY?!C?%Du#;6CVv1GlVT+J$jFagyL#f>$n#H)96$QWE4}M$+}EBsJ`#Km{12}^
zavqsMIn>&PbiPH^T?qjwAia6**%wBRJq4Z{IB}p&bY78Kf!gTxkI5b@6Z-=Um0m%Z
z*ekeoA$$f^QANk5NVn}{_Q9r+Wfq|(nun0H+%Oy`5$|7Z$C=USKBq$K4oEx?W
zMgZ?IrVAy2=!m03#g0g~A%Hxkb4ogaFu))1j3J_t>~3LHM7UrsNWM8xA}$&J}Tz
zkF&-pY)W!-IgUjrCv##y(-0s}iyo#%3@z>LaL=LD+l+T8q*IJI&!X1Fh#K7iX>KvT
zJ#RKb>JB*dED-9A4vSu4SO5jHVBhY1m>#5VhD)J^VR@k_FC3QZd$xq+$zgf2C{Mm(
zv7M~HcO4{(hVs4x0HhF-SA^viqP&9URE6Z#VR^MEucp!Zkh~!*ZxH1Tr2JQvfmL5$
z)pNM7NKD8N$vt7YN0fVp4?nC+=lv?Xmhg~%MOeQ=)UTk$3i}1oRtO=apB2{6
z5@{Ggmz~OUjpr@TY<+Gkpi&6wmxcAqMEx>!+gUc&xAY4zq+S2(qqP@1QzkcEX3!q>x!65b6x8!viD6K;P0DR#4R$!i<0YQgMYpf
zl!K^#bi}nB?S}NK)WnlRk4oA#Iv|rC7q-Doc}DmeMB5mUAB6wF43x4ZcZRQ#e;X+Q
zABOa+73?~4$5lH!?(-~s9gE$EfJ%OJna#)OP6YJ8a1mln2yzh6qr+CjkRTqNuT-Jb0p8VIRdSZW4Pi}g(
z7Cr}+XCHdqMISgTzw&QsTv0x`@1JfGc*n+1LNy!e?@3bj?V|GUyQ
zsX%_bfPLlyo_K-OnF|!e3#83lpfFw_edYqQ;sr8hE>ILNkTr9G;&_3anG4L07s#8r
zKuNrSCt5(83{p%%jFQyJz>HqAuQ|3_XomDrNXZG8>!Iz@n
zfr4N*9Q`xh+&vstAz|Z(|DJjEl(pgiw!n4C$kYFR&fqR8LXO~GPy!FB`fNG*>1V+_
zIkL2fjxsjMqlT_i$q(S_z?qR(j(Ip?HtGJ4#-*!a>K;)_)d*j}h`KZYB#~m|*bhB2
zxNe8a(i$iy(88*sBFW3AgXnIg*>Gu7pV_G2J=|D?JCEm&kvDIYFVz(lVJ~PW+gknz
zC6Vb(;K~yv7~svLKkmE!{L^$erR1+S&T>LIdFMZis$su{BRT}t2x<`2BB(>K9Ki|%
zD-o;$KnHy7EP9S&^!LtZnM1Tj40&imbP|bGh`6t-#?L&w?8j4
zRIzYQ?}r?w`L;8%cK0_q?|B_1%{RM<)_;>Cv88T6yOV0nrMMfd6`fEnIsLvb%
zx67@4xt9%Y(clKJ)*%02LvKS5{Uh4Hx`3x(vWe9@2x{siD$$SUBjTMVF!rYod&
zht+OzLKsFzL74)si^TwW`mgiJ3t7s5s7{Lq>KdqmB7k&m0usIBa;#azyirZjB9W$!8>5t4QKm#)S?IK&%xeke-g;tP0P#9H
zy}&)5dgL>L0Wr{A=uLJ;NJY$qAQ=H{Ka5~OU_}7eCKv(Ce+)f)maHsj$dG0#owGQt
z1k{kEyGoQNqfCBNz4X9AenHoMZ-uZ8%0OT`_W~COk%MK&lsT+?j6ne8U=!{&;NK9V
zy_f!x7yoM=(SNaO5nfqiqd?8FxfqQCh~{B53Lxsis07HvUt}fS#IH-O!g=MqlNX7pKMgq{Z
diff --git a/test/ch395f_socket_test.py b/test/ch395f_socket_test.py
index f384b3b..6575974 100644
--- a/test/ch395f_socket_test.py
+++ b/test/ch395f_socket_test.py
@@ -8,19 +8,22 @@ CH395F BSD Socket API 测试程序
python ch395f_socket_test.py [模式] [选项]
模式:
- tcp_server - 作为 TCP 服务器(测试 CH395F TCP Client)
+ tcp_server - TCP 回显服务器,多连接循环(测试 CH395F TCP Client)
tcp_client - 作为 TCP 客户端(测试 CH395F TCP Server)
udp_server - 作为 UDP 服务器(测试 CH395F UDP Client)
udp_client - 作为 UDP 客户端(测试 CH395F UDP Server)
- tcp_echo - TCP 回显服务器(测试双向通信)
+ tcp_echo - TCP 回显服务器(单连接,测试双向通信)
udp_echo - UDP 回显服务器(测试双向通信)
stress - 压力测试(多连接并发测试)
+ tcp_bulk - 双向大块:先收满 bulk 字节(不回声,校验 LCG),再回放(阶段 5)
选项:
--ip 目标 IP 地址(默认: 192.168.1.100)
--port 端口号(默认: 8080)
--count 测试次数(默认: 10)
--size 数据包大小(默认: 1024)
+ --bulk tcp_bulk 模式双向字节数(默认: 262144)
+ --chunk tcp_bulk 模式块大小,须与固件 PHASE5_CHUNK_SIZE 一致(默认: 4096)
示例:
# 测试 CH395F TCP Server
@@ -37,10 +40,14 @@ CH395F BSD Socket API 测试程序
# 压力测试(多连接)
python ch395f_socket_test.py stress --ip 192.168.1.100 --port 8080 --count 7
+
+ # 阶段 5 双向大块(先收 256KB 再回放 256KB)
+ python ch395f_socket_test.py tcp_bulk --port 8081 --bulk 262144 --chunk 4096
"""
import socket
import sys
+import os
import time
import argparse
import threading
@@ -49,6 +56,10 @@ import random
import string
from datetime import datetime
+# TCP 回显服务器(tcp_server 模式)参数
+INTER_ACCEPT_TIMEOUT = 60 # 首个连接后,等待下一个连接的超时秒数
+ECHO_IDLE_TIMEOUT = 30 # 连接内无数据的空闲超时秒数
+
class Colors:
"""终端颜色"""
@@ -69,19 +80,19 @@ def log_msg(msg, color=Colors.END):
def log_success(msg):
- log_msg(f"✓ {msg}", Colors.GREEN)
+ log_msg("[OK] %s" % msg, Colors.GREEN)
def log_error(msg):
- log_msg(f"✗ {msg}", Colors.RED)
+ log_msg("[ERR] %s" % msg, Colors.RED)
def log_info(msg):
- log_msg(f"ℹ {msg}", Colors.BLUE)
+ log_msg("[..] %s" % msg, Colors.BLUE)
def log_warn(msg):
- log_msg(f"⚠ {msg}", Colors.YELLOW)
+ log_msg("[!!] %s" % msg, Colors.YELLOW)
def generate_data(size):
@@ -99,89 +110,195 @@ def verify_data(data, expected_len):
# ==================== TCP 测试函数 ====================
def tcp_server_test(args):
- """TCP 服务器测试(测试 CH395F TCP Client)"""
+ """TCP 回显服务器测试(测试 CH395F TCP Client)
+
+ 与固件 TC-NET-201/202 配套:MCU 连接后发送数据并等待原样回显,
+ 校验通过后主动关闭。本函数循环接受多个连接,每个连接内将收到的
+ 数据逐字回显,直到对端关闭或空闲超时。
+
+ 首个连接等待 args.timeout 秒;之后每个连接间最多等待
+ INTER_ACCEPT_TIMEOUT 秒,无新连接则结束并汇总。
+ 返回 False 表示失败(无连接或回显出错),main 据此返回非 0 退出码。
+ """
log_info("=" * 60)
- log_info("TCP 服务器测试 - 测试 CH395F TCP Client 功能")
+ log_info("TCP 回显服务器 - 测试 CH395F TCP Client 功能")
log_info("=" * 60)
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
- server_socket.settimeout(args.timeout)
+
+ conn_total = 0
+ echo_bytes = 0
+ conn_errors = 0
try:
server_socket.bind(('0.0.0.0', args.port))
- server_socket.listen(1)
+ server_socket.listen(4)
log_success(f"服务器启动,监听端口 {args.port}")
- for conn_idx in range(3):
+ conn_idx = 0
+ while True:
+ wait = args.timeout if conn_idx == 0 else min(args.timeout, INTER_ACCEPT_TIMEOUT)
+ server_socket.settimeout(wait)
try:
- server_socket.settimeout(args.timeout)
- log_info(f"等待第 {conn_idx+1} 个连接(超时 {args.timeout}s)...")
+ log_info(f"等待第 {conn_idx+1} 个连接(超时 {wait}s)...")
client_socket, client_addr = server_socket.accept()
- log_success(f"连接#{conn_idx+1} 来自: {client_addr[0]}:{client_addr[1]}")
- client_socket.settimeout(5)
-
- # Test 1: 接收数据
- log_info("-" * 40)
- log_info(f"[连接{conn_idx+1}] 测试 1: 接收数据")
- try:
- data = client_socket.recv(args.size)
- if data:
- log_success(f"收到数据 ({len(data)} bytes): {data[:50]}...")
- except socket.timeout:
- log_error("接收超时")
-
- # Test 2: PING echo
- log_info(f"[连接{conn_idx+1}] 测试 2: 双向通信 (PING)")
- ping_ok = 0
- for i in range(5):
- try:
- test_data = f"PING_{i}".encode()
- client_socket.send(test_data)
- data = client_socket.recv(args.size)
- if data and data == test_data:
- log_success(f"回显匹配: {test_data.decode()}")
- ping_ok += 1
- elif data:
- log_error(f"回显不匹配! 收到: {data[:20]}")
- break
- except socket.timeout:
- log_error("通信超时")
- break
- except Exception as e:
- log_error(f"通信错误: {e}")
- break
- log_info(f"PING 匹配: {ping_ok}/5")
-
- # Test 3: 大包发送
- log_info(f"[连接{conn_idx+1}] 测试 3: 大包发送")
- for i in range(args.count):
- try:
- test_data = generate_data(min(100, args.size))
- client_socket.send(test_data)
- time.sleep(0.1)
- except Exception as e:
- log_error(f"发送错误: {e}")
- break
- log_success(f"发送 {args.count} 包完成")
-
- client_socket.close()
- log_success(f"连接#{conn_idx+1} 测试完成")
- time.sleep(0.5)
-
except socket.timeout:
- log_error(f"等待连接#{conn_idx+1} 超时")
+ if conn_idx == 0:
+ log_error("等待连接超时")
+ else:
+ log_info(f"{wait}s 内无新连接,服务器退出")
break
+
+ conn_idx += 1
+ log_success(f"连接#{conn_idx} 来自: {client_addr[0]}:{client_addr[1]}")
+
+ # 回显循环:收到什么回什么(sendall 保证发完),对端关闭或空闲超时结束
+ client_socket.settimeout(ECHO_IDLE_TIMEOUT)
+ rx = 0
+ try:
+ while True:
+ data = client_socket.recv(4096)
+ if not data:
+ log_info(f"[连接{conn_idx}] 对端已关闭")
+ break
+ client_socket.sendall(data)
+ rx += len(data)
+ except socket.timeout:
+ log_warn(f"[连接{conn_idx}] 空闲超时,关闭连接")
except Exception as e:
- log_error(f"连接#{conn_idx+1} 错误: {e}")
- break
+ log_error(f"[连接{conn_idx}] 回显错误: {e}")
+ conn_errors += 1
+ finally:
+ client_socket.close()
- log_success("全部连接测试完成")
+ if rx > 0:
+ log_success(f"连接#{conn_idx} 完成: 回显 {rx} 字节")
+ else:
+ log_warn(f"连接#{conn_idx} 未收到任何数据")
+ conn_errors += 1
+ echo_bytes += rx
+ conn_total += 1
+
+ log_info("-" * 40)
+ log_info(f"服务结束: 连接 {conn_total} 个, 回显 {echo_bytes} 字节, 异常 {conn_errors} 次")
+ if conn_total == 0:
+ log_error("无任何客户端连接")
+ return False
+ return conn_errors == 0
- except socket.timeout:
- log_error("等待连接超时")
except Exception as e:
log_error(f"服务器错误: {e}")
+ return False
+ finally:
+ server_socket.close()
+
+
+# ==================== 阶段 5:双向大块传输 ====================
+
+BULK_IDLE_TIMEOUT = 10 # bulk 接收阶段单次 recv 等待超时(秒)
+
+
+def _lcg_block(idx, size):
+ """生成与固件 phase5_gen_block 完全一致的 LCG 块数据(uint32 回绕)"""
+ seed = (0xC2D2E6F9 ^ (idx * 2654435761)) & 0xFFFFFFFF
+ out = bytearray(size)
+ for k in range(size):
+ seed = (seed * 1664525 + 1013904223) & 0xFFFFFFFF
+ out[k] = (seed >> 24) & 0xFF
+ return bytes(out)
+
+
+def tcp_bulk_test(args):
+ """双向大块传输测试(配合固件阶段 5 硬件层)
+
+ 协议:接受连接 → 收满 bulk 字节(不回声,校验 LCG 模式)→
+ 按相同 LCG 模式回放 bulk 字节 → 关闭。
+ MCU 侧先连续发送 256KB(本端只收),再连续接收 256KB(本端回放),
+ 分别测得纯 TX / 纯 RX 吞吐。
+ """
+ chunk = args.chunk
+ bulk = (args.bulk // chunk) * chunk # 按整块取整
+ blocks = bulk // chunk
+ log_info("=" * 60)
+ log_info("TCP Bulk 双向大块 - 配合 CH395F 阶段 5")
+ log_info(f"协议: 收满 {bulk} 字节(不回声) -> 回放 {bulk} 字节 (chunk={chunk}, blocks={blocks})")
+ log_info("=" * 60)
+
+ server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+ server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+ try:
+ server_socket.bind(('0.0.0.0', args.port))
+ server_socket.listen(4)
+ log_success(f"服务器启动,监听端口 {args.port}")
+
+ server_socket.settimeout(args.timeout)
+ try:
+ client_socket, client_addr = server_socket.accept()
+ except socket.timeout:
+ log_error("等待连接超时")
+ return False
+ log_success(f"连接来自: {client_addr[0]}:{client_addr[1]}")
+ client_socket.settimeout(BULK_IDLE_TIMEOUT)
+
+ # 预生成期望/回放数据(LCG,与固件一致)
+ expected = bytearray(bulk)
+ for i in range(blocks):
+ expected[i * chunk:(i + 1) * chunk] = _lcg_block(i, chunk)
+
+ # ---- 阶段 A:收满 bulk 字节(不回声),校验 LCG 模式 ----
+ rx_buf = bytearray()
+ rx_t0 = time.time()
+ try:
+ while len(rx_buf) < bulk:
+ data = client_socket.recv(min(65536, bulk - len(rx_buf)))
+ if not data:
+ log_error(f"对端提前关闭,仅收到 {len(rx_buf)}/{bulk} 字节")
+ client_socket.close()
+ return False
+ rx_buf += data
+ except socket.timeout:
+ log_error(f"接收空闲超时,仅收到 {len(rx_buf)}/{bulk} 字节")
+ client_socket.close()
+ return False
+ rx_ms = int((time.time() - rx_t0) * 1000)
+
+ ok = (bytes(rx_buf) == bytes(expected))
+ if ok:
+ log_success(f"阶段A 收满 {len(rx_buf)} 字节,LCG 校验一致")
+ else:
+ bad = -1
+ for i in range(min(len(rx_buf), len(expected))):
+ if rx_buf[i] != expected[i]:
+ bad = i
+ break
+ if bad >= 0:
+ log_error(f"阶段A 数据不一致 @第 {bad} 字节 (期望 0x{expected[bad]:02X}, "
+ f"实际 0x{rx_buf[bad]:02X})")
+ else:
+ log_error(f"阶段A 数据不一致(长度 {len(rx_buf)} vs {len(expected)})")
+ log_info(f"阶段A 接收 {len(rx_buf)} 字节,耗时 {rx_ms} ms "
+ f"({len(rx_buf) * 1000 // max(rx_ms, 1)} B/s)")
+
+ # ---- 阶段 B:按 LCG 模式回放 bulk 字节 ----
+ tx_t0 = time.time()
+ try:
+ for off in range(0, bulk, chunk):
+ client_socket.sendall(expected[off:off + chunk])
+ except Exception as e:
+ log_error(f"阶段B 回放错误: {e}")
+ ok = False
+ finally:
+ client_socket.close()
+ tx_ms = int((time.time() - tx_t0) * 1000)
+ if ok:
+ log_success(f"阶段B 回放 {bulk} 字节完成,耗时 {tx_ms} ms "
+ f"({bulk * 1000 // max(tx_ms, 1)} B/s)")
+ return ok
+
+ except Exception as e:
+ log_error(f"服务器错误: {e}")
+ return False
finally:
server_socket.close()
@@ -334,17 +451,24 @@ def udp_server_test(args):
def udp_client_test(args):
- """UDP Echo 测试(测试 CH395F UDP Server)"""
+ """UDP Echo 测试(测试 CH395F UDP Server,对应指南阶段 3)
+
+ 会话结构与固件 phase3_run() 约定:
+ - "HELLO" 探针:回显即就绪,不计入固件轮次
+ - TC-301:30 轮 64B 基础回显(--size 非默认值时覆盖单轮载荷大小)
+ - TC-302:1B/64B/200B 各 --count 轮变长合规(默认 10)
+ 任一轮 mismatch/timeout 立即终止;结束输出汇总,失败退出码 1。
+ """
log_info("=" * 60)
- log_info("UDP Echo 测试")
+ log_info("UDP Echo 测试(TC-301 基础回显 + TC-302 变长合规)")
log_info("=" * 60)
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
dest = (args.ip, args.port)
try:
- # Phase A: HELLO 探针等待 STM32 就绪
- log_info(f"Phase A: 等待 CH395F 就绪(超时 {args.timeout}s)")
+ # Phase A: HELLO 就绪探针(固件只回显不计数,不占用例预算)
+ log_info(f"Phase A: HELLO 就绪探针(超时 {args.timeout}s)")
sock.settimeout(2)
t0 = time.time()
ready = False
@@ -360,55 +484,70 @@ def udp_client_test(args):
pass
if not ready:
log_error(f"未就绪({args.timeout}s 超时)")
- return
+ sys.exit(1)
sock.settimeout(5)
- # Phase B: PING Echo
+ # Phase B: TC-301 基础回显 30 轮 x 64B
+ size_b = 64 if args.size == 1024 else min(args.size, 200)
+ rounds_b = 30
log_info("-" * 40)
- log_info("Phase B: PING Echo(5 轮)")
- ok = 0
- for i in range(5):
- msg = f"PING_{i}".encode()
- try:
- sock.sendto(msg, dest)
- data, _ = sock.recvfrom(64)
- if data == msg:
- ok += 1
- log_success(f"PING_{i} OK")
- else:
- log_error(f"PING_{i} mismatch: {data[:20]}")
- break
- except socket.timeout:
- log_error(f"PING_{i} timeout")
- break
- time.sleep(0.02)
- log_info(f"PING: {ok}/5")
-
- # Phase C: 大包 Echo
- log_info("-" * 40)
- log_info(f"Phase C: 大包 Echo({args.count} 轮)")
- for i in range(args.count):
- td = generate_data(min(100, args.size))
+ log_info(f"Phase B: TC-301 基础回显({rounds_b} 轮 x {size_b}B)")
+ ok_b = 0
+ for i in range(rounds_b):
+ td = generate_data(size_b)
try:
sock.sendto(td, dest)
- data, _ = sock.recvfrom(args.size)
- if data == td:
- log_success(f"#{i+1} OK ({len(data)}B)")
- else:
- log_error(f"#{i+1} mismatch")
+ data, _ = sock.recvfrom(size_b + 16)
+ if data != td:
+ log_error(f"[TC-301] #{i+1} mismatch: {len(data)}B != {len(td)}B")
break
- time.sleep(0.02)
except socket.timeout:
- log_warn(f"#{i+1} timeout")
- except Exception as e:
- log_error(f"#{i+1}: {e}")
+ log_error(f"[TC-301] #{i+1} echo timeout")
break
+ ok_b += 1
+ if ok_b % 10 == 0:
+ log_info(f"[TC-301] 进度 {ok_b}/{rounds_b}")
+ time.sleep(0.02)
- log_success("Phase 3 完成")
+ # Phase C: TC-302 变长合规(仅 Phase B 全过后继续,否则后续必超时)
+ sizes_c = [1, 64, 200]
+ total_c = len(sizes_c) * args.count
+ ok_c = 0
+ if ok_b == rounds_b:
+ log_info("-" * 40)
+ log_info(f"Phase C: TC-302 变长合规({sizes_c}B 各 {args.count} 轮)")
+ for sz in sizes_c:
+ ok_sz = 0
+ for i in range(args.count):
+ td = generate_data(sz)
+ try:
+ sock.sendto(td, dest)
+ data, _ = sock.recvfrom(sz + 16)
+ if data != td:
+ log_error(f"[TC-302] {sz}B #{i+1} mismatch: {len(data)}B != {sz}B")
+ break
+ except socket.timeout:
+ log_error(f"[TC-302] {sz}B #{i+1} echo timeout")
+ break
+ ok_sz += 1
+ time.sleep(0.02)
+ log_info(f"[TC-302] {sz}B: {ok_sz}/{args.count}")
+ ok_c += ok_sz
+ if ok_sz < args.count:
+ break
+
+ # 汇总与退出码
+ log_info("=" * 60)
+ if ok_b == rounds_b and ok_c == total_c:
+ log_success(f"PASS: TC-301 {ok_b}/{rounds_b}, TC-302 {ok_c}/{total_c}")
+ else:
+ log_error(f"FAIL: TC-301 {ok_b}/{rounds_b}, TC-302 {ok_c}/{total_c}")
+ sys.exit(1)
except Exception as e:
log_error(f"错误: {e}")
+ sys.exit(1)
finally:
sock.close()
@@ -647,6 +786,7 @@ DHCP_OFFER = 2
DHCP_REQUEST = 3
DHCP_ACK = 5
OPT_MESSAGE_TYPE = 53
+DHCP_ANNOUNCE_PORT = 60001 # MCU Socket6 广播宣告端口(固件 phase4_run)
OPT_SERVER_ID = 54
OPT_SUBNET_MASK = 1
OPT_ROUTER = 3
@@ -675,6 +815,30 @@ def _build_dhcp_pkt(op, xid, client_mac, yiaddr, siaddr, options):
return op_b + htype + hlen + hops + xid + secs + flags + ciaddr + yiaddr + siaddr + giaddr + chaddr + sname + file + magic + options
+def _announce_listener(results):
+ """后台监听 MCU 的 4B IP 广播宣告(UDP :60001,TC-602 步1 的 PC 侧观测)"""
+ s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+ s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+ try:
+ s.bind(('0.0.0.0', DHCP_ANNOUNCE_PORT))
+ except OSError as e:
+ results['announce_err'] = f'绑定 {DHCP_ANNOUNCE_PORT} 失败: {e}'
+ return
+ s.settimeout(45)
+ try:
+ data, addr = s.recvfrom(16)
+ if len(data) == 4:
+ ip = '.'.join(str(b) for b in data)
+ log_success(f"收到 IP 宣告: {ip} (from {addr[0]}:{addr[1]})")
+ results['announce'] = ip
+ else:
+ results['announce_err'] = f'宣告长度异常 {len(data)}B(预期 4B)'
+ except socket.timeout:
+ results['announce_err'] = '45s 未收到宣告'
+ finally:
+ s.close()
+
+
def dhcp_server_test(args):
"""DHCP Server 模式(DISCOVER → OFFER → REQUEST → ACK)"""
log_info("=" * 60)
@@ -700,9 +864,14 @@ def dhcp_server_test(args):
sock.settimeout(60)
log_info("DHCP 服务器已启动,等待 CH395F DISCOVER...")
- log_info("(请确保 MCU 端已启用 ENABLE_PHASE6_TESTS 并复位)")
+ log_info("(请确保 MCU 端已启用 ENABLE_PHASE4_TESTS 并复位)")
print()
+ # 宣告监听线程:MCU 在 ACK 后立即广播 4B IP 到 :60001
+ results = {}
+ listener = threading.Thread(target=_announce_listener, args=(results,), daemon=True)
+ listener.start()
+
try:
# Phase 1: DISCOVER → OFFER
data, addr = sock.recvfrom(4096)
@@ -799,6 +968,17 @@ def dhcp_server_test(args):
print()
+ # 汇总宣告监听结果(TC-602 步 1 PC 侧观测;join 延迟由固件 30s HELLO 窗覆盖)
+ listener.join(timeout=10)
+ if results.get('announce'):
+ if results['announce'] != offer_ip:
+ log_error(f"IP 宣告 {results['announce']} != 租约 {offer_ip}!"
+ "芯片固件可能回读了未提交的旧 IP 配置")
+ elif 'announce_err' in results:
+ log_warn(f"IP 宣告未观测到:{results['announce_err']}")
+
+ print()
+
# Phase 3: 连通性验证(MCU Phase 6 内置 HELLO 端口 = 60000)
hello_port = args.port if args.port != 8080 else 60000
log_info(f"验证 {offer_ip} 连通性(UDP HELLO → port {hello_port})")
@@ -892,17 +1072,20 @@ def main():
%(prog)s tcp_server --port 8080
%(prog)s stress --ip 192.168.1.100 --port 8080 --count 5
%(prog)s dhcp_server --dhcp-iface 192.168.1.2 --ip 192.168.1.100
+ %(prog)s tcp_bulk --port 8081 --bulk 262144 --chunk 4096
"""
)
parser.add_argument('mode', choices=['tcp_server', 'tcp_client', 'udp_server', 'udp_client',
'tcp_echo', 'udp_echo', 'stress', 'packet_size',
- 'dhcp_server'],
+ 'dhcp_server', 'tcp_bulk'],
help='测试模式')
parser.add_argument('--ip', default='192.168.1.100', help='目标 IP 地址 / DHCP 待分配 IP')
parser.add_argument('--port', type=int, default=8080, help='端口号')
parser.add_argument('--count', type=int, default=10, help='测试次数')
parser.add_argument('--size', type=int, default=1024, help='数据包大小')
+ parser.add_argument('--bulk', type=int, default=262144, help='tcp_bulk 模式双向字节数')
+ parser.add_argument('--chunk', type=int, default=4096, help='tcp_bulk 模式块大小,须与固件 PHASE5_CHUNK_SIZE 一致')
parser.add_argument('--timeout', type=int, default=180, help='接受连接超时(秒,默认180)')
parser.add_argument('--dhcp-iface', default='192.168.1.2', help='DHCP 服务器网卡 IP')
parser.add_argument('--dhcp-mask', default='255.255.255.0', help='DHCP 分配的子网掩码')
@@ -910,15 +1093,24 @@ def main():
args = parser.parse_args()
+ # GBK 控制台容错:不可编码字符替换而非崩溃
+ for stream in (sys.stdout, sys.stderr):
+ if stream is not None and hasattr(stream, 'reconfigure'):
+ stream.reconfigure(errors='replace')
+
+ if sys.platform == 'win32':
+ os.system('') # 启用 Windows 控制台 VT 序列,避免 ANSI 颜色码乱码
+
print()
print(Colors.BOLD + "=" * 60 + Colors.END)
print(Colors.BOLD + " CH395F BSD Socket API 测试程序" + Colors.END)
print(Colors.BOLD + "=" * 60 + Colors.END)
print()
+ ret = None
try:
if args.mode == 'tcp_server':
- tcp_server_test(args)
+ ret = tcp_server_test(args)
elif args.mode == 'tcp_client':
tcp_client_test(args)
elif args.mode == 'udp_server':
@@ -933,14 +1125,21 @@ def main():
stress_test(args)
elif args.mode == 'packet_size':
packet_size_test(args)
+ elif args.mode == 'tcp_bulk':
+ ret = tcp_bulk_test(args)
elif args.mode == 'dhcp_server':
dhcp_server_test(args)
except KeyboardInterrupt:
log_warn("用户中断")
+ sys.exit(130)
except Exception as e:
log_error(f"未预期的错误: {e}")
import traceback
traceback.print_exc()
+ sys.exit(2)
+
+ if ret is False:
+ sys.exit(1)
if __name__ == '__main__':
diff --git a/test/ch395f_test.h b/test/ch395f_test.h
index c4a4ec8..47b999b 100644
--- a/test/ch395f_test.h
+++ b/test/ch395f_test.h
@@ -9,19 +9,19 @@
* 修改记录:
* 2026-07-22 全面重构为单连接模式,增加大文件传输、边界条件等测试
*
- * === 测试阶段一览 ===
- * Phase | 类型 | 描述
- * ---------|--------------|-----------------------------------------------
- * Phase 1 | 独立运行 | 寄存器读写 + SPI 命令路径验证
- * Phase 2 | PC 配合 | TCP Client 收发 + 关闭重连
- * Phase 3 | PC 配合 | UDP Server Echo(HELLO + PING + 大包)
- * Phase 4 | testTask | NET 层 TCP Echo(单连接模式,基础收发验证)
- * Phase 5 | testTask | NET 层大文件传输(20KB+ 分块收发)
- * Phase 6 | PC 配合 | DHCP 自动获取 IP
- * Phase 7 | testTask | Select/Poll I/O 多路复用
- * Phase 8 | testTask | 边界条件测试(零长度、DMA 边界、缓冲溢出)
- * Phase 9 | 需拔插网线 | PHY 链路恢复
- * Phase 10 | testTask | KeepAlive 超时断开测试
+ * === 测试阶段一览(硬件层 1~5 → NET 层 6~10,严格顺序执行) ===
+ * Phase | 层 | 描述
+ * ---------|----------|-----------------------------------------------
+ * Phase 1 | 硬件层 | 独立运行:寄存器读写 + SPI 命令路径验证
+ * Phase 2 | 硬件层 | PC 配合:TCP Client 收发 + 关闭重连
+ * Phase 3 | 硬件层 | PC 配合:UDP Server Echo(60 轮动态源地址回显,HELLO 探针不计数)
+ * Phase 4 | 硬件层 | PC 配合:DHCP 自动获取 IP
+ * Phase 5 | 硬件层 | PC 配合:大文件分块回传(裸命令,tcp_server 配合)
+ * Phase 6 | NET 层 | testTask:TCP Echo(单连接模式,基础收发验证)
+ * Phase 7 | NET 层 | testTask:大文件传输(20KB+ 分块收发)
+ * Phase 8 | NET 层 | testTask:Select/Poll I/O 多路复用
+ * Phase 9 | NET 层 | testTask:边界条件测试(零长度、DMA 边界、缓冲溢出)
+ * Phase 10 | NET 层 | testTask:KeepAlive 超时断开测试
*/
#ifndef __CH395F_TEST_H
@@ -35,19 +35,43 @@ extern "C" {
/*
* 阶段使能开关(取消注释即启用对应阶段)
- * 注意:一次仅启用一个阶段(Phase 4/5/7/8 共享 testTask 循环,可同时启用)
- * Phase 6 (DHCP) 会改变 IP,必须独立运行
+ *
+ * 构建模式互斥(详见 docs/CH395F_Test_Guide.md「构建模式与执行顺序」):
+ * 硬件层模式(阶段 1~5):netTask 不创建,ch395fTestTask 独占 CH395F
+ * NET 层模式 (阶段 6~10):完整网络栈,netTask 轮询 + ch395fTestTask 监听循环
+ *
+ * 注意:同层内可多选(Phase 6~10 共享 testTask 循环);
+ * Phase 4 (DHCP) 会改变 IP,必须独立运行;
+ * 两层同时启用会在下方触发 #error。
*/
-#define ENABLE_PHASE1_TESTS /* 寄存器读写 + SPI 命令路径 */
-//#define ENABLE_PHASE2_TESTS /* TCP Client 收发 + 关闭重连 */
-//#define ENABLE_PHASE3_TESTS /* UDP Server Echo */
-//#define ENABLE_PHASE4_TESTS /* NET 层 TCP Echo(单连接基础收发) */
-//#define ENABLE_PHASE5_TESTS /* NET 层大文件传输(20KB+ 分块) */
-//#define ENABLE_PHASE6_TESTS /* DHCP 自动获取 IP(会改 IP!独立运行) */
-//#define ENABLE_PHASE7_TESTS /* Select/Poll I/O 多路复用 */
-//#define ENABLE_PHASE8_TESTS /* 边界条件测试 */
-//#define ENABLE_PHASE9_TESTS /* PHY 链路恢复测试 */
-//#define ENABLE_PHASE10_TESTS /* KeepAlive 超时断开测试 */
+/* ---- 硬件层(阶段 1~5)---- */
+//#define ENABLE_PHASE1_TESTS /* [硬] 寄存器读写 + SPI 命令路径 */
+//#define ENABLE_PHASE2_TESTS /* [硬] TCP Client 收发 + 关闭重连 */
+//#define ENABLE_PHASE3_TESTS /* [硬] UDP Server Echo */
+//#define ENABLE_PHASE4_TESTS /* [硬] DHCP 自动获取 IP(会改 IP!独立运行) */
+#define ENABLE_PHASE5_TESTS /* [硬] 大文件传输(硬件层,PC 配合) */
+/* ---- NET 层(阶段 6~10)---- */
+//#define ENABLE_PHASE6_TESTS /* [网] TCP Echo(单连接基础收发) */
+//#define ENABLE_PHASE7_TESTS /* [网] 大文件传输(20KB+ 分块) */
+//#define ENABLE_PHASE8_TESTS /* [网] Select/Poll I/O 多路复用 */
+//#define ENABLE_PHASE9_TESTS /* [网] 边界条件测试 */
+//#define ENABLE_PHASE10_TESTS /* [网] KeepAlive 超时断开测试 */
+
+#if defined(ENABLE_PHASE1_TESTS) || defined(ENABLE_PHASE2_TESTS) || \
+ defined(ENABLE_PHASE3_TESTS) || defined(ENABLE_PHASE4_TESTS) || \
+ defined(ENABLE_PHASE5_TESTS)
+#define ENABLE_HW_LAYER_TESTS 1
+#endif
+
+#if defined(ENABLE_PHASE6_TESTS) || defined(ENABLE_PHASE7_TESTS) || \
+ defined(ENABLE_PHASE8_TESTS) || defined(ENABLE_PHASE9_TESTS) || \
+ defined(ENABLE_PHASE10_TESTS)
+#define ENABLE_NET_LAYER_TESTS 1
+#endif
+
+#if defined(ENABLE_HW_LAYER_TESTS) && defined(ENABLE_NET_LAYER_TESTS)
+#error "硬件层(1~5)与NET层(6~10)测试互斥:请分两次构建,见 CH395F_Test_Guide 构建模式与执行顺序"
+#endif
/* 测试统计 */
typedef struct {
diff --git a/test/ch395f_test_task.c b/test/ch395f_test_task.c
index 0696b14..1836b1d 100644
--- a/test/ch395f_test_task.c
+++ b/test/ch395f_test_task.c
@@ -2,17 +2,17 @@
* 模块名称:CH395F Network Test Task
* 模块功能:CH395F 全阶段测试入口,统一在独立 FreeRTOS 任务中运行。
* 测试分两组:
- * Phase 1/2/3/6/9 — 阻塞式,TCP 监听前依次执行(各自有内部循环/等待)
- * Phase 4/5/7/8/10 — 事件驱动,TCP 监听循环中运行(需 PC 客户端连接)
+ * Phase 1~5(硬件层)— 阻塞式独占执行(各自有内部循环/等待),netTask 未运行
+ * Phase 4~10(NET 层)— 事件驱动,TCP 监听循环中运行(需 PC 客户端连接)
* 所有测试结果通过 TEST_CHECK/TEST_REPORT 宏输出到串口。
* 作者:王建锋
* 创建日期:2026-07-22
******************************************************************************/
#include
-#include
#include "ch395f_test_task.h"
#include "cmsis_os.h"
+#include "net_task.h"
#include "net_socket.h"
#include "ch395f_test.h"
#include "ch395f.h"
@@ -20,7 +20,8 @@
#define DBG_TAG "[TEST_TASK]"
#include "dbg_log.h"
-/* netTask 初始化完成标志(由 net_task.c 在 net_init 成功后置 1) */
+/* netTask 初始化完成标志(由 net_task.c 在 net_stack_bring_up 成功后置 1)。
+ * 仅 NET 层模式使用 —— 硬件层模式下 netTask 不创建,由本任务自行初始化。 */
extern volatile uint8_t g_net_ready;
/*
@@ -32,16 +33,16 @@ test_stats_t g_test_stats;
/*
* 收发缓冲区 —— 全局静态,不在任务栈上。
- * s_tx_buf 仅在 Phase 5(大文件传输)和 Phase 8(边界条件)中使用,
+ * s_tx_buf 仅在 Phase 7(大文件传输)和 Phase 9(边界条件)中使用,
* 其他 Phase 不需要发送固定模式数据,故条件编译节省 RAM。
*/
#define TEST_BUF_SIZE 65536
-#if defined(ENABLE_PHASE4_TESTS) || defined(ENABLE_PHASE5_TESTS) || \
- defined(ENABLE_PHASE7_TESTS) || defined(ENABLE_PHASE8_TESTS) || \
+#if defined(ENABLE_PHASE6_TESTS) || defined(ENABLE_PHASE7_TESTS) || \
+ defined(ENABLE_PHASE8_TESTS) || defined(ENABLE_PHASE9_TESTS) || \
defined(ENABLE_PHASE10_TESTS)
static uint8_t s_rx_buf[TEST_BUF_SIZE];
#endif
-#if defined(ENABLE_PHASE5_TESTS) || defined(ENABLE_PHASE8_TESTS)
+#if defined(ENABLE_PHASE7_TESTS) || defined(ENABLE_PHASE9_TESTS)
static uint8_t s_tx_buf[TEST_BUF_SIZE];
#endif
@@ -54,10 +55,36 @@ static uint8_t s_tx_buf[TEST_BUF_SIZE];
* 共 9 项测试(P1-01 ~ P1-09),逐项执行,汇总报告。
* =================================================================== */
+/* 解析点分十进制 IP 字符串为数组(避免引入 sscanf 库) */
+static void test_parse_ip(const char *str, uint8_t *ip_arr)
+{
+ uint32_t val;
+ int i;
+
+ for (i = 0; i < 4; i++) {
+ val = 0;
+ while (*str >= '0' && *str <= '9') {
+ val = val * 10 + (*str - '0');
+ str++;
+ }
+ ip_arr[i] = (uint8_t)val;
+ if (*str == '.') {
+ str++;
+ }
+ }
+}
+
#ifdef ENABLE_PHASE1_TESTS
static void phase1_run(void) {
uint8_t ip_info[20];
+ /* ---- 前置清全局中断(读即清除) ----
+ * net_stack_bring_up() 在 set_phy(100M_FULL) 强制重协商 + 等待链路建立
+ * 期间,芯片会锁存 GINT_STAT_PHY_CHANGE(0x0004)标志;硬件层模式下无
+ * netTask 轮询消费它,若不清除将导致 P1-06 的"原始状态 0x0000"检查误报。
+ * 此处读取一次丢弃,保证 P1-06 反映的是测试期间的纯净状态。 */
+ (void)ch395f_get_glob_int_status_all();
+
DBG_INFO("=== CH395F Phase 1 Tests ===");
DBG_INFO("--- 9 test items (P1-01 ~ P1-09) ---");
@@ -230,7 +257,7 @@ static void phase1_run(void) {
* 测试目的:验证 CH395F 作为 TCP Client 发起连接、发送数据、接收回显、
* 关闭连接、重连的完整生命周期。重复 3 轮以验证连接稳定性。
*
- * 前置条件:PC 上运行 TCP Server(python ch395f_socket_test.py tcp_server --port 8081)
+ * 前置条件:PC 上运行 TCP 回显服务器(python test/ch395f_socket_test.py tcp_server --port 8081)
* 通过:3/3 轮回显成功。
* 失败:任意轮连接失败、回显超时或数据不一致。
* =================================================================== */
@@ -251,122 +278,511 @@ static void phase1_run(void) {
#ifndef PHASE2_TIMEOUT_MS
#define PHASE2_TIMEOUT_MS 10000
#endif
+#ifndef PHASE2_TC203_TIMEOUT_MS
+#define PHASE2_TC203_TIMEOUT_MS 30000 /* TC-203 连接超时窗(指南规定 30s) */
+#endif
-static void phase2_run(void) {
+/* TCP Client 单次会话:对应 TC-NET-201 步 2~7 与 TC-NET-202 每轮 6 步。
+ * 调用前须已设置协议类型 / 目标 IP / 目标端口(TC-NET-201 步 1)。
+ * 每轮使用不同本地端口 local_port 规避 TIME_WAIT。
+ * 返回 1 表示全流程通过,0 表示中途失败(已记录 TEST_CHECK)。
+ */
+/* TC-NET-201(硬件层):单次 TCP Client 连接与数据交换,步骤与文档 7 步严格对应 */
+static void phase2_tc201(void)
+{
+ uint8_t sock = 0; /* 本用例操作的 Socket 索引,固定 0(单连接模式) */
+ uint8_t ip_arr[4]; /* 目标 IP 四字节数组,由 test_parse_ip() 解析 PHASE2_REMOTE_IP 填入 */
+ uint8_t tx[64]; /* 发送缓冲:64 字节递增模式数据 0x00..0x3F */
+ uint8_t rx[300]; /* 接收缓冲:存放 PC 回显数据,300 > 64 预留安全余量 */
+ uint8_t r; /* ch395f_* 命令返回值(0x00 = CH395F_ERR_SUCCESS) */
+ uint8_t ok; /* 当前步骤结果标志:1 = 成功跳出等待循环,0 = 超时失败 */
+ uint16_t p; /* 逐字节比对循环索引(rx[p] vs tx[p]) */
+ uint16_t n; /* 实际参与比对的字节数 = MIN(rl, 64) */
+ uint16_t rl; /* 本次实际读取长度 = MIN(收到长度, sizeof(rx)),防缓冲区溢出 */
+ uint32_t tick; /* HAL_GetTick() 快照;用无符号减法测超时窗口(回绕安全) */
+ int16_t k; /* 通用循环索引(如构造 tx 递增模式) */
+ int16_t match; /* 回显校验结果:1 = 全部字节一致,0 = 发现不符(提前 break) */
+
+ test_parse_ip(PHASE2_REMOTE_IP, ip_arr);
+
+ /* 步1:配置协议类型 / 目标 IP / 目标端口 / 本地端口 */
+ ch395f_set_proto_type(sock, CH395F_PROTO_TYPE_TCP);
+ ch395f_set_des_ip(sock, ip_arr);
+ ch395f_set_des_port(sock, PHASE2_REMOTE_PORT);
+ ch395f_set_sour_port(sock, (uint16_t)PHASE2_LOCAL_PORT);
+ TEST_CHECK(ch395f_get_cmd_status() == CH395F_ERR_SUCCESS,
+ "TC201 step1 cfg proto/ip/port");
+ if (ch395f_get_cmd_status() != CH395F_ERR_SUCCESS) return;
+
+ /* 构造 64 字节递增模式数据 0x00..0x3F */
+ for (k = 0; k < 64; k++) {
+ tx[k] = (uint8_t)k;
+ }
+
+ /* 步2:OPEN Socket 0 */
+ r = ch395f_open_socket(sock);
+ TEST_CHECK(r == CH395F_ERR_SUCCESS, "TC201 step2 open");
+ if (r != CH395F_ERR_SUCCESS) return;
+
+ /* 步3:CONNECT */
+ r = ch395f_tcp_connect(sock);
+ TEST_CHECK(r == CH395F_ERR_SUCCESS, "TC201 step3 connect");
+ if (r != CH395F_ERR_SUCCESS) { ch395f_close_socket(sock); return; }
+
+ /* 步4:等待 CONNECT 中断
+ *
+ * CH395F 的中断上报是【两级】结构:
+ *
+ * 第 1 级 —— 全局中断状态 GET_GLOB_INT_STATUS_ALL(16 位,读即清除)
+ * 只回答"哪个 Socket 发生了事件",不回答具体是什么事件。
+ * 16 位布局(见 ch395f.h GINT_STAT 宏定义):
+ * bit0 UNREACH (0x0001) 目标不可达
+ * bit1 IP_CONFLI (0x0002) IP 冲突
+ * bit2 PHY_CHANGE (0x0004) 链路状态变化
+ * bit3 DHCP (0x0008) DHCP 事件
+ * bit4~7 Socket0~3 (0x0010/0x20/0x40/0x80)
+ * bit8~11 Socket4~7 (0x0100~0x0800)
+ * bit15 DHCPV6 (0x8000)
+ *
+ * 第 2 级 —— Socket 中断状态 CMD_GET_INT_STATUS_SN(8 位,读即清除)
+ * 才包含具体事件类型:SENBUF_FREE / SEND_OK / RECV_OK /
+ * CONNECT / DISCONNECT / DISCARD / SOCK_TIMEOUT。
+ * 必须在第 1 级提示"本 Socket 有事件"后再读,否则读了也是空。
+ *
+ * 【掩码 (1U << (sock + 4)) 的由来】
+ * 全局状态的 bit0~3 被 4 个全局事件占用,因此 Socket N 的事件标志
+ * 固定从 bit4 开始排列 —— Socket N 对应第 (N + 4) 位:
+ * sock=0 → 1<<4 = 0x0010(CH395F_GINT_STAT_SOCK0)
+ * sock=1 → 1<<5 = 0x0020(CH395F_GINT_STAT_SOCK1)
+ * ...
+ * sock=7 → 1<<11 = 0x0800(CH395F_GINT_STAT_SOCK7)
+ * `int_st & (1U << (sock + 4))` 非 0
+ * ⇔ 芯片报告"Socket [sock] 有待处理事件",
+ * 此时才值得再花一次 SPI 事务去读第 2 级确认具体事件。
+ */
+ tick = HAL_GetTick();
+ ok = 0;
+ while (HAL_GetTick() - tick < PHASE2_TIMEOUT_MS) {
+ /* 第 1 级:读全局状态。注意本次读取本身会清掉全部全局标志
+ * 并拉高 INT#(读即清除),所以每轮循环都在重新采样。 */
+ uint16_t int_st = ch395f_get_glob_int_status_all();
+
+ /* 本 Socket 在全局寄存器中有事件挂起? */
+ if (int_st & (1U << (sock + 4))) {
+ /* 第 2 级:读本 Socket 的具体事件类型(同样读即清除) */
+ uint8_t si = ch395f_get_sock_int_status(sock);
+ if (si & CH395F_SINT_STAT_CONNECT) {
+ /* bit3 = 0x08:TCP 三次握手完成,进入 ESTABLISHED */
+ ok = 1;
+ break;
+ }
+ /* 是别的事件(理论上此阶段不应出现),已被读清、直接忽略,
+ * 继续下一轮轮询等 CONNECT */
+ }
+ HAL_Delay(10); /* 10ms 轮询周期,直至 CONNECT 或超时退出 */
+ }
+ TEST_CHECK(ok, "TC201 step4 connected");
+ if (!ok) {
+ ch395f_close_socket(sock);
+ return;
+ }
+ HAL_Delay(100);
+
+ /* 步5:发送 64 字节,并等待 SENBUF_FREE 中断确认发送缓冲释放 */
+ ch395f_write_send_buf(sock, tx, 64);
+ tick = HAL_GetTick();
+ ok = 0;
+ while (HAL_GetTick() - tick < 2000) {
+ uint16_t int_st = ch395f_get_glob_int_status_all();
+ if (int_st & (1U << (sock + 4))) {
+ uint8_t si = ch395f_get_sock_int_status(sock);
+ if (si & CH395F_SINT_STAT_SENBUF_FREE) {
+ ok = 1;
+ break;
+ }
+ }
+ HAL_Delay(10);
+ }
+ TEST_CHECK(ok, "TC201 step5 sendbuf_free");
+ if (!ok) {
+ ch395f_close_socket(sock);
+ return;
+ }
+
+ /* 步6:等待回显并逐字节验证(递增模式 0x00..0x3F)
+ *
+ * 背景:步 5 已把 tx[64] 发给 PC,PC 端 tcp_server 收到后原样回显。
+ * 本步骤最多等 10 秒,每轮轮询做两件事:
+ * ① 查芯片接收缓冲有没有回显数据到达(优先处理);
+ * ② 查有没有 DISCONNECT / TIMEOUT 事件(连接断了就别傻等了)。
+ *
+ * 关键 API 语义区别:
+ * ch395f_get_recv_len() —— 只查询积压字节数,不取走数据(可反复调用)
+ * ch395f_read_recv_buf() —— 真正从芯片 RX FIFO 取出数据(取走即消耗)
+ */
+ tick = HAL_GetTick();
+ ok = 0; /* 尚未收到任何回显数据 */
+ while (HAL_GetTick() - tick < 10000) {
+
+ /* ---- ① 数据到达检查 ----
+ * rlen:芯片 RX 缓冲区当前积压的字节数(纯查询、不消耗)。
+ * rlen > 0 说明 PC 回显已到达,进入读取 + 校验流程。 */
+ uint16_t rlen = ch395f_get_recv_len(sock);
+ if (rlen > 0) {
+
+ /* 截断保护:一次最多读 sizeof(rx)=300 字节,
+ * 防止 rlen 异常偏大时 read_recv_buf 写越界 rx[] */
+ rl = (rlen > (uint16_t)sizeof(rx)) ? (uint16_t)sizeof(rx) : rlen;
+
+ /* 清零将要填充的区域(防御性写法,避免残留脏字节干扰比对) */
+ memset(rx, 0, rl);
+
+ /* 从芯片 RX FIFO 取出回显 —— 此刻起这些数据已被消费 */
+ ch395f_read_recv_buf(sock, rx, rl);
+
+ /* 参与比对的长度:预期回显 64 字节;若 TCP 分片导致本次
+ * 只到了一部分(rl < 64),则只比对已到的部分 */
+ n = (rl < 64) ? rl : 64;
+
+ /* 判定初值:必须收满 64 字节才算通过。若 rl < 64(分片/短读),
+ * match 直接为 0 → "echo verify" 判 FAIL */
+ match = (rl >= 64);
+
+ /* 与发送的递增模式逐字节比对:tx[k]=k,任一不符立即置 FAIL 退出 */
+ for (p = 0; p < n; p++) {
+ if (rx[p] != tx[p]) {
+ match = 0;
+ break;
+ }
+ }
+ TEST_CHECK(match, "TC201 step6 echo verify");
+
+ ok = 1; /* 标记"收到过数据",循环外的 echo rcvd 检查不再重复报错 */
+ break; /* 校验结论已得出,无论 PASS/FAIL 都跳出 */
+ }
+
+ /* ---- ② 连接异常检查(还没等到数据才走到这里)----
+ * 两级中断:全局状态确认本 Socket 有事件 → 再读具体事件类型。
+ * 注意先查数据再查断开:断开事件可能和最后一批数据同时到达,
+ * 数据优先保证"临终回显"不被漏掉。 */
+ uint16_t int_st = ch395f_get_glob_int_status_all();
+ if (int_st & (1U << (sock + 4))) {
+ uint8_t si = ch395f_get_sock_int_status(sock);
+ if (si & (CH395F_SINT_STAT_DISCONNECT | CH395F_SINT_STAT_SOCK_TIMEOUT)) {
+ break; /* 对端断开 / 超时:继续等也不会有回显了。
+ ok 保持 0,跳出后由下方统一判 FAIL */
+ }
+ }
+
+ /* 每 50ms 一轮。若本轮只读了部分数据(rlen > 300 的极端情况),
+ * 剩余字节下一轮 get_recv_len 会继续报告,不会丢 */
+ HAL_Delay(50);
+ }
+ /* 到这里只有两种情况:
+ * ok==1:收到过数据,结果已由循环内 "echo verify" 记录;
+ * ok==0:10s 内什么都没收到 / 中途断开 —— 在此补一条 FAIL。 */
+ if (!ok) {
+ TEST_CHECK(0, "TC201 step6 echo rcvd");
+ }
+
+ /* 步7:关闭 Socket 并等待状态回到 CLOSED(CH395F_SOCKET_CLOSED = 0x00) */
+ ch395f_close_socket(sock);
+ tick = HAL_GetTick();
+ ok = 0;
+ while (HAL_GetTick() - tick < 5000) {
+ uint8_t st[2];
+ ch395f_get_socket_status(sock, st);
+ if (st[0] == CH395F_SOCKET_CLOSED) {
+ ok = 1;
+ break;
+ }
+ HAL_Delay(50);
+ }
+ TEST_CHECK(ok, "TC201 step7 closed");
+ HAL_Delay(200);
+}
+
+/* TC-NET-202(硬件层):关闭重连 x PHASE2_LOOP_COUNT 轮,每轮 6 步 */
+static void phase2_tc202_once(uint8_t sock, uint16_t local_port)
+{
+ uint8_t tx[64];
+ uint8_t rx[300];
+ uint8_t r;
+ uint8_t ok;
+ uint16_t p;
+ uint16_t n;
+ uint16_t rl;
+ uint32_t tick;
+ int k;
+ int match;
+
+ for (k = 0; k < 64; k++) {
+ tx[k] = (uint8_t)k;
+ }
+
+ /* 步1:设置本地端口并 OPEN Socket 0 */
+ ch395f_set_sour_port(sock, local_port);
+ r = ch395f_open_socket(sock);
+ TEST_CHECK(r == CH395F_ERR_SUCCESS, "TC202 step1 open");
+ if (r != CH395F_ERR_SUCCESS) return;
+
+ /* 步2:CONNECT */
+ r = ch395f_tcp_connect(sock);
+ TEST_CHECK(r == CH395F_ERR_SUCCESS, "TC202 step2 connect");
+ if (r != CH395F_ERR_SUCCESS) { ch395f_close_socket(sock); return; }
+
+ /* 步3:等待 CONNECT 中断 */
+ tick = HAL_GetTick();
+ ok = 0;
+ while (HAL_GetTick() - tick < PHASE2_TIMEOUT_MS) {
+ uint16_t int_st = ch395f_get_glob_int_status_all();
+ if (int_st & (1U << (sock + 4))) {
+ uint8_t si = ch395f_get_sock_int_status(sock);
+ if (si & CH395F_SINT_STAT_CONNECT) { ok = 1; break; }
+ }
+ HAL_Delay(10);
+ }
+ TEST_CHECK(ok, "TC202 step3 connected");
+ if (!ok) { ch395f_close_socket(sock); return; }
+ HAL_Delay(100);
+
+ /* 步4:发送 64 字节 + SENBUF_FREE */
+ ch395f_write_send_buf(sock, tx, 64);
+ tick = HAL_GetTick();
+ ok = 0;
+ while (HAL_GetTick() - tick < 2000) {
+ uint16_t int_st = ch395f_get_glob_int_status_all();
+ if (int_st & (1U << (sock + 4))) {
+ uint8_t si = ch395f_get_sock_int_status(sock);
+ if (si & CH395F_SINT_STAT_SENBUF_FREE) { ok = 1; break; }
+ }
+ HAL_Delay(10);
+ }
+ TEST_CHECK(ok, "TC202 step4 sendbuf_free");
+ if (!ok) { ch395f_close_socket(sock); return; }
+
+ /* 步5:等待回显并验证 */
+ tick = HAL_GetTick();
+ ok = 0;
+ while (HAL_GetTick() - tick < 10000) {
+ uint16_t rlen = ch395f_get_recv_len(sock);
+ if (rlen > 0) {
+ rl = (rlen > (uint16_t)sizeof(rx)) ? (uint16_t)sizeof(rx) : rlen;
+ memset(rx, 0, rl);
+ ch395f_read_recv_buf(sock, rx, rl);
+ n = (rl < 64) ? rl : 64;
+ match = (rl >= 64);
+ for (p = 0; p < n; p++) {
+ if (rx[p] != tx[p]) { match = 0; break; }
+ }
+ TEST_CHECK(match, "TC202 step5 echo verify");
+ ok = 1;
+ break;
+ }
+ uint16_t int_st = ch395f_get_glob_int_status_all();
+ if (int_st & (1U << (sock + 4))) {
+ uint8_t si = ch395f_get_sock_int_status(sock);
+ if (si & (CH395F_SINT_STAT_DISCONNECT | CH395F_SINT_STAT_SOCK_TIMEOUT)) break;
+ }
+ HAL_Delay(50);
+ }
+ if (!ok) TEST_CHECK(0, "TC202 step5 echo rcvd");
+
+ /* 步6:关闭 + 等待 CLOSED */
+ ch395f_close_socket(sock);
+ tick = HAL_GetTick();
+ ok = 0;
+ while (HAL_GetTick() - tick < 5000) {
+ uint8_t st[2];
+ ch395f_get_socket_status(sock, st);
+ if (st[0] == CH395F_SOCKET_CLOSED) { ok = 1; break; }
+ HAL_Delay(50);
+ }
+ TEST_CHECK(ok, "TC202 step6 closed");
+ HAL_Delay(200);
+}
+
+static void phase2_tc202(void)
+{
uint8_t sock = 0;
- uint8_t rx_buf[300] = {0};
+ uint8_t ip_arr[4];
int i;
- DBG_INFO("=== CH395F Phase 2 Tests (TCP Client) ===");
+ test_parse_ip(PHASE2_REMOTE_IP, ip_arr);
- /* 解析远程 IP 字符串为字节数组 */
- uint8_t ip_arr[4];
- {
- uint32_t a[4];
- sscanf(PHASE2_REMOTE_IP, "%lu.%lu.%lu.%lu", &a[0], &a[1], &a[2], &a[3]);
- ip_arr[0] = (uint8_t)a[0];
- ip_arr[1] = (uint8_t)a[1];
- ip_arr[2] = (uint8_t)a[2];
- ip_arr[3] = (uint8_t)a[3];
- }
- DBG_INFO("Target: %s:%d", PHASE2_REMOTE_IP, PHASE2_REMOTE_PORT);
-
- /*
- * 配置 Socket 0 为 TCP Client 模式:
- * - 协议类型 TCP
- * - 目标 IP/端口:PC Server
- * - 本地端口:循环内每次+1,避免 TIME_WAIT 冲突
- */
- sock = 0;
+ /* 协议 / 目标端口在重连间保持不变,仅每轮更换本地端口 */
ch395f_set_proto_type(sock, CH395F_PROTO_TYPE_TCP);
ch395f_set_des_ip(sock, ip_arr);
ch395f_set_des_port(sock, PHASE2_REMOTE_PORT);
for (i = 0; i < PHASE2_LOOP_COUNT; i++) {
- DBG_INFO("--- Iteration %d/%d ---", i + 1, PHASE2_LOOP_COUNT);
+ phase2_tc202_once(sock, (uint16_t)(PHASE2_LOCAL_PORT + i));
+ }
+}
- /*
- * 每轮使用不同本地端口(防止前一轮 TIME_WAIT 未完全释放导致绑定失败)。
- * 先 OPEN() 创建 Socket,再 CONNECT() 发 SYN。
- * OPEN() 和 CONNECT() 都是异步命令,需轮询中断状态确认连接完成。
- */
- ch395f_set_sour_port(sock, PHASE2_LOCAL_PORT + i);
+/* TC-NET-203(硬件层):TCP Client 连接超时(负向测试,P1)
+ *
+ * 前置环境:PC 未在 192.168.1.2:8081 提供服务(与 TC-201/202 互斥,
+ * 需先关闭 PC 端 tcp_server)。固件自行辨别环境错误:
+ * 若等待期间误收到 CONNECT,说明 PC 服务未关,判 FAIL 并给出指引。
+ *
+ * 负向通过路径(本质都是"未建立连接",按事件+耗时细分原因):
+ * SOCK_TIMEOUT(快, <3s) —— 实测主路径:对端在线但端口关闭,RST 拒绝,
+ * 芯片毫秒级上报,并非等待重传耗尽
+ * SOCK_TIMEOUT(慢, ≥3s) —— 对端无响应(掉电/防火墙丢包),重传耗尽后报超时
+ * DISCONNECT —— 预留兼容路径(SYN_SENT 阶段实测基本不出现)
+ * UNREACH(全局位) —— ARP 失败、对端不在线(仅作备注,不影响判定)
+ *
+ * 已知陷阱(Trap 14):上一会话 close 的 DISCONNECT 会滞后锁存在
+ * SINT_SN(wait-CLOSED 的 STATUS 查询不清中断)。防御双保险:
+ * ① 步 2 前预清两级中断;
+ * ② 判负向后用 GET_SOCKET_STATUS 反核实,ESTABLISHED 即改判环境错误。
+ */
+static void phase2_tc203(void)
+{
+ uint8_t sock = 0; /* 操作 Socket 0(单连接模式) */
+ uint8_t ip_arr[4]; /* 目标 IP 四字节数组 */
+ uint16_t sour_port = (uint16_t)(PHASE2_LOCAL_PORT + 16); /* 避开 201/202 用过的端口防 TIME_WAIT */
+ uint32_t tick;
+ uint32_t elapsed; /* 步3 从 CONNECT 到收到负向事件的耗时(ms),用于细分原因 */
+ uint8_t r;
+ uint8_t neg_si; /* 步3 命中的 socket 事件位(SOCK_TIMEOUT/DISCONNECT) */
+ uint8_t ev; /* 步3 结果:0=无事件 1=收到负向事件(过) 2=误收到CONNECT(环境错误) */
- if (ch395f_open_socket(sock) != CH395F_ERR_SUCCESS) { TEST_CHECK(0, "open socket"); continue; }
- if (ch395f_tcp_connect(sock) != CH395F_ERR_SUCCESS) { TEST_CHECK(0, "tcp connect"); ch395f_close_socket(sock); continue; }
+ DBG_INFO("--- TC-NET-203: connect timeout (PC 8081 MUST be OFF) ---");
- /* 等待 CONNECT 中断(最多 PHASE2_TIMEOUT_MS) */
- uint32_t tick = HAL_GetTick();
- uint8_t connected = 0;
- while (HAL_GetTick() - tick < PHASE2_TIMEOUT_MS) {
- uint16_t int_st = ch395f_get_glob_int_status_all();
- if (int_st & (1U << (sock + 4))) {
- uint8_t si = ch395f_get_sock_int_status(sock);
- if (si & CH395F_SINT_STAT_CONNECT) { connected = 1; break; }
- }
- HAL_Delay(10);
- }
- if (!connected) { TEST_CHECK(0, "connect timeout"); ch395f_close_socket(sock); continue; }
+ test_parse_ip(PHASE2_REMOTE_IP, ip_arr);
- HAL_Delay(100);
+ /* 步1:配置协议/目标 IP/目标端口/本地端口,校验 CMD_STATUS */
+ ch395f_set_proto_type(sock, CH395F_PROTO_TYPE_TCP);
+ ch395f_set_des_ip(sock, ip_arr);
+ ch395f_set_des_port(sock, (uint16_t)PHASE2_REMOTE_PORT);
+ ch395f_set_sour_port(sock, sour_port);
+ TEST_CHECK(ch395f_get_cmd_status() == CH395F_ERR_SUCCESS,
+ "TC203 step1 cfg proto/ip/port");
+ if (ch395f_get_cmd_status() != CH395F_ERR_SUCCESS) return;
- /*
- * 发送 64 字节测试数据(前部为可读字符串,后部填充数字字符)。
- * 然后等待 PC Server 回显(将收到的数据原样发回),
- * 收到后立即把回显数据再次发送回去(实现双向验证)。
- */
- {
- uint8_t test_buf[64] = {0};
- const char *msg = "HelloFromCH395F_TCP_Client! This is a 64-byte test message.";
- int p, mlen = (int)strlen(msg);
- memcpy(test_buf, msg, mlen);
- for (p = mlen; p < 64; p++) test_buf[p] = (uint8_t)('0' + (p - mlen) % 10);
- ch395f_write_send_buf(sock, test_buf, 64);
+ /* 预清陈旧事件(Trap 14):上一会话 close 的 DISCONNECT 可能滞后锁存
+ * 在 SINT_SN 中(wait-CLOSED 轮询的 STATUS 是纯查询、不清中断),
+ * 若不清除,本用例首次读中断会误吃旧事件导致负向误判。 */
+ (void)ch395f_get_glob_int_status_all();
+ (void)ch395f_get_sock_int_status(sock);
+
+ /* 步2:OPEN + CONNECT。命令为异步下发,此时均应立即返回成功,
+ * 真正的失败结果由步 3 的中断体现 */
+ r = ch395f_open_socket(sock);
+ TEST_CHECK(r == CH395F_ERR_SUCCESS, "TC203 step2 open");
+ if (r != CH395F_ERR_SUCCESS) return;
+
+ r = ch395f_tcp_connect(sock);
+ TEST_CHECK(r == CH395F_ERR_SUCCESS, "TC203 step2 connect");
+ if (r != CH395F_ERR_SUCCESS) { ch395f_close_socket(sock); return; }
+
+ /* 步3:30s 两级中断轮询,等"连不上"的证据。
+ * 先扫全局 UNREACH 位作备注,再查本 socket 位取具体事件。
+ *
+ * 实测行为(2026-08 上板):PC 端口关闭时 SYN 被 RST 拒绝,
+ * 芯片以【毫秒级 SOCK_TIMEOUT】上报,并非等待 30s 静默重传耗尽;
+ * DISCONNECT 仅在已建立连接断开时触发,SYN_SENT 阶段基本不会出现。
+ * 因此同时记录耗时用于细分失败原因:
+ * <3s → 对端主动拒绝(RST,端口关闭)
+ * ≥3s → 真无应答(对端离线/防火墙丢包,重传耗尽) */
+ tick = HAL_GetTick();
+ ev = 0;
+ neg_si = 0;
+ while (HAL_GetTick() - tick < PHASE2_TC203_TIMEOUT_MS) {
+ uint16_t int_st = ch395f_get_glob_int_status_all();
+
+ if (int_st & CH395F_GINT_STAT_UNREACH) {
+ DBG_INFO(" global UNREACH: ARP fail (peer offline)");
}
- /* 等待回显(最多 10 秒),收到后原样发回作为二次验证 */
- int got_echo = 0;
- uint32_t wait = HAL_GetTick();
- while (HAL_GetTick() - wait < 10000) {
- uint16_t rlen = ch395f_get_recv_len(sock);
- if (rlen > 0) {
- uint16_t read_len = (rlen > sizeof(rx_buf)) ? (uint16_t)sizeof(rx_buf) : rlen;
- memset(rx_buf, 0, sizeof(rx_buf));
- ch395f_read_recv_buf(sock, rx_buf, read_len);
- ch395f_write_send_buf(sock, rx_buf, read_len);
- got_echo = 1;
+ if (int_st & (1U << (sock + 4))) {
+ uint8_t si = ch395f_get_sock_int_status(sock);
+ if (si & (CH395F_SINT_STAT_SOCK_TIMEOUT | CH395F_SINT_STAT_DISCONNECT)) {
+ neg_si = si; /* 记下事件位,跳出后再细分原因 */
+ ev = 1;
break;
}
- uint16_t int_st = ch395f_get_glob_int_status_all();
- if (int_st & (1U << (sock + 4))) {
- uint8_t si = ch395f_get_sock_int_status(sock);
- if (si & CH395F_SINT_STAT_DISCONNECT) break;
- if (si & CH395F_SINT_STAT_SOCK_TIMEOUT) break;
+ if (si & CH395F_SINT_STAT_CONNECT) {
+ ev = 2; /* 连上了 = PC 服务没关,属环境错误而非芯片故障 */
+ break;
}
- HAL_Delay(50);
}
- TEST_CHECK(got_echo, "Echo #%d", i + 1);
-
- /*
- * 关闭 Socket(使用 close_socket 而非 disconnect,避免进入 FIN_WAIT_2)。
- * 等待状态机回到 CLOSED(CH395F_SOCKET_CLOSED = 0x05)。
- */
- ch395f_close_socket(sock);
- {
- uint8_t st[2];
- wait = HAL_GetTick();
- while (HAL_GetTick() - wait < 5000) {
- ch395f_get_socket_status(sock, st);
- if (st[0] == CH395F_SOCKET_CLOSED) break;
- HAL_Delay(50);
- }
- DBG_INFO("closed: sock=0x%02X tcp=0x%02X", st[0], st[1]);
- }
- HAL_Delay(200);
+ HAL_Delay(10);
}
+ elapsed = HAL_GetTick() - tick;
+
+ /* 反核实(Trap 14 第二道防线):负向事件与实际状态矛盾时以状态为准。
+ * 若收到"负向事件"但 socket 实际已 ESTABLISHED,说明刚才读到的是
+ * 上一会话遗留的陈旧 DISCONNECT,真实结果是连接成功 —— 环境错误。 */
+ if (ev == 1) {
+ uint8_t st_chk[2];
+ ch395f_get_socket_status(sock, st_chk);
+ if (st_chk[0] == CH395F_TCP_ESTABLISHED) {
+ DBG_ERROR(" negative event but socket ESTABLISHED -> stale DISCONNECT!");
+ ev = 2;
+ }
+ }
+
+ if (ev == 1) {
+ const char *why;
+ const char *short_tag;
+
+ if (neg_si & CH395F_SINT_STAT_DISCONNECT) {
+ why = "DISCONNECT: peer sent RST (port closed)";
+ short_tag = "DISC/RST";
+ } else if (elapsed < 3000U) {
+ /* 毫秒级超时 = 收到了 RST 快速失败,而非静默无应答 */
+ why = "SOCK_TIMEOUT fast: peer actively refused (RST, port closed)";
+ short_tag = "T/O-fast(refused)";
+ } else {
+ why = "SOCK_TIMEOUT slow: no response (offline / firewall drop)";
+ short_tag = "T/O-slow(silence)";
+ }
+ DBG_INFO(" negative event @%lums: %s", elapsed, why);
+ TEST_CHECK(1, "TC203 step3 no-connect OK (%lums %s)", elapsed, short_tag);
+ } else if (ev == 2) {
+ DBG_ERROR(" CONNECT received -> PC 8081 server is still running!");
+ TEST_CHECK(0, "TC203 step3 connected?! stop PC server and retry");
+ } else {
+ TEST_CHECK(0, "TC203 step3 no interrupt in %dms (state machine hang?)",
+ PHASE2_TC203_TIMEOUT_MS);
+ }
+
+ /* 步4:无论步 3 结论如何都关闭 Socket,确认状态机可恢复到 CLOSED */
+ ch395f_close_socket(sock);
+ tick = HAL_GetTick();
+ ev = 0;
+ while (HAL_GetTick() - tick < 5000) {
+ uint8_t st[2];
+ ch395f_get_socket_status(sock, st);
+ if (st[0] == CH395F_SOCKET_CLOSED) { ev = 1; break; }
+ HAL_Delay(50);
+ }
+ TEST_CHECK(ev == 1, "TC203 step4 closed");
+
+ HAL_Delay(200);
+}
+
+static void phase2_run(void)
+{
+ DBG_INFO("=== CH395F Phase 2 Tests (TCP Client) ===");
+
+ DBG_INFO("--- TC-NET-201: connect & 64B exchange ---");
+ phase2_tc201();
+
+ DBG_INFO("--- TC-NET-202: close/reconnect x%d ---", PHASE2_LOOP_COUNT);
+ phase2_tc202();
+
+ DBG_INFO("--- TC-NET-203: negative test, stop PC 8081 server first ---");
+ phase2_tc203();
+
TEST_REPORT("Phase 2");
}
+
+
#endif
/* ===================================================================
@@ -379,16 +795,26 @@ static void phase2_run(void) {
* 4. 向对应源地址回显数据
* 5. SENDBUF_FREE 中断等待(确保发送缓冲可用)
*
- * 前置条件:PC 发送 UDP 包到 192.168.1.100:60000
- * 通过:30/30 轮回显成功。
+ * 前置条件:PC 运行 udp_client 发包到 192.168.1.100:60000
+ * 会话结构:累计 PHASE3_TOTAL_ROUNDS(60) 个有效数据包后关闭 Socket
+ * 第 1~30 轮 = TC-301(PC 发 64B);第 31~60 轮 = TC-302(1B/64B/200B)
+ * "HELLO"(5B) 为 PC 就绪探针:照常回显但不计入轮次
+ * 通过:60/60 有效轮回显成功。
* 失败:任意轮回显超时或解析错误。
* =================================================================== */
#ifdef ENABLE_PHASE3_TESTS
+
+/* UDP 有效回显轮数:1~30 = TC-301(64B),31~60 = TC-302(变长)。
+ * "HELLO" 探针只回显不计数,与 test/ch395f_socket_test.py udp_client 约定 */
+#ifndef PHASE3_TOTAL_ROUNDS
+#define PHASE3_TOTAL_ROUNDS 60
+#endif
+
static void phase3_run(void) {
uint8_t sock = 0;
uint8_t rx_buf[300] = {0};
- int i;
+ int counted;
DBG_INFO("=== CH395F Phase 3 Tests (UDP) ===");
@@ -413,7 +839,7 @@ static void phase3_run(void) {
HAL_Delay(200);
/*
- * 循环接收并回显,最多 30 轮。
+ * 计数式回显循环:累计 PHASE3_TOTAL_ROUNDS 个有效数据包。
* CH395F UDP 接收数据格式(read_recv_buf 返回):
* [0-1] 保留
* [2-3] 源端口(大端)
@@ -422,10 +848,15 @@ static void phase3_run(void) {
* 回显前需根据源 IP/Port 设置目标地址,写回载荷数据。
* 每次 write_send_buf 后需等待 SENDBUF_FREE 中断,确保数据已
* 从 MCU 传输到 CH395F 内部发送缓冲,避免后续接收覆盖。
+ *
+ * "HELLO"(5B) 为 PC 就绪探针:照常回显但不计入轮次,
+ * 使脚本探针阶段不占用用例预算(与 udp_client 脚本约定)。
*/
- for (i = 0; i < 30; i++) {
+ counted = 0;
+ while (counted < PHASE3_TOTAL_ROUNDS) {
uint32_t tick = HAL_GetTick();
int echo_ok = 0;
+ int is_probe = 0;
while (HAL_GetTick() - tick < 30000) {
uint16_t rlen = ch395f_get_recv_len(sock);
if (rlen > 8) {
@@ -437,6 +868,9 @@ static void phase3_run(void) {
uint8_t *src_ip = &rx_buf[4];
uint8_t *payload = &rx_buf[8];
+ is_probe = (payload_len == 5 &&
+ memcmp(payload, "HELLO", 5) == 0);
+
ch395f_set_des_ip(sock, src_ip);
ch395f_set_des_port(sock, src_port);
ch395f_write_send_buf(sock, payload, payload_len);
@@ -455,8 +889,15 @@ static void phase3_run(void) {
}
HAL_Delay(50);
}
- TEST_CHECK(echo_ok, "UDP echo #%d", i + 1);
- if (!echo_ok) break;
+
+ if (!echo_ok) {
+ TEST_CHECK(0, "UDP echo #%d timeout", counted + 1);
+ break;
+ }
+ if (!is_probe) {
+ counted++;
+ TEST_CHECK(1, "UDP echo #%d", counted);
+ }
}
ch395f_close_socket(sock);
@@ -466,121 +907,7 @@ static void phase3_run(void) {
#endif
/* ===================================================================
- * Phase 4 — NET 层 TCP Echo(基础收发)
- *
- * 测试目的:验证 BSD Socket API(net_socket)的单连接 TCP Echo 通路。
- * Socket 0 复用监听和数据通道。PC 发任意数据,MCU 原样返回。
- * 这是 Phase 5/7/8/10 的基础。
- *
- * 入口条件:Socket 0 处于 ESTABLISHED(TCP 连接已建立)。
- * 通过:数据收发一致。
- * 失败:send/recv 数量不匹配。
- * =================================================================== */
-
-#ifdef ENABLE_PHASE4_TESTS
-static uint32_t s_phase4_count = 0;
-
-static void phase4_run(int sockfd) {
- /*
- * 使用 NET_MSG_DONTWAIT 非阻塞接收 —— 没有数据时立即返回,
- * 不阻塞任务循环(Phase 5/7/8/10 也共享同一个循环)。
- * 收到数据后立即原样发送回显。
- */
- int n = net_recv(sockfd, s_rx_buf, TEST_BUF_SIZE, NET_MSG_DONTWAIT);
- if (n > 0) {
- int sent = net_send(sockfd, s_rx_buf, n, 0);
- if (sent != n) {
- DBG_ERROR("echo: send %d != recv %d", sent, n);
- return;
- }
- s_phase4_count++;
- if (s_phase4_count <= 10 || (s_phase4_count % 100 == 0)) {
- DBG_INFO("Phase4: echo #%lu (%d bytes)", s_phase4_count, n);
- }
- }
-}
-#endif
-
-/* ===================================================================
- * Phase 5 — 大文件传输(超过 CH395F 硬件缓冲 4KB)
- *
- * 测试目的:验证超过 Socket 0 接收缓冲(4KB)的数据在 net_send/
- * net_recv 层的正确处理。net_send_locked 自动将大数据
- * 拆分为 ≤4096B 的块,每块通过一次 DMA 事务写入 CH395F。
- * 接收端同样分多次调用 ch395f_read_recv_buf 读空硬件缓冲。
- *
- * 数据模式:递增字节(s_tx_buf[i] = i & 0xFF),接收端按 offset 逐字节比对。
- * 通过:全部 20480 字节逐字节匹配。
- * 失败:任意字节不一致或收发过程中断。
- * =================================================================== */
-
-#ifdef ENABLE_PHASE5_TESTS
-#define PHASE5_FILE_SIZE 20480
-
-static void phase5_fill(uint8_t *buf, uint32_t size) {
- for (uint32_t i = 0; i < size; i++) {
- buf[i] = (uint8_t)(i & 0xFF);
- }
-}
-
-static int phase5_verify(uint8_t *buf, uint32_t size, uint32_t offset) {
- for (uint32_t i = 0; i < size; i++) {
- if (buf[i] != (uint8_t)((offset + i) & 0xFF)) {
- DBG_ERROR("Phase5: mismatch at %lu (expect 0x%02X, got 0x%02X)",
- offset + i, (uint8_t)((offset + i) & 0xFF), buf[i]);
- return 0;
- }
- }
- return 1;
-}
-
-static void phase5_run(int sockfd) {
- DBG_INFO("Phase5: starting %d-byte file transfer", PHASE5_FILE_SIZE);
-
- phase5_fill(s_tx_buf, PHASE5_FILE_SIZE);
-
- /*
- * 发送阶段:分块发送,每块最多 4096B。
- * net_send 内部通过消息队列转发到 netTask,由 net_send_locked
- * 按 CH395F_SPI_DMA_MAX_PAYLOAD(4096)自动拆分 DMA 事务。
- * 等待 PC 端回显(echod)全部数据。
- */
- uint32_t sent = 0;
- while (sent < PHASE5_FILE_SIZE) {
- int chunk = (PHASE5_FILE_SIZE - sent) > 4096 ? 4096 : (PHASE5_FILE_SIZE - sent);
- int n = net_send(sockfd, s_tx_buf + sent, chunk, 0);
- if (n <= 0) {
- DBG_ERROR("Phase5: send fail at %lu (ret=%d)", sent, n);
- return;
- }
- sent += (uint32_t)n;
- DBG_INFO("Phase5: sent %lu/%d", sent, PHASE5_FILE_SIZE);
- }
-
- /*
- * 接收阶段:分块接收,逐块验证。
- * PC 回显数据需与发送数据逐字节一致(递增模式)。
- * 验证失败立即返回,不继续接收剩余数据。
- */
- uint32_t recvd = 0;
- while (recvd < PHASE5_FILE_SIZE) {
- int n = net_recv(sockfd, s_rx_buf, TEST_BUF_SIZE, 0);
- if (n <= 0) {
- DBG_ERROR("Phase5: recv fail at %lu (ret=%d)", recvd, n);
- return;
- }
- int ok = phase5_verify(s_rx_buf, (uint32_t)n, recvd);
- TEST_CHECK(ok, "Phase5: verify at %lu (%d bytes)", recvd, n);
- if (!ok) return;
- recvd += (uint32_t)n;
- }
-
- TEST_CHECK(1, "Phase5: %d-byte file transfer complete", PHASE5_FILE_SIZE);
-}
-#endif
-
-/* ===================================================================
- * Phase 6 — DHCP 自动获取 IP
+ * Phase 4 — DHCP 自动获取 IP
*
* 测试目的:验证 CH395F DHCP 客户端功能,包括:
* 1. DHCP DISCOVER → OFFER → REQUEST → ACK 完整握手
@@ -594,18 +921,23 @@ static void phase5_run(int sockfd) {
* 失败:DHCP 超时或 HELLO 无响应。
* =================================================================== */
-#ifdef ENABLE_PHASE6_TESTS
-#ifndef PHASE6_ANNOUNCE_PORT
-#define PHASE6_ANNOUNCE_PORT 60001
+#ifdef ENABLE_PHASE4_TESTS
+#ifndef PHASE4_ANNOUNCE_PORT
+#define PHASE4_ANNOUNCE_PORT 60001
#endif
-#ifndef PHASE6_ANNOUNCE_SOCK
-#define PHASE6_ANNOUNCE_SOCK 6
+#ifndef PHASE4_ANNOUNCE_SOCK
+#define PHASE4_ANNOUNCE_SOCK 6
+#endif
+#ifndef PHASE4_HELLO_WAIT_MS
+#define PHASE4_HELLO_WAIT_MS 30000 /* HELLO 回显窗:PC 在 ACK 后固定 sleep(3)s,
+ * 窗口须覆盖 PC 侧启动延迟(旧值 5s 重叠仅 ~2s) */
#endif
-static void phase6_run(void) {
+static void phase4_run(void) {
uint8_t ip_info[20] = {0};
+ int same = 0;
- DBG_INFO("=== CH395F Phase 6 Tests (DHCP) ===");
+ DBG_INFO("=== CH395F Phase 4 Tests (DHCP) ===");
/*
* 启用 DHCP:ch395f_set_dhcp(1) 使 CH395F 进入 DHCP 自动协商。
@@ -624,9 +956,37 @@ static void phase6_run(void) {
HAL_Delay(500);
}
TEST_CHECK(dhcp_ok, "DHCP completed within 30s");
- if (!dhcp_ok) goto phase6_end;
+ if (!dhcp_ok) goto phase4_end;
+
+ /*
+ * IP 寄存器提交滞后(2026-08-24 上板实测):DHCP 状态已置成功、
+ * 芯片已按新租约通信,但此刻 get_ip_inf 仍回读旧静态配置——
+ * 串口打印与宣告广播会带出过期 IP。
+ * 对策:轮询直至连续 3 次(间隔 300ms)读到相同非零值才采信。
+ */
+ {
+ uint8_t last[20] = {0};
+ tick = HAL_GetTick();
+ while (HAL_GetTick() - tick < 8000) {
+ memset(ip_info, 0, sizeof(ip_info));
+ ch395f_get_ip_inf(ip_info);
+ if ((ip_info[0] || ip_info[1] || ip_info[2] || ip_info[3]) &&
+ memcmp(last, ip_info, sizeof(ip_info)) == 0) {
+ if (++same >= 3) break;
+ } else {
+ same = 0;
+ }
+ if (memcmp(last, ip_info, sizeof(ip_info)) != 0) {
+ DBG_INFO(" DHCP IP report: %d.%d.%d.%d",
+ ip_info[0], ip_info[1], ip_info[2], ip_info[3]);
+ memcpy(last, ip_info, sizeof(ip_info));
+ }
+ HAL_Delay(300);
+ }
+ memcpy(ip_info, last, sizeof(ip_info));
+ }
+ TEST_CHECK(same >= 3, "IP registers settled (3 consecutive reads)");
- ch395f_get_ip_inf(ip_info);
DBG_INFO(" IP: %d.%d.%d.%d", ip_info[0], ip_info[1], ip_info[2], ip_info[3]);
TEST_CHECK(ip_info[0]!=0||ip_info[1]!=0||ip_info[2]!=0||ip_info[3]!=0,
"IP non-zero");
@@ -637,7 +997,7 @@ static void phase6_run(void) {
* 然后等待 PC 回复 HELLO(5 字节),收到后原样回显。
*/
{
- uint8_t anno_sock = PHASE6_ANNOUNCE_SOCK;
+ uint8_t anno_sock = PHASE4_ANNOUNCE_SOCK;
uint8_t bcast[4] = {0xFF,0xFF,0xFF,0xFF};
uint8_t rx_buf[64] = {0};
@@ -650,7 +1010,7 @@ static void phase6_run(void) {
if (ch395f_open_socket(anno_sock) == CH395F_ERR_SUCCESS) {
ch395f_set_des_ip(anno_sock, bcast);
- ch395f_set_des_port(anno_sock, PHASE6_ANNOUNCE_PORT);
+ ch395f_set_des_port(anno_sock, PHASE4_ANNOUNCE_PORT);
ch395f_write_send_buf(anno_sock, ip_info, 4);
uint32_t sw = HAL_GetTick();
while (HAL_GetTick() - sw < 2000) {
@@ -667,7 +1027,7 @@ static void phase6_run(void) {
int hello_ok = 0;
uint32_t wait = HAL_GetTick();
- while (HAL_GetTick() - wait < 5000) {
+ while (HAL_GetTick() - wait < PHASE4_HELLO_WAIT_MS) {
ch395f_get_glob_int_status_all();
uint16_t rlen = ch395f_get_recv_len(anno_sock);
if (rlen > 8) {
@@ -688,18 +1048,425 @@ static void phase6_run(void) {
}
HAL_Delay(50);
}
- TEST_CHECK(hello_ok, "HELLO echo within 5s");
+ TEST_CHECK(hello_ok, "HELLO echo within %dms", PHASE4_HELLO_WAIT_MS);
ch395f_close_socket(anno_sock);
}
}
-phase6_end:
- TEST_REPORT("Phase 6");
+phase4_end:
+ TEST_REPORT("Phase 4");
}
#endif
/* ===================================================================
- * Phase 7 — Select/Poll I/O 多路复用
+ * Phase 5 — 大文件传输(硬件层裸命令)
+ *
+ * 测试目的:不依赖 net_socket/netTask,直接用 ch395f_* 命令验证
+ * TCP 批量数据搬运能力:
+ * 1. 裸命令建立 TCP Client 连接(open/connect/等 CONNECT)
+ * 2. 顺序双测向:先连续发送 256KB(PC 只收不回声,SENBUF_FREE 流控),
+ * 再连续接收 256KB(PC 按相同 LCG 模式回放,滚动校验),内存 O(CHUNK)
+ * 3. 全量累加和 TX/RX 对总账 + 双向独立吞吐基线
+ *
+ * PC 配合:python test/ch395f_socket_test.py tcp_bulk --port 8081 --bulk 262144 --chunk 4096
+ * (先收满 256KB 不回声,再按 LCG 模式回放 256KB)
+ * 通过:全部块校验一致,且 SUM(TX)==SUM(RX)。
+ * 失败:连接超时 / SENBUF_FREE 超时 / RX 停滞 / 数据不一致。
+ * =================================================================== */
+
+#ifdef ENABLE_PHASE5_TESTS
+
+/* 回传参数(TC-NET-512 合规测试时按档位修改重编译) */
+#ifndef PHASE5_REMOTE_IP
+#define PHASE5_REMOTE_IP "192.168.1.2"
+#endif
+#ifndef PHASE5_REMOTE_PORT
+#define PHASE5_REMOTE_PORT 8081 /* PC tcp_server 监听端口 */
+#endif
+#ifndef PHASE5_LOCAL_PORT
+#define PHASE5_LOCAL_PORT 50010
+#endif
+#ifndef PHASE5_TOTAL_BYTES
+#define PHASE5_TOTAL_BYTES (256*1024) /* 回传总量 */
+#endif
+#ifndef PHASE5_CHUNK_SIZE
+#define PHASE5_CHUNK_SIZE 4093 /* 单块 = socket 默认发送缓冲,DP-04 边界 */
+#endif
+#ifndef PHASE5_CONN_TIMEOUT_MS
+#define PHASE5_CONN_TIMEOUT_MS 15000
+#endif
+#define PHASE5_TX_TIMEOUT_MS 2000 /* 单块 SENBUF_FREE 等待上限 */
+#define PHASE5_RX_STALL_TIMEOUT_MS 5000 /* 发送完成后 RX 无进展上限 */
+
+/* 32 位累加和:足以发现丢字节/错位,比 CRC32 便宜 */
+static uint32_t phase5_sum32(const uint8_t *p, uint32_t n) {
+ uint32_t s = 0;
+ while (n--) s += *p++;
+ return s;
+}
+
+/* 按块索引确定性生成模式数据(LCG):发送与回读两侧可独立复现,逐字节比对 */
+static void phase5_gen_block(uint8_t *buf, uint32_t idx) {
+ uint32_t seed = 0xC2D2E6F9u ^ (idx * 2654435761u);
+ uint32_t k;
+
+ for (k = 0; k < PHASE5_CHUNK_SIZE; k++) {
+ seed = seed * 1664525u + 1013904223u;
+ buf[k] = (uint8_t)(seed >> 24);
+ }
+}
+
+static void phase5_run(void) {
+ static uint8_t tx[PHASE5_CHUNK_SIZE];
+ static uint8_t rx[PHASE5_CHUNK_SIZE];
+ static uint8_t exp[PHASE5_CHUNK_SIZE];
+ uint8_t sock = 0;
+ uint8_t ip_arr[4];
+ int chunks;
+ int bad = 0;
+ int conn_ok = 0;
+ int blk_tx = 0;
+ int blk_rx = 0;
+ int can_write = 1;
+ int progress_64k = -1;
+ uint32_t send_bytes;
+ uint32_t sum_tx = 0;
+ uint32_t sum_rx = 0;
+ uint32_t rx_total = 0;
+ uint32_t exp_off = 0;
+ uint32_t rx_stall = 0;
+ uint32_t tx_sw = 0;
+ uint32_t t0;
+
+ DBG_INFO("=== CH395F Phase 5 Tests (HW Bulk Transfer) ===");
+ DBG_INFO(" target %s:%d, %d bytes x %d B/chunk",
+ PHASE5_REMOTE_IP, PHASE5_REMOTE_PORT,
+ PHASE5_TOTAL_BYTES, PHASE5_CHUNK_SIZE);
+
+ /*
+ * 步1:裸命令建立 TCP 连接。
+ * 先 close 清理上轮残留(结果不关心),再配置并 connect。
+ */
+ (void)ch395f_close_socket(sock);
+ HAL_Delay(50);
+ ch395f_set_proto_type(sock, CH395F_PROTO_TYPE_TCP);
+ test_parse_ip(PHASE5_REMOTE_IP, ip_arr);
+ ch395f_set_des_ip(sock, ip_arr);
+ ch395f_set_des_port(sock, PHASE5_REMOTE_PORT);
+ ch395f_set_sour_port(sock, PHASE5_LOCAL_PORT);
+ TEST_CHECK(ch395f_open_socket(sock) == CH395F_ERR_SUCCESS &&
+ ch395f_tcp_connect(sock) == CH395F_ERR_SUCCESS,
+ "step1 open+connect issued");
+ if (ch395f_get_cmd_status() != CH395F_ERR_SUCCESS) {
+ TEST_REPORT("Phase 5");
+ return;
+ }
+
+ t0 = HAL_GetTick();
+ while (HAL_GetTick() - t0 < PHASE5_CONN_TIMEOUT_MS) {
+ uint16_t gs = ch395f_get_glob_int_status_all();
+ if ((gs & (1U << (sock + 4))) &&
+ (ch395f_get_sock_int_status(sock) & CH395F_SINT_STAT_CONNECT)) {
+ conn_ok = 1;
+ break;
+ }
+ HAL_Delay(10);
+ }
+ TEST_CHECK(conn_ok, "connected within %dms", PHASE5_CONN_TIMEOUT_MS);
+ if (!conn_ok) {
+ (void)ch395f_close_socket(sock);
+ TEST_REPORT("Phase 5");
+ return;
+ }
+
+ /*
+ * 步2A:连续发送 256KB(单向,PC 只收不回声)。
+ * 节奏:写 4096B → 等 SENBUF_FREE(芯片搬走数据后触发)→ 写下一块,
+ * 全程不等回显,测得纯 TX 吞吐。
+ * 步2B:连续接收 256KB(PC 收到 256KB 后按相同 LCG 模式回放),
+ * 对字节流做滚动校验(期望流按块生成 exp[],字节对位 + sum_rx 累加),
+ * 天然处理 TCP 分包/粘包,测得纯 RX 吞吐。
+ */
+ chunks = PHASE5_TOTAL_BYTES / PHASE5_CHUNK_SIZE;
+ send_bytes = (uint32_t)chunks * PHASE5_CHUNK_SIZE; /* 实际上送字节(4093 档 < TOTAL,余尾不送) */
+
+ /* ---- 步2A:连续发送 ----
+ * 目标:把 chunks×PHASE5_CHUNK_SIZE 字节按 LCG 模式数据一次性连续交出,
+ * 全程不等回显,测得纯 TX 吞吐。
+ *
+ * 发送状态机(can_write 标志):
+ * can_write == 1 : 发送缓冲空闲,可写入下一块
+ * can_write == 0 : 上一块已写入,等待芯片把数据搬出 socket 发送缓冲
+ * (首次进入 can_write 初始为 1,因为连接建立后发送缓冲为空)
+ *
+ * 芯片写节奏约束(CH395 手册 / Trap 记录):
+ * 每次 WRITE_SEND_BUF 后必须收到 SINT_STAT_SENBUF_FREE 才能再次写入,
+ * 否则下次写入会被芯片静默丢弃。SENBUF_FREE 表示芯片已把本次写入的数据
+ * 从 socket 发送缓冲搬到内部协议栈/MAC 缓冲(腾出空间),故每写一块
+ * 就转 can_write=0 等待该事件——这正是"连续发送"的天然流控节拍,
+ * 不会因超过发送缓冲(默认 4096B)而溢出。
+ */
+ {
+ uint32_t tx_t0 = HAL_GetTick(); /* 发送阶段起点:用于计算 TX 吞吐 */
+ blk_tx = 0; /* 已交出的块计数 */
+ can_write = 1; /* 初始:连接后发送缓冲为空,可直接写 */
+ while (blk_tx < chunks && !bad) {
+ if (can_write) {
+ /* ---- 发送缓冲空闲:生成并写入一块 ---- */
+ phase5_gen_block(tx, (uint32_t)blk_tx); /* 确定性生成第 blk_tx 块模式(TX/RX 可复现) */
+ sum_tx += phase5_sum32(tx, PHASE5_CHUNK_SIZE); /* 先累加发送侧总账(与 RX 侧对账用) */
+ ch395f_write_send_buf(sock, tx, PHASE5_CHUNK_SIZE); /* 4096B 单次写入(= 发送缓冲上限,DP-04 边界) */
+ blk_tx++; /* 该块已交出 */
+ can_write = 0; /* 进入等待 SENBUF_FREE 状态 */
+ tx_sw = HAL_GetTick(); /* 记录等待起点(供超时判定) */
+ } else {
+ /* ---- 等待上一次写入被芯片搬走(SENBUF_FREE) ----
+ * 两级中断轮询(DP-02):先读全局中断状态确认本 socket 有事件,
+ * 再读该 socket 的中断状态确认具体为 SENBUF_FREE。
+ * 读全局中断状态即清除中断标志(读即清)。
+ */
+ uint16_t gs = ch395f_get_glob_int_status_all();
+ if ((gs & (1U << (sock + 4))) && /* socket 中断位(socket 0 → bit 4) */
+ (ch395f_get_sock_int_status(sock) & CH395F_SINT_STAT_SENBUF_FREE)) {
+ can_write = 1; /* 缓冲已腾空,下一轮写入下一块 */
+ } else if (HAL_GetTick() - tx_sw >= PHASE5_TX_TIMEOUT_MS) {
+ /* 超时:芯片迟迟未腾出缓冲 —— 对端未收/链路异常/芯片堵死 */
+ bad++;
+ DBG_ERROR("TX SENBUF_FREE stall @chunk %d", blk_tx);
+ break;
+ }
+ }
+ /* ---- 进度打印(每交出 64KB 打一行) ---- */
+ if ((int)(((uint32_t)blk_tx * PHASE5_CHUNK_SIZE) / (64 * 1024)) != progress_64k) {
+ progress_64k = (int)(((uint32_t)blk_tx * PHASE5_CHUNK_SIZE) / (64 * 1024));
+ DBG_INFO(" TX %d/%d blocks (%lu bytes)", blk_tx, chunks,
+ (uint32_t)blk_tx * PHASE5_CHUNK_SIZE);
+ }
+ }
+ /* 全部块已写入发送缓冲即视为发送完成:最后一块已交给芯片,
+ * 无需再等其 SENBUF_FREE,数据会随 TCP 正常发往对端。 */
+ TEST_CHECK(bad == 0, "TX phase: %d/%d blocks (%lu bytes)",
+ blk_tx, chunks, (uint32_t)blk_tx * PHASE5_CHUNK_SIZE);
+ {
+ uint32_t ms = HAL_GetTick() - tx_t0;
+ DBG_INFO(" TX throughput: %lu bytes in %lums (%lu KB/s)",
+ (uint32_t)blk_tx * PHASE5_CHUNK_SIZE, ms,
+ ms > 0 ? (uint32_t)(((uint32_t)blk_tx * PHASE5_CHUNK_SIZE) / ms) : 0u);
+ }
+ }
+
+ /* ---- 步2B:连续接收 ----
+ * 目标:PC 收到 256KB 后按相同 LCG 模式回放,MCU 连续排空接收缓冲并对
+ * 字节流做滚动校验,测得纯 RX 吞吐。
+ *
+ * 滚动校验原理:
+ * 期望流按块确定性生成,同一时刻只保留当前块的 exp[](内存 O(CHUNK))。
+ * exp_off 指向当前期望块内的偏移;回显流可能分包/粘包,故按"字节流"消费:
+ * 每次读到 rlen 字节 → 切成若干段(take,每段不超过当前期望块剩余)逐字节
+ * 与 exp[exp_off+k] 比对,同时累加 sum_rx;当前块消费完(exp_off==CHUNK)
+ * 则回绕并生成下一块期望 —— 与 TCP 的分包/粘包边界完全解耦。
+ *
+ * 停滞检测(rx_stall):
+ * 记录"最后收到数据"的时刻,>PHASE5_RX_STALL_TIMEOUT_MS 无新数据即失败。
+ * 用最后进度而非阶段起点,是为了兼容 PC 端回放开始的延迟与块间间隙。
+ */
+ if (!bad) {
+ uint32_t rx_t0 = HAL_GetTick(); /* 接收阶段起点:用于计算 RX 吞吐 */
+ exp_off = 0; /* 当前期望块内的消费偏移 */
+ blk_rx = 0; /* 已完整校验的块数 */
+ rx_total = 0; /* 已接收字节总数 */
+ rx_stall = rx_t0; /* 最后收到数据的时刻(停滞检测基准) */
+ progress_64k = -1; /* 重置进度打印基准(TX 阶段已推进过) */
+ phase5_gen_block(exp, 0); /* 预生成第 0 块期望数据 */
+ while (!bad && rx_total < send_bytes) {
+ /* ---- 排空接收缓冲:一次可能读出多包数据,全部消费完再进入下一步 ---- */
+ for (;;) {
+ uint16_t rlen = ch395f_get_recv_len(sock); /* 查询当前可读字节数 */
+ if (rlen == 0) {
+ break; /* 缓冲空,跳出排空循环 */
+ }
+ if (rlen > PHASE5_CHUNK_SIZE) {
+ rlen = PHASE5_CHUNK_SIZE; /* 单次读取上限 = 块大小(DP-04 4KB DMA 边界) */
+ }
+ ch395f_read_recv_buf(sock, rx, rlen); /* 一次 SPI 事务读走 rlen 字节 */
+ {
+ uint32_t off = 0; /* 本次读取数据内的消费偏移 */
+ while (off < rlen) {
+ uint32_t take = PHASE5_CHUNK_SIZE - exp_off; /* 当前期望块剩余 */
+ uint32_t k;
+ if (take > (uint32_t)(rlen - off)) {
+ take = rlen - off; /* 截断:本次读取只消费到块边界为止 */
+ }
+ for (k = 0; k < take; k++) {
+ uint8_t b = rx[off + k];
+ if (b != exp[exp_off + k]) {
+ bad++; /* 逐字节比对失败(定位精确偏移) */
+ DBG_ERROR("rx mismatch @%lu", rx_total + off + k);
+ }
+ sum_rx += b; /* 同时累加接收侧总账 */
+ }
+ off += take;
+ exp_off += take;
+ rx_total += take;
+ if (exp_off == PHASE5_CHUNK_SIZE) {
+ exp_off = 0; /* 当前块消费完:回绕并预生成下一块期望 */
+ blk_rx++;
+ if (blk_rx < chunks) {
+ phase5_gen_block(exp, blk_rx);
+ }
+ }
+ }
+ }
+ rx_stall = HAL_GetTick(); /* 有数据到达:推进停滞检测基准 */
+ }
+ if (bad) {
+ break;
+ }
+ /* ---- 停滞保护:发送方已回放完或链路异常,迟迟无新数据 ---- */
+ if (HAL_GetTick() - rx_stall >= PHASE5_RX_STALL_TIMEOUT_MS) {
+ bad++;
+ DBG_ERROR("RX stall @%lu/%lu", rx_total, send_bytes);
+ break;
+ }
+ /* ---- 进度打印(每收到 64KB 打一行) ---- */
+ if ((int)(rx_total / (64 * 1024)) != progress_64k) {
+ progress_64k = (int)(rx_total / (64 * 1024));
+ DBG_INFO(" RX %lu/%lu bytes (%d blocks)", rx_total, send_bytes, blk_rx);
+ }
+ HAL_Delay(2); /* 轮询间隔:让出总线/降低 SPI 事务频率 */
+ }
+ TEST_CHECK(bad == 0, "RX phase: %lu/%lu bytes (%d blocks)", rx_total, send_bytes, blk_rx);
+ {
+ uint32_t ms = HAL_GetTick() - rx_t0;
+ DBG_INFO(" RX throughput: %lu bytes in %lums (%lu KB/s)",
+ rx_total, ms,
+ ms > 0 ? (uint32_t)(rx_total / ms) : 0u);
+ }
+ }
+ TEST_CHECK(sum_tx == sum_rx, "checksum TX==RX (%08x/%08x)", sum_tx, sum_rx);
+
+ /* 步3:关闭,PC 侧应统计到收满 256KB(校验一致)并回放完成 */
+ ch395f_close_socket(sock);
+ TEST_CHECK(1, "socket closed");
+ TEST_REPORT("Phase 5");
+}
+#endif
+/* ===================================================================
+ * Phase 6 — NET 层 TCP Echo(基础收发)
+ *
+ * 测试目的:验证 BSD Socket API(net_socket)的单连接 TCP Echo 通路。
+ * Socket 0 复用监听和数据通道。PC 发任意数据,MCU 原样返回。
+ * 这是 Phase 7/8/9/10 的基础。
+ *
+ * 入口条件:Socket 0 处于 ESTABLISHED(TCP 连接已建立)。
+ * 通过:数据收发一致。
+ * 失败:send/recv 数量不匹配。
+ * =================================================================== */
+
+#ifdef ENABLE_PHASE6_TESTS
+static uint32_t s_phase6_count = 0;
+
+static void phase6_run(int sockfd) {
+ /*
+ * 使用 NET_MSG_DONTWAIT 非阻塞接收 —— 没有数据时立即返回,
+ * 不阻塞任务循环(Phase 7/8/9/10 也共享同一个循环)。
+ * 收到数据后立即原样发送回显。
+ */
+ int n = net_recv(sockfd, s_rx_buf, TEST_BUF_SIZE, NET_MSG_DONTWAIT);
+ if (n > 0) {
+ int sent = net_send(sockfd, s_rx_buf, n, 0);
+ if (sent != n) {
+ DBG_ERROR("echo: send %d != recv %d", sent, n);
+ return;
+ }
+ s_phase6_count++;
+ if (s_phase6_count <= 10 || (s_phase6_count % 100 == 0)) {
+ DBG_INFO("Phase6: echo #%lu (%d bytes)", s_phase6_count, n);
+ }
+ }
+}
+#endif
+
+/* ===================================================================
+ * Phase 7 — 大文件传输(超过 CH395F 硬件缓冲 4KB)
+ *
+ * 测试目的:验证超过 Socket 0 接收缓冲(4KB)的数据在 net_send/
+ * net_recv 层的正确处理。net_send_locked 自动将大数据
+ * 拆分为 ≤4096B 的块,每块通过一次 DMA 事务写入 CH395F。
+ * 接收端同样分多次调用 ch395f_read_recv_buf 读空硬件缓冲。
+ *
+ * 数据模式:递增字节(s_tx_buf[i] = i & 0xFF),接收端按 offset 逐字节比对。
+ * 通过:全部 20480 字节逐字节匹配。
+ * 失败:任意字节不一致或收发过程中断。
+ * =================================================================== */
+
+#ifdef ENABLE_PHASE7_TESTS
+#define PHASE7_FILE_SIZE 20480
+
+static void phase7_fill(uint8_t *buf, uint32_t size) {
+ for (uint32_t i = 0; i < size; i++) {
+ buf[i] = (uint8_t)(i & 0xFF);
+ }
+}
+
+static int phase7_verify(uint8_t *buf, uint32_t size, uint32_t offset) {
+ for (uint32_t i = 0; i < size; i++) {
+ if (buf[i] != (uint8_t)((offset + i) & 0xFF)) {
+ DBG_ERROR("Phase7: mismatch at %lu (expect 0x%02X, got 0x%02X)",
+ offset + i, (uint8_t)((offset + i) & 0xFF), buf[i]);
+ return 0;
+ }
+ }
+ return 1;
+}
+
+static void phase7_run(int sockfd) {
+ DBG_INFO("Phase7: starting %d-byte file transfer", PHASE7_FILE_SIZE);
+
+ phase7_fill(s_tx_buf, PHASE7_FILE_SIZE);
+
+ /*
+ * 发送阶段:分块发送,每块最多 4096B。
+ * net_send 内部通过消息队列转发到 netTask,由 net_send_locked
+ * 按 CH395F_SPI_DMA_MAX_PAYLOAD(4096)自动拆分 DMA 事务。
+ * 等待 PC 端回显(echod)全部数据。
+ */
+ uint32_t sent = 0;
+ while (sent < PHASE7_FILE_SIZE) {
+ int chunk = (PHASE7_FILE_SIZE - sent) > 4096 ? 4096 : (PHASE7_FILE_SIZE - sent);
+ int n = net_send(sockfd, s_tx_buf + sent, chunk, 0);
+ if (n <= 0) {
+ DBG_ERROR("Phase7: send fail at %lu (ret=%d)", sent, n);
+ return;
+ }
+ sent += (uint32_t)n;
+ DBG_INFO("Phase7: sent %lu/%d", sent, PHASE7_FILE_SIZE);
+ }
+
+ /*
+ * 接收阶段:分块接收,逐块验证。
+ * PC 回显数据需与发送数据逐字节一致(递增模式)。
+ * 验证失败立即返回,不继续接收剩余数据。
+ */
+ uint32_t recvd = 0;
+ while (recvd < PHASE7_FILE_SIZE) {
+ int n = net_recv(sockfd, s_rx_buf, TEST_BUF_SIZE, 0);
+ if (n <= 0) {
+ DBG_ERROR("Phase7: recv fail at %lu (ret=%d)", recvd, n);
+ return;
+ }
+ int ok = phase7_verify(s_rx_buf, (uint32_t)n, recvd);
+ TEST_CHECK(ok, "Phase7: verify at %lu (%d bytes)", recvd, n);
+ if (!ok) return;
+ recvd += (uint32_t)n;
+ }
+
+ TEST_CHECK(1, "Phase7: %d-byte file transfer complete", PHASE7_FILE_SIZE);
+}
+#endif
+
+/* ===================================================================
+ * Phase 8 — Select/Poll I/O 多路复用
*
* 测试目的:验证 net_select() API 在单 Socket 模式下正确工作:
* 1. Socket 0 有数据到达时 select 返回正数
@@ -711,11 +1478,11 @@ phase6_end:
* 失败:select 未检测到数据或回显失败。
* =================================================================== */
-#ifdef ENABLE_PHASE7_TESTS
+#ifdef ENABLE_PHASE8_TESTS
#include "net_select.h"
-static uint32_t s_phase7_count = 0;
+static uint32_t s_phase8_count = 0;
-static void phase7_run(int sockfd) {
+static void phase8_run(int sockfd) {
net_fd_set readfds;
net_timeval tv;
@@ -738,8 +1505,8 @@ static void phase7_run(int sockfd) {
if (n > 0) {
int sent = net_send(sockfd, s_rx_buf, n, 0);
if (sent == n) {
- s_phase7_count++;
- TEST_CHECK(1, "Phase7: select echo #%lu (%d bytes)", s_phase7_count, n);
+ s_phase8_count++;
+ TEST_CHECK(1, "Phase8: select echo #%lu (%d bytes)", s_phase8_count, n);
}
}
}
@@ -747,7 +1514,7 @@ static void phase7_run(int sockfd) {
#endif
/* ===================================================================
- * Phase 8 — 边界条件测试
+ * Phase 9 — 边界条件测试
*
* 测试目的:验证以下 DMA 和协议栈边界情况:
* 1. TC-NET-801: 4095B(SPI 最大载荷 -1,单次 DMA 容纳)
@@ -756,7 +1523,7 @@ static void phase7_run(int sockfd) {
* 4. TC-NET-804: 零长度发送(返回 -1)
* 5. TC-NET-805: 20 × 100B 连续快速发送
*
- * 各用例通过状态机(s_phase8_stage)串行执行,每次 phase8_run 推进一个
+ * 各用例通过状态机(s_phase9_stage)串行执行,每次 phase9_run 推进一个
* 步骤(发送→等待→接收→验证→下一阶段)。发送数据为递增模式字节
* (buf[i] = seed + i),接收端按相同模式验证。
*
@@ -764,128 +1531,128 @@ static void phase7_run(int sockfd) {
* 通过:各用例自身判定。
* =================================================================== */
-#ifdef ENABLE_PHASE8_TESTS
-static int s_phase8_stage = 0;
-static uint32_t s_phase8_recv = 0;
+#ifdef ENABLE_PHASE9_TESTS
+static int s_phase9_stage = 0;
+static uint32_t s_phase9_recv = 0;
-static void phase8_fill(uint8_t *buf, uint32_t size, uint8_t seed) {
+static void phase9_fill(uint8_t *buf, uint32_t size, uint8_t seed) {
for (uint32_t i = 0; i < size; i++) {
buf[i] = (uint8_t)(seed + i);
}
}
-static int phase8_verify(uint8_t *buf, uint32_t size, uint8_t seed) {
+static int phase9_verify(uint8_t *buf, uint32_t size, uint8_t seed) {
for (uint32_t i = 0; i < size; i++) {
if (buf[i] != (uint8_t)(seed + i)) return 0;
}
return 1;
}
-static void phase8_run(int sockfd) {
+static void phase9_run(int sockfd) {
/* 阶段 0 → 1:发送 4095B */
- if (s_phase8_stage == 0) {
- DBG_INFO("Phase8: 4095B (DMA-1)");
- phase8_fill(s_tx_buf, 4095, 0x10);
+ if (s_phase9_stage == 0) {
+ DBG_INFO("Phase9: 4095B (DMA-1)");
+ phase9_fill(s_tx_buf, 4095, 0x10);
int sent = net_send(sockfd, s_tx_buf, 4095, 0);
- TEST_CHECK(sent == 4095, "Phase8: send 4095B (sent=%d)", sent);
- s_phase8_recv = 0;
- s_phase8_stage = 1;
+ TEST_CHECK(sent == 4095, "Phase9: send 4095B (sent=%d)", sent);
+ s_phase9_recv = 0;
+ s_phase9_stage = 1;
return;
}
/* 阶段 1:接收并验证 4095B 回显 */
- if (s_phase8_stage == 1) {
- int n = net_recv(sockfd, s_rx_buf + s_phase8_recv, (int)(4095 - s_phase8_recv), 0);
+ if (s_phase9_stage == 1) {
+ int n = net_recv(sockfd, s_rx_buf + s_phase9_recv, (int)(4095 - s_phase9_recv), 0);
if (n > 0) {
- s_phase8_recv += (uint32_t)n;
- if (s_phase8_recv >= 4095) {
- TEST_CHECK(phase8_verify(s_rx_buf, 4095, 0x10), "Phase8: verify 4095B");
- s_phase8_stage = 2;
+ s_phase9_recv += (uint32_t)n;
+ if (s_phase9_recv >= 4095) {
+ TEST_CHECK(phase9_verify(s_rx_buf, 4095, 0x10), "Phase9: verify 4095B");
+ s_phase9_stage = 2;
}
}
return;
}
/* 阶段 2 → 3:发送 4096B(DMA 边界精确值) */
- if (s_phase8_stage == 2) {
- DBG_INFO("Phase8: 4096B (DMA exact)");
- phase8_fill(s_tx_buf, 4096, 0x20);
+ if (s_phase9_stage == 2) {
+ DBG_INFO("Phase9: 4096B (DMA exact)");
+ phase9_fill(s_tx_buf, 4096, 0x20);
int sent = net_send(sockfd, s_tx_buf, 4096, 0);
- TEST_CHECK(sent == 4096, "Phase8: send 4096B (sent=%d)", sent);
- s_phase8_recv = 0;
- s_phase8_stage = 3;
+ TEST_CHECK(sent == 4096, "Phase9: send 4096B (sent=%d)", sent);
+ s_phase9_recv = 0;
+ s_phase9_stage = 3;
return;
}
/* 阶段 3:接收并验证 4096B 回显 */
- if (s_phase8_stage == 3) {
- int n = net_recv(sockfd, s_rx_buf + s_phase8_recv, (int)(4096 - s_phase8_recv), 0);
+ if (s_phase9_stage == 3) {
+ int n = net_recv(sockfd, s_rx_buf + s_phase9_recv, (int)(4096 - s_phase9_recv), 0);
if (n > 0) {
- s_phase8_recv += (uint32_t)n;
- if (s_phase8_recv >= 4096) {
- TEST_CHECK(phase8_verify(s_rx_buf, 4096, 0x20), "Phase8: verify 4096B");
- s_phase8_stage = 4;
+ s_phase9_recv += (uint32_t)n;
+ if (s_phase9_recv >= 4096) {
+ TEST_CHECK(phase9_verify(s_rx_buf, 4096, 0x20), "Phase9: verify 4096B");
+ s_phase9_stage = 4;
}
}
return;
}
/* 阶段 4 → 5:发送 4097B(超过 DMA 上限,自动拆 4096+1) */
- if (s_phase8_stage == 4) {
- DBG_INFO("Phase8: 4097B (DMA+1, 2 SPI xacts)");
- phase8_fill(s_tx_buf, 4097, 0x30);
+ if (s_phase9_stage == 4) {
+ DBG_INFO("Phase9: 4097B (DMA+1, 2 SPI xacts)");
+ phase9_fill(s_tx_buf, 4097, 0x30);
int sent = net_send(sockfd, s_tx_buf, 4097, 0);
- TEST_CHECK(sent == 4097, "Phase8: send 4097B (sent=%d)", sent);
- s_phase8_recv = 0;
- s_phase8_stage = 5;
+ TEST_CHECK(sent == 4097, "Phase9: send 4097B (sent=%d)", sent);
+ s_phase9_recv = 0;
+ s_phase9_stage = 5;
return;
}
/* 阶段 5:接收并验证 4097B 回显 */
- if (s_phase8_stage == 5) {
- int n = net_recv(sockfd, s_rx_buf + s_phase8_recv, (int)(4097 - s_phase8_recv), 0);
+ if (s_phase9_stage == 5) {
+ int n = net_recv(sockfd, s_rx_buf + s_phase9_recv, (int)(4097 - s_phase9_recv), 0);
if (n > 0) {
- s_phase8_recv += (uint32_t)n;
- if (s_phase8_recv >= 4097) {
- TEST_CHECK(phase8_verify(s_rx_buf, 4097, 0x30), "Phase8: verify 4097B");
- s_phase8_stage = 6;
+ s_phase9_recv += (uint32_t)n;
+ if (s_phase9_recv >= 4097) {
+ TEST_CHECK(phase9_verify(s_rx_buf, 4097, 0x30), "Phase9: verify 4097B");
+ s_phase9_stage = 6;
}
}
return;
}
/* 阶段 6:零长度发送 —— 期望 net_send 返回 -1(NET_ERR_INVAL) */
- if (s_phase8_stage == 6) {
- DBG_INFO("Phase8: zero-length send");
+ if (s_phase9_stage == 6) {
+ DBG_INFO("Phase9: zero-length send");
int sent = net_send(sockfd, s_tx_buf, 0, 0);
- TEST_CHECK(sent < 0, "Phase8: send 0B returns %d (expect <0)", sent);
- s_phase8_stage = 7;
+ TEST_CHECK(sent < 0, "Phase9: send 0B returns %d (expect <0)", sent);
+ s_phase9_stage = 7;
return;
}
/* 阶段 7:20 × 100B 快速发送 */
- if (s_phase8_stage == 7) {
- DBG_INFO("Phase8: 20x rapid sends (100B each)");
- phase8_fill(s_tx_buf, 100, 0x40);
+ if (s_phase9_stage == 7) {
+ DBG_INFO("Phase9: 20x rapid sends (100B each)");
+ phase9_fill(s_tx_buf, 100, 0x40);
int all_ok = 1;
for (int i = 0; i < 20; i++) {
if (net_send(sockfd, s_tx_buf, 100, 0) != 100) {
- TEST_CHECK(0, "Phase8: rapid #%d fail", i + 1);
+ TEST_CHECK(0, "Phase9: rapid #%d fail", i + 1);
all_ok = 0; break;
}
osDelay(1);
}
if (all_ok) {
- TEST_CHECK(1, "Phase8: 20x rapid sends OK");
- s_phase8_recv = 0;
- s_phase8_stage = 8;
+ TEST_CHECK(1, "Phase9: 20x rapid sends OK");
+ s_phase9_recv = 0;
+ s_phase9_stage = 8;
} else {
- s_phase8_stage = 0;
+ s_phase9_stage = 0;
}
return;
}
/* 阶段 8:接收 2000B 回显总和并验证 */
- if (s_phase8_stage == 8) {
- int n = net_recv(sockfd, s_rx_buf + s_phase8_recv, (int)(2000 - s_phase8_recv), 0);
+ if (s_phase9_stage == 8) {
+ int n = net_recv(sockfd, s_rx_buf + s_phase9_recv, (int)(2000 - s_phase9_recv), 0);
if (n > 0) {
- s_phase8_recv += (uint32_t)n;
- if (s_phase8_recv >= 2000) {
- TEST_CHECK(1, "Phase8: all echo received");
- TEST_REPORT("Phase 8");
- s_phase8_stage = 0;
+ s_phase9_recv += (uint32_t)n;
+ if (s_phase9_recv >= 2000) {
+ TEST_CHECK(1, "Phase9: all echo received");
+ TEST_REPORT("Phase 9");
+ s_phase9_stage = 0;
}
}
return;
@@ -893,72 +1660,6 @@ static void phase8_run(int sockfd) {
}
#endif
-/* ===================================================================
- * Phase 9 — PHY 链路恢复
- *
- * 测试目的:验证 CH395F 的 PHY 状态监测功能:
- * 1. 拔网线后 net_poll 检测到 PHY_CHANGE 中断并识别 DISCONN
- * 2. 插回网线后 PHY 自动恢复连接
- *
- * 需物理操作(拔插网线),测试会等待最多 15s 检测断开、30s 检测重连。
- * 通过:断开和重连均被检测到。
- * 失败:任意步骤超时。
- * =================================================================== */
-
-#ifdef ENABLE_PHASE9_TESTS
-static void phase9_run(void) {
- DBG_INFO("=== CH395F Phase 9 Tests (PHY Recovery) ===");
-
- /*
- * 第一步:等待 PHY 断开(需拔网线)。
- * 轮询 GINT 状态寄存器中的 PHY_CHANGE 位,
- * 然后读取 PHY 状态确认是否为 DISCONN。
- * 超时 15 秒 —— 若超时未检测到,提示拔网线。
- */
- uint8_t phy_disconnected = 0;
- uint32_t wait = HAL_GetTick();
- while (HAL_GetTick() - wait < 15000) {
- if (ch395f_get_glob_int_status_all() & CH395F_GINT_STAT_PHY_CHANGE) {
- if (ch395f_get_phy_status() == CH395F_PHY_DISCONN) {
- TEST_CHECK(1, "PHY disconnect detected");
- phy_disconnected = 1;
- break;
- }
- }
- HAL_Delay(100);
- }
- if (!phy_disconnected) {
- TEST_CHECK(0, "PHY disconnect NOT detected (unplug cable?)");
- goto phase9_end;
- }
-
- /*
- * 第二步:等待 PHY 重连(需插回网线)。
- * 同样检测 PHY_CHANGE 中断,然后读取 PHY 状态确认不是 DISCONN。
- * 超时 30 秒。
- */
- uint8_t phy_reconnected = 0;
- wait = HAL_GetTick();
- while (HAL_GetTick() - wait < 30000) {
- if (ch395f_get_glob_int_status_all() & CH395F_GINT_STAT_PHY_CHANGE) {
- uint8_t phy = ch395f_get_phy_status();
- if (phy != CH395F_PHY_DISCONN) {
- TEST_CHECK(1, "PHY reconnected (0x%02X)", phy);
- phy_reconnected = 1;
- break;
- }
- }
- HAL_Delay(100);
- }
- if (!phy_reconnected) {
- TEST_CHECK(0, "PHY reconnect NOT detected (re-plug cable?)");
- }
-
-phase9_end:
- TEST_REPORT("Phase 9");
-}
-#endif
-
/* ===================================================================
* Phase 10 — TCP KeepAlive 超时断开
*
@@ -1003,11 +1704,13 @@ static void phase10_run(int sockfd) {
/* ===================================================================
* 任务入口:StartCh395fTestTask
*
- * 执行顺序:
+ * 执行顺序(按构建模式二选一,见 docs/CH395F_Test_Guide.md「构建模式与执行顺序」):
+ * 硬件层模式(阶段 1~5):netTask 不创建,本任务调用
+ * net_stack_bring_up() 完成协议栈初始化后独占 CH395F 阻塞执行。
+ * NET 层模式(阶段 6~10):
* 1. 等待 g_net_ready(netTask 初始化完成标志)
- * 2. 阻塞执行 Phase 1/2/3/6/9(各 Phase 内部有独立循环和等待)
- * 3. 创建 TCP 监听 Socket(单连接模式,端口 8080)
- * 4. 进入事件驱动循环,等待 PC 连接并执行 Phase 4/5/7/8/10
+ * 2. 创建 TCP 监听 Socket(单连接模式,端口 8080)
+ * 3. 进入事件驱动循环,等待 PC 连接并执行 NET 层测试
*
* 单连接模式说明:
* Socket 0 复用监听和数据通道。accept 返回的 fd 与监听 fd 相同。
@@ -1019,22 +1722,33 @@ void StartCh395fTestTask(void *argument)
{
(void)argument;
+#if defined(ENABLE_NET_LAYER_TESTS)
int sockfd = -1;
int phase_active = 0;
uint32_t accept_retry = 0;
struct net_sockaddr_in client_addr;
int addrlen = sizeof(client_addr);
+#endif
- DBG_INFO("Test task started, waiting for netTask...");
+ DBG_INFO("Test task started");
- /* 等待 netTask 完成 net_init() 及 CH395F 初始化 */
+#if defined(ENABLE_HW_LAYER_TESTS)
+ /* 硬件层模式(阶段 1~5):netTask 未创建,由本任务完成一次性协议栈
+ * 初始化并独占 CH395F —— 无 net_poll() 并发读取中断,无 SPI 并发事务 */
+ if (net_stack_bring_up() != 0) {
+ DBG_ERROR("net stack bring-up FAIL");
+ goto task_end;
+ }
+#else
+ /* NET 层模式(阶段 6~10):等待 netTask 完成 net_init() 及 CH395F 初始化 */
while (!g_net_ready) {
osDelay(100);
}
DBG_INFO("netTask ready");
+#endif
/* ==================== 阻塞阶段 ====================
- * Phase 1/2/3/6/9 在 TCP 监听之前执行,不依赖外部连接。
+ * Phase 1~5(硬件层)在 TCP 监听之前执行,不依赖外部连接。
* 各 Phase 有各自的测试逻辑,完成后继续下一 Phase。
*/
#ifdef ENABLE_PHASE1_TESTS
@@ -1046,14 +1760,15 @@ void StartCh395fTestTask(void *argument)
#ifdef ENABLE_PHASE3_TESTS
phase3_run();
#endif
-#ifdef ENABLE_PHASE6_TESTS
- phase6_run();
+#ifdef ENABLE_PHASE4_TESTS
+ phase4_run();
#endif
-#ifdef ENABLE_PHASE9_TESTS
- phase9_run();
+#ifdef ENABLE_PHASE5_TESTS
+ phase5_run();
#endif
- /* ==================== 创建 TCP 监听 ==================== */
+#ifdef ENABLE_NET_LAYER_TESTS
+ /* ==================== 创建 TCP 监听(NET 层模式) ==================== */
DBG_INFO("Creating test socket...");
sockfd = net_socket(NET_AF_INET, NET_SOCK_STREAM, 0);
@@ -1082,7 +1797,7 @@ void StartCh395fTestTask(void *argument)
DBG_INFO("Test task: listening on 8080 (single-socket mode)");
/* ==================== 事件驱动阶段 ====================
- * Phase 4/5/7/8/10 在 TCP 监听循环中运行,需要 PC 客户端连接。
+ * Phase 6~10(NET 层)在 TCP 监听循环中运行,需要 PC 客户端连接。
* 没有连接时循环等待;连接建立后执行对应 Phase。
* 断开后自动重新 listen。
*/
@@ -1102,8 +1817,8 @@ void StartCh395fTestTask(void *argument)
DBG_INFO("Test task: client accepted (fd=%d)", acc);
/* 连接建立,重置各 Phase 内部状态 */
-#ifdef ENABLE_PHASE8_TESTS
- s_phase8_stage = 0;
+#ifdef ENABLE_PHASE9_TESTS
+ s_phase9_stage = 0;
#endif
#ifdef ENABLE_PHASE10_TESTS
s_phase10_armed = 0;
@@ -1111,19 +1826,19 @@ void StartCh395fTestTask(void *argument)
}
/* 每 10ms 依次执行各已启用 Phase */
-#ifdef ENABLE_PHASE4_TESTS
- phase4_run(sockfd);
-#endif
-#ifdef ENABLE_PHASE5_TESTS
- phase5_run(sockfd);
- phase_active = 0; /* Phase 5 一次性完成,发完即止 */
+#ifdef ENABLE_PHASE6_TESTS
+ phase6_run(sockfd);
#endif
#ifdef ENABLE_PHASE7_TESTS
phase7_run(sockfd);
+ phase_active = 0; /* Phase 7 一次性完成,发完即止 */
#endif
#ifdef ENABLE_PHASE8_TESTS
phase8_run(sockfd);
#endif
+#ifdef ENABLE_PHASE9_TESTS
+ phase9_run(sockfd);
+#endif
#ifdef ENABLE_PHASE10_TESTS
phase10_run(sockfd);
#endif
@@ -1146,6 +1861,7 @@ void StartCh395fTestTask(void *argument)
osDelay(10);
}
+#endif /* ENABLE_NET_LAYER_TESTS */
task_end:
for (;;) {