mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-09-27 10:50:04 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 13

bpo-32662: Try making test_asyncio.test_server more reliable (#5338)

Browse source
This commit is contained in:
Yury Selivanov 2018-01-26 01:30:57 -05:00 • committed by GitHub
parent 863b1e4d0e
commit 4112c5b97d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -1,8 +1,10 @@
import asyncio import asyncio
import socket import socket
import time
import threading import threading
import unittest import unittest
from test import support
from test.test_asyncio import utils as test_utils from test.test_asyncio import utils as test_utils
from test.test_asyncio import functional as func_tests from test.test_asyncio import functional as func_tests
@ -16,6 +18,14 @@ class BaseStartServer(func_tests.FunctionalTestCaseMixin):
HELLO_MSG = b'1' * 1024 * 5 + b'\n' HELLO_MSG = b'1' * 1024 * 5 + b'\n'
def client(sock, addr): def client(sock, addr):
for i in range(10):
time.sleep(0.2)
if srv.is_serving():
break
else:
raise RuntimeError
sock.settimeout(2)
sock.connect(addr) sock.connect(addr)
sock.send(HELLO_MSG) sock.send(HELLO_MSG)
sock.recv_all(1) sock.recv_all(1)
@ -33,7 +43,7 @@ class BaseStartServer(func_tests.FunctionalTestCaseMixin):
await srv.serve_forever() await srv.serve_forever()
srv = self.loop.run_until_complete(asyncio.start_server( srv = self.loop.run_until_complete(asyncio.start_server(
serve, '127.0.0.1', 0, loop=self.loop, start_serving=False)) serve, support.HOSTv4, 0, loop=self.loop, start_serving=False))
self.assertFalse(srv.is_serving()) self.assertFalse(srv.is_serving())
@ -65,6 +75,7 @@ class SelectorStartServerTests(BaseStartServer, unittest.TestCase):
started = threading.Event() started = threading.Event()
def client(sock, addr): def client(sock, addr):
sock.settimeout(2)
started.wait(5) started.wait(5)
sock.connect(addr) sock.connect(addr)
sock.send(HELLO_MSG) sock.send(HELLO_MSG)