summaryrefslogtreecommitdiffstats
path: root/Lib/test/test_asyncio/test_server.py
diff options
context:
space:
mode:
Diffstat (limited to 'Lib/test/test_asyncio/test_server.py')
-rw-r--r--Lib/test/test_asyncio/test_server.py28
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):