Urma event mode

.claude/plans/urma-ctp-implementation-plan.md

@@ -0,0 +1,142 @@
+# URMA CTP 实现计划
+
+## 当前状态
+
+### 已完成
+1. `circle_buffer` 提取到 `coro_io/detail/circle_buffer.hpp`
+2. `urma_device.hpp` 类型冲突修复（`urma_device_wrapper_t`）
+3. `urma_socket.hpp` 基础重构
+4. JFC/JFR/Jetty 创建流程修正
+
+### 已知问题
+1. `urma_query_jetty` 签名不正确
+2. `urma_import_jetty` 参数结构错误
+3. ASIO 协程兼容性问题
+4. Socket wrapper 接口不匹配
+
+---
+
+## URMA CTP API 正确用法
+
+### 1. JFC 创建 (Completion Channel)
+```c
+urma_jfc_cfg_t jfc_cfg = {};
+jfc_cfg.depth = 64;
+jfc_cfg.flag.value = 0;
+jfc_cfg.jfce = nullptr;  // polling mode
+jfc_cfg.user_ctx = 0;
+urma_jfc_t* jfc = urma_create_jfc(ctx, &jfc_cfg);
+```
+
+### 2. JFR 创建 (Receive Queue)
+```c
+urma_jfr_cfg_t jfr_cfg = {};
+jfr_cfg.depth = recv_cnt;
+jfr_cfg.flag.value = 0;
+jfr_cfg.trans_mode = URMA_TM_RM;
+jfr_cfg.max_sge = 1;
+jfr_cfg.min_rnr_timer = 12;
+jfr_cfg.jfc = jfc;
+jfr_cfg.token_value = {};
+urma_jfr_t* jfr = urma_create_jfr(ctx, &jfr_cfg);
+```
+
+### 3. Jetty 创建 (CTP Mode)
+```c
+urma_jetty_cfg_t jetty_cfg = {};
+jetty_cfg.flag.bs.share_jfr = 1;
+jetty_cfg.jfs_cfg.depth = send_cnt + 1;
+jetty_cfg.jfs_cfg.flag.value = 0;
+jetty_cfg.jfs_cfg.trans_mode = URMA_TM_RM;
+jetty_cfg.jfs_cfg.jfc = jfc;
+jetty_cfg.jfs_cfg.user_ctx = 0;
+jetty_cfg.shared.jfr = jfr;
+urma_jetty_t* jetty = urma_create_jetty(ctx, &jetty_cfg);
+```
+
+### 4. Jetty ID 获取
+```c
+// 通过 jetty->jfs_id.id 获取
+uint32_t jetty_id = jetty->jfs_id.id;
+```
+
+### 5. Segment 注册
+```c
+urma_seg_cfg_t seg_cfg = {};
+seg_cfg.va = (uint64_t)buffer;
+seg_cfg.len = buffer_size;
+seg_cfg.flag.bs.access = URMA_ACCESS_READ | URMA_ACCESS_WRITE;
+seg_cfg.flag.bs.token_policy = URMA_TOKEN_NONE;
+urma_target_seg_t* tseg = urma_register_seg(ctx, &seg_cfg);
+```
+
+### 6. 导入远端 Jetty
+```c
+urma_rjetty_t remote = {};
+remote.jetty_id.eid = peer_eid;
+remote.jetty_id.id = peer_jetty_id;
+remote.trans_mode = URMA_TM_RM;
+remote.type = URMA_JETTY;
+remote.tp_type = URMA_CTP;  // or URMA_RTP
+urma_target_jetty_t* remote_tjetty = urma_import_jetty(ctx, &remote, nullptr);
+```
+
+### 7. 发送数据 (SEND)
+```c
+urma_sge_t sge = {
+    .addr = (uint64_t)buffer,
+    .len = data_len,
+    .tseg = local_tseg
+};
+urma_sg_t src = {
+    .sge = &sge,
+    .num_sge = 1
+};
+urma_send_wr_t send_wr = {
+    .src = src
+};
+urma_jfs_wr_t jfs_wr = {
+    .opcode = URMA_OPC_SEND,
+    .send = send_wr,
+    .tjetty = remote_tjetty
+};
+urma_post_jetty_send_wr(jetty, &jfs_wr, &bad_wr);
+```
+
+### 8. 轮询完成
+```c
+urma_cr_t cr[8];
+int cnt = urma_poll_jfc(jfc, 8, cr);
+for (int i = 0; i < cnt; ++i) {
+    // cr[i].completion_len - 传输字节数
+    // cr[i].status - 状态
+    // cr[i].flag.bs.s_r - 0=send, 1=recv
+}
+```
+
+---
+
+## 待修复清单
+
+### 高优先级
+- [ ] `urma_socket.hpp`: 修复 `urma_query_jetty` 调用
+- [ ] `urma_socket.hpp`: 修复 `urma_import_jetty` 参数
+- [ ] `urma_socket.hpp`: 正确获取 Jetty ID
+- [ ] `socket_wrapper.hpp`: 添加缺失接口
+
+### 中优先级
+- [ ] ASIO 协程兼容性问题
+- [ ] `await_ready` Future 使用错误
+- [ ] `async_read/write` 调用方式
+
+### 低优先级
+- [ ] `urma_socket_info` 序列化格式
+- [ ] 连接握手协议
+
+---
+
+## 参考文档
+
+- URMA API Guide: `.claude/skills/query-urma-docs/URMA API Guide.ch.md`
+- URMA User Guide: `.claude/skills/query-urma-docs/URMA User Guide.ch.md`
+- URMA 头文件: `include/ylt/urma/urma_api.h`, `urma_types.h`

