变更摘要

本 PR 修复多个 AIV/block 共享同一 peer/QP 时，SQ 槽位分配、门铃发布和 CQ 消费缺少并发保护的问题，使同一 workspace 上的 RDMA PUT、GET 与 PUT+notify 接口可被并发调用。核心做法是在 hns_1825_backend.hpp 中为每个 peer/QP 引入共享队列状态 QueueState，通过原子 fetch-add 预留 WQE 区间并按预留顺序推进就绪进度，配合提交锁与独立 CQ 锁保护 owner/门铃发布和 CQE 消费，同时调整 workspace 初始化与校验逻辑，并在 RDMA ST 中新增 16 AIV 持续压力用例。

主要改动

• 新增共享队列状态与原子原语: 在 hns_1825_types.hpp 中新增 64 字节的 QueueState 结构（reserveHead、readyHead、postedHead、completedHead、postLock、cqLock、error），并为 SqContext 增加 stateAddr 字段；后端新增 QueueFence、AtomicLoad、TryQueueLock/UnlockQueue、FailQueue 等基于本地标量原子与 DSB_DDR 的同步原语，并新增错误码 kQueueIndexExhaustedError、常量 kMaxQueueIndex、kCqProgressBatch、kPostSendBatch。

• WQE 预留与有序提交: 后端新增 ReserveWqes（用 atomicAdd 预留相邻 WQEBB，并按 SQ/CQ 实际深度 QueueCapacity 做容量等待）、SubmitReadyWqes（按预留顺序以 atomicCAS 推进 readyHead，仅由队尾或批次边界调用 PostSend）、TryPostSend/PostSend（在 postLock 内发布 owner 并响铃）；PostSendReadWrite 与 PostSendWriteNotify 改为先预留再填充，PUT+notify 一次预留两个槽位。

• CQ 消费并发保护: 将原 PollCq 拆分为带 cqLock 的 ProgressCq（按批次检查 CQE、维护 completedHead 与错误状态、仅在消费推进时响铃）与锁外轮询的 PollCq；TestEvent/WaitEventStatus 改为基于 completedHead 与 QueueError 判断，并可通过 SubmitReady 补提交就绪前缀。

• Workspace 初始化与校验调整: hns_1825_workspace_manager 新增 stateDeviceBase 与 InitializeSqOwners（按 64 字节 WQEBB 初始化 owner 为无效），PrepareRdmaInfoLayout 在元数据后按 QueueState 对齐追加每 peer/QP 的状态区并写入 sq[peer].stateAddr，CQ 深度校验增加 cqRing < 4 限制；rdma_workspace_types.hpp 将 kRdmaWorkspaceVersion 从 1 升为 2；后端新增 IsQueueValid 统一校验队列深度、对齐与 stateAddr。

• 新增并发压力测试用例: tput_async_rdma_kernel.cpp 新增 TPutAsyncRdmaConcurrentKernel、RunPutAsyncRdmaConcurrent 及 VerifyConcurrentRdmaBuffers，main.cpp 新增 TPutAsyncRdma.Vec_Int32_MultiAiv，并通过 blockCount 参数将 block 数下传至 kernel；rdma_test_backend.hpp 新增 ReadBackendQueueSnapshot 读取队列深度与状态快照，测试头文件与实现改为直接包含 acl/acl.h 及自持 Runtime 声明与设备数量查询。

代码审查

✅ 未发现问题

Thanks for your pull-request.
The full list of commands accepted by me can be found at here.
You can get sig-info at here.
You can self-configure the PR merge rules for this repository. For more details, please refer to Here.
For more, you also can visit HICANN.

PR Approval Progress

✅ Congratulations! All modules have met the lgtm and approve requirements.

Module Approval Details

💡 Tip:

• Committer can comment /approve or /lgtm
• Commenting /approve implies both code review (lgtm) and intent to merge (approve)

CLA Signature Pass

mengxun233, thanks for your pull request. All authors of the commits have signed the CLA. 👍

/compile

compile

compile

/approve

/approve