执行摘要

• 一句话：修复 EPD 路径因 ZMQ 端口复用导致的崩溃或数据污染
• 推荐动作：该 PR 修复了一个隐蔽的并发问题，设计思路清晰，适合精读以理解分布式推理中的端口复用场景和防御性编程实践。建议未来添加对应的单元测试或集成测试覆盖端口复用竞争的边界条件。

功能与动机

在 EPD 路径中，请求中止后 ZMQ 端口被立即释放，而编码器侧可能仍在发送该请求的嵌入数据，导致新请求的 socket 收到旧数据，触发 assert self.req_id == embedding_data.req_id 崩溃或数据污染。PR body 详细描述了这种 race condition 的完整链式影响，包含调用栈和断言位置。

实现拆解

1. 在 _try_recv_mm_data 中提前过滤过期负载：在反序列化后立即提取原始请求 ID，若与当前请求的 rid 不匹配，则记录 warning 并 continue，跳过后续所有处理（包括 buffer 解码）。这一改动将 req_id 提取和比较移到了最前方，避免了对过期数据的任何处理。
2. 在 MultiModalEmbeddingData.add 中容错：将 assert self.req_id == embedding_data.req_id 替换为条件判断，不匹配时记录 warning 并 return False，作为兜底保护，防止遗漏的过期数据依然导致崩溃。
3. 调整提取逻辑顺序：原来在 buffer 解码后才提取 original_req_id，现在提前到 buffer 解码之前，使得过期数据不消耗解码开销。

仅修改单一文件 python/sglang/srt/disaggregation/encode_receiver.py，无测试、配置或部署配套改动。

关键文件：

• python/sglang/srt/disaggregation/encode_receiver.py（模块 编码接收器；类别 source；类型 core-logic）: 所有变更均在此文件，包含两处防御性修改：_try_recv_mm_data 中提前过滤过期负载，以及 MultiModalEmbeddingData.add 中容错处理。

关键符号：_try_recv_mm_data, add

评论区精华

Review 由 ShangmingCai 完成并批准（"LGTM"），无额外评论讨论。未发现争议点。

• 暂无高价值评论线程

风险与影响

• 风险：
  • 回归风险较低：改动仅在已有的 _try_recv_mm_data 和 add 方法中添加了条件判断与 warning，不改变正常路径的控制流与数据结构，且与原断言逻辑语义等价（只是将硬失败改为软丢弃）。
  • 性能影响可忽略：两条 log 语句仅在异常路径触发，正常路径仅有新增的 if 比较，开销可忽略。
  • 潜在隐患：若 extract_original_req_id 被调用在 recv_obj.req_id 还未被修改为 original_req_id 的地方，可能产生误判，但目前代码中该函数仅在此处调用一次。
• 影响：
  • 影响范围：仅影响 EPD 路径下使用 ZMQ 接收嵌入数据的请求。对于正常请求，行为完全不变。
  • 对用户的影响：修复了在请求中止场景下的罕见崩溃和数据污染 bug，提升了系统稳定性。
  • 对系统的影响：无新增依赖或资源占用。
  • 对团队的影响：低风险修复，无需额外培训或文档更新。
  • 风险标记：缺少测试覆盖, 核心路径变更

关联脉络

• 暂无明显关联 PR