diff --git a/python/sglang/srt/disaggregation/common/conn.py b/python/sglang/srt/disaggregation/common/conn.py index 2eb2dbc18..607f0b735 100644 --- a/python/sglang/srt/disaggregation/common/conn.py +++ b/python/sglang/srt/disaggregation/common/conn.py @@ -1091,6 +1091,8 @@ class CommonKVReceiver(BaseKVReceiver): sock = cls._ctx.socket(zmq.PUSH) if is_ipv6: sock.setsockopt(zmq.IPV6, 1) + sock.setsockopt(zmq.RECONNECT_IVL, -1) + sock.setsockopt(zmq.LINGER, 0) sock.connect(endpoint) cls._socket_cache[endpoint] = sock cls._socket_locks[endpoint] = threading.Lock()