变更摘要

此 PR 将 RFC 0001 中已为 ReduceScatter 引入的 BIRS（批量不变性）算法扩展至 AllReduce，新增名为 AllReduceBIAR 的实验性算法实现。该算法在 A3（SIO + HCCS 混合拓扑）上针对 DEV_TYPE_910_93 设备，采用 ReduceScatter + AllGather 两阶段模式，通过 3 线程并行利用 SIO 和 HCCS 两类链路完成确定性的归约与广播。整体变更通过 ENABLE_EXPERIMENTAL 编译选项控制，新增了完整的 executor 基础框架、BIAR 模板实现、算法选择逻辑及仿真测试用例。

主要改动

• 新增 AllReduceBIARExecutor 与 AllReduceExecutorBase 框架: 在 experimental/ops/all_reduce/biar/ 下新增 executor 基类和 BIAR 专用子类，AllReduceExecutorBase::Orchestrate 负责参数还原与多线程编排，AllReduceBIARExecutor::CalcResRequest 为单/多服务器 A3 拓扑分别计算资源（level0 NP_MESH + 3 线程），并通过 REGISTER_EXEC 注册为 "AllReduceBIARExecutor"。

• 新增 AllReduceBIAR 模板实现: 在 experimental/ops/all_reduce/biar/template/all_reduce_biar.cc 中实现两阶段通信模板——RunReduceScatter（HCCS 写入 + SIO 带 reduce 写入 + 本地 Tree Reduce）和 RunAllGather（HCCS 写入 + SIO 读取 + 本地拷贝），以 TEMPLATE_ALL_REDUCE_BIAR（类型值 1005）注册到模板工厂。

• 算法选择与调度入口: op_common_experimental.cc 新增 SelectAlgAllReduce 函数，对 DEV_TYPE_910_93 且 rank 数为偶数时选中 AllReduceBIARExecutor；all_reduce_op_experimental.cc 新增 AllReduceExperimental 入口，先通过 MatchBIRS() 判断，命中 BIAR 路径时调用 ProcessA3 执行。

• 编译控制与集成: build.sh 新增 ENABLE_EXPERIMENTAL 选项传导至 CMake；src/ops/all_reduce/all_reduce_op.cc 在 ENABLE_EXPERIMENTAL 宏下将 HcclAllReduce 重定向至 AllReduceExperimental；all_reduce_op.h 条件包含实验性头文件。

• 仿真测试用例: 添加 test/st/algorithm/testcase/all_reduce_testcase_a3.cc，覆盖 4/6/8/10/12/14/16 卡及 1 超节点×4 服务器×16 卡等多 rank 规模，验证 V-style 分片（含余数）下的归约正确性。

代码审查

审查完成 — 逐文件总结

总结

• P1: 1 个 — AllReduceOutPlaceCustom 中 beginTime 未初始化即按值传递，触发未定义行为。
• P2: 3 个 — TreeReduceRs 中用 u32 容器存储 u64 字节偏移导致大消息数据损坏；日志格式 %u/%zu 不匹配；dynamic_cast 失败时静默跳过操作。
• P3: 7 个 — 未使用变量、复制粘贴残留注释、冗余校验/分配等代码清理项。

整体风险评估：中等。P1 的未初始化变量在实际未启用 profiling 时有 UB 风险但概率较低；P2 的 u32 截断问题在大消息（单 slice 超过 ~4 GiB）时会静默数据损坏，是最值得关注的逻辑缺陷。建议在合入前至少修复 P1 和 P2 级别问题。

⛔ 需要修改

/ai review force

🤖 AI 代码检视正在进行中，请稍候…

/approve