From 5561be24e0534873b8dc8c87b42f540640c70e27 Mon Sep 17 00:00:00 2001 From: Jerry Zhao Date: Tue, 20 Oct 2026 04:49:22 +0000 Subject: [PATCH] test: tolerate closed sockets in lease policy proxy --- tests/meta_integration/gate_lease_policy.py | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/tests/meta_integration/gate_lease_policy.py b/tests/meta_integration/gate_lease_policy.py index dc7835d2f..7dfa5cf87 100644 --- a/tests/meta_integration/gate_lease_policy.py +++ b/tests/meta_integration/gate_lease_policy.py @@ -109,7 +109,16 @@ def send(frame): for frame in pending: send(frame) pending.clear() - if not select.select([src], [], [], 0.01)[0]: + try: + readable = select.select([src], [], [], 0.01)[0] + except ValueError: + # The opposite pump can close both sockets before select + # reads their descriptors. Treat only that teardown race + # as EOF; other ValueErrors remain proxy failures. + if src.fileno() < 0: + break + raise + if not readable: continue header = exact(28) magic, version, kind = struct.unpack_from(">IHH", header)