avoid refcycles in tracebacks from happy eyeballs exceptions

pyproject.toml

@@ -56,6 +56,7 @@ test = [
     and platform_system != 'Windows' \
     and python_version < '3.14'\
     """
+    "ephemeral-port-reserve >= 1.1.4",
 ]
 doc = [
     "packaging",

src/anyio/_core/_sockets.py

@@ -224,20 +224,23 @@ async def try_connect(remote_host: str, event: Event) -> None:
                 target_addrs.append((af, sa[0]))
 
     oserrors: list[OSError] = []
-    async with create_task_group() as tg:
-        for i, (af, addr) in enumerate(target_addrs):
-            event = Event()
-            tg.start_soon(try_connect, addr, event)
-            with move_on_after(happy_eyeballs_delay):
-                await event.wait()
-
-    if connected_stream is None:
-        cause = (
-            oserrors[0]
-            if len(oserrors) == 1
-            else ExceptionGroup("multiple connection attempts failed", oserrors)
-        )
-        raise OSError("All connection attempts failed") from cause
+    try:
+        async with create_task_group() as tg:
+            for i, (af, addr) in enumerate(target_addrs):
+                event = Event()
+                tg.start_soon(try_connect, addr, event)
+                with move_on_after(happy_eyeballs_delay):
+                    await event.wait()
+
+        if connected_stream is None:
+            cause = (
+                oserrors[0]
+                if len(oserrors) == 1
+                else ExceptionGroup("multiple connection attempts failed", oserrors)
+            )
+            raise OSError("All connection attempts failed") from cause
+    finally:
+        oserrors = []
 
     if tls or tls_hostname or ssl_context:
         try:

tests/test_sockets.py

@@ -19,6 +19,7 @@
 from threading import Thread
 from typing import TYPE_CHECKING, Any, Literal, NoReturn, TypeVar, cast
 
+import ephemeral_port_reserve
 import psutil
 import pytest
 from _pytest.fixtures import SubRequest
@@ -43,6 +44,7 @@
     create_unix_datagram_socket,
     create_unix_listener,
     fail_after,
+    get_current_task,
     getaddrinfo,
     getnameinfo,
     move_on_after,
@@ -58,6 +60,7 @@
     SocketAttribute,
     SocketListener,
     SocketStream,
+    TaskStatus,
 )
 from anyio.lowlevel import checkpoint
 from anyio.streams.stapled import MultiListener
@@ -133,6 +136,31 @@ def check_asyncio_bug(anyio_backend_name: str, family: AnyIPAddressFamily) -> No
             pytest.skip("Does not work due to a known bug (39148)")
 
 
+if sys.version_info >= (3, 14):
+
+    async def no_other_refs() -> list[object]:
+        frame = sys._getframe(1)
+        coro = get_current_task().coro
+
+        async def get_coro_for_frame(*, task_status: TaskStatus[object]) -> None:
+            my_coro = coro
+            while my_coro.cr_frame is not frame:
+                my_coro = my_coro.cr_await
+            task_status.started(my_coro)
+
+        async with create_task_group() as tg:
+            return [await tg.start(get_coro_for_frame)]
+
+elif sys.version_info >= (3, 11):
+
+    async def no_other_refs() -> list[object]:
+        return []
+else:
+
+    async def no_other_refs() -> list[object]:
+        return [sys._getframe(1)]
+
+
 _T = TypeVar("_T")
 
 
@@ -315,6 +343,29 @@ def serve() -> None:
         server_sock.close()
         assert client_addr[0] == expected_client_addr
 
+    @pytest.mark.skipif(
+        sys.implementation.name == "pypy",
+        reason=(
+            "gc.get_referrers is broken on PyPy see "
+            "https://github.com/pypy/pypy/issues/5075"
+        ),
+    )
+    async def test_happy_eyeballs_refcycles(self) -> None:
+        """
+        Test derived from https://github.com/python/cpython/pull/124859
+        """
+        ip = "127.0.0.1"
+        port = ephemeral_port_reserve.reserve(ip=ip)
+        exc = None
+        try:
+            async with await connect_tcp(ip, port):
+                pass
+        except OSError as e:
+            exc = e.__cause__
+
+        assert isinstance(exc, OSError)
+        assert gc.get_referrers(exc) == await no_other_refs()
+
     @pytest.mark.parametrize(
         "target, exception_class",
         [