.claude/plans/urma-ctp-next-steps.md

@@ -0,0 +1,169 @@
+# URMA CTP 实现计划 - 下一步
+
+## 当前状态
+
+### 已完成 ✅
+1. `urma_socket.hpp` 重构修复:
+   - `urma_query_jetty` 调用已移除，直接通过 `jetty_->jetty_id.id` 访问
+   - `urma_import_jetty` 参数已正确初始化 (`trans_mode`, `type`, `tp_type`, `flag`)
+   - ASIO 协程兼容性问题已修复 (`async_simple::CurrentExecutor{}`)
+   - 添加缺失方法: `prepare_accept`, `get_remote_address`, `get_local_address`, `get_remote_qp_num`, `get_local_qp_num`
+   - 添加 `urma_md5_header`, `urma_md5_first_header` 常量
+
+### 待解决问题 🔴
+
+#### 1. urma_example.cpp 集成问题
+
+**错误1**: `get_global_urma_device()` 不接受参数
+```cpp
+// 当前错误用法:
+coro_io::get_global_urma_device({
+    .dev_name = "",
+    .buffer_pool_config = {...},
+    .eid_index = 0
+});
+```
+
+**错误2**: `coro_rpc_client::config::socket_config` 是 variant 类型，不支持 URMA
+```cpp
+// 当前错误用法:
+conf.socket_config = urma_config;  // urma_socket_t::config_t 不能直接赋值
+```
+
+#### 2. 缺失的 API
+- `urma_device_wrapper_t::init(const urma_config&)` - 需要支持完整配置
+- `coro_rpc_client::config` variant 需要 URMA 类型支持
+
+---
+
+## 参考实现: ib_socket 集成模式
+
+### ib_socket 的结构
+
+```cpp
+// ib_socket.hpp
+class ib_socket_t {
+ public:
+  struct config_t {
+    uint32_t cq_size = 128;
+    uint16_t recv_buffer_cnt = 8;
+    uint16_t send_buffer_cnt = 4;
+    ibv_qp_type qp_type = IBV_QPT_RC;
+    ibv_qp_cap cap = {...};
+    std::shared_ptr<ib_device_t> device;
+  };
+
+  struct ib_socket_info {
+    uint8_t gid[16];
+    uint16_t lid;
+    uint32_t buffer_size;
+    uint32_t qp_num;
+  };
+
+  ib_socket_t(coro_io::ExecutorWrapper<>* executor, const config_t& config);
+  async_simple::coro::Lazy<std::error_code> connect(const std::string& addr, const std::string& port);
+  async_simple::coro::Lazy<std::error_code> accept() noexcept;
+  void prepare_accpet(asio::ip::tcp::socket soc) noexcept;
+  // ... 其他方法
+};
+```
+
+### socket_wrapper 的 variant 支持
+
+```cpp
+// socket_wrapper.hpp
+class socket_wrapper_t {
+#ifdef YLT_ENABLE_IBV
+  std::unique_ptr<ib_socket_t> ib_socket_;
+#endif
+#ifdef YLT_ENABLE_URMA
+  std::unique_ptr<urma_socket_t> urma_socket_;
+#endif
+
+ public:
+  template<typename T>
+  auto visit(T&& op) {
+#ifdef YLT_ENABLE_IBV
+    if (ib_socket_) return op(*ib_socket_);
+#endif
+#ifdef YLT_ENABLE_URMA
+    if (urma_socket_) return op(*urma_socket_);
+#endif
+    return op(*socket_);
+  }
+};
+```
+
+---
+
+## 下一步修改计划
+
+### 阶段1: 修复 urma_example.cpp
+
+#### 1.1 修改 get_global_urma_device() 支持配置参数
+
+参考 ib_device 的初始化模式:
+
+```cpp
+// urma_device.hpp
+inline bool urma_device_wrapper_t::init(const urma_init_config_t& config) {
+  // 支持配置参数初始化
+}
+```
+
+#### 1.2 修改 coro_rpc_client::config 支持 URMA
+
+需要在 variant 中添加 URMA 类型:
+
+```cpp
+// coro_rpc_client.hpp
+struct config_t {
+  using socket_config_t = std::variant<
+      tcp_config,
+      tcp_with_ssl_config,
+      tcp_with_ntiles_config
+#ifdef YLT_ENABLE_URMA
+      , urma_socket_t::config_t  // 添加 URMA 支持
+#endif
+  >;
+  socket_config_t socket_config;
+};
+```
+
+### 阶段2: 实现 URMA 连接的建立流程
+
+#### 2.1 参考 ib_socket 的连接建立
+
+```cpp
+// ib_socket 连接流程:
+async_simple::coro::Lazy<std::error_code> connect(const std::string& addr, const std::string& port) {
+  // 1. TCP 连接
+  // 2. 交换 socket_info (gid, lid, buffer_size, qp_num)
+  // 3. 初始化 QP
+  // 4. 返回
+}
+```
+
+#### 2.2 URMA CTP 模式连接
+
+根据 URMA API Guide，CTP 模式流程:
+1. 创建 JFC (Completion Channel)
+2. 创建 JFR (Receive Queue)
+3. 创建 Jetty (Combined send/recv)
+4. 通过 TCP 交换 Jetty ID 和 EID
+5. 导入远端 Jetty
+6. 建立连接
+
+### 阶段3: 测试验证
+
+1. 单元测试: urma_socket 基本功能
+2. 集成测试: urma_example 与 coro_rpc 集成
+
+---
+
+## 参考文档
+
+- URMA API Guide: `.claude/skills/query-urma-docs/URMA API Guide.ch.md`
+- URMA User Guide: `.claude/skills/query-urma-docs/URMA User Guide.ch.md`
+- ib_socket 实现: `include/ylt/coro_io/ibverbs/ib_socket.hpp`
+- socket_wrapper: `include/ylt/coro_io/socket_wrapper.hpp`

