修复decode节点init req 代码重复。

Author: hiworldwzj

lightllm/server/router/model_infer/mode_backend/continues_batch/pd_mode/decode_node_impl/decode_impl.py

@@ -49,16 +49,7 @@ def init_custom(self):
         return
 
     def prefill(self, reqs: List[Tuple]):
-        # 当 dp_size 不等于 1 的时候，需要提前从发来的请求参数中
-        # 剔除掉不需要处理的请求参数, deepseekv2 这种特殊的模型
-        # 在 dp 模式下 tp_rank == dp_rank
-        if self.dp_size != 1:
-            cur_dp_index = self.tp_rank
-            reqs = [req for req in reqs if req[3] == cur_dp_index]
-
-        g_infer_state_lock.acquire()
-        g_infer_context.add_reqs(reqs, init_req_obj=False)  # 请求对象进行延迟初始化
-        g_infer_state_lock.release()
+        self._init_reqs(reqs, init_req_obj=False)
         return
 
     def decode(self):

lightllm/server/router/model_infer/model_rpc.py

@@ -305,7 +305,7 @@ async def start_model_process(
 ):
     import lightllm.utils.rpyc_fix_utils as _
 
-    # 单卡时不使用 rpc
+    # 单卡单机时不使用 rpc
     if node_world_size == 1 and args.nnodes == 1:
         return ModelRpcServer(
             args,