mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-08-27 20:25:18 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 8

Make asyncio stream sendfile fail on error (was hang) (GH-14025)

Browse source
This commit is contained in:
Andrew Svetlov 2019-06-12 21:50:23 +03:00 • committed by GitHub
parent ff6bb0aa95
commit 0d1942774a
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

13
Lib/test/test_asyncio/test_streams.py
View file

@ -1656,22 +1656,25 @@ os.close(fd)
async def serve_callback(stream):
data = await stream.readline()
self.assertEqual(data, b'begin\n')
await stream.write(b'ack-' + data)
data = await stream.readline()
self.assertEqual(data, b'data\n')
await stream.write(b'ack-' + data)
data = await stream.readline()
self.assertEqual(data, b'end\n')
await stream.write(b'done\n')
await stream.write(b'ack-' + data)
await stream.close()
async def do_connect(host, port):
stream = await asyncio.connect(host, port)
await stream.write(b'begin\n')
data = await stream.readline()
self.assertEqual(b'ack-begin\n', data)
with open(support.TESTFN, 'rb') as fp:
await stream.sendfile(fp)
data = await stream.readline()
self.assertEqual(b'ack-data\n', data)
await stream.write(b'end\n')
data = await stream.readline()
self.assertEqual(data, b'done\n')
self.assertEqual(data, b'ack-end\n')
await stream.close()
async def test():