[PD] Fix send_multipart blocking after prefill failure (#31306)
This commit is contained in:
@@ -1324,7 +1324,6 @@ class CommonKVReceiver(BaseKVReceiver):
|
|||||||
sock = cls._ctx.socket(zmq.PUSH)
|
sock = cls._ctx.socket(zmq.PUSH)
|
||||||
if is_ipv6:
|
if is_ipv6:
|
||||||
sock.setsockopt(zmq.IPV6, 1)
|
sock.setsockopt(zmq.IPV6, 1)
|
||||||
sock.setsockopt(zmq.RECONNECT_IVL, -1)
|
|
||||||
sock.setsockopt(zmq.LINGER, 0)
|
sock.setsockopt(zmq.LINGER, 0)
|
||||||
sock.connect(endpoint)
|
sock.connect(endpoint)
|
||||||
cls._socket_cache[endpoint] = sock
|
cls._socket_cache[endpoint] = sock
|
||||||
|
|||||||
Reference in New Issue
Block a user