diff options
| author | Serhiy Storchaka <storchaka@gmail.com> | 2024-01-10 10:38:36 (GMT) |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-01-10 10:38:36 (GMT) |
| commit | ab0ad62038317a3d15099c23d2b0f03bee9f8fa7 (patch) | |
| tree | 1b2d001d33c8de5c497caf5840c80ca586313f74 | |
| parent | 1b7e0024a16c1820f61c04a8a100498568410afd (diff) | |
| download | cpython-ab0ad62038317a3d15099c23d2b0f03bee9f8fa7.zip cpython-ab0ad62038317a3d15099c23d2b0f03bee9f8fa7.tar.gz cpython-ab0ad62038317a3d15099c23d2b0f03bee9f8fa7.tar.bz2 | |
gh-113879: Fix ResourceWarning in test_asyncio.test_server (GH-113881)
| -rw-r--r-- | Lib/test/test_asyncio/test_server.py | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/Lib/test/test_asyncio/test_server.py b/Lib/test/test_asyncio/test_server.py index f22cf30..918faac 100644 --- a/Lib/test/test_asyncio/test_server.py +++ b/Lib/test/test_asyncio/test_server.py @@ -200,13 +200,13 @@ class UnixServerCleanupTests(unittest.IsolatedAsyncioTestCase): async def serve(*args): pass - sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) - sock.bind(addr) + with socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) as sock: + sock.bind(addr) - srv = await asyncio.start_unix_server(serve, sock=sock) + srv = await asyncio.start_unix_server(serve, sock=sock) - srv.close() - self.assertFalse(os.path.exists(addr)) + srv.close() + self.assertFalse(os.path.exists(addr)) @socket_helper.skip_unless_bind_unix_socket async def test_unix_server_cleanup_gone(self): @@ -215,14 +215,14 @@ class UnixServerCleanupTests(unittest.IsolatedAsyncioTestCase): async def serve(*args): pass - sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) - sock.bind(addr) + with socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) as sock: + sock.bind(addr) - srv = await asyncio.start_unix_server(serve, sock=sock) + srv = await asyncio.start_unix_server(serve, sock=sock) - os.unlink(addr) + os.unlink(addr) - srv.close() + srv.close() @socket_helper.skip_unless_bind_unix_socket async def test_unix_server_cleanup_replaced(self): @@ -234,11 +234,11 @@ class UnixServerCleanupTests(unittest.IsolatedAsyncioTestCase): srv = await asyncio.start_unix_server(serve, addr) os.unlink(addr) - sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) - sock.bind(addr) + with socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) as sock: + sock.bind(addr) - srv.close() - self.assertTrue(os.path.exists(addr)) + srv.close() + self.assertTrue(os.path.exists(addr)) @socket_helper.skip_unless_bind_unix_socket async def test_unix_server_cleanup_prevented(self): |