diff --git a/archive/kt-sft/ktransformers/server/balance_serve/sched_rpc.py b/archive/kt-sft/ktransformers/server/balance_serve/sched_rpc.py index ccc30af58..589a696fb 100644 --- a/archive/kt-sft/ktransformers/server/balance_serve/sched_rpc.py +++ b/archive/kt-sft/ktransformers/server/balance_serve/sched_rpc.py @@ -28,7 +28,7 @@ def __init__(self, settings, main_args): self.context = zmq.Context() self.frontend = self.context.socket(zmq.ROUTER) print(f"sched zmq rpc server on port {main_args.sched_port}") - self.frontend.bind(f"tcp://*:{main_args.sched_port}") + self.frontend.bind(f"tcp://127.0.0.1:{main_args.sched_port}") self.backend = self.context.socket(zmq.DEALER) self.backend.bind("inproc://backend") diff --git a/archive/ktransformers/server/balance_serve/sched_rpc.py b/archive/ktransformers/server/balance_serve/sched_rpc.py index ab8b0dd7d..9fc835236 100644 --- a/archive/ktransformers/server/balance_serve/sched_rpc.py +++ b/archive/ktransformers/server/balance_serve/sched_rpc.py @@ -40,7 +40,7 @@ def __init__(self, settings, main_args): self.context = zmq.Context() self.frontend = self.context.socket(zmq.ROUTER) print(f"sched zmq rpc server on port {main_args.sched_port}") - self.frontend.bind(f"tcp://*:{main_args.sched_port}") + self.frontend.bind(f"tcp://127.0.0.1:{main_args.sched_port}") # 创建内部的 DEALER 套接字,用于与工作线程通信 self.backend = self.context.socket(zmq.DEALER)