.claude/rules/common/agents.md

@@ -0,0 +1,50 @@
+# Agent Orchestration
+
+## Available Agents
+
+Located in `~/.claude/agents/`:
+
+| Agent | Purpose | When to Use |
+|-------|---------|-------------|
+| planner | Implementation planning | Complex features, refactoring |
+| architect | System design | Architectural decisions |
+| tdd-guide | Test-driven development | New features, bug fixes |
+| code-reviewer | Code review | After writing code |
+| security-reviewer | Security analysis | Before commits |
+| build-error-resolver | Fix build errors | When build fails |
+| e2e-runner | E2E testing | Critical user flows |
+| refactor-cleaner | Dead code cleanup | Code maintenance |
+| doc-updater | Documentation | Updating docs |
+| rust-reviewer | Rust code review | Rust projects |
+
+## Immediate Agent Usage
+
+No user prompt needed:
+1. Complex feature requests - Use **planner** agent
+2. Code just written/modified - Use **code-reviewer** agent
+3. Bug fix or new feature - Use **tdd-guide** agent
+4. Architectural decision - Use **architect** agent
+
+## Parallel Task Execution
+
+ALWAYS use parallel Task execution for independent operations:
+
+```markdown
+# GOOD: Parallel execution
+Launch 3 agents in parallel:
+1. Agent 1: Security analysis of auth module
+2. Agent 2: Performance review of cache system
+3. Agent 3: Type checking of utilities
+
+# BAD: Sequential when unnecessary
+First agent 1, then agent 2, then agent 3
+```
+
+## Multi-Perspective Analysis
+
+For complex problems, use split role sub-agents:
+- Factual reviewer
+- Senior engineer
+- Security expert
+- Consistency reviewer
+- Redundancy checker