From 615a9b13e91aeafdeb08b5137d47668370c9c9cd Mon Sep 17 00:00:00 2001 From: wandering1 <1624155937@qq.com> Date: Fri, 28 Aug 2026 12:22:10 +0800 Subject: [PATCH] =?UTF-8?q?FTP=20=E6=B5=8B=E8=AF=95=E9=80=9A=E8=BF=87?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Drivers/BSP/NET/net_socket.c | 1 - MDK-ARM/build_log.txt | 64 +++---- Src/freertos.c | 26 ++- docs/FTP_Test_Guide.md | 168 ++++++++++++++++++ .../ftp_speed_test.cpython-311.pyc | Bin 0 -> 13447 bytes test/__pycache__/ftp_test.cpython-311.pyc | Bin 0 -> 11885 bytes .../ftp_up_dl_test.cpython-311.pyc | Bin 0 -> 18966 bytes test/ftp_speed_test.py | 121 ++++++++----- test/ftp_test.py | 82 ++++++--- test/ftp_up_dl_test.py | 103 +++++++---- 10 files changed, 437 insertions(+), 128 deletions(-) create mode 100644 docs/FTP_Test_Guide.md create mode 100644 test/__pycache__/ftp_speed_test.cpython-311.pyc create mode 100644 test/__pycache__/ftp_test.cpython-311.pyc create mode 100644 test/__pycache__/ftp_up_dl_test.cpython-311.pyc diff --git a/Drivers/BSP/NET/net_socket.c b/Drivers/BSP/NET/net_socket.c index ca388e7..e67d99b 100644 --- a/Drivers/BSP/NET/net_socket.c +++ b/Drivers/BSP/NET/net_socket.c @@ -946,7 +946,6 @@ static int net_recv_locked(net_sock_t *p_sock, void *buf, int len, int flags) { ch395f_read_recv_buf(sockfd, (uint8_t *)buf, (uint16_t)read_len); p_sock->recv_bytes += (uint32_t)read_len; p_sock->readable = 0; /* 已消费数据（注：部分读受 Trap 13 限制，下一次 RECV_OK 会重新置位） */ - HAL_Delay(1); /* 等待 CH395F 刷新 recv_len 寄存器 */ return read_len; } diff --git a/MDK-ARM/build_log.txt b/MDK-ARM/build_log.txt index f50e611..1389fc3 100644 --- a/MDK-ARM/build_log.txt +++ b/MDK-ARM/build_log.txt @@ -1,74 +1,74 @@ *** Using Compiler 'V5.06 update 7 (build 960)', folder: 'C:\Keil_v5\ARM\ARMCC\Bin' Rebuild target 'STM32F407-Demo' assembling startup_stm32f407xx.s... -compiling crc.c... compiling ringbuf.c... +compiling crc.c... compiling stm32f4xx_hal_flash_ramfunc.c... compiling stm32f4xx_hal_gpio.c... -compiling stm32f4xx_hal_msp.c... compiling i2c.c... -compiling stm32f4xx_hal_dma_ex.c... -compiling stm32f4xx_hal_dma.c... +compiling stm32f4xx_hal_msp.c... compiling stm32f4xx_hal_timebase_tim.c... +compiling dma.c... +compiling stm32f4xx_hal_dma_ex.c... +compiling spi.c... +compiling stm32f4xx_hal_flash_ex.c... +compiling stm32f4xx_hal_dma.c... compiling stm32f4xx_it.c... -compiling usart.c... compiling stm32f4xx_hal_flash.c... compiling sys_clock.c... -compiling app_main.c... -compiling spi.c... -compiling gpio.c... -compiling dma.c... -compiling rs485_task.c... compiling stm32f4xx_hal_rcc_ex.c... -compiling adc_task.c... -compiling stm32f4xx_hal_flash_ex.c... -compiling freertos.c... +compiling stm32f4xx_hal_tim_ex.c... +compiling app_main.c... +compiling gpio.c... +compiling usart.c... compiling stm32f4xx_hal_rcc.c... +compiling rs485_task.c... +compiling adc_task.c... +compiling freertos.c... compiling main.c... compiling net_task.c... -compiling stm32f4xx_hal_tim_ex.c... -compiling stm32f4xx_hal_tim.c... compiling lftpd_string.c... +compiling stm32f4xx_hal_tim.c... compiling croutine.c... compiling event_groups.c... compiling list.c... compiling queue.c... compiling stream_buffer.c... +compiling stm32f4xx_hal_pwr.c... compiling timers.c... compiling tasks.c... compiling heap_4.c... compiling port.c... compiling journal.c... -compiling stm32f4xx_hal_pwr.c... compiling map.c... -compiling stm32f4xx_hal_pwr_ex.c... compiling ff.c... -compiling stm32f4xx_hal_i2c_ex.c... -compiling stm32f4xx_hal.c... -compiling stm32f4xx_hal_cortex.c... +compiling stm32f4xx_hal_pwr_ex.c... compiling stm32f4xx_hal_exti.c... -compiling sd2506.c... -compiling cmsis_os2.c... -compiling stm32f4xx_hal_spi.c... +compiling stm32f4xx_hal_i2c_ex.c... +compiling stm32f4xx_hal_cortex.c... +compiling stm32f4xx_hal.c... compiling system_stm32f4xx.c... +compiling sd2506.c... compiling rs485.c... -compiling gd5f2gq5ue.c... -compiling nand_ftl.c... +compiling stm32f4xx_hal_spi.c... +compiling ch395f.c... +compiling cmsis_os2.c... compiling lftpd_io.c... compiling tpafe5160.c... -compiling lftpd_inet.c... +compiling nand_ftl.c... +compiling gd5f2gq5ue.c... compiling net_select.c... -compiling stm32f4xx_hal_i2c.c... -compiling ch395f.c... -compiling lftpd.c... compiling stm32f4xx_hal_uart.c... +compiling lftpd_inet.c... +compiling lftpd.c... compiling net_socket.c... +compiling stm32f4xx_hal_i2c.c... compiling ch395f_test_task.c... compiling net_test_task.c... -compiling storage_test_task.c... compiling gd5f_test_task.c... +compiling storage_test_task.c... linking... -Program Size: Code=56352 RO-data=3756 RW-data=228 ZI-data=54044 +Program Size: Code=58880 RO-data=2436 RW-data=408 ZI-data=51872 FromELF: creating hex file... ".\STM32F407-Demo\STM32F407-Demo.axf" - 0 Error(s), 0 Warning(s). -Build Time Elapsed: 00:00:16 +Build Time Elapsed: 00:00:17 diff --git a/Src/freertos.c b/Src/freertos.c index 9bd7ffc..bc0d77c 100644 --- a/Src/freertos.c +++ b/Src/freertos.c @@ -168,9 +168,33 @@ void MX_FREERTOS_Init(void) { void StartDefaultTask(void *argument) { /* USER CODE BEGIN StartDefaultTask */ - /* 测试任务已全部收归 ch395fTestTask 统一调度，本任务不再承担任何测试 */ (void)argument; + /* 系统启动期挂载 NAND 上的 FatFS 卷，供 FTP 及其它模块访问。 + * f_mount(forced=1) 会触发 disk_initialize() → nand_ftl_init() + * （dhara_map_resume）。此前默认构建从未挂载，导致 FTP 的 + * LIST/STOR/RETR 全部返回 550（f_opendir 失败）。 + * 若卷为空（FR_NO_FILESYSTEM，如恢复/坏块重建后清空），则首次自动 + * 格式化建卷（MKFS_PARM 与存储测试一致：FM_FAT32 / 无分区表）。 */ + static FATFS default_fatfs; + FRESULT fr = f_mount(&default_fatfs, "", 1); + if (fr == FR_NO_FILESYSTEM) { + DBG_INFO("[FS] no FAT volume, formatting NAND..."); + static uint8_t fs_work[FF_MAX_SS]; + MKFS_PARM opts = { FM_FAT32, 0, 0, 0, 0 }; + fr = f_mkfs("", &opts, fs_work, sizeof(fs_work)); + if (fr == FR_OK) { + fr = f_mount(&default_fatfs, "", 1); + } else { + DBG_ERROR("[FS] f_mkfs failed (fr=%d)", (int)fr); + } + } + if (fr == FR_OK) { + DBG_INFO("[FS] FATFS mounted"); + } else { + DBG_ERROR("[FS] f_mount failed (fr=%d)", (int)fr); + } + for (;;) { osDelay(1000); } diff --git a/docs/FTP_Test_Guide.md b/docs/FTP_Test_Guide.md new file mode 100644 index 0000000..a4797aa --- /dev/null +++ b/docs/FTP_Test_Guide.md @@ -0,0 +1,168 @@ +# FTP 功能测试指导 + +> 适用对象：STM32F4-Base 上基于 `lftpd` 的 FTP Server 功能验证。 +> 配套源码：`Drivers/BSP/NET/lftpd/`、`App/task/net_task.c`、`Src/freertos.c`（StartFtpTask）。 +> 关联文档：`CH395F_Test_Guide.md`（网络测试总说明·阶段 8）、`NET_Socket_FTP_Support_Plan.md`（PASV 改造方案）、`CH395F_Trap_Records.md`。 + +--- + +## 1. 概述 + +- FTP Server（`lftpd`）在**默认固件构建中即常驻运行**：`Src/freertos.c` 的 `StartFtpTask`（默认 `__weak` 实现）直接调用 `lftpd_start("/", 21, &ftp)`，与测试套件选择无关。 +- 监听端口 **21**，根目录 `/`（即 NAND 上的 FatFS 卷），**匿名登录**（`USER anonymous` / `PASS` 任意）。 +- 仅支持 **1 个并发客户端**（控制通道 Socket0 + PASV 数据通道动态 Socket2，backlog=1）。 +- 测试分两类： + - **PC 端手测（推荐，覆盖真实 FTP 行为）**：用 `test/` 下 Python 脚本或 GUI 客户端。 + - **固件自动化（TEST_SUITE_CH395F 阶段 8）**：TC-NET-801/802/803 文件传输。 + +--- + +## 2. 测试环境 + +### 2.1 硬件与网络 + +- CH395F 网口经以太网连接到 PC 或同一台交换机。 +- PC 网卡与固件 IP **同网段**。固件默认静态 IP **192.168.1.100**（掩码 255.255.255.0）；PC 可设 192.168.1.x（如 192.168.1.77）。 +- 启动时 `netTask` 完成 `net_init()` + PHY 稳定（约 >2s），`ftpTask` 另有 `osDelay(7000)` 等待后才 `listen`；若 `open_socket` 失败会 `vTaskDelay(3000)` 重试（最多 3 次）。**客户端应在上电约 7s 后、串口出现 `[FTP] waiting for connection...` 再连接。** + +### 2.2 软件 + +- Python 3.x（脚本位于 `test/`）。 +- 可选 GUI 客户端：FileZilla / MobaXterm / lftp。 + +--- + +## 3. 编译与运行（固件侧） + +- **默认构建即可提供 FTP Server**，无需切换测试套件。 +- 任何改动后必须执行 `@build`（即 `MDK-ARM/build.bat`），确认 **0 Error(s) 0 Warning(s)** 再烧录（遵循 AGENTS.md 铁律）。 +- 若需跑**自动化 FTP 文件传输用例**：在 `test/test_config.h` 选择 `TEST_SUITE_CH395F`，并在 `test/ch395f_test.h` 打开 `ENABLE_PHASE8_TESTS`（文件传输阶段），重新编译烧录。 +- 烧录后打开串口（115200bps）观察： + - `net_init` 完成、PHY link up； + - `[FTP] waiting for connection...`（约 3 次重试足够 PHY 稳定）； + - 客户端连接后进入 FTP 会话（控制通道 220 欢迎）。 + +--- + +## 4. PC 端脚本手测（主要手段） + +所有脚本支持 `--host`（默认 `192.168.1.100`）、`--port`（默认 21），在 `test/` 目录运行。 + +### 4.1 冒烟测试：`ftp_test.py` + +- 用途：验证连接、登录、`PWD`、`PASV`、`LIST` 基本链路。 +- 命令：`python ./test/ftp_test.py --host 192.168.1.100` +- 预期： + - 连接成功并读到 `220` 欢迎； + - `USER anonymous` / `PASS` 返回 `230`； + - `PASV` 返回 `227` 并解析出数据端口（或回退 `EPSV`）； + - `LIST` 返回目录列表； + - `QUIT` 正常关闭。 +- 判据：全程无 `[NO RESPONSE]` / `CONNECT FAILED`，且 LIST 返回 `226` 即 PASS。**空卷下 LIST 数据通道为 0 字节属正常**（新格式化卷无文件），不必要求有目录列表输出。 + +### 4.2 上传 / 下载 / 比对：`ftp_up_dl_test.py` + +- 用途：验证 `STOR`/`RETR`/`DELE` 与数据一致性（`TYPE I` 二进制 + `PASV`）。 +- 命令：`python ./test/ftp_up_dl_test.py --host 192.168.1.100` +- 流程：登录 → `TYPE I` → `STOR up_test.dat` → `LIST` 校验存在 → `RETR up_test.dat` → 逐字节比对 → `DELE` 清理 → `QUIT`。 +- 预期：`*** MATCH! Upload/Download success. ***`，且 LIST 中出现 `up_test.dat`。 +- 判据：上传/下载字节数相等且内容逐字节一致。 + +### 4.3 速度与大数据量：`ftp_speed_test.py` + +- 用途：测量上传/下载吞吐，作回归基线，同时验证大文件不丢字节。 +- 命令：`python ./test/ftp_speed_test.py --host 192.168.1.100 --size 512`（默认 512KB，`--size` 可调）。 +- 预期：上传/下载均返回 `226`，回读 `MATCH!`，打印 KB/s。 +- 注意：脚本使用 8.3 文件名 `SPEEDTST.DAT`（**FTP 仅支持 8.3 短文件名**，见 §8.3）；以回读比对（MATCH）为最终判据，中间打印的 Sent 字段仅供参考。 +- 判据：size 一致 + MATCH + 速度稳定（受 SPI2 分频 8 限制，通常约 300~450 KB/s，参见 `CH395F_Test_Guide.md` 阶段 5 吞吐基线）。 + +### 4.4 抓包辅助：`ftp_capture.py` + +- 用途：连接/传输过程中抓包，分析 PASV 端口、命令/数据通道交互，用于疑难排查。 +- 用法参见脚本内 `--help` / 注释。 + +--- + +## 5. GUI 客户端手测（可选） + +- **FileZilla**：主机 `192.168.1.100`，端口 21，用户 `anonymous`，密码任意；可拖拽上传/下载、浏览目录。 +- 要点：使用二进制模式传输；文件名遵守 8.3；**一次只连一个客户端**。 + +--- + +## 6. 自动化测试（TEST_SUITE_CH395F 阶段 8） + +- 入口：`ENABLE_PHASE8_TESTS` → 文件传输阶段（100KB 文件）。 +- 用例： + - `TC-NET-801`：100KB 文件上发（MCU→PC）； + - `TC-NET-802`：100KB 文件下发（PC→MCU）； + - `TC-NET-803`：round-trip（可选）。 +- 详见 `docs/CH395F_Test_Guide.md` 阶段 8。 + +--- + +## 7. 测试清单（Checklist） + +- [ ] 默认构建烧录，串口见 `[FTP] waiting for connection`。 +- [ ] `ftp_test.py` 冒烟 PASS（连接 / 登录 / PASV / LIST）。 +- [ ] `ftp_up_dl_test.py` 上传下载比对 `MATCH`。 +- [ ] `ftp_speed_test.py` 大文件 `MATCH` + 记录速度基线。 +- [ ] （可选）GUI 客户端手动上传/下载成功。 +- [ ] （可选）阶段 8 自动化 `TC-NET-801/802/803` PASS。 + +--- + +## 8. 常见失败与排查（基于已知陷阱） + +### 8.1 连接被拒 / 长时间无欢迎 + +- 确认 PC 与固件同网段、IP 正确；上电后等待约 7s（PHY 稳定 + `ftpTask` 延迟）再连。 +- 若反复 `open_socket` 失败：见 **TRAP-09**（PHY 未稳定；固件已做 3 次重试 + 7s 延迟，仍失败检查网线/交换机）。 + +### 8.2 PASV 失败 / 数据通道连不上 + +- 确认 PC 防火墙未阻断高端口（PASV 动态端口）。 +- **数据通道必须先 `connect` 再发命令**（如 `LIST`/`STOR`），顺序反了会失败（脚本已遵循）。 +- **TRAP-11**：`net_accept_locked` 在 `ESTABLISHED` 状态导致 PASV 失败——需校验 `ESTABLISHED`。 + +### 8.3 STOR 报 FR_INVALID_NAME (err=6) + +- **8.3 文件名限制**：`upload_test.dat`（11+3）超过 8.3 → `FR_INVALID_NAME`。改用短名如 `UPLOAD.DAT` / `SPEEDTST.DAT`。这是 FatFS LFN/8.3 约束，非驱动 bug。 + +### 8.4 大文件传输中途 RST / 速度抖动 + +- **TRAP-13** / 设计约束：CH395F `WRITE_SEND_BUF` 芯片侧吞吐限制，单帧 >1KB 才稳定；TCP 背压会"堵一会儿"，属正常流控，不丢数据。 +- 接收侧 `recv_len` 首包可能较大、次包可能为 0，**必须循环读直到连接关闭**（脚本已处理）。 +- 若持续 RST：检查 **SPI 分频 = 8**（PCB 设计限制）、`net_poll()` 周期（10ms）是否正常、中断是否统一在 `net_poll()` 中经 `GET_GLOB_INT_STATUS` 处理。 + +### 8.5 路径问题 + +- **TRAP-12**：FatFS 根路径 `/` 前缀由 `to_fatfs_path()` 统一处理；客户端用绝对路径（如 `/UPLOAD.DAT`）即可。 + +### 8.6 单客户端限制 + +- FTP 仅接受 1 个并发客户端；上一个会话未 `QUIT` 前，新连接会被拒。每次测完务必 `QUIT` / 断开。 + +### 8.7 LIST/STOR/RETR 全部 550：卷未挂载 / 无 FAT 文件系统 + +- 根因：FTP 服务的是 NAND 上的 FatFS 卷。固件在 `StartDefaultTask` 启动期执行 `f_mount(&fs, "", 1)`（会触发 `disk_initialize` → `nand_ftl_init`），使卷可用。 +- **首启自动建卷**：若 `f_mount` 返回 `FR_NO_FILESYSTEM`（如坏块重建/恢复测试后卷被清空），固件会自动 `f_mkfs`（FM_FAT32、无分区表，参数与存储测试一致）再挂载。该过程上电会多花数秒（格式化），串口可见 `[FS] no FAT volume, formatting NAND...` → `[FS] FATFS mounted`。 +- 若串口见 `[FS] f_mount failed (fr=...)` 且非首次（已建卷仍失败）：检查 `f_mkfs` 是否报错（`[FS] f_mkfs failed`），或 NAND 是否存在物理/ECC 错误；必要时用 `TEST_SUITE_STORAGE` 跑一次确认磁盘健康。 + +--- + +## 9. 诊断手段（沿用前期测试经验） + +- **串口日志 + `DBG_*`**：在 `lftpd.c` / `net_socket` 关键路径加 `DBG_ERROR/INFO` 打印（注意编码安全铁律——只用 Edit 改中文源文件，禁止用 `Get/Set-Content` 整文件重写）。 +- **抓包**：`ftp_capture.py` 或 Wireshark 过滤 `tcp.port==21`。 +- **编译验证**：`@build` 必须 0/0 再烧录（AGENTS.md 铁律）。 +- **套件切换**：`test/test_config.h` 改 `TEST_SUITE_CH395F` / `TEST_SUITE_GD5F` / `TEST_SUITE_STORAGE`（三选一，互斥）。 + +--- + +## 10. 参考文档 + +- `docs/CH395F_Test_Guide.md` —— 网络测试总说明（含阶段 8 文件传输、FTP 陷阱清单） +- `docs/NET_Socket_FTP_Support_Plan.md` —— FTP / PASV Socket 改造方案 +- `docs/CH395F_Trap_Records.md` —— CH395F 已知陷阱 +- `docs/BSD_Socket_API_使用指南.md` —— BSD Socket API 用法 diff --git a/test/__pycache__/ftp_speed_test.cpython-311.pyc b/test/__pycache__/ftp_speed_test.cpython-311.pyc new file mode 100644 index 0000000000000000000000000000000000000000..6859380514847232780cc62601ad18747c89650a GIT binary patch literal 13447 zcmdrzYj7LKd3U%4aCq_wk{~Jis0T@qA}PueWl5xDJ|$8TDU+}qOH?s152PSb0DTAA z7IH`sM;${pr-ocPf*orDcN~X~<%#-8M@gMFb=sLU>5n_jCB|HbGoIE;>|bHV^^C^9 z`t1S)aUi8~(j@J4x%hT(-@D&y_uJ)n91bf5?p;^%d{aF|{RjS7b%tEzvm`{WQ#^H= z;%VM6N1vuiXgF;kA#<7`Av%pnXgqBsq3N`VXHJ`WbeiRjr!BncGIiR@J9+jpecHxb z;LFZi0XldaKqqepSQ04Z9T!N?g55v`O5TRP-(4LMMN_lkdIC{d@cx_wnr)KYl;m`SIw1xHIkTVlW!u_IB+)i$CVWLWJAhb=LYR9_(1up)3BW3lf7A%xjv) z`8j8V&ZAFz;Pa0 zGtLXaP{d=LS`^md8GY#( z6RO%qMR0#PcOLgk+;&PpH1#A|$!DqOm?x=cX^9a{l0h&?h7gTcSTaaV)Im`&K0~^o zmDM&Vibwh$aotI3al&I96EK5$Kg9zj$Z%LaM$IY)B9Y+5KzJddAt5mRjAjzU(-#5} z&Agh-212~}Y%p@pgEWLQg)(SDL%cuY*9_C=L_81X+Vysy)FqWE3nd`dy6?dxZYW=nPM1P|H-g1d+ z@hdA7ZK+uUnTqP;=1@tSHz|dZI?V@g#^fAmo8fbtU)5aT6@H)mcgzKFIk|+wv z8`FVacIYugQxVL4Ik!d+{5l?sVA{_)iPEa5b zp=n?^4Pl&WMsY3>m?zlr7=#LFQDder@;MI8Vv)sFeUK__f&6Xo6MF#w5&?h5pFf`5 zmNH%4`C(bpow6pStVJzrQIJPP9vOL-5qo(wA%1QA@_2lF*;WZ$d3f=#jA{u1>ckEf zIfU{46(V}Eb3V^dAb_ZJA-h7^tSeepDD!TDPwe7|tgV zOnyOkd`bb9Kigc&?;d?;^yVlGTB+No0%U6vbfPQaPnIS7l22#KE98-Vieu3IU)qP_jIdXn;mSd8Qj?J;Uq825*)ap8Y1`EjNlSk!z-dJKL60=`sV`g2Sj&<#0?##J0u@nKmSas*Ip7B@*mObd)w-ax zoW*^EN@ddp{jZh98hcR2sF4^O)q}_VHOtPji=dN>lt+2Vib8S{jHo~=b zpfjepW~6|ce=pqRkQ|%kCMfA#H&IB?aV_2m5vNPd^Ax|Oct*gZj{ESaO|t(^JlgO8 z9)0K!%cBH`4{bo{+g8_wqR!)uFL8P*i8+gSn3M3{z@VpV8m|{Vx~y|j(Waf0ERaWQ z6?C|%Tus+gJE>hDaaKze?|6U@3rd0HX}q~rKjN4*vYFYJNF|ap3a5)$sZ`2uyFj#p zz)Fl%8nprc(-^`5W?KxnPN88J_@aKdMbh$c5bAhq;h^&)({b^AXM5V zRY>I^X?Ewv`S1-?%$rh$SXV@od-S-yul^{+cwRH{dmp&6-RpAmHHl8Uzl7iS2a@oQ z{C*|;|EBc*Bg@(Se*`(Z|Mw(k4{R)F`Gc`aVwQ2FYt}IxB=9|YdX2dxmq>@|rAo;~ z%qx{47wjhs_NwRe!U}el3^vn*jH|o5#l0Zc3nb}Uk9z+81IXJdsVXmTU6H+OJxi7P z8A??}lDJwY@p>Ormz*m$FJr4VDPybuFUi=*zJj$Y+C7FVLB@kgdcETh=~p?H-L)Q; zYW`<>4rKeIQg(edknK9m_31|dH1;4WV6u87Yy?V2Ii2E`+=5HjW`9nf4y@OIp_s1Z zAhCxGJ*ZF6XzO-24=OJ)7syFVDAn~eTs+UvBawq^7%4te4^n4aVzn^K+C1Y@5-R-4 z^-`(p<%m?fkp`w=_p<0Ay7#E$=0|et^XP--LAYjBLyzXMX(`s!MOymU#uBZl)FySg z=fqf$g56luK6!FzXwW<9?HKIyMqSq4-d+yhS4`sT1*r>I za{&$tMI9W;<*=<67ugvt6;YR+(+hxa;JS=EO6JXVO&(w9GnW=SY$V06rA}aJx$0aU>mBnt3yn z4*hr{o1?I!DmyB#`i*U@1Rn{o)nR-TTBUgUGIhmRZ2Q#n8dx9;v9QkeqRU-}P2Bp~ zho+!~tTk0v8c7V`+L*;4*s#FHx?Wl=a=JR}>?c4krMePD)*Im75?y|gdl})*5wO;se zlM5Gtzb+jBrsU2Dm|KJc7+?t>ZP`?tP$*h)=+Gg~J2dI#Fv|}Oay>mg1&LS!UjcWa_u#i>+P)t{hJcC3h#EUbdIXk?EFMz3S+TdM_7<7=ySTlz6f%Sz3frWzO)}dA z_iQT^vbf+T&*93HR$jNhV!dj=W>3Q3z2%B}7@EVi2B1U|!5yB%Megui35SSnBOh$3 z?B7j&u-n>ynEBuk4KP}LW*{621*Risxm+X|n(gT55WuQHMawyEV0>(BXu!*5@q2*N z%(-&IQRm~6Llc}o6b@aw7+w&g*5l#XV2H!1(Q-^A97fEe7<9k|$!b2%iI!!{w&22@ zIK|_Qn!Hb*9O6czRc9VQd3?NYuxLm`*PM#lLSYWycZ5S?AZmrGr#Nz>Az+JRw3_1v zL7j5b*;#QjpkD&~0WMlbN@7*Jnin-rddDZYS*Ql?PagHq`~_M;loju z<0bbRhT)9xRb-WKg77c2N9WZ`5Kvb82W}WcbOmc&F0Z+RB~i z^9~$szDe)IP~QmwTWd9QjzEMF{Kbe7 zfn3>=3t4h4CU|fLzQM=0^5OZ2W*a$qa$?*&?(+_u)NBBJW8*N6z9)rRC@SE?u*Qn# z79u>1T{BM}ecbDNVnR5I(@ii_AviD8;gZ-GoW15}<^mxNJrxemK~E9C5Ft+iG$YJp zHsGn(5Pp)PA^hqD?wer&eHWh6Y>{xpKj$MmMa@EFA4YdB8uDKZ2>rN+V;JDgiO_{X z8vxCW?W+J;q$N31|K@+lW~RL^E$ugYY0|5Ne_H1~o zIU530&=D0KkrrhzYY#aF735ZtTSo2`gV9(I?=D`p zzi3bLslnuw!fsXBtupcV;3)te5h#LHKr~2Gx=VI8fmhgOm2H;U<_st!VX+QK1w!kc^~|I+1i6It1<3fiWk zZ8F+Mx=A%Ju z^7BgX`Od+=IQVAoTfGX~rLtWz+of-T3^%beh0@h>LpS)P{n=1K`&6_~M*Hq=679Jc zJ+BU{l}+!N)RqIc`xJCYMTcZ`NJkR0sY|kJ?Ysj=p8L^6+Y&81+rTUAPLf~1ajGMUJoFO6(9<0F^=w99ETt@5=TE%abge@{jVfxCQ6o+peSY+7$1fj`AHR#=y`=ZbHjiTS zs5Vc0aCxnxOnGHexY`^)mf6?;L8gzxAw^HfmG$U>RzvVZOa>5K6JO=akne( zPSxEhyE|{6lC41YLkb#J(Xfn$KPszD1@4q>1F?oVBGH-*rbpyP>~HmC!z@(LsES5q zH2M)13_$kFY-zGG`AmL~t0!2@JeGooMOa*JSI`a>?U2!q2XfMd)ZR3_6WOJ*yJU8k zzS-pmagywODD7H8-?M$!_KxGGLt(pBwp(Vqi<;OZqx?T%24`9P$cn*iEMGC0EajQX zn(HI4jHLLheC1ej zJ8+Aofa5hLB9F)J%S4q`sq(8w;wLgaBR}oC({n=ZIq~Xbs`~2GwW;(8#np9dP;osX zgP-)q$B1_AyHSyP;Sb$R)-N5)MXtq6Bdbg_o7vhV zJGwxhY)y70w=RC^W#5ZF#nGTT8e~Vq60qPn_*-AehFSPqhBiJ%|0jhZEIUA~7p;kQ z1=XmiMn*Nuj?!fHm8r$4)R{Yu7TM9a^u%q;o%X)?P{wRup{&MQqNDp$7i4FD-Ye{Y z$_~iH-^F&Sfiwu~0r20Syj}g5Q-3p+{ZiOLl^vAX!DX8>@$8kJ#h%o`JGLg-)zw4@n4Uwx^bv45V!BI;c<)C7mW3kllg_C`;>+GB|}5}mlh+y56#t2?4Uk;$cW*Nk|*{tA9m9Kr=i!p!&X^* zVEpV2ur%mxfNL+)c=~3MbuWe=yyDa5I>$4G_hUCv@$K?`>lq_>EIAh;kN&eCH%-O1 z@%y%6*0o_@Z4GYr*hs+_+@rvIxSQ6u!Mye^Hn9M&D+4{X)m@k64RbzEb7#o$KY|NjSq;^a5}?w zsHiFXe*lnd<^wbSg}De$!UrWVWuwTY`GD|c7!OXw2ePPp7@PBPlmpubnD<+9)xeuz`$Ecs2Vl7~6c4Bd3Ra$NIJ0i%$HH0OV98VB!>bQXCHqj<=V3}HejGNdV9}EdEL4kjRpZL!JzS0?}BX56{o%1N#A{E>D?e_WAhmw9iM(2Eq%Fm_5@s zZ*Uq8O@>+Y}n9gBq_ARH);pITEv5dV!nvO$x1`T9J(TqiiNTKuFAQ=Im&j-w9iIo)9cr@u%Xra1#ZBS!;dI3qw4#{e{YEu85z z=D?dZgxCBw@OUrFnIH*HGlu_8^UO<-%nXh1W5>MwSuf9i{^5`BfAGrvi#I>N^*;Mw z(QEAe-@Nwu-@e6;jqh!94Yjj>`snf(H!rfjm)T^OmO8rq-60qbPYgz=v2@>rv)Q zRJoC`MTPRE0}@Z59D=Cb?jh4}80r9O;r}%SsnC05gcOJ*&dLX&Y)?bR+kpMv5*?B- z!Vk*jU@VvBv}){##$Ugd2(M94TmmdV%CM0_i7Fx&SF*3qe3@$Yc(u9J+cnMO1c-nB|;?ne~8m|AS8!uKXQ~ z#&hAPKUw(Iwfk?(e)VbWPoKQSS{U|=Pky>^=U>12^wQUe;P{uQC&HCS#&_)<9DQc| zDC<5R0tw)~9`DrIDgTKsb|i?p#=FfvOBJqzg(VZy;^mxDz+oG#C}@K^zwX#Xe7L%=Li@XN5}+qn7Lf#CDL;s% zJhUXaAYULMuM#We3#2&*3(9AL0JbFz?+=%CwS7=a7|69DONAhoWjFQYG}HRtND z|Mbb53m^YWTAR{}6sCH5df2eW!koBy1BH)!!_>BI+gQcGd#8PFkM~_t(R+D5zz4(Y zP{xswQFi~}*uK$`u|c+(?H?T(8SEe5H9Erf508!w4jgsTycswvh9D@4+vkJgeh(;u zLLo&`bU~ljJB=k=(Q{s$qvwMmernpO<*lfs)^mnaXxodg7a z6@0FSe=rFkN-R*uSYx~>));G)s8X3K6{%9BGQ%$o$JZwGR~zry>+ag?BzwJVua_vN zOgTl$IZx3ScgKP+j$Ry%j?UZ462+HZn0+DoRLWpmB(%CM^Rz{@_QelgpL}_8ZdZI# za%`3zo9{Wg?>f3AN3ZPYg=~lty+fvVh&V2wGMgp3L#8`Kx+7&OijMNgw5x1A8hfk- z{|PV1*265BwvZ2%bWZyyi>{WJw?Wh1ThcZxpFJFPkpQVg+*Sm2=>bChJ)sAyt&LC- zT|^%-L})?#Dp-1f!cd2y9wgKdF$yquhoO-Ijr1|X2u6W9j^<+nmckTh|NON$ zyRUETS=Qz1$e8l4KApY)n`;ZNzQ)#1O*gV=?sW2~0VCnH^%Go!v+=P|)u*VFi{Srt zBY^8L$qK|#dxXr@7J*c2%T>*6;TZ8Q;UpC;Sa+vJ(KNLvUS2Hr=q!bPBg-OTj<~=9*N}!7diZBZ55YLxnt}kZy%MrjQVMPxt7fTdkKDCKqK9RAINFyo(2E46D@)-f&Gmio)X$%KclZ0dp*>P%hYXM|i;=O` zm^*Hd_r;$}71%|~Dv0sE^fN(bo|*5MCS@y#w_Q4yuwVKcm{Dx@czf)8%$71aVqIxv zSrTHXC^9HmSzZGJ@uRZqMDCEnq(Oiv!jb`?_O?zvz$A#l-qIGQu6Ye^FR0ayki^P35<`0I#JD!L3({FRe)hN3Bi40I+4d3@i7 z-g$4Shwy@th)~Z{oC!<>emh5Imyar*=KT7Hkb-Bq-#n}?PShEcNtG@5Fgq80^ozBbVcCoYA%1>`sDYk-=%7Op_(^I;IS&;Ok7cZNsu>K zqOT0<_QNI%Moh({IG;zTdYOu#=zoV$?->SdRzt#Dz4xyD%CJ1@fFi`wRIjvFii5PHOR|y8tsrtWe zdtqC+VmwuCX4Q28tE?XB)%k7a)=Yp^j?l0W(eZ^Lv@U!^4=mvsqcq^^xwU9yc@0=0 zqhO5As_Ieu7wWMtzaBvGG*^cyp5WGVgwGC3Ats6Tb1MS($X-?JTpkaTV1g|N+7@Sm zU`iHe-*cawQ(b%Y7qk}oOV!#90*&WUBUrgS`%Mypkt1fv2smC~{%8=)f|)nu;A>$_ z8}oHkfDI$RUBzQ#PMH-vRG3Zb`hE{Hvqi8xd}ijF^LfL3YJ6}f8d?E5Qe=MFWWND*#v zzfknO$i#}d_DNS?q1I)s~x4$n0*x@vu2+mQ|J6lg~jY<_lC9!}%C_uC=}S`Kr<*`ME+dI6L-@ zgst7(-Pq?g4nE#4_FJ+mtYaaKQ3%h{CJ4HghClXKMB(KX@;Y&eO2XU9fHr-C=J*OD ziM;F_^0I3p+T4vRc#DvyhC&-b@KEZ&XM_EufQkGyd5c0=)Duu~!-ztGb7oAThWd65 zLyaLE`Brn34QttrEZ+&$0{4jCJv|LBIPBwd>J**Nea!1qG=bB|n-_9V`4sAmn};vY zNw4R0Fo=9Ih*C7|i_qcZa4GVBPlES**@uENwgGm~4d6kPNYU0Smdlp-OyXFwPAqXs z^ah#UAkrIB<&~msee7)PY_cRqVHe%5I44?nK}>i7d{iQ?+nMyv9e=~0^#68$I!B^+ z%k*wB8?loiTzjPTDBBHu?h@N?{9gr0pm>95^xMM^vrPj1BH* z-Tr|8!kNHKFwEc_7Nv$wP%7(G4Hu%3X3;2YN1zF6mqkW7=^C^_4blYa5rt-4#?{v1 z44arE?MK;t2L^ztqJ?L=z^0C{0X|q4yqK9In*as8eFz6h*0a154KLCF@c)I20pZwD zcAUR}dT4N81`)kva5}LgFl?WwpAgUwdjjFb$%9{#2s5a65PBCIE<*I1(Fco8W3V4F zY=9Ocw^+CkVGf}5%&0;MsNZJjxm{!9P`?vE4?^+waLF=iS}ZaHP9aQOuhva1Sa_xg zaOR(B4ctc-;bQFiR~)bup!Kuo6|TD;VLCu(EIQTFL)cA+*Z6ne?j zsWnWaFL1=Rs$8hZQ`H9luh#(B1K!E&$cf5et4u~TaD=CMmbgxm#HnBcmv zg@-~;^4sBwnLy>z?o;Eo6JEdf{50Pau3V}2OPL>|g7pCI!w=l21q~2y&LXvJu&hrM!gh3mI1b{@j?J6_D|Mj@OdETI-wI55WP12+0O9&4q6SFeB6NB( zJ_v)4RAX>}g%gsT#PmqvL!Ewbj zHrl^ua%_D6VBcOI9T)IuzEBKcppdyzjDzPr-s#X(z^`cG`~)AVV8=0Eh47eQ$PFH0 zbW*A4ur%Q#6NNe!2>7rc7<-iY21I!+Dxt&vX5NSrkS|Qp`n*6J&TyRN3WW~4`AsNq z00HDGmNpMXY@e5MKG)Lrr&g24`5y|T$K1ekp zH~J*f03ID8LbXrM_)jYgPR3183~3ag{@lzI;39VJV9?9)y{JOl5!j1BKY(C401(56 zhVAJIiOxzSe-eh_T6 zwCK_B8#AF}M5aZeT4kzLq*~`q_Sx>+CAVsRQ6f9HN~UeHY1_k(cnvxS9K2pJUpB|N z#6WyPqSwgu8j)Uu=e=gAmbDq;Tygp-(JeCFBGN4>+7i>nrV_;xT_e*qB90H{O~t6D zj%9$!)F+=7t@RKk+9}gck%q(GbaBU9+GO7w`Zx6wy@!I?<5=o3^A+YY zbICkwj+t>Qp%@yr3W=(esY;QmoHrH42gHgElBq#9H9)gW_?Qrn&~j1Sb-u)45}MH} z)2$-iipedcOE*cTX4%yIe=VJ|ITFRO=izLUGDZhQW_5B)im_g4xZIF96l;)}^)j>m z9@BIeB)T(p2+IknYnrcKKSxQ`8|CVa5?v89#LH8L0?|;G z7zdC%euqlJ%I>q`vY0WQj?Y||hj-pqnxGQLCEGgLwhmudSS0kuuJ}-bi;u)dQf5bN z7y6|N3a=YqHi{KZcc@>Q{?YUgmVdTL1wC>>Ppl6Ps6b0BUGr6|lH@yvpBd)JH<&k> z8>6>Ia(6jnxJieCf4X&SZ5F$>lTQ>20tabQ>Hsbx)ZWv zfh8rMFRr+@_pQ1&n?9_QT?10_pjGN?ua@c6BE5Q1Q)zTTPuw$C z-!)e!&dnLc8kb~llg(|SxeebH**@1H7H)@l=TQ17nfqjOpJ?uzFRDxoBd_KIbYDlU%?E@~kSnH>v| z{HB1g6pDqNZ+Yfw-6*kL-&62rAHn)i8 z7HIvI(aWQfxmq??i{|S2B520d-fO+kqVnnlccbD~g;?G@M}1)Xx$PspRNpJt_r`Vu zNvKoNelpeDFFHmaYt0;6|DyzI49MvseM#5TlFd}kx`8Qk{R{nG9ihc6CChoL4`dwQ{$9D=7*&>#b} zG{}~Q=nzcpxwS+SeYHf@$W)C;fgskv$mlvTxMYS|l#jP!CG1EX6N?+;L-C>HanTA2 z*>OjgeoFKfncgDeh=|vxZ^l#Muesg1gz4qVgb?`23?OS_*B<`*%-QP{z-AtnQ4jp>m zhTpqwV>ay{%o<4lgOx<@w*FT5xJNPv9ol=QKH^}3HdUa555#6Epe3dj{$Kw9{IBYB z_T|%Xj(k7w1UmAV3x~Ov3ppzH3tSYs+gi951srovhaYv-g)@Xu{W2l<{G6k6zcO@< zZ^LfpJ@}^sc!PWrF@0qIZnyMsIjclrk4lGzp;-PC7lC^I-C2ON>ZH(@mrwkXLimw+fZ0zaS z(~0LKYPC$Q7PArWPZfG{618G-(rHx;lapM)GdYQOdi)GDheul!K7as^Ko9{WaOv$F zI?7G&)lQ-})DwuH-+jglRM5^FGfD5W>1}5M+>FoL!#@uh==>!3O8_wakmRCXOHyEq z05Ak;jatwzMKDqPOA)3h{-p?86#qUmltihN!3cn{Mh%OUm4umP39t+a8;K=QW+Y1% zi6u}ntRdkFX%3vA4CIaUDR5z=uguT$Pc>`bn7b zx=Q8BN6x(fK{PAo4aGF_5?Mh*8iVF$w4hBN&dD1>+Ic zYd%2>ri=6ui(nTRcyogJB6Y+nI0OrP*#r*0?1B}b!|N1mXGj}FPDgni??5ZwTWK3b zQ-W@c{CS*nPeCv{Fn);t{hiCd|9PzL_ji8u#V>yG`G-IH;)B<|xOn69H*T?ixVHHD zzklt&|NO@6h2SZ_k3SKdotT@Q5N0NV-axQ%_5$C~aLOMD@-6MHjV;@EHnudjG&i#k zaD^iwt0we;3j$B#7>a7#9r!g(QA6ID89#qQ^q=JqB`d(q!9{Pdvg4Na}?-&OwJGFxJcy3Mbr-#2US(srU06MIbs2Bv~J`(*7 zqrjajkvhfGFb0HVcA06L!uz&Q)@#FmLq!^r@oax{n9D=w29!)FjF(%l6 zHyE5g>-EnC6G-$Wp1zJ_d;NmCZn=t9cw6B)**9I-08Yr z{A%$+%PVEq$|8Frdmi4iyRQ6TnbMhyR>3{aDd+82tX>S<)-48ZdEf(_!tGSKoievG zp6`yfMcbAQkm=#Whs#FFk+)3I<}LBkN;%(y<6`47=ZQ01RCkGupt!|;wd-=%f?Kg{ zP%Rs9+9D_iPDx5)=PTvyrhre zKIJ?Dx@FL&k7d-knq1q?Fw%^OQ9^5uh)!&mP>fkEWz`qVU-e5_l&Eb_z^$pvB^#3^%ND->g<0=Z&@1pEQ$2suAMD^mP8@%9WRySLKXzzzWUT+VhZQ;KUBVOq z(wv-`fuej3|oX|s%#~|8pQTnN~ zLc-!DwNH>7jOY!_`h5Xhs`rIp0Ix`x%6ZX=GcdUB3CJZ@!Dlu61^yd=dFmcAN9v>b zk@`rzg4`-{%gBw%cld|H(W(XGEA@AsHA~JK#aXL5YZc^Ckw-?Jdx*KXKN3_>fr<)b zRB+E;v`}#Ar7JJZ55-OPWy)wMird{+U%LEKY&!CiVsBRM&3ElPmh3wed%J3HkDz;u zHF7pO9yuF1t1x9MQzkQIaZ4dt0TzNkdFjSW?+0%0Qkr_yrXHnow_3TIM3Hr&J9a?M z>jrlRCEp6yqjEhm*F)9?s5xSXe#vaPf+|#0A)^YQ|45sN2W2XQc2{?(-$0C(u1}}a z0fn!RT7jb9OH*|i)&;Rc&|Rb?I+nSXKuyU_WKynXIK~3hf&xNHinaU4zvr{ zuE*F8&;V3sl8gchLB}K$UR6$Drp_=%d5j~Ws@h{hou~e>P%|2McrYD)Sr6bkaA*>B z+!>}b=`DMoenodBZ;X1E^3VxA>^>e{Lf6=wpkE+6R|@&QW;DX&b8n1(ec+9ObP$=zuj$4Iz{gS^ z-N*=Rb~@1uo1%A8oH`|zLJ0}uNzp$y8}KlA#|+FS=(7oWGC@C=pr;bFkf6N@`a}S) zMubk%q{6PYP}~WzTj4M8LjXW5412{a=k2^x{Wo=gUH2awe%_!kLn<>g-y1hEfS-n@ zIBE1^?*~Ia9eQ{Ft^LqqrF4f1kSU7Lk(S70)EVuKJ|EA^m+c$CMJJQ*1^fYSA@v<= zi3Q%=vG~NByJUN#%rwR=u1E*z_P`WiM*6{g4cVC*VV%}uFyJl579HN709)`niEf&* zSHEBeZm!~dFpb9)bvo_Wgr@Vo1MwMnZC_|T z&Qj+7XcA1?F^9fuXGnQsC-gG|lU8bh9RNvIfy3#7p`t;76cA%#334eGIE=QFIxbyv1&`sLEh9H*@bdR(|>k29!m zr6wwCKL`O#UgZ`yZ~$09dBb!yV* z^Um;J(;XpwV`JkVlD)6q9V+JezRVO;en^O=iN>#OPmc8;<|loA--WaOxxm+XhkD1x zh&pUHQMUmvl|T^oRLIKn_|4DyMUXyD-gq59pY)7`pfO{>^W%0vP0w9`e0Nl# z_Z}26gO)I*#wKA(X-c5?qld?d&_pB}!l{W^pCgvw4Eh> zZ0O1HiKh>Xm}yF?MGR9j{(zV8i((nhXzqVu$~zmJ_WL}}1i~84gb6dN6CjP5i3g9g zSc%hecmO7X{s~eK=tL%k2^^F#lL(@G!7H`cj8oGSsc>9Cf=wrBO&DRk=4OHkL(m_b zoJr8WgkkE`obQZCxM93%tZ=C5cT%czV$ICTn3Af+BapfS{sO-MZfKsmkHw&YXcYi( zizk!sJ2)`u6f~%!K^YC+a}-{)-aPS!@BI^M<8H;#t2%n;_r;O*E-G3=Al{{Asb$@6 z+E5T@oOhYxC8l^`M{J*5(x@;^D$^u0O(5CHwk--%r!sXiQ+FSv8z47e(PpJ(( zihZ|g-wpa0hP!INY`*0l_`~(($Ac(h%s() zFH>f7GZAAC+ziAzmC9zdvRTdpi55GB8&f!|z*GFF+jSb&+-7dUcs8;V(3fk3z_9z|CFIb>o-5%W@FDQ;XTno-u*r;LIOyw74 zm+=)#S@Yz)Eerhsl1}03RIX0u>f&7CU9NJ8t9;w|mQCTBRIW+pnm)4>EK{s`h>p98 zA_L1hleJ`7XLOdt%W8fydSi64Pbq6r%UYuS@lqaiYp#lTQF*+eWWoE&XmlVt@bI3y z{2HkEXlKbPfM!Pfm-P^aHF#Di@+${v*TCEQ*ua~Xw=8nrK+-APpvn!(+~8+;LW-7{ zB84eYnG%^PNoyX6jt}eg_R?f@dlw5nDE(>ayXCja?|QnHJY9;XNA>i`dA;BiZjZ|C zk-0thF;Yd(DNKdRRLD#P#zOWodx^WkML0lljHC)vtTM$iQyjOuBG!lZ@K_iP8Gv9_ z-6Ad9>cFMZaapG~JL8<|>geTBg)3LNa+$b?%Q_lII3j(}^SC`f5?uMgHw*<74)4Ho zK*k>x4_Oa7s82S#_Zz5Bx@qk1F@XP5g#Diy?EBsNPYZO|Ur1xWd(Tez_^pE-DbWA6 zByYs7|7}CTh)(xAng;*xbh;6v;djV@{dNPS(P-?k-VjSsUw$8U+dnPLktZqOfKu}0 z%^Yd&Bz3t^7>yLd5tZShIjkc-<3%Q{*X;4Rvdwobw;|9nt|@^A$zdJz4<0RNM`Tg7 zwoX(64Nk87;2QyMCW8+LZl*VE(Dalc8k!s_RtIMXf>~fS{9x8-z5`?OUV2<;3i5!~ zN89Ep9X_E58-4)#p5%L#x6#OhS^0ny&EOd&Bv=GaTVKFU+GrKnY_4#vc7T3WTOJ%k zu34Uaz2%YG9fC8vcFpMKX-6ZcSNYo9VPh~u;*+wp2mS)!W7AS#5<`+ON7^uv*13R# z2i|E_?*a9vbq*k-6n;bN+}hk>(3%8_NXc%21#WyD^AF>mDP?B$h)C^B*sN()vBVGx zHUpQPixp{n`;PP{pd(nD4uz8J(E$#heFXI}k~x?9G`%X#E^QsOS@sy(EdS%uCYj}O z!I?1^`t146qNoZjwt%*vG7OrLVEHPh2C>#O^=QWUP+7JnRz9PKs`o> zz)74?nbsi;N*0MDGPlL&$ypD}verX>?J-|j#e97BD)#Mqc>8$`R&0mP)O!#>(TZ$XD@j4YP;n-UTyyw*U)ddf@=5dx||iJ zK5QdeI5t+eiutQPp+P(5X)T;BrG>NQXyMZP?>B1U8YSD>_#-skYSz}f9{txWEwrqq zSNbDRs7>2Cze{L^z7(yF+p15i$2&)b9fan#N{;WGg4%MZXX|P^PGgM;d4z4+)@SiF z+jC;IIP_>L+wuPnm3>=I<^PZu+4)bvi|qVXyh!^RD~0oaYo&0eRto30TPgksRGY;+ zKSmnJ+E>GQgl0RWynh0k&D`;J<U3=J36omrCP)Yb}I(;E3DXC^7@0H8t8n#b?Op|fiL&L>MJm&$T@HZ z^CYl82lg6_j53ey!BhmBjUWk>ePHlv5DXGAScH^DV4|`VRY@Z|Fli;{QDX@-(7SIK zS`5$8uXV@yke+Yg#beMcunjU!&ce}{K+b$ThJ;~e@;UEJLgzn&4c~&3(=!Qlc2b0| zsZ-vmGl8@b+kEo415QOCI8=p?z`*z%kJAJ`*ukDvV{prn@`@uzWg0UoY%ob?CIV=VXGTNb^hN5DA=}t13pHuYeB>w)HL*GKic3FUc?_1A zr1_X8H3H*LonT1Lr9h0zauq>Wcuk%xa}W@0X;{iL1RWvAq|#^C#IxG|0f}ek&M~== zD6t0EtaTaP!M5Q5#Y2WkR9d(|D+j$24aCNcXeJ5khcOTQlu^ ziD}<-;M6MCrZfHs7mDln0)AixSI`9R^`V8{1u@nVJ)Hc`gaiRY9v0S!bv>c7wbq-l zxwAle7vPK<2v>X->K7+4_&$J8?YatvM4|ld?rwg(e{39|N{{vT@tvKW8G(3lNCmne zIa%f4)cEY|j5p}Ts~p(z>A^%cc`AGWH((fm$CxyGHNpXGz$=LOWQ2@aW z%mdG-77Jr?ghSQqnTN}`1V943T->;@~D_pJ0)yl-($A z6kKOtWnba0aZ&g^yq8}FO|!aI0i=i`ID)gf;JoQGe7Y6DmNFlg7wl=JK5k|A^yokC zrU8cXkG34g$NSho0qh=z{U@h=_{1O1{6|Md`uC3W$*F}Ce^V;ifY=FTJ@_0z$VM{o z#HyinYqQvu5lBoMATZ=gCaT4$npQ$RW(e}nP5S^x`Lkd=9WstTbEu!+ zN9eD$xjDopzj^F0XOC_@p4w77__6WP!#vzo!idla$L?Y`uHEAEr|lH5u|(320=C>; zI5r;#^bzZfv{eQ+*w6;1I~{ToBMf||&!C zU(-!u4taW>;oYvOuFz&>RBVpeRgyub_7aK|I)7cY1M_*C%8 zLlc;+8~b|4LxrTwz$yRv0G}CdN)72rNDt3)PpFbTy6rf>!qjwtP5iiKDne!wf(I|; zBwpsx2nz(kQ5l3*)C971X1m9vSt-t@inWWu!M8pkXI?9AupaxHgds zzN)1Rtjty_h*uFWBmSPnd8O-S;Tsk27pk6JiltMvbf)iWy_R`b%U~!=o8v5Gn&W^) zPSXBCZ-BjI1&~dsHui*Us|BYp9+mOP3|zjlMhubZ1sB+J^uB3)%cwA$Rc5oyY{rHZ z=c2+T>52rFFGYM;vaM}l{3jDPCKjJk%G=cPw)sI)T%>-%l%9-KXZ9jn zwjNxpIQdpkgNhnt)Nub>Sb7=p2tUryt6E_;smvysxJThe!{P?n)&Ndn8dZi|XGl)l zhS;|Es}?8Ut+`dBFfA(6A~P-8-aQ66mH|0fJWJ&Z!9|n2sSDg~Px7sxZWVRQsQW(R zBI9!YCI!`~s76LLan3s5A7|~aRlPR-O5?T0C6;ci-n7Y zV3(yhT2x0%q&IGNM0+oTpa_Olan2ci;?n*|f21F-E|NQoaQ9GWP6EQQVOq$m1*dQx zmGj_>h@2B=AejKK@x{eF{I*gShqfhOo4elvJUhN)=VgsPeJ6e`aA@3=k(} zWv9iCT-;wja+Be6Eg@I*e9SBtu2LdFndo)}m8hshMkVA*Dr8T2KpCdij6^w6&1nh9la4>0qP}OuJIoT4{_JD}bN@Fx;uhha$n|4UffB(ctwL zUwv`W6Ma!}x2f*7yY5{}?p=zzOLce2?s2(y91?+3(9A*@*kHW6R%UlZs;|~vuDjH5rQt4Hu>_OC@+u*T#c4cq?Reta@w~O; zX*0vMzd&+1POdWPRpp;$4wrRgt9rx&1;(iVB32}ubAE8W_>~`>Q@FCoU}SKe2(}Ce zX47B_7%;A}B0OTx+7dl^r$DY8hC7)r-gxo#@EhT~m0Oo8w)S8MPi@9Gv_QtW?__(#; zrg_P_0Tyf%hm9@=Xu@lBDomHkbjifs$M(jseXQ^n7P1gSN-Qb&edxKf_s-!vdwS0Q@hW+TkMVH+cpOi`e0A{ckqr4Y%um({2F2s&|iXpwvvLNI}nI7ju1 zb)g>fNT_Hn9pX4BSl}YCMeqiu;PyJcL=iG3|1AszgG6;=60SMmAS}|sc>uz)oA|Gw zPI3=L#NG6831(6}NiN|gY`x;ixwBqh@DRQ=EGD=~L70G85|%(iqoB~(jI$2_NThD= zLVSQoTtt2p&*Lb4;6fmQye~`#J^BQw5lLwXrv&jZDe)80805O790vyx(?0PkKI|h= z?J8=QQ9G#j?pn&0EMN?XC7j;nuWb+o{@i&JW&0ri(+-&9aq`JP~i!sK7r006vGNmyLQFfv5<8rD)r{760NCJ5PRb$}&%WamqYTesRh^Pk!l;&rF5$ zC~h(XU~TiJ&$tuw=FiHimMJR@e3uqfSZN0i%LEk$8sy_Nu=Ue4*zV`R5#0+qTwn$~ rXE4&B(oF*g1;RvVNnb4Mi{XDH%=f)KaB*Os{Fe0;@QV6kGAjQIsLb`b literal 0 HcmV?d00001 diff --git a/test/ftp_speed_test.py b/test/ftp_speed_test.py index abd8cad..f96d48b 100644 --- a/test/ftp_speed_test.py +++ b/test/ftp_speed_test.py @@ -52,84 +52,122 @@ def test_speed(host, port, size_kb): print(f"\n=== FTP Speed Test: {host}:{port}, {size_kb}KB file ===") print(f" Test data: {total_bytes:,} bytes generated\n") - # ---- Upload ---- - print("[UPLOAD] Connecting...") + checks = [] + + def check(label, ok, detail=""): + checks.append((label, ok, detail)) + mark = "PASS" if ok else "FAIL" + print(f" [{mark}] {label}{(' - ' + detail) if detail else ''}") + + def finish(sock): + passed = all(ok for _, ok, _ in checks) + print("\n" + "=" * 40) + print("FTP Speed Test Summary:") + for label, ok, _ in checks: + print(f" [{'PASS' if ok else 'FAIL'}] {label}") + print("=" * 40) + if passed: + print(">>> TEST PASSED <<<") + else: + print(">>> TEST FAILED <<<") + print("=== Test Complete ===") + if sock: + try: + sock.close() + except Exception: + pass + return passed + + # ---- Connect + Login ---- + print("[Connect] Connecting...") sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.settimeout(60.0) - sock.connect((host, port)) + try: + sock.connect((host, port)) + except Exception as e: + print(f" CONNECT FAILED: {e}") + check("Connect", False, str(e)) + return finish(sock) recv_line(sock) # 220 - send_cmd(sock, "USER anonymous") - send_cmd(sock, "PASS test@test.com") + if not send_cmd(sock, "USER anonymous"): + check("Login USER", False) + return finish(sock) + if not send_cmd(sock, "PASS test@test.com"): + check("Login PASS", False) + return finish(sock) + check("Login (USER/PASS)", True) send_cmd(sock, "TYPE I") - # PASV + # ---- Upload ---- + print("[UPLOAD] Connecting...") resp = send_cmd(sock, "PASV") if not resp: - print(" PASV failed"); sock.close(); return + check("PASV", False, "no response") + return finish(sock) pasv_ip, pasv_port = parse_pasv(resp) if pasv_port is None: - print(f" PASV parse failed: {resp.decode()}"); sock.close(); return + check("PASV parse", False, resp.decode()) + return finish(sock) + check("PASV parse", True, f"{pasv_ip}:{pasv_port}") - # Connect data channel data = socket.socket(socket.AF_INET, socket.SOCK_STREAM) data.settimeout(60.0) data.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) # 关 Nagle，防 FIN 跑在数据前面 try: data.connect((pasv_ip, pasv_port)) except Exception as e: - print(f" Data connect failed: {e}"); sock.close(); return + print(f" Data connect failed: {e}") + check("PASV data connect", False, str(e)) + return finish(sock) + check("PASV data connect", True) - # STOR - measure from STOR send to 226 response t0 = time.time() send_cmd(sock, f"STOR {test_name}") - - # Send all data at once (sendall handles partial sends) data.sendall(test_data) data.shutdown(socket.SHUT_WR) data.close() - # Wait for response from server (data received + written to disk) resp = recv_line(sock, timeout=120.0) t1 = time.time() - upload_time = t1 - t0 upload_speed = total_bytes / upload_time / 1024 if upload_time > 0 else 0 - - # Read STOR response - resp = recv_line(sock) stor_code = resp[:3].decode() if resp else "???" - print(f" Sent: {sent:,} / {total_bytes:,} bytes") + print(f" Sent: {total_bytes:,} / {total_bytes:,} bytes") print(f" Time: {upload_time:.1f}s") print(f" Speed: {upload_speed:.1f} KB/s") print(f" Response: {resp.decode().rstrip() if resp else 'NONE'}") - if stor_code != "226": - print(f" UPLOAD FAILED (code={stor_code}), skipping download") + upload_ok = (stor_code == "226") + check("STOR 226", upload_ok, f"{stor_code} up={upload_speed:.1f}KB/s") + + if not upload_ok: send_cmd(sock, "QUIT") - sock.close() - return + return finish(sock) # ---- Download ---- time.sleep(3.0) - + print("[DOWNLOAD] Connecting...") resp = send_cmd(sock, "PASV") if not resp: - print(" PASV failed"); sock.close(); return + check("RETR PASV", False, "no response") + return finish(sock) pasv_ip, pasv_port = parse_pasv(resp) if pasv_port is None: - print(f" PASV parse failed"); sock.close(); return - + check("RETR PASV parse", False, resp.decode()) + return finish(sock) data = socket.socket(socket.AF_INET, socket.SOCK_STREAM) data.settimeout(60.0) try: data.connect((pasv_ip, pasv_port)) except Exception as e: - print(f" Data connect failed: {e}"); sock.close(); return + print(f" Data connect failed: {e}") + check("RETR data connect", False, str(e)) + return finish(sock) + check("RETR data connect", True) t0 = time.time() send_cmd(sock, f"RETR {test_name}") - dl_data = b"" while True: try: @@ -140,25 +178,24 @@ def test_speed(host, port, size_kb): except socket.timeout: break data.close() - resp = recv_line(sock, timeout=120.0) t1 = time.time() - download_time = t1 - t0 download_speed = len(dl_data) / download_time / 1024 if download_time > 0 else 0 - resp = recv_line(sock) - retr_code = resp[:3].decode() if resp else "???" - - print(f"\n[DOWNLOAD]") print(f" Received: {len(dl_data):,} / {total_bytes:,} bytes") print(f" Time: {download_time:.1f}s") print(f" Speed: {download_speed:.1f} KB/s") print(f" Response: {resp.decode().rstrip() if resp else 'NONE'}") + retr_ok = bool(resp) and resp.startswith(b"226") + check("RETR 226", retr_ok, + f"{resp[:3].decode() if resp else '???'} dl={download_speed:.1f}KB/s") + # Compare print(f"\n[VERIFY]") - if len(dl_data) == total_bytes and dl_data == test_data: + match = (len(dl_data) == total_bytes and dl_data == test_data) + if match: print(f" *** MATCH! {total_bytes:,} bytes identical. ***") else: print(f" MISMATCH: sent={total_bytes}, got={len(dl_data)}") @@ -169,16 +206,15 @@ def test_speed(host, port, size_kb): if dl_data[i] != test_data[i]: print(f" First diff at byte {i}") break + check("Upload/Download MATCH", match, + f"up={total_bytes:,} dl={len(dl_data):,} up={upload_speed:.1f}KB/s dl={download_speed:.1f}KB/s") # Cleanup send_cmd(sock, f"DELE {test_name}") send_cmd(sock, "QUIT") - sock.close() - print(f"\n=== Summary ===") - print(f" File size: {total_bytes:,} bytes ({size_kb} KB)") - print(f" Upload: {upload_speed:.1f} KB/s ({upload_time:.1f}s)") - print(f" Download: {download_speed:.1f} KB/s ({download_time:.1f}s)") + return finish(sock) + def main(): parser = argparse.ArgumentParser(description="FTP Speed Test") @@ -187,7 +223,8 @@ def main(): parser.add_argument("--size", type=int, default=FILE_SIZE_KB, help=f"File size in KB (default {FILE_SIZE_KB})") args = parser.parse_args() - test_speed(args.host, args.port, args.size) + success = test_speed(args.host, args.port, args.size) + sys.exit(0 if success else 1) if __name__ == "__main__": main() diff --git a/test/ftp_test.py b/test/ftp_test.py index 0908c04..f3b6eef 100644 --- a/test/ftp_test.py +++ b/test/ftp_test.py @@ -55,6 +55,12 @@ def parse_pasv(response): def test_ftp(host, port): print(f"=== FTP Test: {host}:{port} ===\n") + checks = [] # (label, ok, detail) + + def check(label, ok, detail=""): + checks.append((label, ok, detail)) + mark = "PASS" if ok else "FAIL" + print(f" [{mark}] {label}{(' - ' + detail) if detail else ''}") # 1. Connect print("[1] Connecting to control channel...") @@ -63,8 +69,10 @@ def test_ftp(host, port): try: sock.connect((host, port)) print(f" Connected to {host}:{port}") + check("Connect", True) except Exception as e: print(f" CONNECT FAILED: {e}") + check("Connect", False, str(e)) return False # 2. Read welcome @@ -72,8 +80,11 @@ def test_ftp(host, port): resp = recv_line(sock) if resp: print(f" {resp.decode(errors='replace').rstrip()}") + check("Welcome 220", resp.startswith(b"220"), + resp.decode(errors='replace').rstrip()) else: print(" NO WELCOME BANNER") + check("Welcome 220", False, "no banner") sock.close() return False @@ -82,27 +93,35 @@ def test_ftp(host, port): resp = send_cmd(sock, "USER anonymous") if not resp: sock.close() + check("Login USER", False, "no response") return False resp = send_cmd(sock, "PASS test@test.com") if not resp: sock.close() + check("Login PASS", False, "no response") return False + login_ok = b"230" in resp + check("Login (USER/PASS 230)", login_ok, + resp.decode(errors='replace').rstrip()) # 4. PWD print("\n[4] PWD...") resp = send_cmd(sock, "PWD") + pwd_ok = bool(resp) and resp.startswith(b"257") + check("PWD 257", pwd_ok, + resp.decode(errors='replace').rstrip() if resp else "no response") # 5. PASV mode print("\n[5] PASV...") resp = send_cmd(sock, "PASV") - if not resp: - sock.close() - return False - - pasv_ip, pasv_port = parse_pasv(resp) + pasv_ip, pasv_port = (None, None) + if resp: + pasv_ip, pasv_port = parse_pasv(resp) + if pasv_port is None and resp and b"227" in resp: + # 227 响应但解析端口失败 + pasv_port = None if pasv_port is None: - print(" FAILED to parse PASV response") # Try EPSV print("\n[5b] Trying EPSV...") resp = send_cmd(sock, "EPSV") @@ -113,21 +132,21 @@ def test_ftp(host, port): pasv_port = int(m.group(1)) pasv_ip = host print(f" EPSV: {pasv_ip}:{pasv_port}") + pasv_ok = pasv_port is not None + check("PASV/EPSV data port", pasv_ok, + f"{pasv_ip}:{pasv_port}" if pasv_ok else "no port") - if pasv_port is None: - print(" PASV/EPSV FAILED, trying PORT mode...") - # Skip data connection tests - else: + # 6. LIST (correct PASV flow: connect data first, then send LIST) + if pasv_ok: print(f" Data channel: {pasv_ip}:{pasv_port}") - - # 6. LIST (correct PASV flow: connect data first, then send LIST) print("\n[6] LIST...") data_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) data_sock.settimeout(5.0) try: data_sock.connect((pasv_ip, pasv_port)) print(f" Data connected to {pasv_ip}:{pasv_port}") - send_cmd(sock, "LIST") + resp = send_cmd(sock, "LIST") + list_open = bool(resp) and resp.startswith(b"150") data = b"" while True: try: @@ -140,22 +159,41 @@ def test_ftp(host, port): print(f" LIST result ({len(data)} bytes):") print(data.decode(errors='replace')) data_sock.close() + resp = recv_line(sock) + list_close = bool(resp) and resp.startswith(b"226") + print(f" LIST response: " + f"{resp.decode(errors='replace').rstrip() if resp else 'none'}") + list_ok = list_open and list_close + check("LIST 150->226", list_ok, + f"open={list_open} close={list_close} bytes={len(data)}") except Exception as e: print(f" LIST FAILED: {e}") data_sock.close() - - # Read LIST response - resp = recv_line(sock) - if resp: - print(f" LIST response: {resp.decode(errors='replace').rstrip()}") + check("LIST 150->226", False, str(e)) + else: + print(" Skipping LIST (no data port)") # 7. QUIT print("\n[7] QUIT...") - send_cmd(sock, "QUIT") - + resp = send_cmd(sock, "QUIT") + quit_ok = bool(resp) and resp.startswith(b"221") + check("QUIT 221", quit_ok, + resp.decode(errors='replace').rstrip() if resp else "no response") sock.close() - print("\n=== Test Complete ===") - return True + + # Summary + passed = all(ok for _, ok, _ in checks) + print("\n" + "=" * 40) + print("FTP Test Summary:") + for label, ok, _ in checks: + print(f" [{'PASS' if ok else 'FAIL'}] {label}") + print("=" * 40) + if passed: + print(">>> TEST PASSED <<<") + else: + print(">>> TEST FAILED <<<") + print("=== Test Complete ===") + return passed def main(): parser = argparse.ArgumentParser(description="FTP Server Test") diff --git a/test/ftp_up_dl_test.py b/test/ftp_up_dl_test.py index bd474b0..2c65d1b 100644 --- a/test/ftp_up_dl_test.py +++ b/test/ftp_up_dl_test.py @@ -128,33 +128,67 @@ def ftp_transfer_data(host, pasv_ip, pasv_port, cmd, data_to_send=None, read_dat def test_upload_download(host, port): print(f"=== FTP Upload/Download Test: {host}:{port} ===\n") + checks = [] + + def check(label, ok, detail=""): + checks.append((label, ok, detail)) + mark = "PASS" if ok else "FAIL" + print(f" [{mark}] {label}{(' - ' + detail) if detail else ''}") + + def finish(sock): + passed = all(ok for _, ok, _ in checks) + print("\n" + "=" * 40) + print("FTP Upload/Download Summary:") + for label, ok, _ in checks: + print(f" [{'PASS' if ok else 'FAIL'}] {label}") + print("=" * 40) + if passed: + print(">>> TEST PASSED <<<") + else: + print(">>> TEST FAILED <<<") + print("=== Test Complete ===") + if sock: + try: + sock.close() + except Exception: + pass + return passed # 1. Connect + Login print("[1] Connect + Login") sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.settimeout(TIMEOUT) - sock.connect((host, port)) + try: + sock.connect((host, port)) + except Exception as e: + print(f" CONNECT FAILED: {e}") + check("Connect", False, str(e)) + return finish(sock) recv_line(sock) # 220 if not send_cmd(sock, "USER anonymous", 230): - sock.close(); return + check("Login USER 230", False) + return finish(sock) if not send_cmd(sock, "PASS test@test.com", 230): - sock.close(); return + check("Login PASS 230", False) + return finish(sock) + check("Login (USER/PASS 230)", True) # 2. TYPE I (binary mode) print("\n[2] Set binary mode") - send_cmd(sock, "TYPE I") + resp = send_cmd(sock, "TYPE I") + type_ok = bool(resp) and resp.startswith(b"200") + check("TYPE I 200", type_ok) # 3. PASV + STOR (upload) print("\n[3] Upload: STOR up_test.dat") resp = send_cmd(sock, "PASV") if not resp: - sock.close(); return - + check("PASV", False, "no response") + return finish(sock) pasv_ip, pasv_port = parse_pasv(resp) print(f" PASV: {pasv_ip}:{pasv_port}") - # Connect data channel data_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) data_sock.settimeout(10.0) try: @@ -162,12 +196,11 @@ def test_upload_download(host, port): print(f" Data connected.") except Exception as e: print(f" Data connect FAILED: {e}") - sock.close(); return + check("PASV data connect", False, str(e)) + return finish(sock) + check("PASV data connect", True, f"{pasv_ip}:{pasv_port}") - # Send STOR send_cmd(sock, "STOR up_test.dat") - - # Send file data total = 0 while total < len(TEST_DATA): try: @@ -179,20 +212,20 @@ def test_upload_download(host, port): print(f" Send error: {e}") break print(f" Uploaded {total}/{len(TEST_DATA)} bytes.") - data_sock.shutdown(socket.SHUT_WR) data_sock.close() - # Read STOR response resp = recv_line(sock) - if resp: - print(f" Response: {resp.decode().rstrip()}") + stor_ok = bool(resp) and resp.startswith(b"226") and total == len(TEST_DATA) + check("STOR 226 + bytes", stor_ok, + f"uploaded={total}/{len(TEST_DATA)} resp={resp.decode().rstrip() if resp else 'none'}") # 4. PASV + LIST (verify) print("\n[4] Verify: LIST") resp = send_cmd(sock, "PASV") if not resp: - sock.close(); return + check("LIST PASV", False, "no response") + return finish(sock) pasv_ip, pasv_port = parse_pasv(resp) data_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) @@ -213,15 +246,17 @@ def test_upload_download(host, port): data_sock.close() resp = recv_line(sock) - if resp: - print(f" Response: {resp.decode().rstrip()}") + list_ok = bool(data) and b"UP_TEST.DAT" in data.upper() + check("LIST shows UP_TEST.DAT", list_ok, + resp.decode().rstrip() if resp else "no resp") # 5. PASV + RETR (download) time.sleep(1.0) print("\n[5] Download: RETR up_test.dat") resp = send_cmd(sock, "PASV") if not resp: - sock.close(); return + check("RETR PASV", False, "no response") + return finish(sock) pasv_ip, pasv_port = parse_pasv(resp) data_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) @@ -230,10 +265,11 @@ def test_upload_download(host, port): data_sock.connect((pasv_ip, pasv_port)) except Exception as e: print(f" Data connect FAILED: {e}") - sock.close(); return + check("RETR data connect", False, str(e)) + return finish(sock) + check("RETR data connect", True, f"{pasv_ip}:{pasv_port}") send_cmd(sock, "RETR up_test.dat") - dl_data = b"" while True: try: @@ -244,39 +280,46 @@ def test_upload_download(host, port): except socket.timeout: break data_sock.close() - resp = recv_line(sock) - if resp: - print(f" Response: {resp.decode().rstrip()}") + retr_ok = bool(resp) and resp.startswith(b"226") + check("RETR 226", retr_ok, resp.decode().rstrip() if resp else "no resp") # Compare print(f"\n[6] Compare") print(f" Uploaded: {len(TEST_DATA)} bytes") print(f" Downloaded: {len(dl_data)} bytes") - if dl_data == TEST_DATA: + match = (dl_data == TEST_DATA) + if match: print(f" *** MATCH! Upload/Download success. ***") else: print(f" *** MISMATCH! ***") if dl_data: print(f" First 80 bytes uploaded: {TEST_DATA[:80]!r}") print(f" First 80 bytes downloaded: {dl_data[:80]!r}") + check("Upload/Download MATCH", match, f"up={len(TEST_DATA)} dl={len(dl_data)}") # 7. DELE (delete test file) print("\n[7] Cleanup: DELE up_test.dat") - send_cmd(sock, "DELE up_test.dat") + resp = send_cmd(sock, "DELE up_test.dat") + dele_ok = bool(resp) and resp.startswith(b"250") + check("DELE 250", dele_ok, resp.decode().rstrip() if resp else "no resp") # 8. QUIT print("\n[8] QUIT") - send_cmd(sock, "QUIT") - sock.close() - print("\n=== Test Complete ===") + resp = send_cmd(sock, "QUIT") + quit_ok = bool(resp) and resp.startswith(b"221") + check("QUIT 221", quit_ok, resp.decode().rstrip() if resp else "no resp") + + return finish(sock) + def main(): parser = argparse.ArgumentParser(description="FTP Upload/Download Test") parser.add_argument("--host", default=HOST) parser.add_argument("--port", type=int, default=PORT) args = parser.parse_args() - test_upload_download(args.host, args.port) + success = test_upload_download(args.host, args.port) + sys.exit(0 if success else 1) if __name__ == "__main__": main()